文档onMessage
/worker/on-message.md)回调相同，区别是只针对当前连接有效，也就是可以针对某个连接的设置onMessage回调。'/vendor/autoload.php';
$worker = new Worker('websocket://0.0.0.0:8484');
// 当有客户端连接事件时
$worker->onConnect= function(TcpConnection $connection)
{
// 设置连接的onMessage回调
$connection->onMessage = function$connection->send('receive success');
};
};
// 运行worker
Worker::runAll();
```
上面代码与下面的效果是一样的'/vendor/autoload.php';
$worker = new Worker('websocket://0.0.0.0:8484');
// 直接设置所有连接的onMessage回调
$worker
问答【已解决】遇到个非常怪的问题，数据丢失
#### 问题描述
这边有个支付的项目，从日志看拉起支付了，生成了订单，订单信息也在，但是在异步回调的时候，去校验订单在不在，这时候查不到了，然后我从库查也没有，而且id一列是自增的，发现会出现如：1002有没有大佬帮分析一下
感谢老大指点，确实是事务上有问题
分享开源利器：Madong-Admin——让企业级SaaS开发变得简单高效
内置了基于RBAC（基于角色的访问控制）和ABAC（基于属性的访问控制）的混合权限系统，内置适配Casbin插件轻松拓展自己的权限，支持：
- 可视化权限配置界面
- 细粒度资源控制
- 实时权限变更生效控制层 (Controller)
控制层负责处理来自客户端的请求，接收输入并返回响应。它的主要职责包括：
- 接收和解析 HTTP 请求。
- 调用服务层的相应方法进行业务处理。- 返回处理结果给客户端，通常是 JSON 格式的数据。
- 处理请求的路由和参数。
### 2.服务层 (Service)
服务层负责实现具体的业务逻辑，通常包括：
- 处理复杂的业务规则和流程。
- 调用 DAO 层进行数据访问。
- 进行事务管理，确保数据一致性。- 返回验证错误信息，阻止无效数据进入业务逻辑层。
### 4. DAO层 (Data Access Object)
DAO层负责与数据库进行交互，提供数据访问方法。
问答关于断开客户端连接后，Events::onClose 中调用 Gateway::getUidByClientId 返回空值null问题
**问题重现：**
模拟一客户端成功与服务器建立连接
事先在 Events::onConnect 中调用 Gateway::bindUid
Events::onClose 中调用 Gateway::getUidByClientId模拟断开客户端连接，结果 Gateway::getUidByClientId 返回空值null
[attach]1194[/attach]
**问题调试：**
如图 return 断点调试，发现能如期获取到映射的uid, 个人理解原因是：
$this->sendToWorker 异步通知 Events，BusinessWorker异步收到转发来的数据，
导致 Events::onClose 业务逻辑可能尚未执行，而断点后的清理代码已经先行执行完毕了，
不知道理解是否正确？**期望结果：**
期望业务逻辑执行完成后，再行断点后的后续清理工作。
问答webman什么时候加入或者支持php原生的$curl呢？
移植项目过程中使用curl()报错，
> Access to undeclared static property，$_http_code
原生不支持，那什么时候集成服务端对外访问的功能呢？
问答如何在一个tcp的服务中，返回给客户端http json
. ':8181',
tcp的服务，现在想在：
$worker->onMessage = function (TcpConnection $connection, $buffer) {
$connection->send(xxxxx); //这里想返回给客户端http json格式的数据 要怎么写？
问答用户在房间正常聊天，但是getClientIdListByGroup获取不到这个用户
使用Gateway::isOnline判断一个用户是在线的
但是Gateway::getClientIdListByGroup获取不到
但是发消息还是可以收到的
这是咋回事呢？
问答socket可写事件怎么触发
$this->checkBufferWillFull();
}
```
walkor大佬, 这里的添加了可写事件，怎么触发这个可写事件呢，
问答webman使用channel做进程间的通信，如何保障连接的publish，自己订阅不消费
1661484194207,"returnMessage":"success","type":1,"status":"0"}';
if ($data == 'rub') {
//心跳不回复} else {
Client::connect('127.0.0.1', 2206);
// 要订阅的事件名称（名称可以为任意的数字和字符串组合）
$event_name = 'event_luckysheet';
// 发布某个自定义事件，订阅这个事件的客户端会收到事件数据，并触发客户端对应的事件回调Client::publish($event_name, $data);
// 订阅某个自定义事件并注册回调，收到事件后会自动触发此回调->id]);
echo "onClose\n";
}
}
```
基于luckysheet做一个webman的后台，但是Channel进行进程间的通信，自己接受的data，返回
问答GW的心跳包有点不理解
1，GW向客户端发送心跳包后，客户端需要回应给GW吗？还是只需要客户端自行处理即可？
2，客户端向GW发送心跳包，是不是可以理解为只是个onMessage的事件处理？收到心跳包后再回应给客户端？看了官方的文档，不知道是不是我理解能力的问题，不知道怎么下手，求大大解惑，谢谢！
问答想做这样子的一个事件处理
用户A给用户B送一朵花，B的界面上要知道A给送了朵小花，因为类似的相同事件非常多。
目前的思路是这样子的，A给B送花的时候，A调用接口，接口把事件写入redis。A和B都连接到了workerman，当用户连接上来的时候，会一直死循环查询redis关于自己uid的事件。如果查询到有关于到自己的事件，则发送给用户信息
问答webman使用gateway，客户端发送数据服务端收不到
#### 问题描述
客户端连接时可以正常发送数据，服务端可以正常收到。一段时间后，客户端还显示在连接，但是发送数据收不到，或者过了几分钟才能收到服务端的返回数据
#### 程序代码
这里是gateway的config信息
!upload/img/20230619/1964901056cc13.png)
#### 截图报错信息里报错文件相关代码
这个是网络调试助手连接的gateway，截图上能看出上面发送的过了好一会才返回，下面客户端发送的数据没有收到服务端返回
!
问答webman 多层路由分组嵌套 设置别名后生成的url不完整
## webman 多层路由分组嵌套 设置别名后生成的url不完整
!
问答workman 可以连接成功，但不会产生$client_id，导致信息不会发送，是怎末回事呢？改怎末解决呢?
```php
public static function onConnect($client_id)
{
// 向当前client_id发送数据
//Gateway::sendToClient($client_id, "Hello $client_id\r\n");
// 向所有人发送
//Gateway::sendToAll("$client_id login\r\n");
/**
* 设备首次连接时
*/
//绑定fd
$port = $_SERVER;
self::get_or_post_request(self::request_url().'/bind_worker_fd','POST',array('fd' => $client_id,'port' => $port));
}
```
问答【已解决】使用官方demo，生产环境中channel server不能接收、推送事件消息
[](/upload/img/20220106/0661d6c2f8cf4d.png)
服务器环境
阿里云ECS centos
php 5.6.33
workerman 4.0.26
阿里云安全组里面已经添加了允许2206端口访问
重新安装composer package，还是卡在启动画面不动。
问答可以通过设置系统内的tcp keepalive来缩短极端情况的断线吗?
当服务端不要求客户端必须回应心跳检测时，假如客户端遇到掉电等极端情况，这时服务端向客户端发送的心跳数据在TCP层面就会发送超时，遇到这种超时情况TCP会重试多次（**次数及间隔依赖操作系统的配置**），这种极端情况从连接断开到服务端检测到可能要持续至少10分钟才触发onClose事件回调。
可以通过以下的设置来缩短超时情况下的断线吗？net.ipv4.tcp_keepalive_probes = 5
net.ipv4.tcp_keepalive_intvl = 30
$ sysctl -p
```
以上设置以后似乎没有效果
问答Workerman 执行队列任务，不执行
foreach (Yii::$app->service->workermanQueue->jobConfig() as $config) {
// 订阅队列名，回调方案使用配置的handler execute 来处理数据
// 这里的 回调，如果返回 true, 运行后会从 queue 中删除，否则 不删除
$clientfalse;
}
});
}
};
```
```php
/**
* 任务配置try {
$task = $this->task;
if (isset($task['type'])) {
// 根据 任务里面的>task = json_encode($task, JSON_UNESCAPED_UNICODE);
$log->save(false);
// 偶现 下面的不执行了
问答消费队列的时候，控制器返回的数据对象如何取值？
#### 问题描述
我的逻辑是：python采集数据，扔进redis队列，然后消费者扔给控制器，返回数据库数据，再扔给其它队列去消费，现在是返回的数据一直错误，json_decode 出来的是空的，打印出来的是对象，但是不是一般的对象。["_body":protected] ，这里我看 Response 里面有这个方法，但好像不是针对这个对象的？我尝试了，没效果。但我在控制器，同样的model返回的，都直接可以用数组返问到？：
// 通过事务确保数据一致性
```php
$last_id = Game::GetId($insertData);
if ($last_id) {query = self::where(['id'=>$id])->find();
return $query;
}
````
#### 为此你搜索到了哪些方案及不适用的原因
问答一直连接不上TCP服务器，服务器防火墙已经关了
大家好，现在一直连接不上TCP服务器
代码如下：
```php
// 新增8283端口，开启tcp协议
$gateway_tcp = new Gateway("tcp://0.0.0.0:8283")gateway_tcp->count = 4;
// 本机ip（分布式部署时需要设置成内网ip）
$gateway_tcp->lanIp = '127.0.0.1';
// gateway内部通讯起始端口，起始端口不要重复pingInterval = 10;
$gateway_tcp->pingNotResponseLimit = 2;
// 心跳数据
$gateway_tcp->pingData = 'ping';
// 设置服务注册地址defined('GLOBAL_START'))
{
Worker::runAll();
}
```
服务器状态是下面这样，但是用网络助手连接TCP服务器就是连接不上，用的是腾讯云国外Linux服务器，防火墙已经关闭，请大家帮忙看看是怎么回事
```
----------------------------------------------GLOBAL STATUS------------
分享简单快速的“ORM”框架，基于PHP和PDO的数据库中间层
## 简介
一个简单、快速的基于PHP和PDO的数据库中间层
使用Laravel ORM和ThinkORM，感觉不好用，把Svick框架里面的ORM抽离出来搞了一个
## 项目地址
https://gitee.com/tomener/svickorm
## 安装
`composer require tomener/svickorm`
安装后将自动生成 config/svickorm.php 数据库配置文件>where('a.status', 1)
->where(['u.level' => 2, 'u.status' => 1])
->page($page)
->list()
```
### 事务```php
//开启事务
User::connection()->startTrans();
//回滚事务
User::connection()->rollback();
//提交事务
User
赞助商
