问答关于使用mqtt做异步消息分发问题
#### 问题描述
我单独开了一个进程，异步请求数据后，往mqtt里面publish数据，但是我发现一个问题，在new mqtt client的时候，如果写在onMessage里面，就会出现很多mqtt连接，如果写在onMessage外面，则会只publish一次，导致没有后续数据，我现在只能publish一次后，close掉，然后重新connect 然后重新close。
问答gatewayworker做IM系统的疑问
gatewayworker 做消息推送的时候，
app应用在后台运行 不能接受到信息 这个怎么解决
这种必须要实现 xmpp或者mqtt才行么
问答异步任务中，使用了Gateway发送不了信息给websocket 客户端
我在websocket服务里绑定了uid了，但是再AsyncTcpConnection异步任务中，使用了Gateway：：sendToClient中发送不了信息给websocket 客户端，当前是在异步任务监听器里处理任务，但是消息发来的时候，发送不了对应绑定的websocket客户端
#### 程序代码或配置
!/img/20240923/2366f11b0b7857.png)
#### 重现问题的步骤
这里写步骤
这个异步任务监听器处理任务的类，但是用了Gateway：：sendToClient ，无法发送给对应
问答关于rawBody()原始请求post包体的数据来源
#### 问题描述
一般获取php包体的数据来源可以使用file_get_contents('php://input'),
我看了webman的原始包体请求方式$request->rawBody(),文件位置在Protocols\Http\Request.php中,其中构造函数$buffer的数据哪来的,,也没看见实例化的地方,这个数据是什么时候注入的;
问答tdengine数据库有大佬弄了orm的没
tdengine数据库有大佬弄了orm的没
问答[已解决]webman+swoole，协程环境中HttpRequest已经做了协程上下文处理了吗
#### 问题描述
1.测试两个请求，第一个请求协程挂起5秒后输出所有请求参数；第二个请求直接输出所有请求参数。如果\Workerman\Protocols\Http\Request没存储上下文的话，第一个请求返回的应该已经被第二个请求污染了啊
2.如果\Workerman\Protocols\Http\Request做了协程上下文处理，那是否意味着在webman控制器中可以不用考虑自己处理请求上下文，可以直接用$request对象？1365a1ec9c007d.png)
#### 结论
通过代码得知，Request确实针对swoole、swow、Fiber的协程做了上下文处理
1.通过Webman\App::onMessage()方法可知，当请求进来时，会使用webman\Context设置上下文，发送完毕后会清理上下文
!
问答大佬们本地webman搞下来之后websocket控制台连接测试失败,http也起不来了 ，重新来更新了，已经解决了，结果在最后
#### 问题描述
大佬们本地webman搞下来之后websocket控制台连接测试失败， 尝试了各种姿势 结果就是一个字 fail
!>>>>>>>>>>>>>>
// // 处理代码业务
// // >>>>>>>>>>>>>>>>>>>>>>>
//
// // 发送数据$return_ret 推送的数据
// $connection->send(json_encode($return_ret));
// });
问答进入deamon模式后数据库报Error while sending QUERY packet
用debug模式运行时没有任务问题，但是只要进入deamon模式，
mysql就会报> mysql_select_db Error while sending INIT_DB packet.
问答设备发送字节码怎么正常打印
#### 问题描述
这里写问题具体描述
设备向tcp服务器发送的字节码如何怎么解析使用呢？这是我的问题还是设备那边的问题呢
!
问答onBufferFull被调用后,怎么停止send???
手册原文：
**每个连接都有一个单独的应用层发送缓冲区，缓冲区大小由TcpConnection::$maxSendBufferSize决定，默认值为1MB，可以手动设置更改大小，更改后会对所有连接生效。该回调在应用层发送缓冲区数据全部发送完毕后触发。一般与onBufferFull配合使用，例如在onBufferFull时停止向对端继续send数据，在onBufferDrain恢复写入数据。
问答请教定时器如何连接Gatway?
/Workerman/Autoloader.php';
$worker = new Worker();
// 开启多少个进程运行定时任务，注意多进程并发问题
$worker->count = 3;
$worker->onWorkerStart = function ($worker) {
}
```
定时器启动文件start_timer
启动后，无法使用Gatway::sendtogroup()等方法发送数据但是使用Github上提供的GatewayClient库 可以正常发送消息
初步判断是Timer未能连接Gateway导致
也尝试过添加
`$worker->registerAddress = '127.0.0.1:1238';`
但是依然是不能连接，使用
php start.php status 查看gateway的连接数没有任何变化
请教一下，这个问题怎么破？
问答[Websocket]如何向指定终端发送消息？
我启动了一个websocket服务（websocket协议），然后打开了浏览器，打开了两个浏览器标签页与其建立连接（通过js原生的Websocket对象），然而，实际上我发现connections只有一个，这导致我无法向指定的标签页发送信息。请问，如何向指定的客户端发送信息？
----------------------------分割线----------------------------
我是按照如下方式发现多个标签页用的是同一个connection的。**首先**，在join或login时打印workerId和$connection->id拼成的字符串（logEvent是我自定义的日志输出函数）
[attach]1866[/attach]
[attach
问答Workerman如何链接数据库服务
已经安装了mysql组件，对应的数据库服务端口也开了，要在Events类里面去链接的
问答zend_mm_heap corrupted
#### 问题描述
用的宝塔 supervisor 运行的项目 二进制打包的
/程序目录/webman.bin restart
然后错误日志 有很多zend_mm_heap corrupted
问答如何二次请求，关闭第一个计数器
use think\worker\Application;
// $app = new Application;
// $app->initialize();// 内部通道发起倒计时Timer::del($_SESSION[$sessionid]);
}
};
$http_worker->listen();
}
只开了一个进程根据时间time如果为0就删除上一个计数器。但是删除不了。执行后感觉是个死循环，最后就502了。
哪位大神能帮助一下。困扰新手几天了
问答$worker->onMessage 对 http 协议没有作用吗？
Worker 代码：
```php
$worker = new Worker('http://192.168.50.168:8800');
// 这里进程数必须设置为1
$worker->count= 1;
// worker进程启动后建立一个内部通讯端口
$worker->onWorkerStart = function($worker)
{
// 开启一个内部端口，方便内部系统推送数据，里面有uid，表示向那个uid的页面推送数据
$data = json_decode($buffer, true);
$uid = $data;
print_r($data);
// 通过workerman，向uid的页面推送数据
$ret = sendMessageByUid($uid, $buffer);
/connection->uid = $data;
/* 保存uid到connection的映射，这样可以方便的通过uid查找connection，
* 实现针对特定uid推送数据
问答webman安装数据库后无法启动
composer require illuminate/database
执行上面安装数据库后无法启动
!
问答gatewayworker中php.ini文件内容解读
打开php.ini文件，发现只有以下内容：
extension="mongo.so"
extension="memcache.so"
extension="memcached.so"
extension="redis.so"
apc.enabled=1
apc.enable_cli=1
查看gatewayworker的文档，发现检查禁用函数检查有以下内容：
!
问答自定义进程无法启动 class processCheckDevActiveTask not exists
**一、版本**
Webman 1.2.4
Webman-framework v1.2.4
**二、问题描述**
我再process路径创建了一个CheckDevActiveTask，内容如下：
`}
public function onWorkerStart()
{
var_dump("onWorkerStart");
// 每隔10秒检查一次数据库是否有新用户注册
分享提一点希望，在B站，腾讯课堂，网易课堂多发视频教程，促进webman发展，
提一点希望，在B站，腾讯课堂，网易课堂多发视频教程，促进webman发展，视频讲座，比文档更加易懂，能够让更多普通人学习webman，进而促进促进webman发展。我们看到许多国产如thinkphp、织梦等产品，都是这样发展壮大的。
赞助商
