testBufferWorker.php 460 B

123456789101112131415161718
  1. <?php
  2. error_reporting(E_ALL);
  3. ini_set('display_errors', 'on');
  4. include '../../man/Protocols/Buffer.php';
  5. $sock = stream_socket_client("tcp://127.0.0.1:20305");
  6. if(!$sock)exit("can not create sock\n");
  7. $code = 0;
  8. while(1)
  9. {
  10. $buf = new \Man\Protocols\Buffer();
  11. $buf->body = 'HELLO YAOYAO';
  12. $buf->header['code'] = $code++;
  13. fwrite($sock, $buf->getBuffer());
  14. $ret = fread($sock, 10240);
  15. var_export(\Man\Protocols\Buffer::decode($ret));
  16. }