问答问大佬们一个问题，多进程下，数据库数据出现混乱
目前问题在于高并发多进程的情况下，提现记录增加了，但是修改用户余额的时候，数据可能并不是最新的。
目前测试改为单进程是没有这么问题。然后想问一下大佬有没有办法让这个请求始终在同一个进程中
问答AsyncTcpConnection无法触发onMessage
AsyncTcpConnection('Text://127.0.0.1:12345');
// $task_connection->connect();
// 发送数据});
}
}
// task worker，使用Text协议
$task_worker = new Worker('Text://0.0.0.0:12345');
// task进程数可以根据需要多开一些"\n";
};
// 设置业务处理函数
$task_worker->onMessage = function($connection, $task_data)
{
// 假设发来的是json数据$task_data = json_decode($task_data, true);
trace([$task_data,'msg'=>'发送后'],'crontab');$task_result = 'done';
// 发送结果
$connection->send(json_encode($task_result));
};
```
问答workerman如何使用图数据库neo4j
如何在Workerman中使用Neo4j进行图数据库存储与查询
概述：
Workerman是一个高性能的PHP异步网络编程框架，而Neo4j是一个功能强大的图数据库。本篇文章将介绍如何在Workerman中使用Neo4j进行图数据库的存储与查询，并提供具体的代码示例。
步骤一：安装Neo4j扩展
首先，在PHP中安装Neo4j扩展。步骤二：连接图数据库
在Workerman的事件回调函数中，使用如下代码连接到Neo4j数据库：
```php
use GraphAwareBoltGraphDatabase ;
$driver =进行图数据库存储与查询的基本步骤。以上就是如何在Workerman中使用Neo4j进行图数据库存储与查询的详细内容。
文章转自：https://www.php.cn/faq/626970.html
问答自定义进程访问数据库的诡异问题
#### 问题描述
背景：1个服务端程序和1个客户端的程序，他们两个中间有个rabbitmq，两端都约定了索要数据的json格式，客户端到定期向队列中放入请求数据的要求，服务端收到需求检索数据库将检索出来的数据放回队列，现在出现了个诡异的问题：程序刚启动时候获取数据都正常，但是当这个程序持续运行1天到2天后诡异的问题出现，客户端与服务端跟mq的通讯都没有问题，只是服务端检索出来的数据不是预期的数据结果，例如：客户端本来是想服务器索要20日的数据，结果服务端给返回的是11日的数据，这段儿程序非常简单就是使用的eloqent orm进行获取的数据，也没有用缓存等组件，纯纯的搜索数据库。我的程序已经启用了swoole协程化，并且数据库都用了连接池。
问答使用gatewayworker 和redis消息订阅造成的多进程阻塞
在gatewayworker中，使用redis做消息订阅，由于数据量大，现在在两台服务器上做的分布式部署，每台服务器businessworker都是开的十个进程，但是进程还是会很快都阻塞，请问各位大牛们怎么解决呢
问答webman GatewayWorker插件 发送消息延迟是怎么回事？
gateway-worker
```
Events 连接事件中我把：$client_id 绑定为：123456 (用于测试)
然后 在app\controller\test.php 新建一个控制器不在线"]);
}
}
```
访问Url发送消息，明显感觉有延迟500毫秒 - 2秒左右，客户端才收到，反正不是那种秒到 ，问题出在哪里啊
PS：（**绝不是本地网络问题，也不可能是服务器网络问题**,因为我服务器有搭建一个java的tcp服务端 我客户端链接这个java服务端收发消息都是秒到）
文档sendToUid
sendToUid
## 说明:
```php
void Gateway::sendToUid(mixed $uid, string $message);
```
向uid绑定的所有**在线**client_id发送数据如果为数组，则是给数组内所有uid发送数据
* ```$message```
要发送的数据（字符串类型），此数据会被Gateway所使用协议的encode方法打包后再发送给客户端
### 返回值因为数据发送是异步进行的，所以没有返回值。一般来说只要uid在线就可以发送成功。
发送前先可以用Gateway::getClientIdByUid判断下uid是否有在线的client_id。## 范例
```php
use \GatewayWorker\Lib\Gateway;
class Events
{
...
问答worker多进程重复读取同一条redis数据
MessageWorker的进程数是指为4，同一条redis数据就会被重复读取，有时候显示1条，有时候2条，3条。但把$worker->count改成1就只读1条了，不会重复。这是为什么呢？
问答GatewayWorker最大连接数1024
GatewayWorker服务器 是Liunx服务器，已经按照Linux优化和安装event扩展的操作过了。但是用另一台Liunx服务器来进行压力测试，最大连接数一直是1024，难道这台服务器也需要优化和装扩展吗？
压力测试到底该如何进行，请大神指教
问答UDP服务器主动向客户端发送消息
大家好，请问一下：我用workerman搭建了一个UDP服务，用于和物联网设备通讯，现在的情况是服务器能收到设备发来的数据，但是我想主动给设备发送命令（不在onMessage里面send），修改设备的一些参数
问答webman 控制器返回远程服务器的文件流
#### 问题描述
webman 控制器返回远程服务器的文件流,参考了帖子
https://www.workerman.net/q/13212
#### 程序代码或配置
```
public functionuse ($connection) {
$connection->send(new \Workerman\Protocols\Http\Chunk('')); // 发送空的的>"attachment;filename=\"$downloadName\""
]);
}
```
请求后下载的是一个空文件，
progress 回调内也是可以读取到文件的二进制内容的
问答GatewayWorker没有按照预期断开连接导致客户端重连问题
pingNotResponseLimit = 1
pingInterval = 60
60s内如果客户端没有发送任何数据，服务端则断开客户端连接
客户端已经做了重连策略，而且是每30s会发送一次心跳包到服务端，我看了一下Gateway的重连策略代码，大致的意思如下：
GatewayWorker进程启动的时候呢，如果有要求重连则设置一个定时器定期去检测客户端连接的心跳，如果在心跳检测时间内客户端有互动，则pingNotResponseCount=-1，否则pingNotResponseCount++，如果上次发送的心跳还没有回复次数大于限定值就断开
但是这样配置服务端还是会定时断开连接，不太明白，也就是说客户端一定要自己做重连策略了是吗？仅仅是定期发心跳包也是会断开连接？
问答webman打包二进制如何能缩小内存
#### 问题描述
使用`php webman build:bin 8.2`打包项目以后, 得到的`webman.bin`文件大小为`52.7M`;
放到服务器上启动以后共17个进程, 每个进程都是`62.5M`;总消耗内存`1059M`;
我想知道如何才能缩小内存占用,毕竟本地的每个进程才占用`5-10M`左右;
#### 为此你搜索到了哪些方案及不适用的原因
查询了可能有帮助的方法, 排除
问答GatewayWorker 怎么通知 Thinkphp 给维护人员发短信
根据GatewayWorker 手册
[attach]797[/attach]
GatewayWorker 不做业务处理，业务逻辑放到MVC中，
现在有个物联网项目，实现30秒没有检测到心跳包，则改机器已经断网发短信的业务放到Thinkphp处理，请教一下GatewayWorker 怎么通知 Thinkphp 发短信？
问答为什么我post过来的数据想转发给过去，但是返回值为NUlLL，我看了下表示放入待发送队列，等待异步发送，怎么能立即发送出去呢
异步建立一个到实际ccs服务器的连接
$connection_to_css = new AsyncTcpConnection($REAL_CCS_ADDRESS);
// ccs连接发来数据时，转发给对应客户端的连接
$connection_to_css->onMessage = function($connection_to_css, $buffer)use($connectionfunction($connection_to_css)use($connection)
{
$connection->close();
};
// ccs连接上发生错误时{
$connection->close();
};
// 执行异步连接
$connection_to_css->connect();
// 客户端发来数据时，转发给对应的ccs连接
$connection->onMessage = function($connection, $buffer)use($connection_to_css)
{
问答关于心跳发送一个可以一个不行！
场景：我做的是一个聊天的，分商户和用户，目前用户可以正常发送心跳数据维持不掉线！但是商家那边却会自动掉线、然后经过测试发现两个只能有一个是正常发送的！
问答配置wss和消息推送
我这里开发一个微信共享雨伞的小程序，用到了长连接，用到了workerman,
问题一：现在微信端websocket直接用wss访问报错如下，failed: Error in connection establishment问题二：微信端共享雨伞的每个用户和服务器php通过websocket保持连接，现在可以实现案例中的客户端发送某个消息到服务器，服务器返回某个消息给前端，能不能做到，客户端传入某个用户id到服务器，当数据库某个字段（如雨伞关锁字段）发生变化时，直接推送消息到前端，如何实现啊？因为如果要监测到问题2的某个字段发生变化，必然php是和mysql进行轮训的查询啊（比如10s查询一次mysql），这样mysql性能会不会受影响哦？有没有好的办法哦？如php何mysql进行长连接
麻烦大神解答一下，谢谢您，好人一生平安。
问答大家在用DTU与服务端通信的时候是如何传输数据的
#### 问题描述
大家在用DTU与服务端通信的时候是如何传输数据的，比如采集的数据是 hex数据 ，是在DTU上写脚本转换成友好json格式还是原文发送到服务器端？服务器端发送指令给DTU下挂设备时呢？
#### 为此你搜索到了哪些方案及不适用的原因
讨论讨论
问答workerman运行一段时间后，进行数据库操作会显示Mysql server has gone away，开启数据库配置断线重连无法进行重连，求助应该怎么解决
workerman运行一段时间后，进行数据库操作会显示Mysql server has gone away，开启数据库配置断线重连无法进行重连，求助应该怎么解决
问答webman 用云数据库 并上去了 所有进程都busy
#### webman用云数据库经过一轮并发强度1500后所有进程处于busy状态并且恢复的很慢用.本地数据库就好点能到cpu差不多打满
服务器 ：12核心 12g内存 10m 带宽
测试用例 ： 一个简单的sql 查询
云数据库配置:serveless
数据库类型 MySQL5.7
数据库内存 [1024 M - 16384 M]
CPU [0.5 - 8]
#### 程序代码 (此代码和我thinkphpfpm[截图](/upload/img/20250827/2768ae61a8ed81.png)
#### 并发1500 进程全busy 并且 恢复很慢
!
赞助商
