AsyncTcpConnection类 - __construct

优质

小牛编辑

122浏览

2023-12-01

void AsyncTcpConnection::__construct(string $remote_address, $context_option = null)

创建一个异步连接对象。

AsyncTcpConnection可以让Workerman作为客户端向远程服务端发起异步连接，并通过send接口和onMessage回调异步发送和处理连接上的数据。

参数

参数:remote_address

连接的地址，例如

tcp://www.baidu.com:80

ssl://www.baidu.com:443

ws://echo.websocket.org:80

frame://192.168.1.1:8080

text://192.168.1.1:8080

参数:$context_option

此参数要求（workerman >= 3.3.5）

用来设置socket上下文，例如利用bindto设置以哪个(网卡)ip和端口访问外部网络，设置ssl证书等。

参考 stream_context_create、套接字上下文选项、SSL 上下文选项

注意

目前AsyncTcpConnection支持的协议有tcp、ssl、ws、frame、text。

同时支持自定义协议，参见如何自定义协议

其中ssl要求Workerman>=3.3.4，并安装openssl扩展。

目前不支持http协议的AsyncTcpConnection。

可以用new AsyncTcpConnection('ws://...')像浏览器一样在workerman里发起websocket连接远程websocket服务器，见示例。但是不能以 new AsyncTcpConnection('websocket://...')的形式在workerman里发起websocket连接。

示例

示例 1、异步访问外部http服务

use WorkermanWorker;
use WorkermanConnectionAsyncTcpConnection;
require_once __DIR__ . '/Workerman/Autoloader.php';
$task = new Worker();
// 进程启动时异步建立一个到www.baidu.com连接对象，并发送数据获取数据
$task->onWorkerStart = function($task)
{
    $connection_to_baidu = new AsyncTcpConnection('tcp://www.baidu.com:80');
    // 当连接建立成功时，发送http请求数据
    $connection_to_baidu->onConnect = function($connection_to_baidu)
    {
        echo "connect successn";
        $connection_to_baidu->send("GET / HTTP/1.1rnHost: www.baidu.comrnConnection: keep-alivernrn");
    };
    $connection_to_baidu->onMessage = function($connection_to_baidu, $http_buffer)
    {
        echo $http_buffer;
    };
    $connection_to_baidu->onClose = function($connection_to_baidu)
    {
        echo "connection closedn";
    };
    $connection_to_baidu->onError = function($connection_to_baidu, $code, $msg)
    {
        echo "Error code:$code msg:$msgn";
    };
    $connection_to_baidu->connect();
};
// 运行worker
Worker::runAll();

示例 2、异步访问外部websocket服务，并设置以哪个本地ip及端口访问

<?php
use WorkermanWorker;
use WorkermanConnectionAsyncTcpConnection;
require_once __DIR__ . '/Workerman/Autoloader.php';
$worker = new Worker();
$worker->onWorkerStart = function($worker){
    // 设置访问对方主机的本地ip及端口(每个socket连接都会占用一个本地端口)
    $context_option = array(
        'socket' => array(
            // ip必须是本机网卡ip，并且能访问对方主机，否则无效
            'bindto' => '114.215.84.87:2333',
        ),
    );
    $con = new AsyncTcpConnection('ws://echo.websocket.org:80', $context_option);
    $con->onConnect = function($con) {
        $con->send('hello');
    };
    $con->onMessage = function($con, $data) {
        echo $data;
    };
    $con->connect();
};
Worker::runAll();

示例 3、异步访问外部wss端口，并设置本地ssl证书

<?php
use WorkermanWorker;
use WorkermanConnectionAsyncTcpConnection;
require_once __DIR__ . '/../Workerman/Autoloader.php';
$worker = new Worker();
$worker->onWorkerStart = function($worker){
    // 设置访问对方主机的本地ip及端口以及ssl证书
    $context_option = array(
        'socket' => array(
            // ip必须是本机网卡ip，并且能访问对方主机，否则无效
            'bindto' => '114.215.84.87:2333',
        ),
        // ssl选项，参考http://php.net/manual/zh/context.ssl.php
        'ssl' => array(
            // 本地证书路径。 必须是 PEM 格式，并且包含本地的证书及私钥。
            'local_cert'        => '/your/path/to/pemfile',
            // local_cert 文件的密码。
            'passphrase'        => 'your_pem_passphrase',
            // 是否允许自签名证书。
            'allow_self_signed' => true,
            // 是否需要验证 SSL 证书。
            'verify_peer'       => false
        )
    );
    // ssl需要访问443端口
    $con = new AsyncTcpConnection('ws://echo.websocket.org:443', $context_option);
    // 设置以ssl加密方式访问
    $con->transport = 'ssl';
    $con->onConnect = function($con) {
        $con->send('hello');
    };
    $con->onMessage = function($con, $data) {
        echo $data;
    };
    $con->connect();
};
Worker::runAll();