workerman作為客戶端怎么向另一個(gè)ws服務(wù)端發(fā)送emit指令
use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;
$worker = new Worker();
// 進(jìn)程啟動(dòng)時(shí)
$worker->onWorkerStart = function()
{
// 以websocket協(xié)議連接遠(yuǎn)程websocket服務(wù)器
$ws_connection = new AsyncTcpConnection("ws://0.0.0.0:9501/socket.io/?EIO=3&transport=websocket");
// 連上后發(fā)送hello字符串
$ws_connection->onConnect = function($connection){
$connection->send('hello');
};
// 遠(yuǎn)程websocket服務(wù)器發(fā)來消息時(shí)
$ws_connection->onMessage = function($connection, $data){
echo "recv: $data\n";
};
// 連接上發(fā)生錯(cuò)誤時(shí),一般是連接遠(yuǎn)程websocket服務(wù)器失敗錯(cuò)誤
$ws_connection->onError = function($connection, $code, $msg){
echo "error: $msg\n";
};
// 當(dāng)連接遠(yuǎn)程websocket服務(wù)器的連接斷開時(shí)
$ws_connection->onClose = function($connection){
echo "connection closed\n";
};
// 設(shè)置好以上各種回調(diào)后,執(zhí)行連接操作
$ws_connection->connect();
};
Worker::runAll();