问答GatewayWorker 在Event.php onMessage 中发生阻塞.....
GatewayWorker 在Event.php onMessage 中处理某个客户端发来的数据时，发生了阻塞，导致其它客户端进来的请求到event.php onMessage就被阻塞了。
问答如何使用webman创建一个text/eventstream响应, 使服务端持续向客户端发送数据
#### 问题描述
#####如题, 最近看到一个Content-type类型:`text/eventstream`, 可以持续向客户端发送数据, 使用webman作为服务端应当如何实现?
问答GatewayWorker并发上限
#### 问题描述
php使用GatewayWorker实现了直播间 但是直播间每天记录下来的最高并发每天都是4027 然后服务器cpu最高也就不到70% 这是什么原因
#### 程序代码或配置websocket+SSL 即wss
$gateway->transport = 'ssl';
// 设置名称，方便status时查看
$gateway->name = 'ChatGateway';
// 设置进程数，gateway进程数建议与cpu核数相同
$gateway->count = 4;
// 分布式部署时请设置成内网ip（非127.0.0.1）
$gateway->lanIp = '127.0.0.14001 4002 4003 4个端口作为内部通讯端口
$gateway->startPort = 8822;
// 心跳间隔
$gateway->pingInterval = 10;
// 心跳数据= 'ChatBusinessWorker';
// bussinessWorker进程数量
$worker->count = 8;
// 服务注册地址
$worker->registerAddress
问答【已解决】AsyncTcpConnection 重连机制，是否可以更改send的数据
使用过程中，触发onClose重连的时候，发现里面send的订阅数据是刚启动时候的数据。这里有没有地方可以设置reConnect时发送的数据呢？不太懂如何处理？
问答硬件数据推送给特定手机端
我使用的gateway，硬件传输数据的时候可以带上当前硬件设备的pid，然后我用gateway推送给当前正在使用这台硬件设备的用户手机app上。如果硬件用tcp长连接把数据存数据库，然后然后app用http轮询调用倒是可以实现。 只是我希望服务端也能通过和app长连直接推送，这样应该更快一些
问答Android 客户端 Okhttp 发送 心跳 PHP 服务端无法收到心跳
如题，急急急，求大佬指点一二，Okhttp 自带心跳机制， 发送的是0x09 这种 ，php无法收到这个消息，就自动断开，@walkor 大佬指点一下。看看有啥方法处理，android 端打断点看到， 心跳消息 一直再发，也一直再收，但是 服务端就是不走 onmessage 方法（后端大佬说的）
问答tcp接受数据转发给websocket
需要做一个tcp接受数据以后 实时转发给前端的web页面
我在TCP的业务逻辑中 怎么把接受到的数据 转发给websocket呢
问答redis-queue 延迟任务 可否延迟第二天触发？
use Webman\RedisQueue\Client;
// 投递延迟消息，消息会在第二天此时处理
Client::send($queue, $data, 24*3600);
请问队列可以延迟第二天执行吗1、如果当天队列堆积4万条，也可以延迟第二天执行吗？
2、4万条数据需要php处理 会不会瞬间把CPU打满？
问答请问向uid发数据和向client_id发数据哪个快？
我想给一批用户发数据，用户大约有1万左右。由于一些原因，不能使用分组。
请问
sendToUid()
和
getClientIdByUid()
sendToClient()
哪个效率更高？
问答如何根据文本内容(路径)调用控制器
#### 我把对应的控制器路径放在数据库，如何根据内容调用控制器
下面的是正常的以命名空间调用控制器方法
```php
$u = new \app\admin\controller\Index;
$u->index();
```
由于业务所需我可能在需要根据不同的参数调用控制器（控制器太多 if 代码量太大）
因此我定了数据库储存控制器路径 ，根据请求取得对应的然后调用方法
但是储存在数据库是字符串比如$path = '\app\admin\controller\Index';
根本无法实现：$u = new $path; 这样调用控制器
请问大家我该如何做？
问答GatewayClient是通过TCP连接和发送消息的吗
```php
/**
* 发送数据到网关
* @param string $address
* @param string $buffer
*/
protectedsendToGateway($address, $gateway_data)
{
// 有$businessWorker说明是workerman环境，使用$businessWorker发送数据self::$businessWorker->gatewayConnections->send($gateway_data);
}
// 非workerman环境，使用udp发送数据return strlen($gateway_buffer) == stream_socket_sendto($client, $gateway_buffer);
}
```
代码注释里写着使用UDP发送数据
问答全真回放（在2个小时内每1秒发送一次数据到前台），这样的业务应用定时器的时候，有什么要注意的吗？
当前业务是这样：
老师端在直播的时候会把没一个操作记录到一个TXT文件里，当直播结束时，服务端把这个TXT命令导入到mongodb数据库中。当学生来看回放时，使用定时器功能，每1秒发送一次数据到前台（查询数据是一次可以预先查询1000条， 然后检索这1000条，取出1秒内的数据发到前台）；定时器的ID可能会一直变化，因为用户可以暂停，拖进度当前我开的定时器是在当前进程，没有新开task。
有没有更好的方法？
问答给rabbitmq发送数据，前台运行完全没问题，但是一旦 -d 到后台就不能发送出去了。mqtt不受影响，都正常
#### 问题描述
给rabbitmq发送数据，前台运行完全没问题，但是一旦 -d 到后台就不能发送出去了。
#### 程序代码或配置
```
<?false,true,false);
//消息队列
$channel->queue_bind($queueName, $exchangeName, $my_routing_key);
//worker数据messageData);
$message = new AMQPMessage(json_encode($messageData));
// 发送消息到队列$channel->basic_publish($message, $exchangeName, $my_routing_key);
echo "消息已发送到队列GLOBAL_START')) {
Worker::runAll();
}
```
#### 重现问题的步骤
1、mq上建立相应的路由和 queue
2、start 运行没有问题，mq可以收到数据
问答异步消息推送
使用Gatewayworker做了一个服务端，使用tcp协议和客户端进行通信，用于推送订单数据给店铺，一个店铺对应一个客户端。在redis中存储客户端的身份标识和client_id，然后thinkphp调用GatewayClient推送数据给相应的客户端。现在问题是这样的，如果某一个店铺**同时**收到了n个订单，Gatewayworker是不是会瞬间将这些订单推送给客户端呢？要想让客户端来得及反应，这时候是不是需要做异步消息队列了，然后设置间隔时间一条一条推送给客户端。或者有更好的解决方案呢？
希望大神可以给予解答，感激不尽！
问答请教一下大神websocket发送的数据会因延迟造成变化不？
该情况用在比如加钻石数时，前端同步更新，后端会和前端发来的数值t=4进行比对，如果符合就+1，不符合就报作弊，现在误报作弊的情况偶尔发生，但不是每次都发生，排查了很多问题，现在只能怀疑是这个了，像是因网络不好造成了传到后端的是如果是这个情况，一般通信中前端同步更新应该怎么做避免数据错乱呢？
问答GatewayWorker平滑重启造成客户端中断链接[已解决]
正常情况下GatewayWorker平滑重启不会造成客户端中断链接, 但是如果在平滑重启的那一刻, 客户端有发送数据进来, GatewayWorker就会报下面的错误:
SendBufferToWorkerSee http://wiki.workerman.net/Error3
客户端也同时中断了链接, 但尴尬的是worker进程却不会收到onClose消息, 造成服务器一些资源没有被释放, 怎么破呢?
问答关于数据库操作问题
最近在做一个在线聊天室，我想请教个问题，例如获取用户的聊天记录，未读消息数量等。是在workerman中使用mysql操作好还是通过socket发送消息给客户端后通过前台ajax请求获取比较好？[截图](//www.workerman.net/upload/20210122/22600a33110abc.png)
我现在的思路是没做worker中做数据操作，都是通过这种ajax进行操作数据
问答我是API开发的后端，后端发送给前端的消息如何通过gatewayworker发送呀，是在后端代码直接调用GatewayClient这个API就行了吗？
我想实现一个简单的后台点击审核是否通过，客户端实时接收审核成功或失败的消息，我现在遇到的问题是gatewayworker怎么跟后端连接在一起，后端发送给前端的消息如何通过gatewayworker发送呀
问答我在tp6.0上安装了Workerman，在GatewayWorker原生框架开启服务，但是在tp上通过websocket协议去连接这个GatewayWorker开启的进程连接不到
()
{
$task_connection = new AsyncTcpConnection('websocket://127.0.0.1:9502');
// 发送数据上开启服务的代码：
```php
class Task
{
//设置Worker子进程启动时的回调函数，每个子进程启动时都会执行。public function onConnect($connection)
{
var_dump(1111);
}
//当客户端通过连接发来数据时(Workerman收到数据时)触发的回调函数
public function onMessage($connection, $data)
{
//处理异步任务
// $task_dataWorkerman\WebServer;
// task worker，使用Text协议
$task_worker = new Worker('websocket://0.0.0.0:9502');
// task进程数可以根据需要多开一些
问答请问一下老大，关于数据接收后处理的问题
我现在用的是 Workerman 3.x ，使用的是TCP协议，接收客户端发送的数据，并做储存，请问数据存储是放在onmessage里面直接进行数据库存储，还是存入队列，然后在数据处理线程中读取队列进行数据库好些
赞助商
