<?php
$http_worker = new Worker ('http://0.0.0.0:8089'); 

$http_worker->onWorkerStart = function($http_worker) {
    //子進程啟動后，建立tcp客戶端，
    $inner_tcp_client = new AsyncTcpConnection('tcp://127.0.0.1:19640'); 

    $inner_tcp_client->onConnect = function( $inner_tcp_client)
    {     
        $reg_info = '';
        $inner_tcp_client->send($reg_info);
    };

    $inner_tcp_client->onMessage = function( $inner_tcp_client, $data) {     
        if ($parse_uid == '_server'){
            //如何返回給http_worker?
            //$http_worker ->send("replay"); //這樣對嗎?
    };

    $inner_tcp_client->connect();
    $http_worker->inner_tcp_client = $inner_tcp_client;
};

$http_worker->onMessage = function ($connection, $data) use ($http_worker) {
    $http_worker->inner_tcp_client->send($data);
};

Worker::runAll();
?>

<?php
$http_worker = new Worker ('http://0.0.0.0:8089'); 

$http_worker->onMessage = function($http_connection, $request) {
    //子進程啟動后，建立tcp客戶端，
    $inner_tcp_client = new AsyncTcpConnection('tcp://127.0.0.1:19640'); 

    $inner_tcp_client->onConnect = function( $inner_tcp_client)
    {     
        $reg_info = '';
        $inner_tcp_client->send($reg_info);
    };

    $inner_tcp_client->onMessage = function( $inner_tcp_client, $data) use ($http_connection) {     
        $inner_tcp_client->close();
        $http_connection->send('.....');
    };

    $inner_tcp_client->connect();
};

Worker::runAll();