AsyncTcpConnection 异步tcp连接类

chinablue

下面的代码不太明白,workman 异步连接 说是“把当前的socket 请求引流至服务器去处理”?
就下面这个段代码,想确认一下

 $this->_socket = stream_socket_client("tcp://{$this->_remoteAddress}", $errno, $errstr, 0, STREAM_CLIENT_ASYNC_CONNECT);

// 创建异步连接
$this->_socket = stream_socket_client("tcp://{$this->_remoteAddress}", $errno, $errstr, 0, STREAM_CLIENT_ASYNC_CONNECT);
// 如果失败尝试触发失败回调(如果有回调的话)
if(!$this->_socket)
{
    $this->_status = self::STATUS_CLOSED;
    $this->emitError(WORKERMAN_CONNECT_FAIL, $errstr);
    return;
}
// 监听连接可写事件(可写意味着连接已经建立或者已经出错)
Worker::$globalEvent->add($this->_socket, EventInterface::EV_WRITE, array($this, 'checkConnection'));
4943 1 0
1个回答

walkor

AsyncTcpConnection 用来发起一个异步连接,
提供onConnect/onMessage/onClose/OnError回调
可以通过这个异步连接和对端通讯数据,通讯内容自己确定。

  • 暂无评论
年代过于久远,无法发表回答
🔝