實(shí)例化AsyncTcpConnection之后,在onMessage方法中調(diào)用并send數(shù)據(jù),測(cè)試發(fā)現(xiàn)拿不到推送到服務(wù)端的數(shù)據(jù),代碼也沒(méi)有報(bào)錯(cuò),求大佬解惑
代碼如下:
<?php
use Workerman\Worker;
use Workerman\Common\Auth;
use Workerman\Common\GetAboutParameter;
use Workerman\Common\GetPositionMessage;
use Workerman\Connection\AsyncTcpConnection;
require 'Autoloader.php';
require_once __DIR__ . '/vendor/autoload.php';
// 創(chuàng)建一個(gè)Worker監(jiān)聽(tīng)8992端口,不使用任何應(yīng)用層協(xié)議
$tcp_worker = new Worker("tcp://0.0.0.0:8992");
//以tcp協(xié)議連接遠(yuǎn)程tcp服務(wù)器
$tcp_connection = new AsyncTcpConnection("tcp://127.0.0.1:8000");
// 啟動(dòng)8個(gè)進(jìn)程對(duì)外提供服務(wù)
$tcp_worker -> count = 8;
$tcp_worker -> onWorkerStart = function ($worker) {
};
// 當(dāng)客戶(hù)端發(fā)來(lái)數(shù)據(jù)時(shí)
$tcp_worker -> onMessage = function ($connection, $data) use (&$tcp_connection) {
? ? $tcp_connection -> send($data);
};
// 運(yùn)行worker
Worker ::runAll();