自定义进程

在webman中你可以像workerman那样自定义监听或者进程。

自定义监听例子

新建 process/Pusher.php

  1. <?php
  2. namespace process;
  4. use Workerman\Connection\TcpConnection;
  6. class Pusher
  7. {
  8.     public function onConnect(TcpConnection $connection)
  9.     {
  10.         echo "onConnect\n";
  11.     }
  13.     public function onWebSocketConnect(TcpConnection $connection, $http_buffer)
  14.     {
  15.         echo "onWebSocketConnect\n";
  16.     }
  18.     public function onMessage(TcpConnection $connection, $data)
  19.     {
  20.         $connection->send($data);
  21.     }
  23.     public function onClose(TcpConnection $connection)
  24.     {
  25.         echo "onClose\n";
  26.     }
  27. }

注意：所有onXXX属性均为public

在config/process.php中添加如下配置

  1. return [
  2.     // ... 其它进程配置省略
  4.     // websocket_test 为进程名称
  5.     'websocket_test' => [
  6.         // 这里指定进程类，就是上面定义的Pusher类
  7.         'handler' => process\Pusher::class,
  8.         'listen'  => 'websocket://0.0.0.0:8888',
  9.         'count'   => 1,
  10.     ],
  11. ];

自定义非监听进程例子

新建 process/TaskTest.php

  1. <?php
  2. namespace process;
  4. use Workerman\Timer;
  5. use support\Db;
  7. class TaskTest
  8. {
  10.     public function onWorkerStart()
  11.     {
  12.         // 每隔10秒检查一次数据库是否有新用户注册
  13.         Timer::add(10, function(){
  14.             Db::table('users')->where('regist_timestamp', '>', time()-10)->get();
  15.         });
  16.     }
  18. }

在config/process.php中添加如下配置

  1. return [
  2.     // ... 其它进程配置省略
  4.     'task' => [
  5.         'handler'  => process\TaskTest::class
  6.     ],
  7. ];

注意：listen省略则不监听任何端口，count省略则进程数默认为1。

配置文件说明

一个进程完整的配置定义如下：

  1. return [
  2.     // ... 
  4.     // websocket_test 为进程名称
  5.     'websocket_test' => [
  6.         // 这里指定进程类
  7.         'handler' => process\Pusher::class,
  8.         // 监听的协议 ip 及端口 （可选）
  9.         'listen'  => 'websocket://0.0.0.0:8888',
  10.         // 进程数 （可选，默认1）
  11.         'count'   => 2,
  12.         // 进程运行用户 （可选，默认当前用户）
  13.         'user'    => '',
  14.         // 进程运行用户组 （可选，默认当前用户组）
  15.         'group'   => '',
  16.         // 当前进程是否支持reload （可选，默认true）
  17.         'reloadable' => true,
  18.         // 是否开启reusePort （可选，此选项需要php>=7.0，默认为true）
  19.         'reusePort'  => true,
  20.         // transport (可选，当需要开启ssl时设置为ssl，默认为tcp)
  21.         'transport'  => 'tcp',
  22.         // context （可选，当transport为是ssl时，需要传递证书路径）
  23.         'context'    => [], 
  24.         // 进程类构造函数参数，这里为 process\Pusher::class 类的构造函数参数 （可选）
  25.         'constructor' => [],
  26.     ],
  27. ];

总结

webman的自定义进程实际上就是workerman的一个简单封装，它将配置与业务分离，并且将workerman的onXXX回调通过类的方法来实现，其它用法与workerman完全相同。