问答在webman中使用事务问题
#### 问题描述
我是在webman用使用GatewayWorker，之后做一些数据库的查询新增操作
```php
// 启动事务
Db::startTrans();
try {StatusReturn(0, $client_id);
return;
}
if($Hardwaredata['xwst']==1){
if($boxinfo){
//执行一些数据库查询和插入的操作}else{
Gateway::sendToClient($client, $send_datas);
return;
}
}
DB::commit();//提交至数据库} catch (\Throwable $e) {
DB::rollback();//数据库回滚
}
```
我在使用事务的时候，我在Gateway::sendToClient 给用户发送消息 我就想不执行下面代码了我就return了，但是貌似这个会变成数据库的数据没有提交，这样数据没有插入成功。
分享GatewayClient 无法使用的问题
有时候会出现 调用GatewayClient中的sendToClient 方法不能给客户端发送指令的问题，请注意查看 数据库存储的client_id 是否为当前进程的client_id。注意表结构和表字段的类型，如果有错误会造成写入的client_id与实际进程不相符 导致无法发送指令。
[attach]1149[/attach]
问答一个Gateway下挂载多个Worker项目，怎么配置？
想法是，在Application目录下创建多个项目，其中一个项目（A）用于开启Gateway进程，保存客户端连接数据。用户都连接到（A）这个项目上，发消息的时候用协议号，通过（A）向其他的项目发送数据，其他项目返回数据给（A），（A）再返回给用户。
请教如何配置（A）与其他项目的配置文件？（A）只想部署Gateway进程，其他项目只想部署Worker进程
所有项目都是基于Gateway/Worker的框架。
问答webman + RabbitMQ 消费数据问题
wenbman消费数据，刚开始启动程序， RabbitMQ队列显示消费速率，大约一分钟后，webman显示一直在消费，但是RabbitMQ队列数据量没有减少，不显示得消费者客户端
!
问答【已解决】webman中使用swoole，控制器中Request类已经做了协程上下文处理吗
#### 问题描述
**我找到了答案，在协程中使用全局变量确实是会互相干扰，只是我下面的代码是开多个进程处理的，恰好两次请求是两个进程，所以是两份全局变量。改成只开1个进程，就会发现协程污染的问题了**
- 目前在已有的webman项目中想使用swoole的协程，所以Event-loop切换成了swoole。在控制器中的协程环境中，使用全局静态变量，按理说两次请求（两个协程）操作全局变量应该会污染的啊，但是实际上并没有发现污染，是webman已经做了上下文处理了么？
- 如下图
```
按照代码逻辑来看，
第一次请求参数a=1时，当前请求的协程A会先修改全局变量为aaa，然后协程挂起5秒;
第二次请求参数a=2时，当前请求的协程B会直接修改全局变量为bbb,然后返回给客户端
```
- 问题：
```
如果在五秒内依次请求上述两个请求，请求1在5秒协程恢复后，应该已经被请求2污染了啊
问答windows下 gateway+tp5 如何使用gateway进行消息上传和下发
windows下 gateway+tp5 如何使用gateway进行消息上传和下发
官方提供的方式是在和MVC框架结合时 使用ajax进行消息上传 使用gatewayclent进行消息下发 但是这样总是感觉不够清爽可不可以直接使用gateway上传 通过onmessage对上传的消息进行转发 转发的消息通过tp框架进行判断处理 处理后的消息再通过gatewayclent下发
onmessage目前可以实现消息转发但是调用的函数不能使用tp库的类 无法继承think/controller 应该如何处理 我看好多人都遇到了同样问题 官方有没有解决办法 或者哪位路过的大神指导一下 谢谢
问答workman倒计时30秒进行ws前后端交互，怎么做？
如果是前段进行倒计时触发，所有在线用户都会发送向后端发送消息，而后端倒计时触发则直接推送，不需要用户前段发送消息，这个具体怎么做？
问答workerman如何保存一个连接用来下次主动发送消息给客户端？
比如服务端连接回调 onConnect ，连接成功后把回调参数存起来，方便下次需要发送消息给客户端时直接调用
问答json中怎么加入自己的数据
json中怎么加入自己的数据， ws.send('{"type":"say","to_client_id":"'+to_client_id+'","to_client_name":"","contentto_client_id":"'+to_client_id+'","to_client_name":"","content":"'+input.value+'",“number”:"100"}');后，从服务端接受发来的消息
问答【已解决】webman的HTTP进程启动后，建立websocket连接会卡很久
## 问题描述
webman的HTTP进程，设置为`8`个进程提供服务；
在 http进程启动后，执行 `onWorkerStart` 方法时，建立与gatewayWorker 的 `ws`连接。故障现象是：有1-2个进程的链接立刻建立成功 `onMessage` 收到信息；而 余下的 **N个进程**，要**卡顿很久才**能收到 来自 ws 的 `onMessage` 消息。php
namespace app\process;
use GatewayWorker\Lib\Gateway;
use support\Log;
use Throwable;
use Webmanworker = $worker;
\Workerman\Protocols\Http::requestClass(static::$requestClass);
// 连接 GatewayWorker/ 忽略pong
if ('pong' === $data) {
return;
}
// 解析数据
分享整理分享Workerman中利用popen实现多进程web ssh
### 起源
群友询问如何进程异步执行命令行任务，且有通知机制，想用来做web ssh，兔子大佬指导可以通过 `popen` 来实现：
!== false) {
unset($this->processes[$key]); // 从活动进程池移除
}
}
// 获取池中的所有进程数量($processPool->processCount() >= $processPool->maxProcesses) {
return $connection->send('使用进程数已达最大数\Workerman\Worker::$globalEvent->offReadable($process);
} else {
// 将输出发送给客户端PHP_EOL;
}
```
`php start.php start` 启动项目，前端使用 【WebSocket 测试工具】进行连接，发送消息执行命令：`/usr/bin/php8.2 command.php
问答webman+gateway设备数据返回丢失
#### 问题描述
与硬件设备通信，设备登录成功定时批量发送指令，业务逻辑都是推送到队列处理，按理不存在处理延时问题，但是总有个别指令发送过去没有收到响应，不知如何定位问题，使用的都是最新版安装包
问答请教使用socket做为客户端和北向接口对接，请教如何打包数据发送。
5.3.1 消息格式
消息数据由消息头和消息体组成。消息头由9个字节（byte）表示，消息体长度不固定，各类消息不同。消息头的9个字节不能当做字符处理，需要按整型数处理。
!
问答数据量上300以后经常会出现连接失败的问题
有的时候播间连接数达到300人的时候，socket连接就会一直pending...
最后就连接失败~~不能进行数据接收。
请问这个问题处在哪里？应该如何解决和避免？
问答workerman-statistics页面不展示数据
日志文件已经生成，但是后台监控页面没有展示，没有统计数据，数据源试了127.0.0.1还有内网的IP都不行，求助，多谢！
问答关于自定义协议的问题，大端转小端 网络字节序
根据官方文档 http://doc.workerman.net/protocols/example.html，
客户端传输的数据包样本：`1001{"userName":"okXU70-dcPj8wBF4this.sendBytes.writeArrayBuffer(this.bytes.buffer),
this.socket.send(this.sendBytes.buffer),
```
直接复制官方例子二的协议实现代码
问答能不能给控制器加个 Controller 后缀啊，加个配置也行
控制器叫User 模型叫User 在控制器里调用User模型 只有两种办法 否则就会冲突
第一种 别名
```php
use User as UserModel
```
第二种 每次写全命名空间
```php
$model = new app\models\User()
```
无论哪一种都不方便 ，最方便的就是控制器叫 UserController，比较控制器除了定义时，基本不会需要手动调用，而调用模型之类的类频率很高，采用上面两种方式比较繁琐
希望作者能改控制器后缀或者允许自定义
问答请教workman 4台集群，群发漏收问题
我现在有4台workman集群，在一个群聊里发消息，群里面会有其他成员漏收的问题，是在不同的workman，推送不过去吗？因为数据是有写入DB的
问答我已经用TP写了个web网站但是需要在这个服务器弄个长连接实时接收数据的接口，然后再给iOS调用，请问怎么做呢？
原先就是搞嵌入式的那个人调用我给他的一个接口传数据到数据库，然后搞app的再调用另一个接口获取这个数据，只是这个数据是不断变化的，所以他们都是不断的用http请求，但是从硬件上传数据过来延迟有两三秒钟，所以现在就希望用socket来保持长连接发送数据，本身这个服务器已经用tp做了这个app的后台，现在要怎么结合呢，我只是想给硬件的那个接口是长连接的就行了。
问答【请教】延迟队列在执行前数据库数据被修改后如何取消先前投递的队列？
#### 问题描述
> 请教下大哥们，延迟队列在队列执执行前数据库数据可能会被修改（修改数据后会重新投递），这时候不想之前投递的队列在执行，有什么更好的办法吗？#### 现在处理方式
在数据表中加一个`queue_time`（跟随队列数据投递）修改数据后更新下这个时间，队列执行时先对比下，队列数据中的`queue_time`和数据库中的`queue_time`
赞助商
