實例化AsyncTcpConnection之后,在onMessage方法中調(diào)用并send數(shù)據(jù),測試發(fā)現(xiàn)拿不到推送到服務端的數(shù)據(jù),代碼也沒有報錯,求大佬解惑
代碼如下:
<?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)建一個Worker監(jiān)聽8992端口,不使用任何應用層協(xié)議
$tcp_worker = new Worker("tcp://0.0.0.0:8992");
//以tcp協(xié)議連接遠程tcp服務器
$tcp_connection = new AsyncTcpConnection("tcp://127.0.0.1:8000");
// 啟動8個進程對外提供服務
$tcp_worker -> count = 8;
$tcp_worker -> onWorkerStart = function ($worker) {
};
// 當客戶端發(fā)來數(shù)據(jù)時
$tcp_worker -> onMessage = function ($connection, $data) use (&$tcp_connection) {
? ? $tcp_connection -> send($data);
};
// 運行worker
Worker ::runAll();