搜索-workerman社区

问答使用GatewayClient发送消息如何获取服务端返回的结果？

其他程序使用GatewayClient发送消息如何获取服务端返回的结果？比如使用GatewayClient发送登录消息 {"type":"login","uid":"56a5d52a9c9e41d42bb997d9","token":"8j5bpeud2hi6ue5uge8h9ghmj1

问答Workerman 能提供类似 StopHandler 的功能来让用户控制安全停止吗？

比如一个定时任务在执行中有两步操作，Workerman 在使用 stop 停止时可能会出现前一个操作完成后一个操作未完成就停止的情况，虽然 Workerman 提供了 -g 参数来等待链接全部关闭后停止有没有一种机制，让用户自己控制这个关闭流程，比如向 Workerman 中注册一个 StopHandler，当 Workerman 使用 stop 时，触发这些 StopHandler，然后每个 Handler现在有些长时间执行的任务，从零点几秒到几十秒不等，中间去读数据库，也会操作本地文件，也可能还有生成图片，还有可能去连接远程的 http 接口，很容易出现这种情况下停止 Workerman 导致任务和数据处理了一半的情况

文档推送

ajax鉴权请求(ajax地址为new Push时auth参数配置的地址)，开发者可以在这里判断，当前用户是否有权限监听这个频道。webman/push 也支持客户端直接推送消息。 > **注意** > 客户端间推送仅支持私有频道(`private-`开头的频道)，并且客户端只能触发以 `client-` 开头的事件。客户端触发事件推送的例子 ```js var user_channel = connection.subscribe('private-user-1'); user_channel.on('client-message`client-message` 事件的数据(推送客户端不会收到自己推送的数据)。必须使用**ssl证书对应的域名**连接 ## push-vue.js 使用说明 1、将文件 push-vue.js复制到项目目录下，如：src/utils/push-vue.js 2、在vue页面内引入

问答求助：workman能多开进程做下载么

需求是希望大数据量的文件能做到页面筛选条件后以excel形式即时下载。数据量最大能有1000W，数据从库中查出来后还要经过一系列过滤查询等，所以耗时比较长。尝试过workman开几个进程，但是每次一个请求过来还是只有一个进程在执行，能否实现数据按量分批，每批跑一个进程，这样总耗时就是执行最慢的那一批，最后结果再汇总。请实现过的大神赐教，谢谢。

问答想使用AsyncUdpConnection作为客户端，如何发送给多个或者其它（非发消息来的）客户端

#### 问题描述下面这个例子，我一个客户端发送给多个 UDP客户端，难道要实例化多个AsyncUdpConnection 对象吗？$udp_connection->send('hi'); }; #### 为此你搜索到了哪些方案及不适用的原因感觉 send 方法应该提供，ip,port 参数，

问答定时器能否一个客户端一个，并且完成并发运行？

# 关于定时器与业务结合因为涉及到每个设备需要单独读取数据，所以需要针对不同的设备进行不同定时器的开启，可以理解每个设备都是一个客户端，我需要在同一刻并行读取当前所有在线客户端的数据情况问：1、假设10个客户端同时在线，我是开启十个定时器在一个进程？还是十个进程每个进程一个定时器？ 2、十个定时器能否同时触发？串行肯定不行。因为后续如果不是一个客户端而是1000个甚至更多，需要的时间太长了，数据不准确

问答Gateway worker ：使用 stop 命令无法正常触发Event::onclose事件

gatewayworker 启动后假如有3个 websocket 连上了，然后执行 `php start.php stop` 命令，或者使用`ctrl_+ c` 可能会未正常触发 `Event.php如果在 `onClose` 事件中做清理工作，比如同步数据库中的 `client` 在线状态,下线账号什么的。。。会有个别的或者全部的未正常执行。请问，这种情况应该怎么处理

问答workmaner运行时连接数据库失败的问题

workerman连接数据库我写在了$worker->onWorkerStart中，应该数据库与workerman没有在同一服务器上，在workerman运行时，如果数据库连接失败了，怎么让他自动重连？

问答webman的路由参数，如果不是在控制器里面获取，在functions里面获取，应该怎么做

webman的路由参数，如果不是在控制器里面获取，在functions里面获取，应该怎么做我有一个通用的方法要判断请求的参数，返回所有的请求参数给其他函数使用，如果每次都通过控制器来做，代码量会多很多，逻辑也复杂很多，希望能有一个通用的获取参数的方法

问答关于多进程问题；多进程是如何调度的呢

1.客户端消息如何调用；如何分配到哪个进程里的；能否有办法动态数据存到内存中（不用redis）；其他进程也能访问；

问答 [ERROR] stream_socket_client(): unable to connect to tcp://127.0.0.1:2902 (Connection refused)

PHP 框架使用的是 codeigniter4，前端用的是 uniapp，gatewayworker 从官网下载的 linux 版本，gatewayclient 使用composer 安装。App/Gatewayworker/Applications/YourApp/start.gateway.php中只做了一处修改：将原来的: ```$gateway = new Gateway(" tcp'type' => 'init', 'client_id' => $client_id ))); // 向当前client_id发送数据Gateway::sendToClient($client_id, "Hello $client_id\r\n"); // 向所有人发送 Gateway后台接收前端上传的 uid 和 client_id 两个参数后，进行绑定。后台代码如下： ``` <?php namespace App\Controllers; require_once '..

问答大佬们 1秒钟100条消息应该怎么处理呢

#### 问题描述我用thinkphp + gatewayworker写的聊天系统直接在thinkphp调用gateway 100条消息发送耗时130毫秒左右但是经过thinkphp读数据库而且好像这次的不允许玩其他人发的消息也要排队这种应该怎么处理呢或者有什么其他解决方案吗是我mysql环境没整好吗 T T

问答只用来连接做数据统计功能

### 我这边只想运行一个定时任务，然后每天到时间后去读取前一天的数据，根据需求计算出数据，然后再存到数据库。 ### 这样一个功能应该怎么写呢？**（PS：数据量很大，我们有通过linux的定时任务，然后运行tp6的think命令去执行这样一个统计，但是效率很低，每天大概运行接近一个小时才好）**

问答请教关于session和异步任务的两个疑问

项目使用GatewayWorker,碰到两个小问题求教 1.在Events中onMessage中，假设有3000个设备发消息过来，我把每个设备的id都存入到$_SESSION中，这里大量操作$_SESSION因为每天设备上发数据量比较大，都先写入REDIS，现在想用异步任务去读取redis队列中的数据然后写入MYSQL，如果开了多个进程去取数据，会不会造成重复写入另外问个项目实现思路的问题：现在服务器A上单独跑了GW来处理硬件上报数据，然后另外服务器B上WEB后台需要获取硬件的在线状态我现在的做法是单独开了websocket协议的gateway,然后WEB后台连上来，服务器A中GW接收数据，大概代码是这样Gateway::bindUid($client_id, $uid); } ``` 然后，在onClose方法中用 Gateway::sendToUid('WEB后台uid', $deviceId); 推送数据来完成通知某个设备下线了

问答workerman 4.1.13, connections无数据

，正常启动worker服务（tcp、http、ws）等后，客户端正常链接，运行 php start.php status 显示正常，但是运行 php start.php connections 时，无数据返回，检查代码后发现是未找到 .connections 文件 #### 程序代码或配置原始代码 945行左右 ``` $statistics_file = static::$statusFile ?

问答UDP数据缓冲区大小设置

如何设计 UDP协议的数据缓冲区大小？

问答想问下关于数据库负载的问题

#### 问题描述现在公司有个程序用于bi统计数据分析的后台，目前所有的统计数据都是通过各种复杂sql语句联表的复合查询得出的结果集。所以对数据库的计算压力比较大(虽然加了各种索引)，目前的临时解决方案是提升硬件能力，比如在阿里云上面买个16cpu 64g的独享数据库主机(这样能很大程度上缓解)。但是还有些c端程序也要跑，所以会会在这个数据库上面部署多个库。那如果那个统计的程序对数据库的压力比较大计算比较耗时，是否也会影响其它库的读写？应该影响比较大吧？有什么好的解决方案吗？

问答新手问题，无法连接WebSocket connection to 'ws://127.0.0.1:8282/' failed:

[截图](/upload/img/20220711/1162cbb76dc3a1.png) 各位大佬好，我是个新手，我是用的thinkphp,点的上图这个位置下载demo 然后复制到项目中vendor文件夹下``` events中： ```html public static function onConnect($client_id) { // // 向当前client_id发送数据// Gateway::sendToClient($client_id, "Hello $client_id\r\n"); // // 向所有人发送Gateway::sendToAll("$client_id login\r\n"); echo "$client_id 你好"; } ``` 然后php start.php start控制台启动

问答服务器通过tcp长连接接收数据

多个终端1s上报一次数据，会出现终端关闭后，服务器还在接收数据是怎么回事？

问答[已解决]webman+swoole，协程环境中HttpRequest已经做了协程上下文处理了吗

#### 问题描述 1.测试两个请求，第一个请求协程挂起5秒后输出所有请求参数；第二个请求直接输出所有请求参数。如果\Workerman\Protocols\Http\Request没存储上下文的话，第一个请求返回的应该已经被第二个请求污染了啊 2.如果\Workerman\Protocols\Http\Request做了协程上下文处理，那是否意味着在webman控制器中可以不用考虑自己处理请求上下文，可以直接用$request对象？1365a1ec9c007d.png) #### 结论通过代码得知，Request确实针对swoole、swow、Fiber的协程做了上下文处理 1.通过Webman\App::onMessage()方法可知，当请求进来时，会使用webman\Context设置上下文，发送完毕后会清理上下文 !