搜索-workerman社区

分享我的第一个Webman插件 - 基于Redis Stream实现的消息队列插件

### 主要特性 - **基于 Redis Stream：** 使用 Redis 最新的 Stream 数据类型，为消息队列和事件流提供优化的存储和访问。- **自定义异常重试：** 支持自定义的消息处理失败重试机制，提高消息处理的可靠性。 - **死信队列处理：** 集成死信队列管理，确保消息不会因处理失败而丢失。- **延时队列支持：** 实现延时消息处理，使得定时任务和延迟执行变得简单易行。 - **高效的异常处理机制：** 强化的异常处理策略，确保队列的稳定运行。function pushMessage(string|array|int|QueueMessageInterface $data): string|bool; ``` ```php // 消息内容，无需序列化createQueueProducer()->scheduleDelayedMessages($dataArr); ``` > 多redis只需要在队列配置`connection`连接标识，投递方式没有任何变化。

分享修改了下webman的请求和响应类，使得可以在中间件中更新Cookie

添加若干方法用于在发送响应之前修改cookie，需要先调用`cookiesToJar`将响应中的Cookie解析出来，然后使用`updateCookie`来更新，我这里主要用来在中间件中加密，这个方法不支持添加不存在的

问答docker 集群部署问题 stream_socket_client(): unable to connect to tcp://172.25.70.8:2900

/docker/app_start PUBLISH_SSH_KEY: | -----BEGIN RSA PRIVATE KEY----- 换成部署私钥并保持这种缩进模式

问答长连接转发会阻塞吗？对后端的请求做一个并发控制，会阻塞吗，会断开吗？

不要直接断开前端请求（连接onConnect之后先不要处理，等后端空闲了在转发到后端） - 后端的响应时间可能很长所以我的问题是： - 等待后端空闲时收到的连接会断开吗（因为这中间不会传输心跳以维持链接

问答workerman unix如何自定义协议？

' => 'JsonRpc:///tmp/user-service', // 进程数（可选，默认1） 'count' => 1, // 当前进程是否支持reload

文档自动加载

而利用框架`config/autoload.php`加载的文件支持热加载，更改后reload即可生效。

文档创建wss服务

5、此方法要求PHP版本>=5.6，因为微信小程序要求tls1.2，而PHP5.6以下版本不支持tls1.2。

文档一键菜单

[img_18.png](img_18.png) # 说明支持手动指定控制器、模型的类名及位置。

分享webman里面使用swaager自动生成api文档（低于php8.0也可以）

在控制器中（app/controller）注释如下： /** * @OA\Server(url="/report", description="这是下面所有Api前缀(使用json序列化传输

问答我在网页端 JS连接 WebSocket 总是失败

/Workerman/Autoloader.php'; // 初始化一个worker容器，监听1234端口 $worker = new Worker('websocket://127.0.0.1:1234

问答webman 二进制打包后，执行stop出现报错 zend_mm_heap corrupted

php版本：PHP 8.0.28 (cli) workerman/webman-framework：v1.5.2 webman/console:v1.2.33 ``` #### 调试1 重新拉取初始化webman

问答关于webman异步任务的连接创建的问题（workerman道理相同）

{ switch ($data['command']) { case 'init': // 指令为“初始化呼叫任务

问答如何不同的页面统计在线人数？

#### 问题描述有很多文章，想知道每个文章的在线人数 #### 我的代码 ```php private function start() { // 初始化worker类

分享如何为某个应用配置独立数据库？

[]; // 配置 Db::setConfig($config); // 维持mysql心跳 if ($worker) {

分享一个超级简单的RPC

使用 `stream_socket_*` 实现了一个简单的同步 client ，目前只支持 workman 的 frame 协议。