swoole创建TCP服务器和客户端

Posted 2020-10-03 cxscode

 

<?php

    //创建Server对象，监听 127.0.0.1:9501端口
   $serv = new swoole_server("127.0.0.1", 9501);

   //监听连接进入事件
   $serv->on(‘connect‘, function ($serv, $fd) {
      echo "Client: Connect.\n";
      $serv->send($fd, "Server: connent");
   });

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

   //监听连接关闭事件
   $serv->on(‘close‘, function ($serv, $fd) {
      echo "Client: Close.\n";
   });
   //启动服务器
   $serv->start();

?>

 

<?php

    //创建Client对象，连接 127.0.0.1:9501端口
    $client = new swoole_client(SWOOLE_SOCK_TCP);

    //判断连接是否成功
    if (!$client->connect(‘127.0.0.1‘, 9501, -1))
    {
        exit("connect failed. Error: {$client->errCode}\n");
    }

    //发送数据接收事件
    $client->send("hello world\n");

    //输出服务返回参数
    echo $client->recv();

    //连接关闭
    $client->close();

?>