dispatch_stream.php 358 B

12345678910111213141516
  1. <?php
  2. $serv = new swoole_server("127.0.0.1", 9501);
  3. $serv->set(array(
  4. 'dispatch_mode' => 7,
  5. 'worker_num' => 2,
  6. ));
  7. $serv->on('receive', function (swoole_server $serv, $fd, $threadId, $data)
  8. {
  9. var_dump($data);
  10. echo "#{$serv->worker_id}>> received length=" . strlen($data) . "\n";
  11. $serv->send($fd, "Swoole $data\n");
  12. });
  13. $serv->start();