文档PHP的几种回调写法
= function(TcpConnection $connection, Request $data)
{
// 向浏览器发送hello world
$connection->send= 'on_message';
// 普通函数
function on_message(TcpConnection $connection, Request $request)
{
// 向浏览器发送以MySQL为例，在主进程初始化的MySQL连接等资源会被子进程继承，每个子进程都可以操作这个数据库连接，但是这些连接在MySQL服务端对应的是同一个连接，会发生不可预期的错误，例如```mysql gone由于MyClass.php是在子进程载入的，根据reload规则业务更改MyClass.php后直接reload即可生效。的运行机制，如果没用调用new 则不会调用构造函数，另外静态类的方法里面不允许使用```$this```。
问答关于gatewayworker中使用redis
$user_list = array_values($user_list);
});
```
使用redis的时候zRange 在测试服务器上可以正常获取到数据没有数据也会返回空数组
问答同时做了监听http 和 websocket 为何 onmessage方法的参数不同
前任留下的代码
这里起了一个监听 http 的服务 通过 php脚本去发送请求 onmessage 回调方法的参数是一个连接
websocket 的 onmessage 的参数是 clientid
!
问答用定时器调一个函数，但是报错了，大佬帮忙看下，谢谢！！！
我这个函数是用来向服务端发消息的，用的是php自带的socket,我是想每隔5分钟向服务端发送一个消息，所以就想用workerman的定时器来实现，但是现在报错了，郁闷！！！
问答SendBufferToWorker fail.改了也不管用
start_register.php 我都改了 服务器上端口也开了 但是还是不行 求work大大帮忙看看
```php
return true;
use \Workerman\Worker;
use \GatewayWorkerdefined('GLOBAL_START'))
{
Worker::runAll();
}
```
```php
use \Workerman\Worker;
use \GatewayWorker= 'ChatBusinessWorker';
// bussinessWorker进程数量
$worker->count = 8;
// 服务注册地址
$worker->registerAddressWebsocket://0.0.0.0:3204");
// 设置名称，方便status时查看
$gateway->name = 'Push';
// 设置进程数，gateway进程数建议与cpu核数相同4001 4002 4003 4个端口作为内部通讯端口
$gateway->startPort = 2300;
// 心跳间隔
$gateway->pingInterval = 10;
// 心跳数据
问答AsyncTcpConnection 请求，onMessage中send的数据不被代理服务器解析
#### 在构建ai应用的时候 我使用AsyncTcpConnection向接口发起请求，接口测试一切正常，但是代理服务器读不出来onMessage中send的数据
#### 程序代码或配置
```
问答问一个很低级的问题，关于用户组的
// 已经登录过了
if(isset($socket->uid)){
return;
}
// 更新对应uid的在线数据/ 这个uid有++$uidConnectionMap个socket连接
++$uidConnectionMap;
// 将这个连接加入到uid分组，方便针对uid推送数据$socket->join($uid1);
$socket->uid = $uid;
// 更新这个socket对应页面的在线数据
$socket格式是1（用户ID）,5t(房间ID，要用来当做组名),想问的是，join这个是加入组吧，组名是我传的$uid1，也就是5t,那下面的 $socket->uid = $uid;是做什么用的，我想给房间5t发送消息是成功的，我想给单独的一个uid也就是1,5t发送消息，显示OK，但是在实际上并没有收到，感觉对这个分组还不是很理解，求各位大佬帮帮忙
问答workerman\mqtt subscribe订阅问题
根据官方示例
在 onWorkerStart的回调中进行创建mqtt客户端，然后进行订阅
但官方是订阅一个topic
我现在的需求是以数组的方式进行多个topic订阅，
数组来源于数据库，
发现命令行运行之后，数据库订阅信息进行更新但是workerman创建的mqtt客户端里面订阅的仍然是之前的数据，
目前解决的办法是手动reload命令行，
请问官方人员和其他有经验的大佬，这个问题如何在不重启命令行的情况下进行处理[](/upload/img/20220426/2662679338e3e0.png)
如上，测试每10秒进行订阅，订阅信息确实能够及时更新了，但是没有测试其他功能是否正常，希望官方给予最佳实践，感谢
问答Channel中的connection id的生成机制是无限自增的吗？
做进程间通讯的时候，进程重启多次后发现连接Channel的connection自增了
问答新建一个worker服务，可以单独推送Gateway中连接的用户吗?
请问我启动了一个单独的Worker进程，想推送Gateway中的用户是不是只能在worker进程中使用gatewayClient处理？
问答如何获取Socket的消息头和消息体的长度，把这个消息协议给客户端.
[](//www.workerman.net/upload/20210817/17611b70546cee.jpg)
我需要知道这两个参数，但是后台不知道，只能我自己查了。我看了Websocket这个类，试了几个参数但是还是不行。
客户端现在是可以连接，但是发送数据什么的都解析异常，原因就出在这里。
问答如何给每个请求加上一个全局共享变量
#### 问题描述
需要在发起请求和返回数据之间 记录全部新增修改数据ID 目前是请求时在中间件上加了
$request->operDatas = ['created' => [], 'updated' => []];
在Model里涉及到数据修改时操作时对operDatas进行修改
因为部分数据同步操作非常耗时，就添加了一个process，通过AsyncTcpConnection来进行异步操作。//0.0.0.0:8888',
'count' => cpu_count() * 4,
'reusePort' => true,
],
```
异步请求在操作数据的时候
问答这两段java代码，用php怎么翻译？求指点！
Signature.getInstance("MD5withRSA");
signature.initSign(priKey);
signature.update(data);//data为要生成签名的源数据字节数组return Base64Util.encodeBase64(Base64Util.encodeBase64(signature.sign()).getBytes());
```
片段二：
```javapublicKey);//对提供的公钥做base64解码
byte[] sign= Base64Util.decodeBase64(Base64Util.decodeBase64(sign))//签名需要做二次
问答GatewayWorker速度很慢
大佬，GatewayWorker和GatewayClient在百度云的不同服务器，通过内网IP连接，每次打开页面都要等5秒左右的时间，就算一个客户端都没有，也是要等很久，有可能是什么原因呢？在GatewayClient服务器上ping GatewayWorker服务器 速度少于1ms
文档响应
业务逻辑省略
// 设置要返回的数据
$response->withBody('返回的数据');
return $response;
}
```
cookie方法完整参数如下'/favicon.ico');
}
}
```
- webman支持发送超大文件
- 对于大文件(超过2M)，webman不会将整个文件一次性读入内存，而是在合适的时机分段读取文件并发送
-webman会根据客户端接收速度来优化文件读取发送速度，保证最快速发送文件的同时将内存占用减少到最低
- 数据发送是非阻塞的，不会影响其它请求处理
- file方法会自动添加`if-modified-since`头并在下一个请求时检测`if-modified-since`头，如果文件未修改则直接返回304以便节省带宽
- 发送的文件会自动使用合适的`Content-Type`头发送给浏览器
- 如果文件不存在，并不会发送给浏览器，这时候我们需要通过`ob_start();` `ob_get_clean();` 将数据捕获到一个变量中，再将数据发送给浏览器，例如：
```php
<?
问答stomp队列插件 推送消息不起作用
[截图](/upload/img/20220927/27633274fe5f9c.png)
出现图里面的错误 发送不起
问答请教UdpConnection用法
socket,'120.76.169.136:10001');
$connection_to_baidu->send($bin_data);
```
我想把workerman当成一个客户端给别的服务器发UDP消息来通信，在start.php中onWorkerStart的事件处理写了上面这段代码，为什么数据发送不出去？new UdpConnection($socket,'120.76.169.136:10001');这个类的构造函数里面的两个参数分别填写什么？
问答用c写个socket去连接workerman 创建的tcp 端口 ,一直连接不上.
实例三、直接使用TCP传输数据
创建tcp_test.php
```php
<?php
use Workerman\Worker;
require_once '.Autoloader.php';
// 创建一个Worker监听2347端口，不使用任何应用层协议
$tcp_worker = new Worker("tcp://0.0.0.0:2347");
// 启动4个进程对外提供服务$tcp_worker->count = 4;
// 当客户端发来数据时
$tcp_worker->onMessage = function($connection, $data)
{
//向客户端发送hello $data
$connection->send('hello ' .
问答tcp短线重连时候不能正常连上gatewayWorker
环境：客户端实行心跳检测，并正常绑定了uid='A',假设client_id='00000a',
条件：当网线断开或其他因素不能正常发送心跳时，先close（原来的fd），在重新connect服务器，时候，发现gateway没有执行onConnect，但是能够正常执行onMessage，并再次bindUID='A'，(并且已经分配到新的client_id='0000000b')问题是
当其他硬件想通过uid='A'发送给我的客户端设备时，却告知client_id='00000a'，已经掉线，为什么不能直接发送给断网重连后的client_id='0000000b0呢'？
问答服务端推送消息客户端接收不到
#### 问题描述
这里写问题描述
服务端onClose接收到消息了， 但是还能接收客户端心跳检测，而服务端发送推送消息失败
赞助商
