下面的代码不太明白,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'));
AsyncTcpConnection 用来发起一个异步连接,
提供onConnect/onMessage/onClose/OnError回调
可以通过这个异步连接和对端通讯数据,通讯内容自己确定。