文档协程锁 Locker
# Locker 协程锁
Locker是一种内存锁，用于协程间的同步，常用来在协程中排队访问某种临界资源，例如某个数据库组件没有做连接池，则可以通过Locker来排队使用该组件，避免因为多个协程同时使用同一个连接资源导致数据异常> **提示**
> 此特性需要 workerman>=5.1.0
## 注意
* Locker支持Swoole/Swow/Fiber/Select/Event驱动
* Locker是用于同一个进程的不同协程间排队互斥访问某个资源的，进程与进程间互不影响
```php
<?$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
}
// 避免多个协程同时使用同一个连接，发生类似
问答自定义协议的出入口进程是否独立
我是在项目中使用的自定义协议，我想问的是如果我现在有两个客户端，服务端同时分别向两个客户端发送一个命令，如果我在自定义的协议中的encode($buffer)方法中调用sleep(10)这个方法，那么到达两个客户端的命令会有这个
分享写了一个基于 workerman 的小型 HTTP 框架 WorkerA
修复动态路由缓存内存泄漏导致进程重启的问题，使用 LRU 算法控制了缓存的大小。之前有用 laravel \ lumen 做一个接口的项目，虽然 laravel 的开发很方便，但是由于服务器配置和传统 wnmp wamp 模型的限制，QPS 小的可怜。WorkerA 目前只写了一个月不到，第一版发布，实现了一些基础功能。使用自动依赖注入
提供 mysql 驱动、支持断线重连，跑在进程单例模式中
提供单例模式，可以注册需要的类为单例
支持 gizp deflate 压缩传输
个人喜欢 laravel 的查询构造器和路由的风格，于是将路由和查询构造器都写成了 laravel 风，你可以像 laravel 一样的方式写路由和查数据库。
问答webman插件Getwayworker进程busy
#### 问题描述
阿里云机器8h16g服务器 只运行了getway和注册中心 服务器已经进行linux内核优化并安装了event扩展
使用SuperVisord启动
worker进程运行在阿里云ACK Serverless集群中 镜像用的https://github.com[截图](/upload/img/20240419/19662268c6159c.png)
另一台内网阿里云服务器同样进行内核优化过 使用workerman进行压测
查看gateway状态 有两个进程busy状态
!
问答控制器空方法接管的问题 有些成功 有些失败
在test控制器内接管方法
public function __call($method, $request)
{
$path = explode('/', request
问答AsyncTcpConnection链接ws报错 返回404
#### 问题描述
AsyncTcpConnection 进行ws对外服务器进行申请链接时
这个链接我在mtqqx工具测试是可以链接的。他有账号密码之类 不知道是否需要在请求链接时发送 该如何设置参数
#### 程序代码
```
$worker = new Worker();
$worker->onWorkerStart = function630;
$cleanSession = true;//中断清除会话
$options = array(
'keepalive' => $keepalive,//客户端向服务端发送心跳的时间间隔
问答webman运行时间长了，就有好多busy进程
[](/upload/img/20220326/26623e6a5fae78.png)
昨天晚上重启的，这数据正常吗？
!
问答gatewayClient推送又是成功，有时失败报错；
gatewayClient推送又是成功，有时失败报错；Gateway::getAllGatewayAddressesFromRegister() with registerAddress:"127.0.0.1
问答gatewaywork 接收不到请求
gatewayworker有时会接受不到请求
是不是因为状态图中那个有问题的进程引起的
那个有问题的进程是因为什么原因啊 比较郁闷 。
各位大佬 。帮忙看看啊
文档onWorkerStart
# onWorkerStart
## 说明:
```php
callback Worker::$onWorkerStart
```
设置Worker子进程启动时的回调函数，每个子进程启动时都会执行。注意：onWorkerStart是在子进程启动时运行的，如果开启了多个子进程(```$worker->count > 1```)，每个子进程运行一次，则总共会运行```$worker->count```## 回调函数的参数
``` $worker ```
即Worker对象
## 范例
```php
<?\n";
};
// 运行worker
Worker::runAll();
```
> **提示**
> 业务可以根据worker->id来区分不同的进程从而执行不同的业务逻辑，例如只在0号进程执行某个业务，具体[参考这里](workerid.md)
> **提示**
> 除了使用匿名函数作为回调，还可以[参考这里](..
分享workerman多进程定时任务（非crontab）
功能：
1、执行周期：可按月、周、天、时、分定时执行，也可按天、时、分延时执行
2、任务类型：可在此架构基础上，很方便的添加其他类型的任务，已经内置邮件群发
3、任务日志：不仅可以查看历史执行日志，还可以通过websocket实时查看某个任务正在执行的具体日志
4、api接口：可通过http和redis两种方式，对任务增删改查
5、任务分割：多个任务多进程同时执行不会影响定时器，另外，如果某个任务类型比较复杂，还可以通过AsyncTcpConnection再次分派给其他空闲进程
!
问答workerman 能否实现支持 MQTT ？
2.感觉MQTT的消息队列机制很经典，如果问题2做不到，能不能在workerman中实现MQTT消息推送机制（如果可以，求教思路）？
问答性能优化之event扩展疑问
然后一个开启event扩展一个未开启，然后通过宿主机去压测，两边压测结果都没啥区别，于是想到有可能是因为宿主机自身的并发数限制，于是决定直接在阿里云上搞。[截图](/upload/img/20231031/3165406e710667.png)
缩小并发数
ab -n 2000000 -c 1500 -k -r http://172.18.155.51[截图](/upload/img/20231031/31654071a6dac1.png)
增高并发数
ab -n 2000000 -c 5000 -k -r http://172.18.155.51has expired
开启event，压测正常
## 四 疑问
并发数超5000，开启event能正常受理，这个能够理解。但是按照两种多路复用的模型，epoll的方式在性能上不应该比select上更加出色吗，为啥两者在并发数1500的时候，表现出来的性能却是差不多的？
问答workerman作为websocket客户端发送报错Only run in command line mode只能在命令行触发，要怎么直接发送？
代码：
问答GatewayWorker多实例（多应用）启动问题
#### 为此你搜索到了哪些方案及不适用的原因
文档：https://www.workerman.net/doc/gateway-worker/multi-gatewayworker-instance.html
问答gatewayworker路由问题
怎么在使用$gateway->reusePort=true;情况下，让所有的请求都不进入某个bussionworker,重写路由跟$gateway->reusePort=true能共存生效吗
问答有没有特定核心功能加密，其他代码不加密的办法
#### 问题描述
需要对产品特定的核心功能加密，但不影响对方二次开发，有没有相关的解决办法！
问答Memcached存储如何调用
做开发的时候用到了缓存，而在做缓存配置的时候发现现在原来关于store文件配置的说明文档在WorkerMan 3.x 手册没有了（ http://doc.workerman.net/start/store_config.html/question/69 ）却发现按照这样的配置无法调用，报错信息为：
```
/*-----------------------------------------------------------\BusinessWorke
r))
#1 C:\wamp64\www\workerman-todpole-for-win-master\GatewayWorker\BusinessWorker.p
hp(195): call_user_func('Events::onWorke...', Object(GatewayWorker\BusinessWorke
r))
#2 : GatewayWorker(195): call_user_func('Events::onWorke...', Object(GatewayWorker\BusinessWorke
r))
#2 : GatewayWorker
问答为啥sql日志每次都是打印2次
#### 问题描述
使用的是webman + thinkorm库，开启了sql日志，我看日志每次都是执行2次，所有的数据库操作都是放在模型内操作的，没啥特殊的，只有web_app_sign这个查询稍微特殊点，是定义了一个base控制器，所有控制器继承这个base，让后在__construct中查询了配置信息，他打印了4次
!
问答$connection->send 之后自动就返回了不能执行多次吗？
我收到一条总的数据，然后整理后发散给对应的ID ，send之后函数就终止了。怎么样执行多次
赞助商
