关于swoole:swoole客户端分析与讲解作为TCP链接webscoket链接等客户端

swoole 客户端

文章目录

1.swoole 客户端能解决什么样的问题？

2. 如何应用？

3. 注意事项

1. 首先明确 swoole 客户端能帮忙咱们解决什么样的问题？

业务场景当业务中须要链接 TCP,UDP,socket，websocket 服务时，咱们须要编写一个客户端去链接对应的服务（比方链接某些数据源）。
此时有很多种的抉择，workerman 的 AsyncTcpConnection, 或者应用 php 自带的 socket 函数(socket_create,socket_read 等函数)，swoole 的客户端（Swoole\Client）等都能够。各有优劣，抉择适宜本人和业务的就好，这次咱们抉择 Swoole\Client。

2. 如何应用？
废话不多说，间接上我封装好的代码, 看不懂多看正文了解，能够珍藏不便当前能够间接应用。

class SwooleClient
{
    // 链接对象
    private $client;

    /**
     * SwooleClient constructor.
     */
    public function __construct()
    {$this->client = new Swoole\Client(SWOOLE_SOCK_TCP);
        $this->client->set(array(
            'open_eof_check' => true,   // 关上 EOF 检测
            'package_eof'    => "\r\n", // 设置 EOF, 包之间的分隔符
            'package_max_length' => 1024 * 1024 * 2,// 设置一个包的最大数据包尺寸，单位为字节。默认 2m
        ));
    }

    /**
     * Notes: 链接对应的 ip
     * User: 闻铃
     * DateTime: 2021/11/17 下午 10:46
     * @param string $ip 链接的 ip，本地或外网 ip
     * @param  int $port 端口号
     * @throws \Exception
     */
    public function connect($ip = '127.0.0.1', $port = 9501)
    {if (!$this->client->connect($ip, $port, -1)) {throw new \Exception(sprintf('Swoole Error: %s', $this->client->errCode));
        }
    }

    /**
     * Notes: 发送数据
     * User: 闻铃
     * DateTime: 2021/11/17 下午 10:44
     * @param $data 发送的数据
     * @return mixed
     * @throws \Exception
     */
    public function send($data)
    {if ($this->client->isConnected()) {if (!is_string($data)) {$data = json_encode($data);
            }
            return $this->client->send($data);
        } else {throw new \Exception('Swoole Server does not connected.');
        }
    }

    /**
     * Notes: 敞开链接
     * User: 闻铃
     * DateTime: 2021/11/17 下午 10:45
     */
    public function close()
    {$this->client->close();
    }

    /**
     * Notes: 接收数据
     * User: 闻铃
     * DateTime: 2021/11/17 下午 10:45
     * @return array
     */
    public function recv()
    {
        // 承受数据
        return $this->client->recv();}
}

如果想要作为 webscoket 客户端的话, 也是能够的, 能够应用官网的 websocket 包 (saber)
后续更新

3. 注意事项
。。。后续更新