搜索-workerman社区

问答分开部署，GatewayWorker如何把消息收到的消息转发给webman?

#### 问题描述业务都在webman，GatewayWorker没有和webman部署在一起，GatewayWorker和webman分开部署开发，但在一个内网，有办法直接把收到的消息转发给webman

问答自定义进程内存占用过大

使用自定义进程由于需要统计用户的一些数据，需要把用户表的所有数据读取到内存，然后再做进一步的统计和分析。所以会导致内存占用增大。所以有以下4个问题想请教 1.自定义进程能否使用ini_set('memory_limit',256m)的这种代码，因为我想为单独这个进程扩大内存的使用，如果在php.ini修改应该是对所有的都生效。2.自定义进程能否手动释放内存且立即生效(或者说立即生效是指不会触发内存溢出的错误) 3.像这种用户数据的统计分析用什么样的方案比较合适？主要是涉及到递归查询计算和更新，如果用数据库去处理也很麻烦。 4.像数据的批量插入数据库，应当是一次性插入还是分批插入。比如有10万条数据的数组，用array_chunk分批插入还是直接一次性插入

问答【已解决】两个响应数据中间的问题

#### 问题描述定义了两个中间件: - `DesensitizeMiddleware` 响应数据注解脱敏中间件 - `ResponseCaseConverter` 响应数据下划线转驼峰现出现一个问题：当我定一个字段`id_card`，数据脱敏并将字段名变成`idCard`,这个时候，就不能脱敏成功，需将`ResponseCaseConverter`移除掉，才能正常响应脱敏中间件配置： ```php; /** * 注解脱敏中间件 */ class DesensitizeMiddleware implements MiddlewareInterface { /** * 响应数据的根路径field]; } } // 应用脱敏规则 if (is_array($targetData)) { // 根数据是数组Helpers\CamelHelper; use Webman\Http\Request; use Webman\Http\Response; use Webman\Middleware; /** * 响应数据下划线转驼峰

问答数据库查询问题

这样写就查不到数据 ```Mysql::$connect->select('title')->from('users')->where('id in (:ids)')->bindValues(['ids'=>'58,59'])->query();``` 这样写就可以查到数据 ```Mysql::$connect->select('title')->from('users')->where('id in(58,59)')->query();``` 我想用第一种写法查询数据，请问应该怎么解决呢

问答使用workerman发起压测

使用workerman发起的压力测试测试 wss 到250左右就断开了 3个扩展都安装了第一个压测的脚本第二个是结果 gatewayworker 版本是 3.5.17

问答打二进制包运行后，CPU占用率100%

#### 问题描述如图： ![截图](/upload/img/20250509/09681dd9326a57.png) ![截图](/upload/img/20250509/09681dd8bbbf5e.png) 不知道是什么原因，请问有什么解决方法吗？

问答关于Gateway全局$_SESSION的不同步问题

首先这个$_SESSION在gateway和worker之间也是通过Socket通讯的，这里就产生一个数据延迟问题，在项目的反复实践中被证明存在问题。当写入$_SESSION数据量比较大时尤其明显，比如写入2k以上数据。即便强制同步了，由于进入包连续进入，立刻会触发下一次的OnMessage，无论是否强制读取，得到的都是上次更新之前的旧数据。

问答webman/log 无法打印gateway events里的数据库查询语句吗？

webman/log 无法打印gateway event里的数据库查询语句吗？webman安装gateway 在events的onMessage方法里有查询语句，安装webman/log 好像无法打印里面的查询语句但是可以打印webman控制器的查询

问答关于“数据或者资源可以全局共享”

workerman的优点中有一条“数据或者资源可以全局共享”，请问怎么实现？我想在Event.php中用mysql_connect()创建一个数据连接$db_conn，然后后面有新的连接进来时，可以不用再次连接，如何做？

问答作为客户端进行wss订阅

我想用workerman作为客户端去订阅其他网站的信息，那边有数据就会向我发送消息，但是一直没有信息。 linux链接一段时间后就会关闭。

问答在websocket的onWorkerStart方法中，能否发送send到客户端？

www.workerman.net/upload/20200219/195e4d50140e69.png) 需求是这样的，在onWorkerStart中，定时检测并异步执行耗时任务，当有客户端连接ws时，可以实时获取该进程任务的执行日志我在想，既然timer和websocket同属于一个进程，那么能否不用中间件，直接在onWorkerStart里发送send给客户端呢？

文档onMesssge

Events::onMessage ## 说明: ```php void Events::onMessage(string $client_id, mixed $recv_data); ``` 当客户端发来数据(Gateway进程收到数据)后触发的回调函数 ## 参数 ``` $client_id ``` 全局唯一的客户端socket连接标识 ``` $recv_data ``` 完整的客户端请求数据，数据类型取决于Gateway所使用协议的decode方法返的回值类型 ## 返回值无返回值，任何返回值都会被视为无效的 ## 范例 ```php use \GatewayWorker\Lib\Gateway; class Events { /** * 有消息时触发该方法 * @param int $client_id 发消息的client_id *return void */ public static function onMessage($client_id, $message) { // 群聊，转发请求给其它所有的客户端

问答Gateway的sendToClient怎样才能获取到设备的响应数据

Client端向 Server端获取资源，向Server端发送HTTP请求。 2. Server端收到 Client端的HTTP请求后，判断Client端是否需要鉴权。Unauthorized回复后，Client通过返回的algorithm加密算法，对Server端返回的realm、nonce值，用户名ApiAdmin、密码、HTTP url、HTTP method进行加密计算Client端重新发送请求，请求报文头加入Authorization字段，计算出的Digest-Response作为repsonse值。 4. Server端收到Client端重新发送的请求，根据用户名ApiAdmin、密码，采用Client端一样的方法计算出Digest-Response（计算方式查看下方的Digest加密计算公式）。然后将计算出Digest-Response和收到的response值进行比对，比对一致则返回200 OK；比对不一致则返回 401 Unauthorized，其中响应的报文头加入WWW-Authenticate

问答GatewayWorker 前置负载均衡

#### 问题描述 GatewayWorker框架，有个问题想咨询，Gateway 框架前加了一个网关，网关负载均衡到 Gateway,但是cliend_id是由Gateway创建，如果客户端创建连接时，负载均衡到了Gateway1,发送消息时到了Gateway，这样怎么处理

问答binary协议前台js如何发送数据?

如题,搭好了workerman和binary协议,用client.php上传没有问题,但是js使用如下代码: ```javascript var ws=new Websocket(wss://******:8080); ws.send(data); ``` 报错连接502,但是client.php又能上传. 所以问下js应该怎么写才能用binnary协议传文件,谢谢.

问答http-client 最大并发数

#### 问题描述我发现 http-client 是有最大并发数的比如修改配置参数中的max_conn_per_addr 就能调整最大并发参数了 $options = [ 'max_conn_per_addr然后定频的去从队列中获取要请求的数据。然后发起请求但是这又带来一个问题。因为被请求方，有时候响应快有时候响应慢。我就不知道 http-client 当前有多少并发连接数了。我要怎么获取到当前的并发连接数呢？因为如果并发连接数满了的话，我这时候去发去请求，他是无效的彷佛直接未执行该动作一样记录并发请求数。所以 http-client 类的话有直接获取到当前并发的请求数嘛？