文档Channel分布式通讯组件
要求Workerman版本>=3.3.0) ```**
源码地址：https://github.com/walkor/Channel
Channel是一个分布式通讯组件，用于完成进程间通讯或者服务器间通讯## 特点
1、基于订阅发布模型
2、非阻塞式IO
## 原理
Channel包含Channel/Server服务端和Channel/Client客户端
Channel/Client通过connect接口连接Channel/Server并保持长连接
Channel/Client通过调用on接口告诉Channel/Server自己关注哪些事件，并注册事件回调函数（回调发生在Channel/Client所在进程中）
Channel/Client通过publish接口向Channel/Server发布某个事件及事件相关的数据
Channel/Server接收事件及数据后会分发给关注这个事件的Channel/Client
Channel/Client收到事件及数据后触发on接口设置的回调
Channel/Client只会收到自己关注事件并触发回调
## 安装
`composer require
问答请问下代码更新后不自动加载怎么回事？？
只有在on{...}回调中载入的文件平滑重启后才会自动更新，但是我怎么搞都不会自动更新，愣是没搞明白，请指点下！
问答不懂怎么回事 我上图
我上图
问答【已解决】打包为bin模式下，upload_max_filesize 动态设置无效
[截图](/upload/img/20230911/1164fee45d9236.png)
再通过 ini_get 获取，发现只有memory_limit调整生效了，另外2个未生效
!
问答wokerman作http服务时，如何压缩返回的json数据？
用php内置的服务器，在返回的时候加上ob_start("ob_gzhandler");
数据成功压缩。
框架：thinkphp6
用wokerman启动的时候，一直压缩不了。求指导如何压缩返回的数据？
问答每次建立新的连接是如何保证，绑定acceptConnection的事件只触发一次的？
我写的例子总是会触发connect方法，一旦telnet建立了连接，会不停输出1111111。如何才能保证每次建立连接，事件只触发一次呢？
```php
<?event_new();
// 创建socket
$serv_socket = stream_socket_server('tcp://0.0.0.0:8000',$errno,$errstr);
// 设置事件循环监听EV_PERSIST,'connect',);
event_base_set($event,$base);
event_add($event);
event_base_loop($base);
// 定义事件回调
问答关于workerman http http 服务访问过快无返回的问题
[截图](/upload/img/20220627/2762b92ba30adc.png)
实际业务过程中，出现http 请求丢失的问题，我对比了经过nginx服务器 发送到workman http 服务的收发日志，同一时刻收到的记录比发出的记录少，导致发送收到的回复超时，我怀疑是如图的问题。问题：我配置了http 服务器，收到即可回复“hello world”,但是 用curl 请求这个端口的时候，如果发送过快就会无回复，卡住。不知道什么原因
!
问答有这样一种需求，不知wm可不可以用来加快效率？
网站会员有几十万，在网站后台要实现对所有会员发信息，目前的做法就是循环用户表，给每个用户插入一条数据，但是这样效率太低，要一个多小时才能全部发完，用wm能不能加快效率？
问答start_gateway 做鉴权，会一直跑是怎么回事啊？
```php
// 当客户端连接上来时，设置连接的onWebSocketConnect，即在websocket握手时的回调
$gateway->onConnect = function($connectionconnection->onWebSocketConnect = function($connection , $http_header)
{
// 可以在这里判断连接来源是否合法，不合法就关掉连接// onWebSocketConnect 里面$_GET $_SERVER是可用的
// var_dump($_GET);
};
};
```
前端JS
// 连接服务端token=123uji2");
// 当socket连接打开时，输入用户名
ws.onopen = onopen;
// 当有消息时根据消息类型显示不同信息
问答workerman 运行 mqtt 服务的will(遗嘱消息), 在服务启动的时候, 会接收到其他服务的遗嘱消息
workerman 运行 mqtt 服务的will(遗嘱消息), 在服务启动的时候, 会接收到其他服务的遗嘱消息。客户端设置好遗嘱以后启动, 你只要服务端订阅者一启动就会收到遗嘱消息，如果此时客户端发布者已经在线，会导致不准确的问题。
这是怎么回事呢? 应该怎么处理这种问题?
问答$worker->onMessage回调发送数据的问题
$worker->onMessage回调事件里，我调用$connection->send 发送数据
，如果我不主动关闭连接的话是等，数据发送完成之后自动就关了，还是必须客户端来关闭才行。
问答mqtt onmesses 里 改东西 reload 不生效
debug模式 看 确实重载了文件
但是 我发送消息后 没有出来这个打印
问答服务器通过tcp长连接接收数据
多个终端1s上报一次数据，会出现终端关闭后，服务器还在接收数据是怎么回事？
问答监听了几个耗时事件，几十个人访问就卡住了
phpsocket.io 写了一个服务端 监听了几个事件
事件都是查询数据库 数据不打
web端定时请求
几十个人访问就卡住了
lievent和 内核都跳优了
难道他这种单进程，不能做耗时操作
问答linux centos7 GatewayWorker运行不起来是怎么回事
运行链接不上 提示 workerman-for-win can not run in linux
文档PHP的几种回调写法
# PHP几种回调写法
PHP里通过匿名函数写回调是最方便的，但是除了匿名函数方式的回调，PHP还有其它的回调写法。以下是PHP几种回调写法的示例。
## 1、匿名函数回调
```php
<?以MySQL为例，在主进程初始化的MySQL连接等资源会被子进程继承，每个子进程都可以操作这个数据库连接，但是这些连接在MySQL服务端对应的是同一个连接，会发生不可预期的错误，例如```mysql gone这样还有一个好处就是支持业务代码reload。由于MyClass.php是在子进程载入的，根据reload规则业务更改MyClass.php后直接reload即可生效。= array('your\namesapce\MyClass', 'onWorkerStop');
Worker::runAll();
```
注意：根据PHP的运行机制，如果没用调用new 则不会调用构造函数，另外静态类的方法里面不允许使用```$this```。
问答[已解决]路由问题 - 不同端口返回参数
存在问题：
```php
Route::post('/demo',[Test::class, 'test']);
```
1. post 正常自行流程 ，如果用get请求，接口直接空白无反应
## 预期效果如果不是自定的提交类型（post|get）当前的group组路由 进行 fallback ，路由return 400 返回前端
```php
h5 为 return redirect('/');
api为 return json(['code'=>400,'msg'=>'路由不存在']);
admin_api ...
shop_admin 等等
```
已下是我自己写的
```php
Route:Test::class, 'del']);
})->middleware([
//登录权限中间件
app\common\middleware\ApiAuth::class,
]);
#不存在webmam 最新版本
php 7.4
nginx 1.2
## 我的解决方案
把fallback放在Route::any() 回调里面 或者在Route::group()组外面 都不成功
```
问答workman 处理繁重任务
有这么一个需求，假设每天新产生用户10w，每天早上六点给这些用户发送激活邮件，用workman怎么进行多启动进程进行处理呢？有的人说 多开php进行 但是有demo了？workman 能批量启动n个任务做这件事么？
问答虽然webman中间件生效了，但是controller中的方法还是执行了
action}"; // 完整的控制器/方法字符串
$response = $handler($request); // 正常情况下继续响应后续请求
// 白名单方法的请求不拦截$token) {
var_dump('token不存在');
return json($res);
}$tokenData || empty($tokenData)) {
var_dump('token内容无效');
return json[截图](/upload/img/20220616/1662aad4f65b3d.png)
这不是期待的结果，虽然查询类的接口可以改造返回值，但是如果是执行类的接口，那岂不是在拦截时就已经执行了。不知道是我在哪里写错了吗？
文档onConnect
如果client_id对应的客户端连接断开了，那么这个client_id也就失效了。当这个客户端再次连接到Gateway时，将会获得一个新的client_id。也就是说client_id和客户端的socket连接生命周期是一致的。
client_id一旦被使用过，将不会被再次使用，也就是说client_id是不会重复的，即使分布式部署也不会重复。## 返回值
无返回值，任何返回值都会被视为无效的
## 注意
``` $client_id ```是服务端自动生成的并且无法自定义。onConnect事件仅仅代表客户端与gateway完成了TCP三次握手，这时客户端还没有发来任何数据，此时除了通过```$_SERVER['REMOTE_ADDR']```获得对方ip，没有其他可以鉴别客户端的数据或者信息，所以在onConnect事件里无法确认对方是谁。
