windows workerman作为客户端 tcp模拟http请求后，显示 @@@child exit@@@ Worker process terminated并直接退出

ken124 更新于2021-10-18

$worker->onConnect = function($connection){
    $connection->onMessage = function( $connection ){
        $host = "xxx.xxx.xxx.xxx:xxx";
        $bw = "POST / HTTP/1.1
Host:$host
Connection:keep-alive
Content-Type:application/json;charset=UTF-8
Content-Length:0

";

        $http_connect = new AsyncTcpConnection("tcp://$host");

        $http_connect->onConnect = function( $connection ) use ( $bw ){
            echo "握手成功";
            $connection->send( $bw );
        };

        $http_connect->onMessage = function( $http_connection , $response ) use ( $connection ){
            var_dump( $response );
            $http_connection->close();
            $connection->send( $response );
            $connection->close();
        };

        $http_connect->connect();

        return ;

    };
};

简略代码如上
环境 windows 10，php8 , 命令行 php server.php 启动
可以获取到服务端的信息，但是马上就显示
@@@child exit@@@
Worker process terminated
然后主程序关闭
日志也只显示
pid:1 Worker process terminated

有试过 try catch 在不同闭包下捕获，没有任何异常

本人使用学习 workerman 仅三周，欢迎指正

 1967  4 0

4个回答

ken124 2021-10-18

刚看完TI10, 回来补充下开发的想法，我发现自己弯没转过来，既然 workerman 的 http请求我自己做不好，那我就用老办法 curl 或 fsockopen啊，明天试试

暂无评论

喵了个咪 2021-10-18

看看是不是哪里执行exit die 了，我这测试没出现啥错误。下面是测试代码和结果

<?php
require_once __DIR__ . '/vendor/autoload.php';
use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;

$worker = new Worker('http://0.0.0.0:12345');
$worker->onConnect = function($connection){
    $connection->onMessage = function( $connection ){
        $host = "baidu.com";
        $bw = "POST / HTTP/1.1
Host:$host
Connection:keep-alive
Content-Type:application/json;charset=UTF-8
Content-Length:0

";
        $http_connect = new AsyncTcpConnection("tcp://$host");
        $http_connect->onConnect = function( $connection ) use ( $bw ){
            echo "握手成功";
            $connection->send( $bw );
        };
        $http_connect->onMessage = function( $http_connection , $response ) use ( $connection ){
            var_dump( $response );
            $http_connection->close();
            $connection->send( $response );
            $connection->close();
        };
        $http_connect->connect();
        return ;
    };
};
Worker::runAll();

测试结果。