基本流程

（以一个简单的Websocket聊天室服务端为例）

1、任意位置建立项目目录

如 SimpleChat/

2、引入Workerman/Autoloader.php

如

  1. require_once '/your/path/Workerman/Autoloader.php';

3、选定协议

这里我们选定Text文本协议(WorkerMan中自定义的一个协议，格式为文本+换行)

（目前WorkerMan支持HTTP、Websocket、Text文本协议，如果需要使用其它协议，请参照协议一章开发自己的协议）

4、根据需要写入口启动脚本

例如下面这个是一个简单的聊天室的入口文件。

SimpleChat/start.php

  1. <?php
  2. use Workerman\Worker;
  3. require_once '/your/path/Workerman/Autoloader.php';
  5. $global_uid = 0;
  7. // 当客户端连上来时分配uid，并保存连接，并通知所有客户端
  8. function handle_connection($connection)
  9. {
  10.     global $text_worker, $global_uid;
  11.     // 为这个链接分配一个uid
  12.     $connection->uid = ++$global_uid;
  13. }
  15. // 当客户端发送消息过来时，转发给所有人
  16. function handle_message($connection, $data)
  17. {
  18.     global $text_worker;
  19.     foreach($text_worker->connections as $conn)
  20.     {
  21.         $conn->send("user[{$connection->uid}] said: $data");
  22.     }
  23. }
  25. // 当客户端断开时，广播给所有客户端
  26. function handle_close($connection)
  27. {
  28.     global $text_worker;
  29.     foreach($text_worker->connections as $conn)
  30.     {
  31.         $conn->send("user[{$connection->uid}] logout");
  32.     }
  33. }
  35. // 创建一个文本协议的Worker监听2347接口
  36. $text_worker = new Worker("text://0.0.0.0:2347");
  38. // 只启动1个进程，这样方便客户端之间传输数据
  39. $text_worker->count = 1;
  41. $text_worker->onConnect = 'handle_connection';
  42. $text_worker->onMessage = 'handle_message';
  43. $text_worker->onClose = 'handle_close';
  45. Worker::runAll();

5、测试

Text协议可以用telnet命令测试

  1. telnet 127.0.0.1 2347