问答你好，大神，用咱们的GatewayWorker做即时通讯并发问题
你好，我们用GatewayWorker做即时通讯的后端，用redis 做了一部分缓存，同时 消息存储到 mongodb ,业务接口 用 mysql 这块
我们做并发测试，发现 4核的服务器 每秒连接人数基本在 1W左右可以的，但用前端给后端每秒发送数据 发现socket 基本上每秒只能处理 10条左右数据的下发，前端 每秒 100条数据发数据，导致全部堆积到 后端 ， 基本上延时 1-2给小时才能下发完， 到现在也不清楚原因原因
问下大神，咱们 GatewayWorker 每秒理论数据下发至客户端在多少条？想这样的每秒100条消息，服务器没有下发都堆积到哪里了？
问答自定义进程中数据查询数据库连接操时
#### 问题描述
使用webman2.1后，http服务进程数据库操作正常，自定义进程中首次查询数据正常，等待3分钟左右后，数据库连接操时：SQLSTATE[HY000]: General error1.http服务进程因请求结束会调用 Context::destroy() 能正常将连接回收放入连接池，数据库连接心跳正常，所以没有导致连接超时。自定义进程中我是用来做异步执行定时任务的，经过排查发现自定义进程中，首次查询数据心跳是正常执行，定时几分钟再查询数据后，从此心跳不在执行，如果在等几分钟再次查询数据，没有心跳维持连接就会报数据库连接操时了//等待中一直观察数据库链接心跳正常触发
//200秒执行查询一次测试
Timer::add(200, function () {//说明：在次查询会导致数据库连接操时，目前暂时解决是：定时50秒执行一次 Db::query('select 1'); 或者 在该进程中所有查询数据后执行 Context::destroy
问答能通过websocket转发chatgpt的流数据吗？
#### 问题描述
最近在弄chatgpt，前端通过websocket发送消息，后端Gateworker的Events.php里通过workerman的HttpClient请求chatgpt的聊天接口，返回数据发送到前端。现在想实现打字机效果，能通过websocket转发这些数据到前端吗？
问答web服务器 http协议发送几M数据 客户端接受不完整
最近开发过程中，接口调试时发现客户端收到的数据总是不完整，追踪代码发现在TcpConnection.php中
$len = @fwrite($this->_socket, $send_buffer, 8192);
socket最大发送8192字节，超出的部分就丢掉不发了，有什么办法修改吗？
问答Workerman重启后客户端发送心跳服务端报错
服务端是Workerman+GatewayWorker架设
客户端是采用C#开发的。
当服务端断开后，客户端也断开连接了。
当服务端重新启动后，客户端也重新连接上服务端了。然后发送心跳包数据。但有时会出现客户端发送的心跳包数据，服务端也有收到信息。但是使用$data=Gateway::getUidByClientId($client_id);
来获取对应连接绑定的数据时，会报Invalid argument supplied for foreach
问答GatewayWorker 多端口 在控制器中只能获取其中一个端口的数据
系统：centos7
项目：laravel5.8+Workerman+gatewayWorker+nginx
我的项目中共启用了两个GatewayWorker端口，一个Tcp，一个webSocket在控制器中查询Client_id绑定信息或者Session信息的时候只能查询到Tcp端口的信息，webSocket端口的信息无法获取到；
控制器代码如下：
!
问答gateway推送消息
------------
问题已解决，是代码逻辑问题，不好意思~~
<---------------------->
设备端与web控制端各使用一个worker。设备端服务端口为8899，内部通讯端口为4000；web控制端服务端口为8900，内部通讯端口为4001，其余配置基本一样，两个worker的数据收发处理都在同一个Events.php里执行。现在的问题是，web控制端发送命令，onMessage可以成功发送数据到设备端，但反过来，当设备端返回数据到onMessage之后，却无法将数据推送回web端，使用sendToAll也不行。
问答传输二进制省带宽？各种语言通用性？
传输二进制更省带宽？各种语言通用性？
如果我用json-rpc来实现不是更好吗？
问答gatewayWorker负载均衡的机制配置？
1、官方有一篇文章，[平滑重启](http://doc.workerman.net/install/start-and-stop.html)，仅支持**Worker::runAll()**执行后的代码进行如有发布系统，通过软链指向了最新版本的代码，而且只保留10次（01-10）可以回滚的版本，问题是：我在01次启动了register，gateway，worker，这时候发布第11次的代码，会将01的代码删除2、gatewayWorker负载均衡的内部机制是什么，轮询？权重？可以自定义设置吗？文档上面没找到。
望作者指点一二，谢谢~
问答进程数量必须为1的疑问
#### 问题描述
workman 定向某个客户发送
https://www.workerman.net/doc/workerman/faq/send-data-to-client.html
https://www.workerman.net/q/508
其中进程数量为1
phpsocket.io web-msg-sender 虽然没有配置进程数量 但是启动发现也是1 奇怪！/start_io.php
https://github.com/walkor/web-msg-sender/blob/master/start_io.php
1、是不是workman 定向某个客户发送这种情况下进程只能1 。2、是不是还可以使用GatewayWorker，它本身就是多进程的？
文档数据库迁移
# Migration数据库迁移工具 Phinx
## 说明
Phinx 可以让开发者简洁的修改和维护数据库。 它避免了人为的手写 SQL 语句，它使用强大的 PHP API 去管理数据库迁移。开发者可以使用版本控制管理他们的数据库迁移。 Phinx 可以方便的进行不同数据库之间数据迁移。还可以追踪到哪些迁移脚本被执行，开发者可以不再担心数据库的状态从而更加关注如何编写出更好的系统。"charset" => "utf8"
]
]
];
```
## 使用建议
迁移文件一旦代码合并后不允许再次修改，出现问题必须新建修改或者删除操作文件进行处理#### 数据表创建操作文件命名规则
`{time(auto create)}_create_{表名英文小写}`
#### 数据表修改操作文件命名规则
`{time(auto create)}_modify_{表名英文小写+具体修改项英文小写}`
#### 数据表删除操作文件命名规则
`{time(auto create)}_delete_{表名英文小写+具体修改项英文小写}`
#### 填充数据文件命名规则
问答gatewayworker tcp黏包
通过socketManager 发送给服务端包；
发第一个“你好1” 服务端推送给客户端是“你好1”，
发第二个"你好2"、
发第三个“你好3”
返回的数据包居然把你“你好2你好3”合并一起发送给客户端
问答消息转发设计，如何尽最大可能支持高并发？
#### 问题描述
使用GatewayWorker同时做客户端和服务端。
做客户端使用异步请求一个ws连接，不断接受消息，将其发送到Channel通道中。我目前还没有加上数据处理部分，我想加上数据处理部分并发又会下降不少。
需要实时转发的数据处理部分是否可以通过task来实现？使用协程可以来处理不是需要实时转发的数据，比如把接收到的数据存储到数据库这些阻塞操作？其他同第二个方案一样。
**第四个**是把客户端和服务端进行分布式部署。异步请求以及发送消息给通道的操作 与 用户连接订阅通道消息并发送消息给用户 完全分开部署。，作为主进程
if ($businessWorker->id === 0) {
// 获取数据的代码...
问答偶尔触发，服务端接收不到数据的问题
#### 客户端发送数据，服务端，日志没看到
跑几个小时，就会偶尔出现一次，发送了，但是服务端log没有那条id的记录，，都是执行时间比较长的任务，可能1~3分钟之间，开启的进程数为20， 但是每次可能会一次性执行数量达到connection->id.'#'.time().mt_rand(0, 100000);
\app\model\Log::setFlag($finger);
// 响应数据给客户端$_server_port);
// 当连接建立成功时，发送请求数据
$_connection->onConnect = function(AsyncTcpConnection $_connection
问答gatewayworker的 Gateway::sendToUid($senduid,json_encode($data));发送消息会有不稳定性！？？
# 当硬件用tcp协议而前端用websocket时为何Gateway::sendToUid($senduid,json_encode($data))发送数据是不稳定的(不稳定是指我已经走到这一步了var_dump（$senduid）是有数据的 但是我硬件那边是接收不到这个指令 前端从新链接再发送指令就有可能接收到 或者没有那只有重新链接 再发送 就有可能接收到了 注：这期间是没有任何报错的而且$senduid是一直有数据的
问答workerman websocket协议 send 怎么流式发送数据，为什么都是一起返回的
#### 问题描述
workerman websocket协议 send 怎么流式发送数据，为什么都是一起返回的；
windows 本地测试正常，可以流式输出， linux 服务器上不行， 都是一起输出的connection, $data) {
$url = 'https://demo.xxxxxxxxxxxx.com/ai.php';
$postData = []; // 假设这是你要发送的数据$headers = []; // 假设这是你的请求头
// 定义回调函数，并通过 use 关键字传递 $connection
$writeCallback = function($ch, $data) use ($connection) {
// 处理接收到的数据块
$length = strlen($data); // 获取数据块的长度<br>",true); // 将数据发送给客户端
return $length; // 返回处理的数据长度
};
// 发起 cURL 请求
$response
问答gatewayWorker中连续接受tcp数据时候丢包
用gateway在做一个转发的网关，一边是tcp socket，一边是websocket，当tcp连续发十多条数据，每条30字节左右的数据时，gateway有时只收到七八条数据，可是我加了sleep函数1s发送一条时候，又能完整接受所有数据，按理说tcp是不会出现丢包现象吧，而且我的tcp端每次send都是返回成功（没有加延时）的啊，而网关端却接受得不对？
问答使用ssl websocket 时, 连续发送数据时出现链接断开的情况
使用ssl websocket 时, 连续发送数据时出现链接断开的情况, 查找原因后发现是TcpConnection 中 baseWrite() 方法中fwrite() 方法在写数据时报错导致,我们服务器并发并不高, 大约100人同时在线, 所以也没有装event扩展, 是否和这个有关系呢?请求这个问题有什么解决方法吗?
分享webman-admin管理员数据限制的方法
##需求：
每个账号只能管理自己的下级账号，admin账号可以管理所有账号的数据
功能模块进行数据限制仅添加人，以及添加人的上级账号可以看到。
!$field, $order] = $this->selectInput($request);
$model = $this->model;
// 数据限制admin_id());
$ids[] = admin_id();
$model = $model->whereIn('admin_id', $ids);
// 数据限制结束
问答请问怎么发送相关信息呢
我看手册的时候发现属性里找不到一些能顺便发送额外信息的方法，回调方法里的也是。比如
mixed Connection::send(mixed $data )
send的方法，我希望用send发送数据的时候能够将所发送数据的相关信息也一起发送过去。比如我发送一段语音，希望将发送语音的所有者的姓名、id等一些相关信息也一起发送过去。
但是send方法里只有两个参数，一个是要发送的数据，一个是否发送原始数据。请问你们都是用什么方法
来发送相关的信息呢？
赞助商
