tcp_server.php 1008 B

1234567891011121314151617181920212223242526272829303132333435363738
  1. <?php
  2. $serv = new SocketServer();
  3. $serv->run('0.0.0.0', 9504);
  4. class SocketServer
  5. {
  6. protected $serv; //swoole server
  7. const MAX_PACKAGE_LEN = 8000000; //max data accept
  8. function run($host, $port)
  9. {
  10. $this->serv = new swoole_server($host, $port, SWOOLE_BASE);
  11. $this->serv->set(array(
  12. 'enable_coroutine' => false,
  13. 'worker_num' => 1, //how much worker will start
  14. ));
  15. $this->serv->on('receive', array($this, 'onReceive'));
  16. $this->serv->start();
  17. }
  18. function onReceive($serv, $fd, $tid, $data)
  19. {
  20. echo "recv " . strlen($data) . " bytes\n";
  21. // $packet = substr($data, 4);
  22. // $result = array(
  23. // "code" => "0",
  24. // "msg" => "ok",
  25. // "data" => $packet,
  26. // );
  27. // $resp = json_encode($result);
  28. // $send_data = pack('N', strlen($resp)) . $resp;
  29. // echo "send " . strlen($send_data) . " bytes\n";
  30. // $serv->send($fd, $send_data);
  31. }
  32. }