文档workerman/redis-queue
\n";
echo $exception->getMessage(), "\n";
var_export($package);
});
// 定时向队列发送消息消费失败后消息会放到延迟队列等待重试，重试次数由 `max_attempts`控制，重试间隔由`retry_seconds`和`max_attempts`共同控制。` `attempts` `max_attempts`等信息
支持更改内部数据结构`$package`的值，只需要将更改后的`$package` return 即可。`
-------------------------------------------------------
## 在非workerman环境向队列发送消息
有时候一些项目运行在apache或者php-fpm环境，无法使用workerman/redis-queue项目，可以参考如下函数实现发送
```
function redis_queue_send($redis, $queue, $data
问答如何在控制器调用functions.php呀
如何在控制器调用functions.php呀
问答如何控制redis-queue的消费速率
没有找到redis-queue控制消费的速率的设置，如果没有控制那队列就没有削峰的作用了，生产入列的压力直接传导到消费出列，请各位指点下
问答GatewayWorker可以使用socket.io么
GatewayWorker可以使用socket.io么
问答gatewayworker phpsocketio 区别和选择
gatewayworker phpsocketio 区别和选择
问答think-orm读mongo数据webman/log报错
#### 问题描述
think-orm 读取 mongo 数据时，webman/log报错
#### 报错信息
```
#18 {main}Error: Call to undefined method
问答本地开发正常（windows），线上(centos)部署加载扩展错误
本地开发正常（windows），线上(centos)部署加载扩展错误
问题一：
问题二：
!
问答自定义进程是否可以用Worker::stopAll()关闭进程?
JSON_UNESCAPED_UNICODE));
$end = microtime(true);
$time = $end - $start;
if ($time >= self::QINIU_TIMEOUT) {
//推送通知}
```
上述代码是开启了自定义进程，用来将图片上传到七牛云。由于有些图片上传时间过长，所以设置了一个QINIU_TIMEOUT超时时间，当超过这个时间后就使用Worker::stopAll()结束这个进程以终止此次上传操作。按理说这样设计的话单次上传时间不会超过QINIU_TIMEOUT了，但是实际上仍然有很多超时，好像进程并没有被结束，并且推送通知处的代码也仍然会执行（进程结束后，后续代码不是应该不执行了吗？）。当前的方案怎么改进？
问答Workerman3.4.2在3.4.0版本上改动了HTTP协议，导致POST请求收不到内容
之前业务是建立在3.4.0版本上，客户端采用POST发送JSON数据，接收正常，现更换为3.4.2版本后，业务代码不变，但打印data数据段，发现content-type为**application/json**时，post节点一直为空，为**application/x-www-form-urlencoded**时才会有数据。对比两个版本中的Http.php，发现3.4.2改动了一处。
问答workman启动后正常运行一段时间到了晚上固定时间服务端收不到客户端的信息
启动后正常运行一段时间到了晚上固定时间服务端收不到客户端的信息
使用后台运行启动workman gateway服务 到了晚上八点多 会提示内部端口被拒绝 然后服务端收不到客户端的信息，通过TCP测试软件，还能够正常连接，能够向服务端发送消息但是收不到回复，检查workman的进程还在运行，使用restart重启服务后 服务端又能够收到消息并正确回应客户端
#### 程序代码或配置
```
<?\Gateway;
use \GatewayWorker\BusinessWorker;
use \Workerman\Autoloader;
// 自动加载类
require_once __DIR_");
// gateway名称，status方便查看
$gateway->name = 'litapowerGateway';
// gateway进程数
$gateway->count = 4;
// 服务注册地址
$gateway->registerAddress = '127.0.0.1:1238';
// 心跳间隔
//$gateway->pingInterval = 10;
// 心跳数据
问答start_web.php增加ajax功能报错
[截图](/upload/img/20240617/17666ff2d6ca68.png)
我使用最简版聊天室进行修改，修改start_web.php，增加响应前端ajax功能，响应后依据获取到的id进行数据库读取并反馈结果给前端--msg
"forward"=>"",//数据转发--code类似
"vtype"=>0,//数据转发,转发字段使用：asc or hex--msg
"forward"=>"",//数据转发--code类似
"vtype"=>0,//数据转发,转发字段使用：asc or hex'status' => 'success', 'info' => $info, 'myFilter' => $myFilter];
}
// 发送响应守护模式）
AJAX后无法获取后端给的数据，显示无响应。
问答多台gateway之间的通讯原理是什么？
我想通过LVS负载均衡实现多台gateway来满足高并发，如果LVS把用户A连接到了gateway1，用户B连接到了gateway2，两个用户不在一个gateway下面，这两个用户如何互相发送数据？
问答a控制器里的方法如何获取b控制器里方法返回的json()结果？
#### 问题描述
a控制器里的方法如何获取b控制器里方法返回的json()结果？
问答php://output 导出excel 第一次请求OK， 再请求第二次就报错了
#### 问题描述
导出Excel php://output 直接返回response 第一次请求OK， 再请求第二次就报错了
#### 程序代码
```
header('Content-Type[截图](/upload/img/20230223/2363f705d19a89.png)
第二次请求就报错了
!
问答workerman定时器运行一段时间，多个定时器时间重叠
{
Gateway::sendToAll(stripcslashes($command));
});
usleep(200000);
}
```
使用以上代码向同一客户端发送消息，初始时间间隔是每条消息200ms，但运行半小时左右时，会出现部分消息发送的时间间隔消失，导致数据不能按间隔接收处理，请大神们帮忙看看问题出在哪里，谢谢！
分享thinkphp5 workerman开发的在线聊天室
thinkphp5 workerman开发的在线聊天室，实现多人在线网页聊天
我暂时放我桌面的 就以我桌面为例 windows的 linux操作没啥区别 ！windows进入cd命令进入根目录输入php server.php start 启动 如果是linux请删除 workerman for win 的那个目录文件 启动方式端口根目录命令启动与windows一样
此版本只是建议版的聊天，如需后续开发自己根据demo添加相关功能。
问答webman框架经常重启或者关闭之后，htop发现存在僵尸进程
webman框架经常重启或者关闭之后，htop发现存在僵尸进程，确定不是pid文件被覆盖的问题。重启跟stop都正常。之前用workorman3.4的版本是没有出现这种现象的。[](/upload/img/20220225/256218902eb441.jpg)
这个是僵尸进程的运行内容
!
问答请问HTTP后台如何推送消息给Websocket客户端？
Websocket客户端之间可以通过服务器端进行通信，请问服务器端可以直接推送消息给客户端吗？
分享仿微信聊天源码【泡泡IM】
**介绍：**
泡泡IM是一套完整的h5+vue+php仿微信的[即时通讯聊天源码](https://www.popoim.com) ，包含完整的前端、后端、数据库、文档。文档全面，代码精简规范、低耦合、注释全面、接口清晰，非常有利于二次开发。后端即时通讯基于高性能即时通讯框架workerman开发，api接口则基于tp5开发。
前端基于vue开发，前后端分离，模块化开发。以websocket协议完成即时通讯，保证消息数据即时传输。自带网络检测，断网自动重连，保证消息可靠送达。支持SSL/TLS通信隧道加密。即时通讯部分与业务逻辑高度解偶。
**功能：**
1、支持发语音、文字、图片、表情、文件
2、支持一对一私聊和多对多群聊
3、群聊支持建群、退群、解散群组、禁言、踢人、拉人进群、群备注等功能
4、个人信息支持更改昵称、头像、个性签名等
文档协程并发 WaitGroup
与`Barrier`区别的是`WaitGroup`可以由开发者自行控制计数的增加和减少。Done');
};
Worker::runAll();
```
## 接口说明
```php
interface WaitGroupInterface
{
/**
* 增加计数delta
* @return bool
*/
public function add(int $delta = 1): bool;
/**
* 完成计数*
* @return bool
*/
public function done(): bool;
/**
* 返回计数
*
赞助商
