问答异步任务中使用队列
（查询返回慢，所以想用异步去完成，再加上任务多，再在异步http请求任务中使用队列防重复）
业务场景简述：
默认先在一个文件中写死一个时间戳，主程序跑多个定时器，检查是否有新的交易时间戳(操作完成后替换之前的时间戳)，若有，交给异步任务，异步中的程序：循环资金池，查询资金池在"之前交易时间戳"和"当前交易时间戳"中是否有资金到账，若有，根据关键字段循环通过接口查询是哪个商户下的并请求接口发起充值。现在异步任务用的是（http://doc.workerman.net/315283）
请问：
如果还想在里面加个队列去处理任务的话，用https://github.com/walkor/workerman-queue然后关于队列的还有个问题，如何防止多个进程处理了同一个队列中的任务，就是怎么做这个互斥。
在此，感谢大佬的回复！
文档为什么要分布式部署
然而这么做只能是杯水车薪，成本巨大并且效果非常有限。**GatewayWorker支持分布式部署**，你可以利用多台价格低廉的普通服务器，组成一个庞大的服务器集群，成倍的增加系统承载能力，这不管在资金成本上还是人力成本上都是最划算的方案。### 2、提高系统稳定性
**单机**对外提供服务，则风险很大，服务器任何故障都可能引起整个服务的不可用。**GatewayWorker分布式**可以有效的降低这个风险，如果一台服务器故障宕机，还有其它服务器可以继续工作，可以做到对服务无影响或者影响最小化。等请求量降下去时，你可以为降低成本将服务器回收，而不影响任何用户。
分享🧌 视频系列 | 中后台框架saiadmin快速入门
saiadmin是一款基于vue3+webman的极速开发框架，前端采取Vue3+Arco Design+Vite3+Pinia的高效搭配，开发采用JavaScript，自带代码生成功能，丝滑+优雅
问答有100个任务要处理，如何分发任务
1 从数据库获取数据， 数据遍历 发送Http请求,
2 那也是要等待返回数据，串行执行，时间并没减少
疑问 难道得用 curl_multi
```php
// 创建一个Worker监听2345端口，使用http协议通讯
$http_worker = new Worker("http://0.0.0.0:2345");
// 启动4个进程对外提供服务
$http_worker->count
问答求助 业务逻辑找不到问题 process_timeout declare(ticks=1)
业务出现process_timeout 实在是无从下手判断问题出现在哪里 逻辑类加上declare(ticks=1)log会写入定位问题所在吗 或者有什么定位的办法 感谢不尽!
问答[已解决]UDP服务，定时器数量不断自动增加
#### 问题描述
如题，我在UDP服务的onWorkerStart回调中启动了一个定时器，log显示onWorkerStart也只调用了一次，但是status里面发现ntp_worker的内存占用与timer数量在不断增加。百思不得其解，只好来提问，请大神帮忙看看。
以下是debug启动，可以看见Timer added只发生了一次。- 13 0 0 66 0 [Summary]
```
可以发现内存占用与timers都在不停增加
问答AI 使用链接直接进入某个角色,聊天对话框不显示
#### 问题描述
带锚点参数 role=1 时直接进入某个角色后,聊天对话框不显示
https://bla.cn#role=1
!bla.cn#role=1 即个重现
#### 操作系统环境及workerman/webman等具体版本
手机浏览器 android 下 Edge, IOS 下 Safari都有这种情况, 服务端自己部署与官方演示效果都一样
问答请问workerman做服务端推送功能，不能监听80端口吗？
请问workerman做服务端推送功能，不能监听80端口吗？
我的web服务器用apache搭建，有个后台系统，请问后台系统如何推送给80端口的客户端呢？
问答workerman转发提示对方不在线
现在有2个客户端A，B，1个workerman服务端，
客户端A,B是通过守护进程+socket来实现的
现在出现的现象，当长时间不操作：比如过了一天从A 发给B一条数据
那么A发消息给workerman，workerman收到A返回的数据，这一端是正确的
此时workerman收到A的数据 转发给B的时候，就提示B不在线了
而同时：
workerman通过每隔30秒 给客户端A，B发送心跳数据，客户端收到心跳数据返回给workerman,workerman可以收到 ，这个是正常的
2.通过这个方法获得Gateway::getOnlineStatus() 用户A,B都在线
但是在通过这个方法GateWay::isOnline($to_uid) 转发给B的时候，就提示B不在线
问答请问多任务互不影响各自执行用哪种方法比较合适？
如题，假设现在需求是，有3个任务，一个任务是去获取行情挂市场单，一个任务是去检查某个账号的市场单数量超过了指定数量就撤单，一个任务是去挂成交单。我现在想到的有两个方法：
1、用多个new Worker()来执行不同任务
2、在同一worker下开多个count后，再使用if($worker->id==xx){//code}来执行不同任务
请问哪位一种相对好一点呀
问答多个businessWorker放在同一个控制器方法中启动，会不会影响性能
worker->name = 'TpWorkBusinessWorker';
$worker->count = Cfg::tp_business_count;
// 服务注册地址tp_log_register_port;
$worker_log->eventHandler = '\app\admin\controller\GateWayEventsLog';
// 如果不是在根目录启动defined( 'TP_GLOBAL_START' ) ) {
// 启用swoole的事件驱动
Worker::$eventLoopClass = '[截图](/upload/img/20240117/1765a73e2890e4.png)
启动后是这样的，这样放一起会不会影响性能，还是分开启动好？
问答【反馈】router中，如果数据处理失败，希望终止后续路由，希望返回bool false ，则会导致进程重启
并且进程中的变量数据将会丢失
补充下，仅供官方参考
如果传输的是gzip压缩，又需要根据用户发来的消息选择路由，则router函数中，如果根据buffer解压缩失败，或者处理失败，希望终止请求，而不是继续返回一个但是router又必须要返回一个worker
!20191128/285ddf38f33521.png)
也就是此处$worker_connection->send($gateway_data)，如果$worker_connection是路由router返回的对于这种需求，请问是否有更好的方法来处理用户发来的数据而选择不同的路由，并且对于非法的用户数据，因为不能指定到业务逻辑相关的路由，就需要终止掉该请求，而不导致进程重启，谢谢
问答单进程 onClose 时能不能用 $worker->connections 来统计在线人数
测试发现在 onClose 时用 count($worker->connections) 去统计还是之前的数量，请问大佬是不是 onClose 事件触发时，Workerman 还没有完全清理 $worker
问答GateWay -> Gateway::bindUid(clientId, UID)
#### 问题描述
Gateway-workerman起服务之后
客户端链接然后绑定uid和clientid，我在另一个事件里通过Gateway::getClientIdByUid(UID) 获取不到任何绑定的
分享不重复写消息状态，自定义消息体！微服务消息体！
闲话不说，我想懒点。[gitee地址](https://gitee.com/zykk/messages)
[github地址](https://github.com/mofeier/messages)
这是一个返回消息状态的组件* 2、返回数据多格式：json，array，默认array
* 3、参数命名可指定，可追加参数
* 4、返回参数自定义
*/
// ……其他代码
// 使用默认返回状态值，也可以写自己的返回状态码=> '账号退出失败',
// 路由操作相关
40001 => '操作失败',
40004 => '无此方法',
40005 => '无此权限',
*/
/*
* 默认返回参数$result->result();
// 返回json，json($cn=false)，默认原json格式，中文会转义；cn=true时，转义中文，如框架自带json，可能会出现乱码，请使用result
问答AI 关于文心一言的发送返回提示错误
user_message_id":"1697772176902197","assistant_message_id":"169777217690212","role_id":34}
```
对比了跟官网是是一样的
返回数据error_code":336003,"error_msg":"message content can not be empty","id":"as-s5e9buywkh"}
我通过这个创建的应用不知道是否有问题[截图](/upload/img/20231020/206531f4f57b08.png)
错误信息是 参数校验不合法
是不是还需要哪里设置呢？
问答workerman做api接口服务，上传大文件不行代码也不报错
#### 问题描述
使用 workerman 做的接口，上传100多KB的小文件没问题，上传127MB的文件，接口就立即返回错误，代码没报错，终端也没有任何输出，接口报错如下图：
!}
if (empty($this->request->file('file'))) {
return $this->echoJson('文件不能为空
问答返回值如何使用二进制传输
我现在用websocket的协议 在客户端看返回值是明文的 我想问一下 在哪里可以调整变成二进制传输
就是我想在返回值得时候也用无符号整形数组那种形式 我应该怎么操作呀
就是在客户端我接收到的是ArrayBuffer
问答利用WorkMan搭建服务器，通过外网无法访问
利用WORKMAN创建了一个服务器后
```php
<?php
use Workerman\Worker;
require_once './ 创建一个Worker监听2346端口，使用websocket协议通讯
$ws_worker = new Worker("http://0.0.0.0:3307");
// 启动4个进程对外提供服务$ws_worker->count = 4;
// 当收到客户端发来的数据后返回hello $data给客户端
$ws_worker->onMessage = function($connection>
```
通过php * -start启动后，在另外一台电脑上通过服务器的"外网IP:3307"（假设）无法访问,curl http://外网IP:3307也不行（在本机可以），试问下问题出在了哪里
问答写了一个定时器的任务，但是在调用自己写的类的时候，使用命令空间一直报错找不到类,
Worker('http://0.0.0.0:1234');
//设定名字
$http_worker->name = 'TestTimeWorker';
// 启动1个进程对外提供服务$http_worker->count = 1;
//设置Worker子进程启动时的回调函数，每个子进程启动时都会执行
$http_worker->onWorkerStart = function (http_worker) {
Timer::add(1, function () {
TestTime::doData();
});
};
//接收到浏览器发送的数据时回复function ($connection, $data) {
// 向浏览器发送hello world
$connection->send('hello world');
};
// 如果不是在根目录启动
赞助商
