stream_server.php 752 B

12345678910111213141516171819202122232425262728
  1. <?php
  2. $serv = new swoole_server(__DIR__."/svr.sock", 9501, SWOOLE_BASE, SWOOLE_SOCK_UNIX_STREAM);
  3. $serv->set(array(
  4. //'tcp_defer_accept' => 5,
  5. 'worker_num' => 1,
  6. //'daemonize' => true,
  7. //'log_file' => '/tmp/swoole.log'
  8. ));
  9. $serv->on('start', function($serv){
  10. chmod($serv->host, 0777);
  11. });
  12. $serv->on('Connect', function($serv, $fd, $reactorId) {
  13. echo "Connect, client={$fd}\n";
  14. });
  15. $serv->on('Close', function($serv, $fd, $reactorId) {
  16. echo "Close, client={$fd}\n";
  17. });
  18. $serv->on('receive', function (swoole_server $serv, $fd, $reactor_id, $data)
  19. {
  20. echo "[#" . posix_getpid() . "]\tClient[$fd]: $data\n";
  21. $serv->send($fd, json_encode(array("hello" => $data, "from" => $reactor_id)) . PHP_EOL);
  22. });
  23. $serv->start();