搜索-workerman社区

问答关于使用mqtt做异步消息分发问题

#### 问题描述我单独开了一个进程，异步请求数据后，往mqtt里面publish数据，但是我发现一个问题，在new mqtt client的时候，如果写在onMessage里面，就会出现很多mqtt连接，如果写在onMessage外面，则会只publish一次，导致没有后续数据，我现在只能publish一次后，close掉，然后重新connect 然后重新close。

问答链接云服务器数据库显示错误信息

只更改了数据库配置中的host 127.0.0.1，改成了服务器地址 // 默认数据库 'default' => 'mysql', // 各种数据库配置 'connections' => [[](/upload/img/20220630/3062bd593be22e.jpg) 请问下，是什么原因，这个远程数据库在其他地方可以链接使用，没问题，webman链接报这样的错

问答服务端如何实现实时传输数据给客户端？

想客户连接进来之后，就一直推送消息给客户端。 onMessage 只能实现有消息时

问答请教webman控制器方法如何不主动关闭http连接

#### 问题描述请教webman如何在控制器的方法return之后不主动关闭http连接？ ``` <?hello(Request $request) { return response('hello webman'); // 比如我有一个异步的方法，在return之前不会立即返回数据

问答模型添加数据为什么值添加不进去？

[截图](//www.workerman.net/upload/20210326/26605dec41014f.png) 为什么值没有添加进去？？ !

start_gateway.php我现在是使用file_get_content去GET查询数据库。 ```php <?new Gateway("websocket://0.0.0.0:2000"); // gateway名称，status方便查看 $gateway->name = 'Device'; // gateway进程数* * 数据库示例，假设有个your_db_name库，里面有个user表 */ class Events { /** * 新建一个类的静态成员，用来保存数据库实例 */public static $db = null; /** * 进程启动后初始化数据库连接 */ public static function onWorkerStart，根据发来的命令打印2个用户信息 * @param int $client_id 发消息的client_id * @param mixed $message 消息 * @return

问答workerman作为客户端进行压测时

在客户端进行1w次的链接及发送ping，然后使用php start.php status查看状态，显示了10000是否代表可以承受住1w的并发呢 !

问答调用远程GatewayWorker API报错

当前项目是在我本地Windows开发调试的 GatewayWorker 是运行在阿里服务器上的（不处理任何逻辑）本地怎么调用远程GatewayWorker的api接口当前我是这么做的但是会报错20220915/156322f42ad211.png) 具体报错是本地Geteway类里的 sendBufferToGateway() 方法里的 stream_socket_sendto()这个函数

问答关于2.0版本，在其他项目中推送消息问题

php use \Workerman\Worker; use \GatewayWorker\Gateway; use \Workerman\Lib\Timer; use \Workerman\Autoloader/Workerman/Autoloader.php'; Autoloader::setRootPath(__DIR__); // gateway 进程 $gateway = new Gateway("Text://0.0.0.0:2529"); // 名称，以便status时查看方便 $gateway->name = 'Send_HnAnimal_ToPhp_Gateway'; // 进程数，建议与cpu核数相同 $gateway->count = 2; // 分布式部署时需要设置成内网ip $gateway->lanIp = '127.0.0.1'; // 内部通讯起始端口，假如$gateway/GatewayWorker/Lib/Gateway.php on line 603` 然后，我增加 // 服务注册地址 $gateway->registerAddress = '127.0.0.1:

问答webman 如何吧URL 生成二维码

#### 问题描述这里写问题描述 webman 如何吧URL 生成二维码

问答onBufferFull被调用后,怎么停止send???

手册原文： **每个连接都有一个单独的应用层发送缓冲区，缓冲区大小由TcpConnection::$maxSendBufferSize决定，默认值为1MB，可以手动设置更改大小，更改后会对所有连接生效。该回调在应用层发送缓冲区数据全部发送完毕后触发。一般与onBufferFull配合使用，例如在onBufferFull时停止向对端继续send数据，在onBufferDrain恢复写入数据。

问答webman push插件怎么在onMessage写一些东西

webman push插件怎么在onMessage写一些东西根据客户端发送过来的信息进行推送

问答我想把短信发送类里面的curl换成workerman/http-client,请问会有什么问题吗？

#### 问题描述我想把短信发送类里面的curl换成workerman/http-client,请问会有什么问题吗？会不会有一些奇怪的问题？在其他文件里调用这个类中的函数，又是如何返回的呢？

问答think-orm数据库mysql gone away问题

think-orm数据库mysql gone away 打开断线重连有用吗或者有什么解决办法

文档joinGroup

Gateway::joinGroup(string $client_id, mixed $group); ``` 将client_id加入某个组，以便通过```Gateway::sendToGroup```发送数据可以通过```Gateway::getClientSessionsByGroup($group)```获得该组所有在线成员数据。可以通过```Gateway::getClientCountByGroup($group)```获得该组所有在线连接数（人数）。该方法对于分组发送数据例如房间广播非常有用。**注意：** 1、同一个`client_id`**可以**加入多个分组，以便接收不同组发来的数据。5、目前没有获得所有分组id接口，所有分组可以自行存入数据库或者其它存储中。 6、分组数量无上限。

问答长连接转发会阻塞吗？对后端的请求做一个并发控制，会阻塞吗，会断开吗？

#### 问题描述长连接转发会阻塞吗？我想对后端的请求做一个并发控制，超出的来自前端连接暂时不处理，会阻塞吗，会断开吗？我也有比较丰富的workerman开发经验，做个聊天服务端、物联网服务端、内网穿透、端口转发等等。但是上面这个问题，还是比较纠结。我想做的是这样的，后端运行的是图片转换的http服务，但是很吃硬件，超出内存会出错，所以要限制并发，而且一次请求响应的时间很长。所以来自前端的连接，我打算通过workerman做个代理。这里要注意的是： - 要控制对后端的并发 - 不要直接断开前端请求（连接onConnect之后先不要处理，等后端空闲了在转发到后端） - 后端的响应时间可能很长所以我的问题是： - 等待后端空闲时收到的连接会断开吗（因为这中间不会传输心跳以维持链接，这是个Http的请求） - 后端的响应时间是比较长的，会发生阻塞吗？

问答laravel orm调用save方法，无数据问题

#### 问题描述这里写描述该方法未操作事务，$param里面也是有值的，在新增的时候，调用save方法，状态返回的是true，但是数据没有新增/修改到数据库，返回成功使用这种方法DB::enableQueryLog打印出来是个[],是我哪里操作有问题吗 #### 程序代码或配置 ``` class UserPupilService extends BaseService { /** * 构造函数function __construct() { $this->model = G(UserPupilModel::class); } /** * 新增数据= $this->model->save($params); }else{ $arr = $info->toarray(); // 数据查重; // 加入修改时间 $array_diff_assoc['update_time'] = date('Y-m-d H:i:s'); // 修改数据信息