搜索-workerman社区

问答AsyncTcpConnection作为客户端与其他服务端通信连接出现数据延迟的问题

我是用AsyncTcpConnection作为客户端，连接其他socket进行通信，但是当服务器那边发送给我这边的客户端短时间内，也就是并发一多，其实也没多少，差不多100左右，这边的客户端在onMessage打印的数据里有些请求就会延迟个1分钟以内不等的时间，所以想问这个怎么解决？？？

文档send

data ``` 要发送的数据，如果在初始化Worker类时指定了协议，则会自动调用协议的encode方法,完成协议打包工作后发送给客户端 ``` $raw ``` 是否发送原始数据，即不调用协议的encode方法，默认是false，即自动调用协议的encode方法 ## 返回值 true 表示数据已经成功写入到该连接的操作系统层的socket发送缓冲区 null 表示数据已经写入到该连接的应用层发送缓冲区socket发送缓冲区，并不意味着数据已经成功的发送给对端socket接收缓冲区，更不意味着对端应用程序已经从本地socket接收缓冲区读取了数据。** 由于socket发送缓冲区的数据是由操作系统异步发送给对端的，操作系统并没有给应用层提供相应确认机制，所以**应用层**无法得知socket发送缓冲区的数据何时开始发送，**应用层**更无法得知socket发送缓冲区的数据是否发送成功。

问答GatewayWorke 连接数可以过万，但是前面1015个连接可以向服务器发送信息，1015以后的连接发送信息服务器收不到

GatewayWorke 连接数可以过万，但是前面1015个连接可以向服务器发送信息，1015以后的连接发送信息服务器收不到，这是什么情况，是我的内核哪里没有配置吗？

问答workman 如何接收连续的tcp数据流然后得到一个完整的数据流

workman 如何接收连续的tcp数据流，然后得到一个完整的数据流。比如tcp 发过来的数据 fafb010100000017 然后又发的 00003836393530333033333 最后得到 fafb01010000001700003836393530333033333一个完整的数据流呢

文档sendToGroup

如果为数组，则是给数组内所有group发送数据 * ```$message``` 要发送的数据（字符串类型），此数据会被Gateway所使用协议的encode方法打包后再发送给客户端 * ```$exclude_client_id```$exclude_client_id```数组中指定的client_id将被排除在外，不会收到本次发的消息 * ```$raw``` 是否发送原始数据，也就是绕过gateway协议打包过程，gateway对数据不再做任何处理，直接发给客户端。## 更新日志 | 版本 | 说明 | | -- | -- | | 2.0.7 | 增加了```$exclude_client_id```和```$raw```参数 | ### 返回值因为数据发送是异步进行的一般来说只要客户端在线就可以发送成功。 ## 范例 ```php use \GatewayWorker\Lib\Gateway; class Events { ...

问答（急）怎么把前端推送改成php推送

// Channel客户端连接到Channel服务端 Channel\Client::connect('127.0.0.1', 2206); // 监听全局分组发送消息事件$group_con_map = $con; // 记录这个连接加入了哪些群组，方便在onclose的时候清理group_con_map对应群组的数据case "send_to_group": // Channel\Client给所有服务器的所有进程广播分组发送消息事件message'=>$data )); break; } }; // 这里很重要，连接关闭时把连接从全局群组数据中删除>onClose = function($con){ global $group_con_map; // 遍历连接加入的所有群组，从group_con_map删除对应的数据

问答客户端连接gateway得到client_id=01成功后端循环发消息，此时前端页面刷新换了client_id=02，后端的消息会将给01的消息也发给02，这是为何？

目前有个PHP项目，thinkPHP5.1框架，使用gateway库，客户端连接socket成功后client_id为01，服务端开启一个大循环(总耗时数分钟)给该客户端01发消息，消息未发送结束客户端刷新了页面，client_id变成了02，但是原先发给01的数据会叠加发到02上，导致02同时接收到了两条消息。请指点一二，谢谢。 @walkor

文档支持哪些协议

# Workerman支持哪些协议 Workerman在接口上支持各种协议，只要符合```ConnectionInterface```接口即可（参见定制通讯协议章节）。为了方便开发者，Workerman提供了HTTP协议、WebSocket协议以及非常简单的Text文本协议、可用于二进制传输的frame协议。开发者可以直接使用这些协议，不必再二次开发。如果这些协议都不满足需要，开发者可以参照定制协议章节实现自己的协议。开发者也可以直接基于tcp或者udp协议。0.0.0.0:1222'); // text文本协议（telnet协议） $worker3 = new Worker('text://0.0.0.0:1223'); // frame文本协议（可用于二进制数传输

问答关于gatewayworker中多个端口分别心跳检测的问题

wss $gateway->transport = 'ssl'; // gateway名称，status方便查看 $gateway->name = 'WebsocketSSL'; // gateway进程数$gateway->registerAddress = '127.0.0.1:21238'; // 心跳间隔 $gateway->pingInterval = 60; //如果设置为0代表客户端不用发送回应数据gateway->registerAddress = '127.0.0.1:21238'; // 心跳间隔 $gateway->pingInterval = 120; //如果设置为0代表客户端不用发送回应数据名称，status方便查看 $gateway->name = 'SCADAGateway'; // gateway进程数 $gateway->count = 4; // 本机ip，分布式部署时使用内网ipgateway->registerAddress = '127.0.0.1:21238'; // 心跳间隔 //$gateway->pingInterval = 15; //如果设置为0代表客户端不用发送回应数据

问答怎样把接收的数据显示到前台？并且在前台发送对应数据给特定的设备？

注册上之后会去连接服务器，服务端开了一个socket，走的是http协议，$webserver = new WebServer('http://0.0.0.0:8080'); 这些设备连上之后，需要人工操作在前端发送一些指令给设备

问答如何使用多进程并行组合处理一个业务？

我现在使用webman提供一个http接口，该功能需要实现以下： ``` 去ES的A索引中查询数据去数据库中查询去ES的B索引中查询数据 ``` 以上三步IO没有次序，我想可以用多进程的思路来提高并发量如果是在其他php-cli环境下，我可以fork三个子进程，然后阻塞父进程等待三个子进程的返回，得到三个子进程的返回后，父进程统一组装数据响应给调用方。但是在webman中如何实现呢？我看文档中有说明可以创建带监听的task进程，然后控制器中使用异步TCP客户端的方式去投递任务，然后在异步TCP客户端的回调中获取返回结果，但是这种情况下我在控制器这个主进程怎么阻塞等待三个任务的返回啊

问答GatewayWorker

本人大一小白~因为写项目时遇到了这种场景，用户端下订单需要在商家后台实时推送是要选择GatewayWorker更好些是么？因为又看到官网上这么写，另外想问下文档说GatewayWorker是基于workerman开发的框架，那我安装GatewayWorker还需要安装workerman嘛？

问答关于gateway里的worker多进程的疑惑的问题

大致都浏览了好几次文档了，有几个疑惑：看了文档里实例里worker的count都是设置成4，问题来了，那么一个多websocket客户端连接到服务器肯定是会按一定规律分配给不同的worker，多进程间数据是无法共享的，那么广播群发，workerman怎么处理的，利用了什么机制，内存数据共享机制吗？我看了下大致的源码，找到一个gateway类里有一个_clientConnections，不明白这个是怎么共享的，而且gateway也是有count设置成4个进程的，不解

问答为什么workerman中http请求过来的数据，后台打印大多数情况接收不到

#### 问题描述这里写描述你好，问一下为什么http请求过来的数据，我后台打印大多数没有，偶尔能打印2次发送过来的数据，websocket请求数据是正常的，就是http请求有问题，域名解析都是正常的

问答gatewayworker设置的worker数量太多，导致require_once文件失败

一个基于gatewayworker框架的服务器程序，我设置了5个gate， 10个worker，然后一个含5个worker的客户端，每个worker发起1000个连接到服务器，发现服务器报require_once这个相当于多进程同时require_once 某个共享文件造成的，这个有办法解决吗，谁叫php是解释型语言呢，在用到的时候才会require进来！可是就是这么巧，进程数多了点就这样了！

问答Webman中, 分页时,表中字段值过大,排序出错

```php date("ymdhis"); ``` 在表中排序字段类型为bigint, 使用上面date函数去更新值,比如更新某一条的sort为220829043719 今天发现数据出错, 表现为 1正常输出 2.进行分页时,会出现数据错乱. 同一条记录会在第一页,第二页中出现2次, 有的记录在所有分页中都不会出现想了解一下这是什么原因?是数字超过了哪里的处理最大限制吗

问答gatewayworker centos 背景运行不到1小数stream_socket_client(): unable to connect to tcp://127.0.0.1:2900

gatewayworker nohup php start.php start >gateway.log 2>&1 & ；不到1小时报错运行环境centos7 ,有知道原因的吗？ !stream_socket_client(): unable to connect to tcp://127.0.0.1:2901 (Connection refused) in /www/wwwroot/GatewayWorkergateway-worker/src/Lib/Gateway.php on line 755 2022-09-27 05:30:23 8.134.85.72 7f0000010b550000001b收到消息: � 是平台发送消息gateway-worker/src/Lib/Gateway.php on line 755 2022-09-27 05:31:23 8.134.85.72 7f0000010b550000001b收到消息: � 是平台发送消息gateway-worker/src/Lib/Gateway.php on line 755 2022-09-27 05:31:55 8.134.85.72 7f0000010b550000001b收到消息: � 是平台发送消息

问答gatewayworker 可以做为 socket cliednt 向指定服务器端口发送吗？

在收到socket client消息的时候，想把数据发给指定服务器端口，比如 tcp://127.0.0.1:8888 。这个时候，服务器如何创建一个 socket client 去实现这个功能？

文档sendToAll

如果指定的$client_id_array中的client_id不存在则自动丢弃 ## 参数 * ```$send_data``` 要发送的数据（字符串类型），此数据会被Gateway所使用协议的encode方法打包后发送给客户端 * ```$client_id_array``` 指定向哪些client_id发送，如果不传递该参数，则是向所有在线客户端发送 ```$send_data``````$exclude_client_id```数组中指定的client_id将被排除在外，不会收到本次发的消息 * ```$raw``` 是否发送原始数据，也就是绕过gateway协议打包过程，gateway对数据不再做任何处理，直接发给客户端。### 返回值因为数据发送是异步进行的，所以没有返回值。一般来说只要客户端在线就可以发送成功。

问答【反馈】router中，如果数据处理失败，希望终止后续路由，希望返回bool false ，则会导致进程重启

比如官网的http://chat.workerman.net/，如果你的名字选择为 \h\，即带有特殊字符 \ " 等，会导致后台进程报错并重启，是否存在攻击风险，使得进程反复重启，并且进程中的变量数据将会丢失补充下，仅供官方参考如果传输的是gzip压缩，又需要根据用户发来的消息选择路由，则router函数中，如果根据buffer解压缩失败，或者处理失败，希望终止请求，而不是继续返回一个worker,从而导致后续进程的重启。对于这种需求，请问是否有更好的方法来处理用户发来的数据而选择不同的路由，并且对于非法的用户数据，因为不能指定到业务逻辑相关的路由，就需要终止掉该请求，而不导致进程重启，谢谢