问答如何控制指定哪个进程来接收客户端连接？
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去读取最新数据
问题是如何指定一个进程来处理客户端请求？
问答设备第一次登录生成的clientid和第二次的clientid不一致
#### 问题描述
设备登录后绑定对应的设备和clientid，称此时的clientid为id1，设备30分钟会发送一次登录指令，当设备再次发送登录指令时，有时候会出现clientid不一样的情况，称此时的clientid为id2，,那么此时就出现了一台设备，两个clientid的情况，此时设备的心跳指令会在id2的通道进行收发，那么超时之后，id1就会触发onclose。触发onclose时，会更新数据库里面设备的状态，这样就会出现设备在线，但数据库里面的设备离线的情况，所以我需要在onclose里面需要判断设备是否绑定有多个clientid,如果有多个则不去更新数据库设备的状态可以调用Gateway::getClientIdByUid这个函数吗？
问答GatewayWorker 在多进程下怎么创建唯一的全局定时器？
#### 如何设置全局唯一的定时器
由于`GatewayWorker/Applications/YourApp/start_businessworker.php`里设置的进程数量是4
```php
$"\n";
# 进行同步或者异步的数据库写入操作
});
}
```
重启服务后，会连续打印4条数据。说明定时器执行了4次。onWorkerStart 分钟定时器
[10-06 18:27:15] onWorkerStart 分钟定时器
[10-06 18:27:15] onWorkerStart 分钟定时器
```
要在定时器内执行异步的数据库写入操作，如何让多进程下，只有一个全局定时器呢？## 数据库连接的次数
在`Event::onWorkerStart`里设置了mysql和Redis数据库的初始化配置。
如果有4个`businessworker`进程，这里就会初始化4次。
问答GatewayWorker 怎么把onmessage客户端推送的信息，转发到一开始的http请求里去
GatewayWorker 怎么实现
1：用户通过http方式请求 我的一个web接口，
2：然后web接口调用 Gateway::sendToClient，对某个客户端推送一条指令
3：再然后客户端返回该指令是否执行成功我想把客户端发送的结果返回到最初http请求的接口里，展现在前端。这种有什么好的方法实现
文档开发前必读
TCP传输层协议一个重要特点是TCP是基于数据流的，客户端的请求会源源不断的发送给服务端，服务端收到的数据可能不是一个完整的请求，也有可能是多个请求连在一起。### 3、短连接
短连接是指通讯双方有数据交互时，就建立一个连接，数据发送完成后，则断开此连接，即每次连接只完成一项业务的发送。像WEB网站的HTTP服务一般都用短连接。*短连接应用程序开发可以参考基本开发流程一章*
### 4、长连接
长连接，指在一个连接上可以连续发送多个数据包。
注意：长连接应用必须加[心跳](..所以长连接在每个操作完后都不断开，下次处理时直接发送数据包就OK了，不用建立TCP连接。*当需要主动向客户端推送数据时，例如聊天类、即时游戏类、手机推送等应用需要长连接。
问答指定协议发送时，打包两次
求大神帮我解答一个问题，代码如下：
```php
case 'web_control':
//获取要控制的车的client_id
$car_client_id = self::$dbGateway::sendToClient($client_id, json_encode($control_fail));
}
break;
```
通过http协议发过来数据，通过指定协议转发时，正常的数据协议格式应该是如下这样的
"þ12345678900987654321{"opType":"1","opVal":"1"}»»"
但是真实的是这样的
"þ?
分享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\":\"自己的数据\"}]', '
问答gatewayworker如getClientIdByUid对同一个用户时常出现一会获取到client_id,一会又获取不到
gatewayworker如getClientIdByUid对同一个用户时常出现一会获取到client_id,一会又获取不到，过一会之后又能获取到，期间浏览器一直在每隔20秒发送数据ping数据，不太可能在存在掉线的问题
问答同一服务器多个应用发送消息
个workerman， A：web端 127.0.0.1:1240，B: 移动端 127.0.0.1:1238
现在有一个场景，例如同一个人登录了Web何移动端，我在管理后台需要同时对这个用户发送消息**我的问题是：**
我在管理后台通过GatewayClient 设置注册地址 Gateway::$registerAddress 设置到A 127.0.0.1:1240
发现用户在线，给用户成功发送了消息，当我通过吧地址Gateway::$registerAddress 设置到B 127.0.0.1:1238
发现获取不到在B服的用户了，经我打印发现获取的还是Ａ服的在线数据。如果单独连接其中一个都可以获取
正常的用户数据。
下面是我的调试编码：
[attach]2372[/attach]
问答GatewayWorker 异步非阻塞
论坛搜索了一番，了解到
gateway收到请求后是通过socket长连接异步非阻塞发送给worker的
问题1：常规而言，一个gateway进程，通常能维持多少连接呢？问题2：这种异步非阻塞 跟 nginx 的那种异步非阻塞 是不是相同的机制，gateway收到请求后，转发给worker进程，不会一直阻塞等待worker进程返回结果，转而马上处理下一个请求，worker进程处理完毕后，会主动通知gateway进程，然后gateway进程 再把结果返回给客户端
问题3：gateway 与 worker 进程，每个进程里面，都是单线程的吗？总体而言，感觉跟 nginx & php-fpm 有点点类似，nginx 通过事件驱动机制，与 后端的 php-fpm 进行异步非阻塞通信，如果 php-fpm 处理一个请求，稍慢，就会阻塞下一个请求处理以上，这样理解，不知道对不对，还劳烦老大指点一二，感激不尽
问答workerman 修改不了多进程数？
[截图](//www.workerman.net/upload/20200912/125f5c4421e408.png)
我改了
$gateway->count = 1;
为什么依然还是4个进程处理数据[截图](//www.workerman.net/upload/20200912/125f5c449742e1.png)
workstart里触发 testjinchengshu()
问答求解数据粘包问题，使用text协议
系统内核已参照手册优化，php7 已安装event扩展
硬件发送的数据格式
send 1000,86358603733073,0003,AA00000000,0003,00,0818031611,,,con->send($data);
});
$con->connect();
echo $count, "connections complete\n";
}
```
协议部分复制了}
// 获得换行字符"\n"位置
$pos = strpos($buffer, "\r\n");
// 没有换行符，无法得知包长，返回0继续等待数据$message);
}
```
运行几秒后会出现两个不同连接的数据粘一起了
```log
string(88) "ac102fe80b5500000048-send 1000,86358603733073,0003ac102fe80b5500000049-send 4000,86358603733073,0003,AA00000000,0003,00,0818031611,,,,0000"
```
如果客户端发送的数据改为
问答thinkphp中woker_server.php(服务端)接到请求后将每个请求的客户端发送给woker_client可以实现吗
项目的规划是,我们在服务器上起服务端,甲方请求我们的服务端并建立起长连接(加心跳) 这个服务端的子进程数为4
这个是甲方请求乙方的过程 我们需要维持并处理数据
而现在需要我们可以通过广播的方式向所有客户端发送数据那这样不就是 我们服务器上起了一个客户端 子进程数为1(因为使用广播必须子进程数为1) 和 一个服务端 子进程数为4
这个是进程数上起的冲突,表示代码没有办法合并到一个文件中
那么两个文件的话 服务器上的客户端也得知道发送给谁吧
问答webman 控制器返回远程服务器的文件流
#### 问题描述
webman 控制器返回远程服务器的文件流,参考了帖子
https://www.workerman.net/q/13212
#### 程序代码或配置
```
public functionuse ($connection) {
$connection->send(new \Workerman\Protocols\Http\Chunk('')); // 发送空的的>"attachment;filename=\"$downloadName\""
]);
}
```
请求后下载的是一个空文件，
progress 回调内也是可以读取到文件的二进制内容的
问答workerman 已经获得外部的wss数据 ，怎么推送给自己的客户端
workerman 使用AsyncTcpConnection已经获得外部的wss数据 ，现在怎么推送给自己的客户端呢
问答使用gatewayworker 和redis消息订阅造成的多进程阻塞
在gatewayworker中，使用redis做消息订阅，由于数据量大，现在在两台服务器上做的分布式部署，每台服务器businessworker都是开的十个进程，但是进程还是会很快都阻塞，请问各位大牛们怎么解决呢
问答关于数据转发，异步连接问题
#### 问题描述
这里写问题描述
由于外接第三方的WS，他们最多只允许3个ws connect
因此萌生了一个想法：做一个数据转发，异步发一个connect给第三方，然后拿到数据，在转发给多个客户端现在出现一个问题：每次客户端连接，我的发现都会异步介入了一次第三方，有没有大佬帮我看下为啥实现不了我想要的效果。connection, $data) use ($worker) {
TcpConnection::$defaultMaxSendBufferSize = 1048576000;
// 发起异步连接
问答workman可以和单片机设备进行通讯和数据传输吗？
workman可以和单片机设备进行通讯和数据传输吗？
问答为什么我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)
{
问答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));
};
```
赞助商
