搜索-workerman社区

问答我用webman做的项目，如果遇到高并发，会造成数据库数据错乱吗？

#### 问题描述我用webman做的项目，如果遇到高并发，会造成数据库数据错乱吗？#### 为此你搜索到了哪些方案及不适用的原因我的项目是一款问卷，每当用户提交问卷，数据库某个字段会在尾部追加json数据：如果B用户删除他的提交，A用户正在编辑【A的提交】这个json数据【此时也包含B的提交】，然后他们同时发起请求，那么数据库数据会错乱吗？疑问：B删除了他的提交，结果A编辑时传过去的数据也包含B，或出现B删除失败的情况吗？（本来B更新后删除成功，结果A携带B数据，更新后，又加上了）上述都是通过操作数组，然后转json存数据库的，每当用户提交问卷，就会在尾部array_push。然后编辑，删除就是操作这个大数组

问答请问各位大佬如何能打印出数据真实发出那一刻的时间戳

在gateway上，我定时调用 Gateway:sendToClient() 发送一个带有服务器时间前缀的随机字符串给某个客户端，通过客户端接收到的打印来看，存在某个时间段客户端没有任何打印数据,,过后又能一次性打印出前面几分钟服务器发来的数据。请问这是服务器下发有延时和粘包吗？如果有可能，服务端从哪里打印更直观看到发出去的那一刻时间呢？服务器向客户端发送数据的格式为：Y.m.d_H:i:s_xxxxxxxxx 下面是我服务端在调用 Gateway:sendToClient() 时记录的log: a、 !www.workerman.net/upload/20200806/065f2bd0a79178.png) 客户端在05:08分钟、05:12分钟没有打印，而在16分钟的时候的打印是 08、12、16分钟服务器发来的数据的拼接字符串

问答SendToUid 的数组是只包含uid，但是发送内容是一样的吗

向多个用户发送消息，消息内容不一样，sendToUid 的话要用循环发送吗，sendToUid 的数组是只包含uid，但是发送内容是一样的对吗？

问答请问gateway如何快速向数据库中插入大量的数据

我用gateway，在onMessage中用db类插入接收到的数据，模拟器在10s中发送了5万条数据。gateway接收数据后，花了大约20分钟才把数据完全存储到mysql中。

问答controller里面怎么打印数据

#### controller 在控制器里面怎么打印数据

问答关于GatewayWorker框架中，多个gateway，businessworker中，不同gateway客户端如何通信疑惑？

连接到gateway_1上, c3和c4连接到gateway_2上并且c1, c2, c3, c4为同一个分组，如下所示 [attach]2150[/attach] 问题1： c1给c4发送消息，在gatewayWorker内部是如何实现的？看了手册，自己理解为如下流程： c1----->gateway_1转发消息---------->businessWorker_1处理完业务-------------->gateway_2转发消息------------>c4 相当于在businessWorker_1处理完后，通过businessWorker_1和gateway_2已经建立好的TCP连接来转发数据，内部有什么机制吗？看了gatewayWorker框架源代码，还是不太明白，求教各位

问答thinkphp+gatewayworker开发硬件设备，返回值如何接收？walkor大神一定要看看！

官方提供thinkphp+gatewayworker独立部署模式我已经看过了，还查了很多资料。现在服务端主动向设备（自助洗车机）下达指令是没问题的，但是设备接收到指令后需要有一个返回码，服务端需要判断返回码才能进行后续业务。那么问题来了： **thinkphp是通过调用gatewayworker的API单向向设备发送消息的，设备接收到后就只会机械地回复给gatewayworker（而不是像websocket一样自定义逻辑通过get/post发送给thinkphp），所以thinkphp就无法处理gatewayworker接收到的返回码。

文档例子-集群推送

# 例子1 **``` (要求Workerman版本>=3.3.0) ```** 基于Worker的多进程(分布式集群)推送系统，集群群发、集群广播。$to_connection->send($message); }); // 订阅广播事件 $event_name = '广播'; // 收到广播事件后向当前进程内所有客户端连接发送广播数据'/vendor/autoload.php'; // 用来处理http请求，向任意客户端推送数据，需要传workerID和connectionID $http_worker = new Worker(->get(); } $connection->send('ok'); if(empty($_GET['content'])) return; // 是向某个worker进程中某个连接推送数据content={$content}```向所有客户端连接推送```$content```数据 url访问 ```http://192.168.1.4:4237/?

问答关于GatewayWorker的Events::onMessage消息接收问题

问题二：接收前端发送的消息可不可以不使用这个方法（Events::onMessage）？因为我的GatewayWorker和API文件是分服务器布署的；

问答参考文档中的异步任务代码，使用生产环境高频数据进行测试(关键字：Address not available)

如果是集群就是lvs的ip $task_connection = new AsyncTcpConnection('Text://127.0.0.1:22345'); // 任务及参数数据'args' => array('from'=>'xxx', 'to'=>'xxx', 'contents'=>'xxx'), // ); // 发送数据Workerman\Worker; // task worker，使用Text协议 $task_worker = new Worker('Text://0.0.0.0:22345'); // task进程数可以根据需要多开一些json数据 $data = json_decode($task_data, true); // 根据task_data处理相应的任务逻辑....\n"; $task_result = "ok"; // 发送结果 $connection->send($task_result); }; ``` **异常时执行status

文档序言

Gateway进程负责维持客户端连接，并转发客户端的数据给BusinessWorker进程处理，BusinessWorker进程负责处理实际的业务逻辑（默认调用Events.php处理业务），并将结果推送给对应的客户端GatewayWorker提供非常方便的API，可以全局广播数据、可以向某个群体广播数据、也可以向某个特定客户端推送数据。配合Workerman的定时器，也可以定时推送数据。因为绝大多数开发者的目标是基于Workerman开发TCP长连接应用，而长连接应用服务端有很多共同之处，例如它们有相同的进程模型以及单发、群发、广播等接口需求。所以才有了GatewayWorker框架，GatewayWorker是基于Workerman开发的一个TCP长连接框架，实现了单发、群送、广播等长连接必用的接口。GatewayWorker不支持UDP监听，所以UDP服务请选择Workerman。如果你是一个有多进程socket编程经验的人，喜欢定制自己的进程模型，可以选择Workerman。

问答关于redis队列，插入大量数据时报错。

#### 问题描述当我向队列里发送100W条数据时，队列可以正常运行，但是数据量增大到1000w时，就会报错 ``` Error package. package_length=70000155

问答webman-admin使用市场的云邮件报错

二进制打包以后，使用不了，云邮件提示 SMTP ERROR: Failed to connect to server: (0) 2023-10-21 14:36:37 SMTP connect() failed. https://github.com/PHPMailer/PHPMailer/wiki/Troubleshooting 本地可以正常发送

问答在GateWay中使用hproseRPC进行远程调用发出的请求被阻塞了,在GateWay停止后请求的数据才打印出来

在GateWay中使用hproseRPC进行远程调用发出的请求被阻塞了,在GateWay停止后请求的数据才打印出来, 请问这是整么回事呢？

问答workerman并发发送消息，阻塞

](//www.workerman.net/upload/20200603/035ed757348442.png) 我使用了5个shell来模拟，每个shell循环1000次，向workerman发送信息onmessage为空函数。只记录了一个message的消息日志，出现了如此大量的进程一直是busy状态，我想知道如何优化该问题？请求大神帮助。下图为onmessage方法内容 !

问答关于workerman作为TCP服务器时数据粘包问题

第1种：服务器有1台设备连接，这个连接每秒发送100条数据（即服务器1秒内接收了100条数据），这样100%会有粘包问题（这个问题我已经处理），但是如果服务器有100台设备连接，100台设备在1秒内同时发送1条数据（即服务器1秒内也是接收了100条数据），那这种情况会不会出现粘包的情况呢？

问答websocket向指定客户端发送大文件

#### 客户端每次只能接收744 KB (761,856 字节)后就自动断开了以下是在论坛看到的大文件发送例子 ```php <?Found\r\nContent-Length: 18\r\n\r\n404 File Not Found", true); return; } // ======发送// 从磁盘读取文件 $buffer = fread($connection->fileHandler, 8192); // 读不到数据说明文件读到末尾了return; } $connection->send($buffer, true); } }; // 发生连接发送缓冲区满事件时设置一个标记，暂停do_write发送 $connection->bufferFull = true; }; // 当发送缓冲区数据发送完毕时触发 $connection->