国产+高潮+在线,国产 av 仑乱内谢,www国产亚洲精品久久,51国产偷自视频区视频,成人午夜精品网站在线观看

windows workerman 4.0.19，建立 task 異步連接，一段時(shí)間后無(wú)法通信，跪求大佬幫忙看看！

kris

系統(tǒng)：windows server 2016
workerman：4.0.19
php：7.3.4
push主進(jìn)程代碼：

    // 與 接收task 服務(wù)建立異步連接
    $task_received_connection = new AsyncTcpConnection('tcp://127.0.0.1:2000');

    // 告訴接收進(jìn)程，我是 push 進(jìn)程
    $task_received_connection->send(json_encode(array('type' => 'push_process')));

    // 異步獲得結(jié)果
    $task_received_connection->onMessage = function ($task_r_c, $data) {
        $msg = 'date: ' . date('Y-m-d H:i:s') . '--- task_received_message: ' . $data;
        echo $msg;
    };
    $task_received_connection->connect();  // 執(zhí)行接收 task 異步連接

接收進(jìn)程代碼：

<?php

use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;
use Common\Common\PRedis;
use Common\Common\Bytes;
use Workerman\RedisQueue\Client as RQClient;
use Workerman\Redis\Client;
use Workerman\MySQL\Connection;

class Received
{
    public $worker         = null;       // 初始化 worker 容器，監(jiān)聽(tīng) 997 端口
    public $redis          = null;       // redis 單例
    public $uidConnections = array();    // 保存 客戶(hù)端的 uid 標(biāo)識(shí)(唯一) 到 connection 的映射
    public $mysql          = null;       // mysql 實(shí)例
    public $config         = array();    // 加載 mysql 配置

    public $push_process_str = 'push_process';  // push 進(jìn)程名稱(chēng)字符串
    public $special_mark     = '!@#*';          // 每個(gè)數(shù)據(jù)結(jié)尾加上此特殊標(biāo)記，用于分開(kāi)數(shù)據(jù)

    public function __construct()
    {
        require_once __DIR__ . '/vendor/autoload.php';

        $this->worker = new Worker("tcp://0.0.0.0:2000");

        // 這里進(jìn)程數(shù)只能設(shè)置為 1
        $this->worker->count = 1;
        $this->worker->name  = 'TaskWorker';

        // 調(diào)用類(lèi)的方法
        $this->worker->onWorkerStart = array($this, 'onWorkerStart');
        $this->worker->onConnect     = array($this, 'onConnect');
        $this->worker->onMessage     = array($this, 'onMessage');
        $this->worker->onClose       = array($this, 'onClose');
        $this->worker->onWorkerStop  = array($this, 'onWorkerStop');

        // 運(yùn)行所有的 worker（其實(shí)當(dāng)前只定義了一個(gè)）
        Worker::runAll();
    }

    /**
     * worker 進(jìn)程啟動(dòng)后建立一個(gè)內(nèi)部通訊端口
     * @param $worker
     * @throws Exception
     */
    public function onWorkerStart($worker)
    {
    }

    /**
     * 當(dāng)有客戶(hù)端連接時(shí)執(zhí)行該回調(diào)函數(shù)
     * @param $connection
     */
    public function onConnect($connection)
    {
        $ip_msg = "new connection Received from ip " . $connection->getRemoteIp();
        var_dump('date: ' . date('Y-m-d H:i:s') . '---' . $ip_msg);
    }

    /**
     * 當(dāng)有客戶(hù)端發(fā)來(lái)消息時(shí)執(zhí)行該回調(diào)函數(shù)
     * @param $connection
     * @param $message
     * @throws Exception
     */
    public function onMessage($connection, $message)
    {
        $received_msg = "received 2000 port message: " . $message;
        var_dump($received_msg);

        $message_arr = json_decode($message, true);

        if ( $message_arr['type'] == $this->push_process_str ) {      // 當(dāng)收到來(lái)自 push進(jìn)程 的連接時(shí)，保持長(zhǎng)連接
            $this->uidConnections[ $this->push_process_str ] = $connection;
        } else {
            // 接收到數(shù)據(jù)，直接關(guān)閉
            $connection->close();

            $con = isset($this->uidConnections[ $this->push_process_str ]) ? $this->uidConnections[ $this->push_process_str ] : false;
            if ($con) {   // 連接上的客戶(hù)端，才執(zhí)行發(fā)送

                // 每個(gè)數(shù)據(jù)結(jié)尾加上此特殊符號(hào)，用于分開(kāi)數(shù)據(jù)
                $message .= $this->special_mark;

                $log = $this->push_process_str . '--- message: ' . $message;
                var_dump('date: ' . date('Y-m-d H:i:s') . '---' . $log);

                // 向 push 客戶(hù)端發(fā)送數(shù)據(jù)
                $con->send($message);
            } else {
                $log = $this->push_process_str . ' No connection established !';
                var_dump('date: ' . date('Y-m-d H:i:s') . '---' . $log);
            }
        }
    }

    /**
     * 當(dāng)有客戶(hù)端連接斷開(kāi)時(shí)
     * @param $connection
     * @throws Exception
     */
    public function onClose($connection)
    {
    }

    /**
     * 當(dāng) worker 進(jìn)程停止時(shí)
     * @param $connection
     */
    public function onWorkerStop($connection)
    {
    }
}

new Received();

問(wèn)題：
他們兩建立連接，并可以通信，啟動(dòng)幾天或幾個(gè)小時(shí)之后，Received 無(wú)法發(fā)送信息到 push 進(jìn)程中去，windows 端口狀態(tài)截圖：
截圖

1583 1 0
1個(gè)回答
walkor 打賞

截圖下無(wú)法發(fā)送時(shí)界面打印的日志

  • kris 2022-03-17

    沒(méi)記錄，send 返回的結(jié)果， $log = $this->push_process_str . '--- message: ' . $message; 這一步是能正常執(zhí)行的，我添加一下 log
  • kris 2022-09-07

    task 進(jìn)程發(fā)送代碼：
    $res = $con->send($message);
    echo 'received send result = ' . $res;
    打印日志：
    received send result = 1
    send 返回的結(jié)果是 true，現(xiàn)在換到 CentOS Linux release 7.5.1804 (Core) 系統(tǒng)中，還是會(huì)出現(xiàn)偶爾異步次進(jìn)程發(fā)送成功，但主進(jìn)程無(wú)法接收的情況，還額外添加了每隔 35秒 執(zhí)行心跳，reload 一下又可以正常通信，一個(gè)月大概出現(xiàn)一次，打印的狀態(tài)：
    [root@VM-0-7-centos Workerman]# ./status.sh
    Workerman[Received.php] status
    ----------------------------------------------GLOBAL STATUS----------------------------------------------------
    Workerman version:4.0.19 PHP version:7.3.4
    start time:2022-08-19 09:57:10 run 19 days 4 hours
    load average: 1.16, 1, 1 event-loop:\Workerman\Events\React\StreamSelectLoop
    1 workers 1 processes
    worker_name exit_status exit_count
    TaskWorker 0 0
    ----------------------------------------------PROCESS STATUS---------------------------------------------------
    pid memory listening worker_name connections send_fail timers total_request qps status
    1259 2M tcp://0.0.0.0:2000 TaskWorker 1 0 0 51853 0 [idle]
    ----------------------------------------------PROCESS STATUS---------------------------------------------------
    Summary 2M - - 1 0 0 51853 0 [Summary]
    Workerman[SendPush.php] status
    ----------------------------------------------GLOBAL STATUS----------------------------------------------------
    Workerman version:4.0.19 PHP version:7.3.4
    start time:2022-08-19 09:57:10 run 19 days 4 hours
    load average: 1.16, 1, 1 event-loop:\Workerman\Events\React\StreamSelectLoop
    1 workers 1 processes
    worker_name exit_status exit_count
    TaskWorker 0 0
    ----------------------------------------------PROCESS STATUS---------------------------------------------------
    pid memory listening worker_name connections send_fail timers total_request qps status
    1263 2M tcp://0.0.0.0:2001 TaskWorker 1 0 2 47094 0 [idle]
    ----------------------------------------------PROCESS STATUS---------------------------------------------------
    Summary 2M - - 1 0 2 47094 0 [Summary]
    Workerman[PushNew.php] status
    ----------------------------------------------GLOBAL STATUS----------------------------------------------------
    Workerman version:4.0.19 PHP version:7.3.4
    start time:2022-08-19 09:57:10 run 19 days 4 hours
    load average: 1.16, 1, 1 event-loop:\Workerman\Events\React\StreamSelectLoop
    1 workers 1 processes
    worker_name exit_status exit_count
    none 0 0
    ----------------------------------------------PROCESS STATUS---------------------------------------------------
    pid memory listening worker_name connections send_fail timers total_request qps status
    1267 4M tcp://0.0.0.0:997 none 46 0 2 261810 0 [idle]
    ----------------------------------------------PROCESS STATUS---------------------------------------------------
    Summary 4M - - 46 0 2 261810 0 [Summary]
    [root@VM-0-7-centos Workerman]# ./connections.sh
    Workerman[Received.php] connections
    --------------------------------------------------------------------- WORKERMAN CONNECTION STATUS --------------------------------------------------------------------------------
    PID Worker CID Trans Protocol ipv4 ipv6 Recv-Q Send-Q Bytes-R Bytes-W Status Local Address Foreign Address
    1259 TaskWorker 1 tcp tcp 1 0 0B 0B 1.1MB 2.6MB ESTABLISHED 127.0.0.1:2000 127.0.0.1:38027
    Workerman[SendPush.php] connections
    --------------------------------------------------------------------- WORKERMAN CONNECTION STATUS --------------------------------------------------------------------------------
    PID Worker CID Trans Protocol ipv4 ipv6 Recv-Q Send-Q Bytes-R Bytes-W Status Local Address Foreign Address
    1263 TaskWorker 1 tcp tcp 1 0 0B 0B 1.1MB 3.6MB ESTABLISHED 127.0.0.1:2001 127.0.0.1:55405
    Workerman[PushNew.php] connections
    --------------------------------------------------------------------- WORKERMAN CONNECTION STATUS --------------------------------------------------------------------------------
    PID Worker CID Trans Protocol ipv4 ipv6 Recv-Q Send-Q Bytes-R Bytes-W Status Local Address Foreign Address
    1267 none 1 tcp tcp 1 0 0B 0B 2.6MB 1.1MB ESTABLISHED 127.0.0.1:38027 127.0.0.1:2000
    1267 none 2 tcp tcp 1 0 0B 0B 3.6MB 1.1MB ESTABLISHED 127.0.0.1:55405 127.0.0.1:2001
    1267 none 34 tcp tcp 1 0 0B 0B 357.5KB 12.6KB ESTABLISHED 172.20.0.7:997 172.20.0.5:56911
    1267 none 54 tcp tcp 1 0 0B 0B 528.7KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.5:57250
    1267 none 55 tcp tcp 1 0 0B 0B 528.7KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.5:57258
    1267 none 56 tcp tcp 1 0 0B 0B 529.1KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.5:57265
    1267 none 57 tcp tcp 1 0 0B 0B 5.9MB 17.3KB ESTABLISHED 172.20.0.7:997 172.20.0.5:57270
    1267 none 58 tcp tcp 1 0 0B 0B 528.7KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.5:57275
    1267 none 59 tcp tcp 1 0 0B 0B 536.5KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.5:57279
    1267 none 60 tcp tcp 1 0 0B 0B 528.7KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.5:57289
    1267 none 61 tcp tcp 1 0 0B 0B 15.9MB 37.7KB ESTABLISHED 172.20.0.7:997 172.20.0.5:57291
    1267 none 63 tcp tcp 1 0 0B 0B 576.9KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.5:57307
    1267 none 66 tcp tcp 1 0 1.4KB 0B 11.9MB 31.9KB ESTABLISHED 172.20.0.7:997 172.20.0.5:57324
    1267 none 76 tcp tcp 1 0 0B 0B 529.8KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.5:57381
    1267 none 82 tcp tcp 1 0 0B 0B 2.3MB 67.7KB ESTABLISHED 172.20.0.7:997 172.20.0.5:57412
    1267 none 83 tcp tcp 1 0 0B 0B 1.6MB 82KB ESTABLISHED 172.20.0.7:997 172.20.0.5:57417
    1267 none 84 tcp tcp 1 0 0B 0B 3.3MB 63.3KB ESTABLISHED 172.20.0.7:997 172.20.0.5:57423
    1267 none 98 tcp tcp 1 0 0B 0B 227MB 13.1KB ESTABLISHED 172.20.0.7:997 172.20.0.9:49709
    1267 none 107 tcp tcp 1 0 0B 0B 3.2MB 121.4KB ESTABLISHED 172.20.0.7:997 172.20.0.5:62951
    1267 none 112 tcp tcp 1 0 0B 0B 16MB 53.4KB ESTABLISHED 172.20.0.7:997 172.20.0.5:51941
    1267 none 113 tcp tcp 1 0 0B 0B 6.9MB 38KB ESTABLISHED 172.20.0.7:997 172.20.0.5:52368
    1267 none 122 tcp tcp 1 0 0B 0B 3.8MB 143.2KB ESTABLISHED 172.20.0.7:997 172.20.0.5:58738
    1267 none 123 tcp tcp 1 0 0B 0B 4MB 174.8KB ESTABLISHED 172.20.0.7:997 172.20.0.5:58764
    1267 none 124 tcp tcp 1 0 0B 0B 1.2MB 63.7KB ESTABLISHED 172.20.0.7:997 172.20.0.5:58783
    1267 none 125 tcp tcp 1 0 0B 0B 342.2KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.5:58795
    1267 none 126 tcp tcp 1 0 0B 0B 342.2KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.5:58815
    1267 none 127 tcp tcp 1 0 0B 0B 342.2KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.5:58836
    1267 none 143 tcp tcp 1 0 0B 0B 3.3MB 17.3KB ESTABLISHED 172.20.0.7:997 172.20.0.5:62871
    1267 none 199 tcp tcp 1 0 0B 0B 149.5KB 4.4KB ESTABLISHED 172.20.0.7:997 172.20.0.9:62724
    1267 none 201 tcp tcp 1 0 0B 0B 140.3KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.9:62737
    1267 none 203 tcp tcp 1 0 0B 0B 167.3KB 9.7KB ESTABLISHED 172.20.0.7:997 172.20.0.9:62744
    1267 none 207 tcp tcp 1 0 0B 0B 140.3KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.9:62754
    1267 none 209 tcp tcp 1 0 0B 0B 141KB 504B ESTABLISHED 172.20.0.7:997 172.20.0.9:62768
    1267 none 211 tcp tcp 1 0 0B 0B 151KB 8.2KB ESTABLISHED 172.20.0.7:997 172.20.0.9:62778
    1267 none 212 tcp tcp 1 0 0B 0B 164KB 8.9KB ESTABLISHED 172.20.0.7:997 172.20.0.9:62780
    1267 none 213 tcp tcp 1 0 0B 0B 169.2KB 11.2KB ESTABLISHED 172.20.0.7:997 172.20.0.9:62783
    1267 none 214 tcp tcp 1 0 0B 0B 150.7KB 6.3KB ESTABLISHED 172.20.0.7:997 172.20.0.9:62787
    1267 none 216 tcp tcp 1 0 0B 0B 139.8KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.9:62795
    1267 none 217 tcp tcp 1 0 0B 0B 188KB 17.2KB ESTABLISHED 172.20.0.7:997 172.20.0.9:62799
    1267 none 218 tcp tcp 1 0 0B 0B 155.3KB 4.1KB ESTABLISHED 172.20.0.7:997 172.20.0.9:62802
    1267 none 219 tcp tcp 1 0 0B 0B 139.8KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.9:62807
    1267 none 220 tcp tcp 1 0 0B 0B 139.8KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.9:62812
    1267 none 221 tcp tcp 1 0 0B 0B 139.8KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.9:62817
    1267 none 222 tcp tcp 1 0 0B 0B 139.8KB 0B ESTABLISHED 172.20.0.7:997 172.20.0.9:62822
    1267 none 228 tcp tcp 1 0 0B 0B 77.6KB 5KB ESTABLISHED 172.20.0.7:997 172.20.0.9:54402
    [root@VM-0-7-centos Workerman]# netstat -anp | grep 997
    tcp 0 0 0.0.0.0:997 0.0.0.0: LISTEN 1266/WorkerMan: mas
    tcp 4256 0 172.20.0.7:997 172.20.0.9:62724 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:57275 ESTABLISHED 1267/WorkerMan: wor
    tcp 4256 0 172.20.0.7:997 172.20.0.9:62783 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:57265 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:62951 ESTABLISHED 1267/WorkerMan: wor
    tcp 22571 0 172.20.0.7:997 172.20.0.5:57291 ESTABLISHED 1267/WorkerMan: wor
    tcp 43509 0 172.20.0.7:997 172.20.0.5:58764 ESTABLISHED 1267/WorkerMan: wor
    tcp 4256 0 172.20.0.7:997 172.20.0.9:62780 ESTABLISHED 1267/WorkerMan: wor
    tcp 4256 0 172.20.0.7:997 172.20.0.9:62795 ESTABLISHED 1267/WorkerMan: wor
    tcp 4256 0 172.20.0.7:997 172.20.0.9:62778 ESTABLISHED 1267/WorkerMan: wor
    tcp 0 0 172.20.0.7:997 172.20.0.5:56911 ESTABLISHED 1267/WorkerMan: wor
    tcp 1644291 0 172.20.0.7:997 172.20.0.9:49709 ESTABLISHED 1267/WorkerMan: wor
    tcp 5300 0 172.20.0.7:997 172.20.0.9:62787 ESTABLISHED 1267/WorkerMan: wor
    tcp 4256 0 172.20.0.7:997 172.20.0.9:62812 ESTABLISHED 1267/WorkerMan: wor
    tcp 4256 0 172.20.0.7:997 172.20.0.9:62799 ESTABLISHED 1267/WorkerMan: wor
    tcp 4312 0 172.20.0.7:997 172.20.0.9:62744 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:57279 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:57307 ESTABLISHED 1267/WorkerMan: wor
    tcp 4496 0 172.20.0.7:997 172.20.0.5:52368 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:57412 ESTABLISHED 1267/WorkerMan: wor
    tcp 28431 0 172.20.0.7:997 172.20.0.5:58783 ESTABLISHED 1267/WorkerMan: wor
    tcp 4312 0 172.20.0.7:997 172.20.0.5:57270 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:57289 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:57381 ESTABLISHED 1267/WorkerMan: wor
    tcp 8829 0 172.20.0.7:997 172.20.0.5:51941 ESTABLISHED 1267/WorkerMan: wor
    tcp 4256 0 172.20.0.7:997 172.20.0.9:62807 ESTABLISHED 1267/WorkerMan: wor
    tcp 71125 0 172.20.0.7:997 172.20.0.5:58738 ESTABLISHED 1267/WorkerMan: wor
    tcp 3934 0 172.20.0.7:997 172.20.0.5:62871 ESTABLISHED 1267/WorkerMan: wor
    tcp 4604 0 172.20.0.7:997 172.20.0.9:62802 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:58836 ESTABLISHED 1267/WorkerMan: wor
    tcp 4272 0 172.20.0.7:997 172.20.0.9:62737 ESTABLISHED 1267/WorkerMan: wor
    tcp 4272 0 172.20.0.7:997 172.20.0.9:62754 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:58815 ESTABLISHED 1267/WorkerMan: wor
    tcp 4077 0 172.20.0.7:997 172.20.0.5:57423 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:58795 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:57250 ESTABLISHED 1267/WorkerMan: wor
    tcp 4256 0 172.20.0.7:997 172.20.0.9:62817 ESTABLISHED 1267/WorkerMan: wor
    tcp 4256 0 172.20.0.7:997 172.20.0.9:62768 ESTABLISHED 1267/WorkerMan: wor
    tcp 4256 0 172.20.0.7:997 172.20.0.9:62822 ESTABLISHED 1267/WorkerMan: wor
    tcp 3934 0 172.20.0.7:997 172.20.0.5:57324 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:57258 ESTABLISHED 1267/WorkerMan: wor
    tcp 3881 0 172.20.0.7:997 172.20.0.9:54402 ESTABLISHED 1267/WorkerMan: wor
    tcp 3745 0 172.20.0.7:997 172.20.0.5:57417 ESTABLISHED 1267/WorkerMan: wor
    [root@VM-0-7-centos Workerman]# netstat -anp | grep 2000
    tcp 0 0 0.0.0.0:2000 0.0.0.0:     LISTEN 1258/WorkerMan: mas
    tcp 9631 0 127.0.0.1:38027 127.0.0.1:2000 ESTABLISHED 1267/WorkerMan: wor
    tcp 0 0 127.0.0.1:2000 127.0.0.1:38027 ESTABLISHED 1259/WorkerMan: wor
    [root@VM-0-7-centos Workerman]# netstat -anp | grep 2001
    tcp 0 0 0.0.0.0:2001 0.0.0.0:* LISTEN 1262/WorkerMan: mas
    tcp 0 0 127.0.0.1:55405 127.0.0.1:2001 ESTABLISHED 1267/WorkerMan: wor
    tcp 0 0 127.0.0.1:2001 127.0.0.1:55405 ESTABLISHED 1263/WorkerMan: wor
  • kris 2022-09-07

    大佬幫忙看看是為啥，感謝?。?/p>

  • kris 2022-09-08

    大神，能回復(fù)一下嗎，這個(gè)問(wèn)題困擾我很久了，前面太忙了，沒(méi)時(shí)間修復(fù)，現(xiàn)在又重現(xiàn)了，期待您的回復(fù).
年代過(guò)于久遠(yuǎn)，無(wú)法發(fā)表回答
??