3回答

慕的地3178978

提问者

2019-08-28

<?php
//创建Server对象，监听 127.0.0.1:9501端口
$serv = new Swoole\Server("127.0.0.1", 9501);

$serv->set(array(
   'reactor_num' => 2, //reactor thread num
   'worker_num' => 4,    //worker process num
   'backlog' => 128,   //listen backlog
   'max_request' => 50,
   'dispatch_mode' => 1,
));

//监听连接进入事件 监听连接进入事件
/*
* $fd 客户端连接唯一标识
* $reactor_id 线程id
* */
$serv->on('Connect', function ($serv, $fd,$reactor_id) {
   echo "Client:{$reactor_id}-{$fd}-{$serv} - Connect.\n";
});

//监听数据接收事件
$serv->on('Receive', function ($serv, $fd, $reactor_id, $data) {
   $serv->send($fd, "Server: {$reactor_id}-{$fd}-".$data);
});

//监听连接关闭事件
$serv->on('Close', function ($serv, $fd) {
   echo "Client: Close.\n";
});

//启动服务器
$serv->start();

0

0

慕的地3178978

提问者

2019-08-28

最新问题

0

1

慕的地3178978

前面是单词 recv 写成revc 对不起

2019-08-28

共1条回复

慕的地3178978

提问者

2019-08-28

<?php
header("Content-type:text/html; charset=utf-8");
$cli = new swoole_client(SWOOLE_SOCK_TCP);//SWOOLE 常量
if ($cli->connect('127.0.0.1', 9501)) {
    //$cli->send("data");
} else {
    echo "connect failed.";
}
//php内置cli常量
fwrite(STDOUT,"-----------");
$msg = trim(fgets(STDIN));//获取输入的数据
//发送消息给tcp server 服务器
$cli->send($msg);

//接受来自server的数据
$resule = $cli ->revc();
echo $result;

0

0