問題描述

用workman 的AsyncTcpConnection 異步訪問外部wss端口，獲取的message 返回出現(xiàn)問題

為此你搜索到了哪些方案及不適用的原因

遠程socket握手成功

Error: Call to a member function send() on null in /www/wwwroot/streaming.zznet.live/startwork.php:36
Stack trace:
#0 /www/wwwroot/streaming.zznet.live/vendor/workerman/workerman/Connection/TcpConnection.php(646): {closure}()
#1 [internal function]: Workerman\Connection\TcpConnection->baseRead()
#2 /www/wwwroot/streaming.zznet.live/vendor/workerman/workerman/Events/Event.php(193): EventBase->loop()
#3 /www/wwwroot/streaming.zznet.live/vendor/workerman/workerman/Worker.php(1638): Workerman\Events\Event->loop()
#4 /www/wwwroot/streaming.zznet.live/vendor/workerman/workerman/Worker.php(1429): Workerman\Worker::forkOneWorkerForLinux()
#5 /www/wwwroot/streaming.zznet.live/vendor/workerman/workerman/Worker.php(1403): Workerman\Worker::forkWorkersForLinux()
#6 /www/wwwroot/streaming.zznet.live/vendor/workerman/workerman/Worker.php(560): Workerman\Worker::forkWorkers()
#7 /www/wwwroot/streaming.zznet.live/startwork.php(45): Workerman\Worker::runAll()

下面是代碼

$ws_worker = new Worker("websocket://0.0.0.0:2346");

// 啟動4個進程對外提供服務(wù)
$ws_worker->count = 6;

// 當收到客戶端發(fā)來的數(shù)據(jù)后返回hello $data給客戶端
$ws_worker->onMessage = function(TcpConnection $connection, $data) {
    $context_option = array(
        'socket' => array(
            // ip必須是本機網(wǎng)卡ip，并且能訪問對方主機，否則無效
            'bindto' => '202.**.**.192:2346',
        )
    );

    // 發(fā)起異步連接
    $con = new AsyncTcpConnection('ws://*******', $context_option);

    // 設(shè)置以ssl加密方式訪問
    $con->transport = 'ssl';

    $con->onConnect = function(AsyncTcpConnection $con) {
        echo "遠程socket握手成功\n";
        $str = 'hello';
        $con->send($str);
    };

    $con->onMessage = function(AsyncTcpConnection $con, $result) {
        $connection->send($result , true);
    };

    $con->connect();
};