发表新帖

fgets标准输入输出，会阻塞tcp客户端通信，怎么处理？[已解决]

{{{php
$handle=fopen("php://stdin", "r");
$str=fgets($handle);
}}}

编写tcp客户端，这两行代码无论放在哪，都会阻塞$client->send()方法。请问如何才能不阻塞？

## 坑
tcp client端编程，无论是循环，还是读取标准输入，都会阻塞client的事件监听，导致各种奇怪的问题。虽然问题解决了，但我还不肯定我明白了其中的道理。

## 解决方法如下：

###  tcp server 端
{{{php
<?php
/**
 * 演示swoole tcp server
 * User: dylan
 * Date: 2018/1/20
 * Time: 14:28
 */
// 客户端id=>上次心跳时间数组
$GLOBALS['heartMap']=[];

//创建Server对象，监听 127.0.0.1:9501端口
$serv = new swoole_server("127.0.0.1", 9501);
$serv->set(array(
    'open_eof_split' => true, //打开EOF_SPLIT检测
    'open_eof_check' => true, //打开EOF检测
    'package_eof' => "\r\n", //设置EOF
));

//监听连接进入事件
$serv->on('connect', function ($serv, $fd) {
    echo "Client: Connect.\n";
    $GLOBALS['heartMap'][$fd] = time();
});

//监听数据接收事件
$serv->on('receive', function ($serv, $fd, $from_id, $data) use(&$heartMap) {
    $data = trim($data);
    if($data == "ping"){
        $GLOBALS['heartMap'][$fd] = time(); // 其实只要有数据就可以认为有心跳
        $serv->send($fd,"pong\r\n");
    }else{
        $serv->send($fd, "Server: ".$data."\r\n");
    }
});

//监听连接关闭事件
$serv->on('close', function ($serv, $fd) {
    echo "Client: Close.\n";
});

$serv->on('workerStart', function (swoole_server $serv,$worker_id) use(&$heartMap) {
    echo "Server: start.\n";
    // 心跳检测
    // 全局变量
    $heartCheck = $serv->tick(1000*5, function () use (&$serv,&$heartMap) {
        $now = time();
//        var_dump($GLOBALS['heartMap']);
        if($GLOBALS['heartMap']){
            foreach ($GLOBALS['heartMap'] as $id=>$time){
                if(($now - $time) >10){
                    echo $id."因超时而断开链接";
                    $serv->close($id,true);
                    unset($GLOBALS['heartMap'][$id]);
                }
            }
        }
    });

});

//启动服务器
$serv->start();

}}}

### tcp client 端
{{{php

<?php
/**
 * 演示 tcp client端循环发送标准输入给tcp server端
 * User: dylan
 * Date: 2018/1/21
 * Time: 16:50
 */

$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);
$client->set(array(
    'open_eof_check' => true,
    'open_eof_split' => true,
    'package_eof' => "\r\n",
));
//注册连接成功回调
$client->on("connect", function($cli) {
    $cli->send("hello world\r\n");
});

//注册数据接收回调
$client->on("receive", function($cli, $data) use(&$timeout_heater){
    $data = trim($data);
    if($data == "pong"){
        $timeout_heater = time();
    }else{
        echo "Received: ".$data."\n";
    }
});

// 注册连接失败回调
$client->on("error", function($cli){
    echo "Connect failed\n";
});

// 注册连接关闭回调
// 连接关闭时，清理业务和心跳检测
$client->on("close", function($cli) use(&$tick_heater,&$info){
//    Swoole\Timer::clear($info);
    Swoole\Timer::clear($tick_heater);
    echo "Connection close\n";
});

//发起连接
$client->connect('127.0.0.1', 9501, 0.5);

// 心跳检测
$timeout_heater = time();
$tick_heater = Swoole\Timer::tick(1000 * 3, function () use ($client,&$timeout_heater,&$tick_heater) {
    $client->send("ping\r\n");
    if((time() - $timeout_heater) >30){
        echo "心跳检测超时";
        $client->close();
        Swoole\Timer::clear($tick_heater);
    }
});

/**
 * 启动子进程
 * @param $client
 */
function io(&$client){
    $process = new Swoole\Process('asyncChildren',false);
    $pid = $process->start();
    echo "进程{$pid}创建成功.\r\n";

// 用事件机制接收子进程消息
    Swoole\Event::add($process->pipe, function($pipe) use ($process,$client) {
        $recv = trim($process->read());
        if ($recv) {
            echo "From Worker: " . $recv;
            $client->send($recv."\r\n");
        }
    });

// 回收子进程
    swoole_process::signal(SIGCHLD, function($sig){
        while($p = Swoole\Process::wait(false)){
            echo "进程{$p['pid']}回收完成\r\n";
        }
    });

}

/**
 * 异步子进程构造函数
 *
 * @param \Swoole\Process $worker
 */
function asyncChildren(Swoole\Process $worker){
    $pid = $worker->pid;
    $worker->name(sprintf('php-ps:%d',$pid));

// 不知道干嘛用
    swoole_process::signal(SIGTERM, function($signal_num) use ($worker) {
        echo "signal call = $signal_num, #{$worker->pid}\n";
    });

// 发送消息给主进程测试
//    Swoole\Timer::tick(1000, function () use ($worker)
//    {
//        if (rand(1, 3) % 2) {
//            $worker->write("hello master {$worker->pid}\n");
//        }
//    });

// 标准输入消息测试
    $io = true;
    while ($io) {
        $data = trim(fread(STDIN, 8192));
        if ($data == ":q") {
            $io = false;
            break;
        } else {
//            echo $data;
            $worker->write("hello master: {$data}\n");
        }
    }

// 从主进程读取消息
    Swoole\Event::add($worker->pipe, function($pipe) use($worker) {
        $recv = $worker->read();
        echo "From Master: $recv\n";
    });
}

io($client);

}}}

发布于4年前 · 2 次浏览 · 来自提问

　 彳亍上杉