如何使用web端向TCP服務(wù)器發(fā)送消息？

xiaopi 2022-02-17

目前有一個(gè)需求是建立一個(gè)TCP客戶端，與遠(yuǎn)端的TCP服務(wù)端交互。為了方便使用，需要web端發(fā)送信息，然后后端將信息發(fā)送給TCP服務(wù)端，并與之交互，交互結(jié)果發(fā)送給web端
初步的想法是，
1.建立websocket服務(wù)端，與前端進(jìn)行交互
2.websocket服務(wù)端接受到前端發(fā)送的數(shù)據(jù)后，在發(fā)送給TCP服務(wù)端
3.TCP服務(wù)端返回的數(shù)據(jù)，經(jīng)過(guò)處理，再通過(guò)websocket推送給前端
代碼如下

use Workerman\Worker; 
require_once __DIR__ . '/Workerman/Autoloader.php'; 

$worker = new Worker ( 'websocket://0.0.0.0:5678' ); 
$worker->onWorkerStart=function($worker){
    //子進(jìn)程啟動(dòng)后，建立tcp客戶端，
    $conn = new AsyncTcpConnection('tcp://127.0.0.1:8050'); 
    $conn->onMessage = function($conn, $data) {     
        //這里與tcp服務(wù)器交互
    };
    $conn->connect();
};
$worker->onMessage = function ($connection, $data) {
    //此處接受網(wǎng)站發(fā)送過(guò)來(lái)的websocket
    //如何在此處向子進(jìn)程的tcp服務(wù)器發(fā)送消息？？
};

Worker::runAll ();

問(wèn)題來(lái)了，在onMessage中，如何使用OnWorkerStart中創(chuàng)建的TCP客戶端？

 2136  2 2

2個(gè)回答

walkor 2022-02-17

打賞

use Workerman\Worker; 
require_once __DIR__ . '/Workerman/Autoloader.php'; 

$worker = new Worker ( 'websocket://0.0.0.0:5678' ); 
$worker->onWorkerStart=function($worker){
    //子進(jìn)程啟動(dòng)后，建立tcp客戶端，
    $conn = new AsyncTcpConnection('tcp://127.0.0.1:8050'); 
    $conn->onMessage = function($conn, $data) {     
        //這里與tcp服務(wù)器交互
    };
    $conn->connect();
    $worker->conn = $conn;
};
$worker->onMessage = function ($connection, $data) use ($worker) {
    $worker->conn->send('xxx');
};

Worker::runAll ();

xiaopi 2022-02-17

十分感謝！有個(gè)小問(wèn)題哈，我沒(méi)在文檔中發(fā)現(xiàn)Worker類有這個(gè)屬性，這是魔術(shù)方法__set()嗎
walkor 2022-02-17

目前(php<=8.1)php的對(duì)象是可以動(dòng)態(tài)添加任意屬性的。
xiaopi 2022-02-17

感謝

zjcyjj 2022-04-20

3.TCP服務(wù)端返回的數(shù)據(jù)，經(jīng)過(guò)處理，再通過(guò)websocket推送給前端
//子進(jìn)程啟動(dòng)后，建立tcp客戶端，
$conn = new AsyncTcpConnection('tcp://127.0.0.1:8050');
$conn->onMessage = function($conn, $data) {
//這里與tcp服務(wù)器交互
再通過(guò)websocket推送給前端這里代碼怎么寫呢 ?
$worker - > send($data); //是這樣嗎嘿嘿嘿
};