use \Workerman\Worker;
use \Workerman\Connection\AsyncTcpConnection;
require_once './Workerman/Autoloader.php';
define('PING_TIMEOUT', 5);

$task = new Worker();
// 進(jìn)程啟動(dòng)時(shí)異步建立一個(gè)到www.baidu.com連接對(duì)象，并發(fā)送數(shù)據(jù)獲取數(shù)據(jù)
$task->onWorkerStart = function($task)
{
    $connection_to_baidu = new AsyncTcpConnection('ws://127.0.0.1:8080');
    $connection_to_baidu->onWorkerStart = function($connection_to_baidu) {
        echo "3333";
    };

    // 當(dāng)連接建立成功時(shí)，發(fā)送http請(qǐng)求數(shù)據(jù)
    $connection_to_baidu->onConnect = function($connection_to_baidu)
    {
        $connection_to_baidu->lastTime = time();
        $connection_to_baidu->send("lcjn");//隨便發(fā)點(diǎn)什么吧(觸發(fā))
        echo "connect success\n";
    };
    $connection_to_baidu->onMessage = function($connection_to_baidu, $http_buffer)
    {
        $connection_to_baidu->lastTime = time();
        echo $http_buffer;
    };
    $connection_to_baidu->onClose = function($connection_to_baidu)
    {
        echo "connection closed\n";
    };
    $connection_to_baidu->onError = function($connection_to_baidu, $code, $msg)
    {
        echo "Error code:$code msg:$msg\n";
    };
    $connection_to_baidu->connect();
};

// 運(yùn)行worker
Worker::runAll();

比如現(xiàn)在沒(méi)開(kāi)8080端口
1 AsyncTcpConnection 連不上ws，應(yīng)該在onError里面有響應(yīng)事件啊，為什么什么都沒(méi)收到
2 如果端口因?yàn)槟承﹩?wèn)題導(dǎo)致接收不到數(shù)據(jù)，應(yīng)該怎么重新鏈接這個(gè)ws