问答AsyncTcpConnection无法触发onMessage
AsyncTcpConnection('Text://127.0.0.1:12345');
// $task_connection->connect();
// 发送数据});
}
}
// task worker，使用Text协议
$task_worker = new Worker('Text://0.0.0.0:12345');
// task进程数可以根据需要多开一些"\n";
};
// 设置业务处理函数
$task_worker->onMessage = function($connection, $task_data)
{
// 假设发来的是json数据$task_data = json_decode($task_data, true);
trace([$task_data,'msg'=>'发送后'],'crontab');$task_result = 'done';
// 发送结果
$connection->send(json_encode($task_result));
};
```
问答webman GatewayWorker插件 发送消息延迟是怎么回事？
gateway-worker
```
Events 连接事件中我把：$client_id 绑定为：123456 (用于测试)
然后 在app\controller\test.php 新建一个控制器不在线"]);
}
}
```
访问Url发送消息，明显感觉有延迟500毫秒 - 2秒左右，客户端才收到，反正不是那种秒到 ，问题出在哪里啊
PS：（**绝不是本地网络问题，也不可能是服务器网络问题**,因为我服务器有搭建一个java的tcp服务端 我客户端链接这个java服务端收发消息都是秒到）
问答如何控制指定哪个进程来接收客户端连接？
Worker('http://0.0.0.0:2120');
$worker->count = 1;
$worker->onWorkerStart = function($worker)
{
// 读取数据Worker::runAll();
```
需求：我需要把大量数据读取到内存，供客户端查询，需要做到0.2s内响应。数据同时在不断更新，每5秒又要重新去读取数据。
请问这个可以怎么实现？我的不成熟想法：在onMessage中fork了一个进程，总共2个进程，
进程1个提供服务，进程2去读取最新数据
5秒后，进程1去读取最新数据，进程2提供服务，又5秒后，进程1提供服务，进程2去读取最新数据
问题是如何指定一个进程来处理客户端请求？
问答GatewayWorker最大连接数1024
GatewayWorker服务器 是Liunx服务器，已经按照Linux优化和安装event扩展的操作过了。但是用另一台Liunx服务器来进行压力测试，最大连接数一直是1024，难道这台服务器也需要优化和装扩展吗？
压力测试到底该如何进行，请大神指教
问答workerman 修改不了多进程数？
[截图](//www.workerman.net/upload/20200912/125f5c4421e408.png)
我改了
$gateway->count = 1;
为什么依然还是4个进程处理数据[截图](//www.workerman.net/upload/20200912/125f5c449742e1.png)
workstart里触发 testjinchengshu()
分享webman_admin 数据权限设置
return $role_key;
}
}
```
# plugin/admin/app/controller/Base.php
```php
/**
* 数据限制* null 不做限制，任何管理员都可以查看该表的所有数据
* auth 管理员能看到自己以及自己的子管理员插入的数据
* personal 管理员只能看到自己插入的数据* @var string
*/
protected $dataLimit = null;
/**
* 数据限制字段
*/
protected, `updated_at`, `admin_id`) VALUES (41, 'dict_data_permissions', '[{\"value\":\"null\",\"name\":\"全部数据\"},{\"value\":\"auth\",\"name\":\"自己以及自己的子管理员的数据\"},{\"value\":\"personal\",\"name\":\"自己的数据\"}]', '
问答UDP服务器主动向客户端发送消息
大家好，请问一下：我用workerman搭建了一个UDP服务，用于和物联网设备通讯，现在的情况是服务器能收到设备发来的数据，但是我想主动给设备发送命令（不在onMessage里面send），修改设备的一些参数
问答GatewayWorker 怎么通知 Thinkphp 给维护人员发短信
根据GatewayWorker 手册
[attach]797[/attach]
GatewayWorker 不做业务处理，业务逻辑放到MVC中，
现在有个物联网项目，实现30秒没有检测到心跳包，则改机器已经断网发短信的业务放到Thinkphp处理，请教一下GatewayWorker 怎么通知 Thinkphp 发短信？
问答为什么我post过来的数据想转发给过去，但是返回值为NUlLL，我看了下表示放入待发送队列，等待异步发送，怎么能立即发送出去呢
异步建立一个到实际ccs服务器的连接
$connection_to_css = new AsyncTcpConnection($REAL_CCS_ADDRESS);
// ccs连接发来数据时，转发给对应客户端的连接
$connection_to_css->onMessage = function($connection_to_css, $buffer)use($connectionfunction($connection_to_css)use($connection)
{
$connection->close();
};
// ccs连接上发生错误时{
$connection->close();
};
// 执行异步连接
$connection_to_css->connect();
// 客户端发来数据时，转发给对应的ccs连接
$connection->onMessage = function($connection, $buffer)use($connection_to_css)
{
文档sendToUid
sendToUid
## 说明:
```php
void Gateway::sendToUid(mixed $uid, string $message);
```
向uid绑定的所有**在线**client_id发送数据如果为数组，则是给数组内所有uid发送数据
* ```$message```
要发送的数据（字符串类型），此数据会被Gateway所使用协议的encode方法打包后再发送给客户端
### 返回值因为数据发送是异步进行的，所以没有返回值。一般来说只要uid在线就可以发送成功。
发送前先可以用Gateway::getClientIdByUid判断下uid是否有在线的client_id。## 范例
```php
use \GatewayWorker\Lib\Gateway;
class Events
{
...
问答关于心跳发送一个可以一个不行！
场景：我做的是一个聊天的，分商户和用户，目前用户可以正常发送心跳数据维持不掉线！但是商家那边却会自动掉线、然后经过测试发现两个只能有一个是正常发送的！
问答workerman 已经获得外部的wss数据 ，怎么推送给自己的客户端
workerman 使用AsyncTcpConnection已经获得外部的wss数据 ，现在怎么推送给自己的客户端呢
问答关于数据转发，异步连接问题
#### 问题描述
这里写问题描述
由于外接第三方的WS，他们最多只允许3个ws connect
因此萌生了一个想法：做一个数据转发，异步发一个connect给第三方，然后拿到数据，在转发给多个客户端现在出现一个问题：每次客户端连接，我的发现都会异步介入了一次第三方，有没有大佬帮我看下为啥实现不了我想要的效果。connection, $data) use ($worker) {
TcpConnection::$defaultMaxSendBufferSize = 1048576000;
// 发起异步连接
问答配置wss和消息推送
我这里开发一个微信共享雨伞的小程序，用到了长连接，用到了workerman,
问题一：现在微信端websocket直接用wss访问报错如下，failed: Error in connection establishment问题二：微信端共享雨伞的每个用户和服务器php通过websocket保持连接，现在可以实现案例中的客户端发送某个消息到服务器，服务器返回某个消息给前端，能不能做到，客户端传入某个用户id到服务器，当数据库某个字段（如雨伞关锁字段）发生变化时，直接推送消息到前端，如何实现啊？因为如果要监测到问题2的某个字段发生变化，必然php是和mysql进行轮训的查询啊（比如10s查询一次mysql），这样mysql性能会不会受影响哦？有没有好的办法哦？如php何mysql进行长连接
麻烦大神解答一下，谢谢您，好人一生平安。
问答创建tcp异步连接 发送send 是不是统一发送？
[](/upload/img/20211216/1661badaccf9e3.jpg)
我创建tcp后 里面循环发送某些指令， 想顺便send返回一些进度条的信息给前段， 但是我发现是统一返回的
问答GatewayWorker没有按照预期断开连接导致客户端重连问题
pingNotResponseLimit = 1
pingInterval = 60
60s内如果客户端没有发送任何数据，服务端则断开客户端连接
客户端已经做了重连策略，而且是每30s会发送一次心跳包到服务端，我看了一下Gateway的重连策略代码，大致的意思如下：
GatewayWorker进程启动的时候呢，如果有要求重连则设置一个定时器定期去检测客户端连接的心跳，如果在心跳检测时间内客户端有互动，则pingNotResponseCount=-1，否则pingNotResponseCount++，如果上次发送的心跳还没有回复次数大于限定值就断开
但是这样配置服务端还是会定时断开连接，不太明白，也就是说客户端一定要自己做重连策略了是吗？仅仅是定期发心跳包也是会断开连接？
问答TEXT协议传输一次性最大文本数据可以有多大？
比如base64传输文本内容，假如有10MB从客户端发送到服务端。那么服务端在接收这种数据的时候，是否会正常？
另外，TEXT最大支持多少MB的文本字符串发送呢？默认是多大？是不是可以根据设置缓冲区大小，可以无限大？（只要客户端能发送出来）
问答请教大神关于多进程处理业务功能
#### 问题描述
给GatewayWorker设置三个进程数，第一个进程处理WebSocket消息，第二个进程处理Http请求，第三个进程处理一些异步操作，请教一下这个功能呢？怎么实现让指定进程处理某个业务？默认是不是Workerman层自动选择进程处理呀
#### 为此你搜索到了哪些方案及不适用的原因
。
问答咨询一下大佬: gatewayworker 源码阅读 _innerTcpWorker 为什么每个进程使用独立的端口？
咨询一下大佬，我在阅读 gatewayworker 源码的时候 有个疑问，在与BusinessWorker 通讯的时候为啥每个进程独立的端口? 这样做的好处是什么？感谢大佬解答疑惑
```php
// 初始化 gateway 内部的监听，用于监听 worker 的连接已经连接上发来的数据
$this->_innerTcpWorker =
问答worker的数据库操作
先说下业务，在workerman中定时查询一个接口返回数据，然后比对，如果出现新的数据，就加入数据库，然后判断用户是否中奖，并推送消息给用户。问题有如下
1.在workerman中怎么实现连接数据库，并执行增删改查操作。有没有demo，在手册没看到
这样操作的话，对数据库会不会造成很大的压力
后续补充
赞助商
