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 ;

    };
};

簡略代碼如上
環(huán)境 windows 10，php8 , 命令行 php server.php 啟動
可以獲取到服務(wù)端的信息，但是馬上就顯示
@@@child exit@@@
Worker process terminated
然后主程序關(guān)閉
日志也只顯示
pid:1 Worker process terminated

有試過 try catch 在不同閉包下捕獲，沒有任何異常

本人使用學(xué)習(xí) workerman 僅三周，歡迎指正

 2361  4 0

4個回答

ken124 2021-10-18

剛看完TI10, 回來補充下開發(fā)的想法，我發(fā)現(xiàn)自己彎沒轉(zhuǎn)過來，既然 workerman 的 http請求我自己做不好，那我就用老辦法 curl 或 fsockopen啊，明天試試

暫無評論

喵了個咪 2021-10-18

看看是不是哪里執(zhí)行exit die 了，我這測試沒出現(xiàn)啥錯誤。下面是測試代碼和結(jié)果

<?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();

測試結(jié)果。