workerman的协程，运行完就懂销毁协程内的变量?
问题描述 我最近在搞个plc（modbus-tcp）通讯，其中需要用到协程处理.我想问个问题，就是协程会自动销毁其变量吗 $worker2->onWorkerStart = function (TcpConnection $connection, Request $request) { Coroutine::create(function () { $a = 1; $b =...
在协程中创建的定时器，在协程消亡的过程中，会不会随之消亡？
问题描述 ## 假定用swoole驱动 $server = new worker();\ $server->onMessage( function(TcpConnection $connection, $data) { Timer::add( function (1) { ...
我想学习下gataway？
问题描述 如下是关于gataway的介绍， https://www.workerman.net/doc/gateway-worker/principle.html 我的问题是: 1 business进程拿到gateway进程的链接后，就建立链接，我的理解是建立一个tcp的长链接。gateway是tcp的服务端，business是tcp的客户端，我的理解正确吗？ 2 client1和client7是怎么通讯的？假设cl...
我想咨询下，workerman的swoole协程，能否加速物联网modbus tcp协议的开发？
问题描述 以下从官网中，拷贝的例子，做些修改，在我要sleep(1)和sleep（3）处发生了协程切换，使得整个过程只需要3秒就能完成一次的请求，我想问下，如果sleep函数换成发起modbus tcp的请求(一种类似curl的请求，但是不是http协议的)，会有这样的效果吗？ $worker = new Worker('http://0.0.0.0:8001'); $worker->event...
我想问下，他是怎么实现主副协程切换的，？
问题描述 官网的例子中，onmessage应该是个主协程的概念吧？然后在开启两个子协程。我想问下流程： 1 在子协程遇到sleep的时候，就直接运行到主协程那，主协程在遇到$result[] = $channel->pop();就阻塞， 2 等待子协程push的时候，主协程就接着运行$result[] = $channel->pop();，然后再次循环，再次遇到阻塞， 3 直到第2个子协程运行完毕，主协程...
为啥协程文章里面的数据库连接类会用单例？s
问题描述 <?php use Workerman\Connection\TcpConnection; use Workerman\Coroutine\Context; use Workerman\Coroutine; use Workerman\Coroutine\Pool; use Workerman\Events\Swoole; use Workerman\Protocols\Http\Request; u...
要使用swoole驱动的话，除了安装event扩展外，一定要安装swoole扩展吗？
问题描述 要使用swoole驱动的话，除了安装event扩展外，一定要安装swoole扩展吗？ 为此你搜索到了哪些方案及不适用的原因 没有...
我想咨询下协程的好处？
问题描述 上诉是协程的用法： $worker1 = new Worker('http://0.0.0.0:8001'); $worker1->eventLoop = Swoole::class; // 使用Swoole协程 $worker1->onMessage = function (TcpConnection $connection, Request $request) { Coroutine...
workerman中，如果发送的两次modbus tcp连接需要一定的间隔时间，怎么办？
问题描述 业务需要定时去PLC获取数据，为此我在一个进程内，定义了多个定时器 foreach ($devicePlcs as $devicePlc) { // 如果不存在，则表示新增，需创建timer数组 if (!isset($this->timers[$devicePlc->id])) { $timer_id = Tim...
workerman中，while(true)和timer::add的冲突?
问题描述 以下的代码，我写在onworkerstart里面，每隔10秒中向redis的队列写数据，但是为啥while(true)的部分没有执行呢？如果去掉while（true），那只能执行1次，不能执行多次？ protected function loop() { Timer::add(10, function () { $data['DEVICE_ID'] =...
connection对象可以存放在redis中，共享给其他workerman用吗？
问题描述 大概意思就是想要个集群，现在不知道那个connection对象能否共享给其他worekerman用？ 为此你搜索到了哪些方案及不适用的原因 找不到...
我想问下关于onmessage离的connection对象？我想开发个聊天室的项目
问题描述 我想问的问题是，假设每次发的包都包含有fromUserId，content，toUserId这些字段， $userIdToConnection[$fromUserId] = $connection; 那这句话后，他每次的$connection都是一样的吗？ $worker->onMessage = function ($connection, $data) { global $userId...
开启workerman后，能否用不同的子worker，来监听不同的请求？
问题描述 $worker = new Worker(); $worker->count = 4; $worker->onWorkerStart = function ($worker) { try { switch ($worker->id) { case 0: ...
mqtt的onMessage函数，是不是要等使用它的进程退出才退出？
问题描述 $this->mqttClient->onMessage = function($topic, $content) {} 这个函数，，一直loop，直到使用他的进程退出，才会退出？ 请问这样理解是否是正确的？...
workerman中的mqtt类，能否独立出来在其他laravel中运行的php-cli程序中运行？
问题描述 wokerman中能否独立调用类似php artisan queue work的命令？ 因为我有个laravel程序，本身要通过laravel的队列放进去，取出来的时候再通过mqtt发送出去？...
为啥程序发送出去的mqtt消息没有相应，我手动用工具模拟发出的又有相应？
我是用workerman的mqtt和laravel发送的，请问publish的内容是不是2进制的？ protected function sendBinary($device, $start, $registerNum, $byteNum) { $str = $device->address . $device->deviceModel->read_code . $star...
总觉得这样写不正确？
问题描述 public function startWorker2() { $worker = new Worker(); $worker->count = 4; $worker->onWorkerStart = function ($worker) { try { // 为每个子进程创建独立的...
