搜索-workerman社区

问答webman的控制器中如何调用通过自定义进程中变量和函数

自定义进程 ```php class Pusher { public function onWorkerStart() { //$GLOBALS['con']; global$con->send($data); }; $con->connect(); } } ``` APP/CONTROLLER 如何调用上面的 $con->send()函数

问答一个Gateway下挂载多个Worker项目，怎么配置？

想法是，在Application目录下创建多个项目，其中一个项目（A）用于开启Gateway进程，保存客户端连接数据。用户都连接到（A）这个项目上，发消息的时候用协议号，通过（A）向其他的项目发送数据，其他项目返回数据给（A），（A）再返回给用户。请教如何配置（A）与其他项目的配置文件？（A）只想部署Gateway进程，其他项目只想部署Worker进程所有项目都是基于Gateway/Worker的框架。

文档关于client_id

* client_id不能自定义，由GatewayWorker自动生成。 * 如果client_id对应的客户端连接断开了，那么这个client_id也就失效了。* 除非gateway进程退出重启，否则client_id一旦被使用过，将不会被再次使用。也就是说client_id在整个gateway进程生命周期内是不会重复的，即使分布式部署也不会重复。* 业务不应该存储client_id到数据库或redis存储上，因为它是临时id，重启GatewayWorker后client_id会重新计数，导致业务问题。group_id) 等接口将client_id绑定到uid或者gid上，通过Gateway::sendToUid($uid, $data) 或 Gateway::sendToGroup($gid, $data)来发送数据

问答【已解决】webman中使用swoole，控制器中Request类已经做了协程上下文处理吗

#### 问题描述 **我找到了答案，在协程中使用全局变量确实是会互相干扰，只是我下面的代码是开多个进程处理的，恰好两次请求是两个进程，所以是两份全局变量。改成只开1个进程，就会发现协程污染的问题了** - 目前在已有的webman项目中想使用swoole的协程，所以Event-loop切换成了swoole。在控制器中的协程环境中，使用全局静态变量，按理说两次请求（两个协程）操作全局变量应该会污染的啊，但是实际上并没有发现污染，是webman已经做了上下文处理了么？ - 如下图 ![截图](/upload/img/20240112/1265a130569340.png) ``` 按照代码逻辑来看，第一次请求参数a=1时，当前请求的协程A会先修改全局变量为aaa，然后协程挂起5秒; 第二次请求参数a=2时，当前请求的协程B会直接修改全局变量为bbb,然后返回给客户端 ``` - 问题： ``` 如果在五秒内依次请求上述两个请求，请求1在5秒协程恢复后，应该已经被请求2污染了啊

问答关于自定义进程的问题

# 问题描述 #### 应用场景：学校，同步钉钉数据我有个需求，系统每天定时同步钉钉数据，管理人员也可以手动同步钉钉数据。每个学校同步数据根据学校规模耗时大概1-5分钟不等，现有近150所学校需要进行数据同步，如果不做异步任务处理，进程阻塞，整个业务肯定会受影响，因此，我想是否可以将接收到的这些任务，交给新开的进程去做（不影响业务自身的进程数，即新开的进程是在cpu_count() * 2这个数量以外的），后端接收到任务后，直接返回任务提交成功的数据。#### 为此你搜索到了哪些方案及不适用的原因我大致看了下自定义进程的内容，不是太明白。请老大指点，具体做哪几步？

问答【已解决】webman的HTTP进程启动后，建立websocket连接会卡很久

## 问题描述 webman的HTTP进程，设置为`8`个进程提供服务；在 http进程启动后，执行 `onWorkerStart` 方法时，建立与gatewayWorker 的 `ws`连接。故障现象是：有1-2个进程的链接立刻建立成功 `onMessage` 收到信息；而余下的 **N个进程**，要**卡顿很久才**能收到来自 ws 的 `onMessage` 消息。php namespace app\process; use GatewayWorker\Lib\Gateway; use support\Log; use Throwable; use Webmanworker = $worker; \Workerman\Protocols\Http::requestClass(static::$requestClass); // 连接 GatewayWorker/ 忽略pong if ('pong' === $data) { return; } // 解析数据

问答定制udp协议会无效的问题

我需要定制一个运行于udp上的协议，尝试按照手册进行开发，发现udp端口完全收不到任何信息。首先，定制一个协议文件，比如ABC。'ABC://0.0.0.0:1234'); // 注意直接udp协议是有效的，使用自定义协议无效 $worker->transport = 'udp'; // 使用UDP网络通讯协议 // 系统定制的协议也一样无效

问答workerman如何保存一个连接用来下次主动发送消息给客户端？

比如服务端连接回调 onConnect ，连接成功后把回调参数存起来，方便下次需要发送消息给客户端时直接调用

分享整理分享Workerman中利用popen实现多进程web ssh

### 起源群友询问如何进程异步执行命令行任务，且有通知机制，想用来做web ssh，兔子大佬指导可以通过 `popen` 来实现： !== false) { unset($this->processes[$key]); // 从活动进程池移除 } } // 获取池中的所有进程数量($processPool->processCount() >= $processPool->maxProcesses) { return $connection->send('使用进程数已达最大数\Workerman\Worker::$globalEvent->offReadable($process); } else { // 将输出发送给客户端PHP_EOL; } ``` `php start.php start` 启动项目，前端使用【WebSocket 测试工具】进行连接，发送消息执行命令：`/usr/bin/php8.2 command.php

问答webman + RabbitMQ 消费数据问题

wenbman消费数据，刚开始启动程序， RabbitMQ队列显示消费速率，大约一分钟后，webman显示一直在消费，但是RabbitMQ队列数据量没有减少，不显示得消费者客户端 !

问答json中怎么加入自己的数据

json中怎么加入自己的数据， ws.send('{"type":"say","to_client_id":"'+to_client_id+'","to_client_name":"","contentto_client_id":"'+to_client_id+'","to_client_name":"","content":"'+input.value+'",“number”:"100"}');后，从服务端接受发来的消息

问答接收的问题

，返回0 if($buffer === "\n") { return 0; } // 说明还有请求数据没收到，但是由于不知道还有多少数据没收到，所以只能返回1，因为有可能下一个字符就是\n return 1; } /** * 处理业务，当客户端数据接收完毕后触发（这里只是将客户端发来的字符串直接会写到客户端suoyoushuju; $fanhui=array(); array_push($suoyoushuju,$bufferss); echo '初始化所有数据> ``` 比方说每次客户端发送字符串给服务端 1234&few 服务端接收后放到$suoyoushuju 然后来遍历$suoyoushuju 是否包含1234 如果有就添加到$fanhui 这个再发回客户端明显没按照我的逻辑么第一次还会运行初始化第二次发送就没有了。。。

问答请教使用socket做为客户端和北向接口对接，请教如何打包数据发送。

5.3.1　消息格式消息数据由消息头和消息体组成。消息头由9个字节（byte）表示，消息体长度不固定，各类消息不同。消息头的9个字节不能当做字符处理，需要按整型数处理。 !

问答webman+gateway设备数据返回丢失

#### 问题描述与硬件设备通信，设备登录成功定时批量发送指令，业务逻辑都是推送到队列处理，按理不存在处理延时问题，但是总有个别指令发送过去没有收到响应，不知如何定位问题，使用的都是最新版安装包

问答gateway 除了sendtoall 能够推送消息，其他的都不行

```php use \GatewayWorker\Lib\Store; use \GatewayWorker\Lib\Gateway; class Event { /_ 连接服务 _/function onMessage($client_id, $message) { $b = Gateway::sendToCurrentClient('123456'); // 无法推送信息$b = Gateway::sendToClient($client_id,'123456'); // 无法推送信息 $c = Gateway::sendToAll('456'); // 可以推送信息 return ; } ``` 是不是有什么地方，需要设置一下

问答windows下 gateway+tp5 如何使用gateway进行消息上传和下发

windows下 gateway+tp5 如何使用gateway进行消息上传和下发官方提供的方式是在和MVC框架结合时使用ajax进行消息上传使用gatewayclent进行消息下发但是这样总是感觉不够清爽可不可以直接使用gateway上传通过onmessage对上传的消息进行转发转发的消息通过tp框架进行判断处理处理后的消息再通过gatewayclent下发 onmessage目前可以实现消息转发但是调用的函数不能使用tp库的类无法继承think/controller 应该如何处理我看好多人都遇到了同样问题官方有没有解决办法或者哪位路过的大神指导一下谢谢