<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                ??碼云GVP開源項目 12k star Uniapp+ElementUI 功能強大 支持多語言、二開方便! 廣告
                # swoole_server->sendMessage 此函數可以向任意`worker`進程或者`task`進程發送消息。在非主進程和管理進程中可調用。收到消息的進程會觸發`onPipeMessage`事件。 ```php bool swoole_server->sendMessage(mixed $message, int $dst_worker_id); ``` 參數 ---- * `$message`為發送的消息數據內容,沒有長度限制,但超過`8K`時會啟動內存臨時文件 * `$dst_worker_id`為目標進程的`ID`,范圍是`0 ~ (worker_num + task_worker_num - 1)` * 在`Task`進程內調用`sendMessage`是阻塞等待的,發送消息完成后返回 * 在`Worker`進程內調用`sendMessage`是異步的,消息會先存到發送隊列,可寫時向管道發送此消息 * 在`User`進程內調用`sendMessage`底層會自動判斷當前的進程是異步還是同步選擇不同的發送方式 返回值 --- 發送成功返回`true`,失敗返回`false` > `sendMessage`接口在`1.7.9`以上版本可用 > `MacOS/FreeBSD`下超過`2K`就會使用臨時文件存儲 注意事項 --- * 使用`sendMessage`必須注冊`onPipeMessage`事件回調函數 * 設置了`task_ipc_mode = 3`將無法使用`sendMessage`向特定的`task`進程發送消息 實例 ---- ```php $serv = new swoole_server("0.0.0.0", 9501); $serv->set(array( 'worker_num' => 2, 'task_worker_num' => 2, )); $serv->on('pipeMessage', function($serv, $src_worker_id, $data) { echo "#{$serv->worker_id} message from #$src_worker_id: $data\n"; }); $serv->on('task', function ($serv, $task_id, $from_id, $data){ var_dump($task_id, $from_id, $data); }); $serv->on('finish', function ($serv, $fd, $from_id){ }); $serv->on('receive', function (swoole_server $serv, $fd, $from_id, $data) { if (trim($data) == 'task') { $serv->task("async task coming"); } else { $worker_id = 1 - $serv->worker_id; $serv->sendMessage("hello task process", $worker_id); } }); $serv->start(); ```
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看