我想把rabbitmq 数据 转发到worker上面 一直不行 一直在 consume() 方法执行不往下执行

require_once __DIR__ . '/../../vendor/autoload.php'; require_once __DIR__ . '/../common/common.php'; global $location_con; $worker = new Worker(); $worker->count = 1; $worker->onWorkerStart = function ...

zhou2021 发表与 2021-03-29 2413 浏览 2 回答
workerman/rabbitmq 使用这个插件 连接 rabbitmq 从队列获取不到数据

<?php use Bunny\Channel; use Bunny\Message; use Workerman\Worker; use Workerman\RabbitMQ\Client; require_once __DIR__ . '/../../vendor/autoload.php'; $worker = new Worker(); $worker->onWorkerStart = funct...

zhou2021 发表与 2021-03-23 2648 浏览 2 回答
在worker里面连接 redis 连接超时

例如:启动一个worker程序。处理redis里面数据。但是 这个redis一直没有接收到数据,redis 就报超时。 过一会有数据上报。发现redis超时了。不在执行数据了。怎么让redis 有数据处理数据,报超时 再次连接 处理数据。 redis类 那些需要调整 namespace dg; use Exception; class RedisCache { private static $redis; priva...

zhou2021 发表与 2021-01-19 3221 浏览 1 回答
查询worker程序有几个启动

每次都是 php data_storage.php status 一个一个查询程序是否启动。 能不能有一个命令 查询全部 启动程序 ?命令怎么写呢?...

zhou2021 发表与 2021-01-19 1816 浏览 1 回答
http协议怎么实现双向通讯

在workerman 里面能实现 http 协议 双向通讯吗? 或者其他 方法可以实现 http 协议 双向通讯...

zhou2021 发表与 2021-01-18 4701 浏览 2 回答
对多个启动worker进行管理

描述: 比如:写很多 $worker = new Worker(); 5个文件。 突然服务器 从新启动了,还需要每个文件 都要进行重新启动 php data_status.php restart -d 分别启动5次。 有没有哦使用脚本 或者 什么sh 脚本 进行对5个 worker 一块 启动呢。 类似 根目录下面 start.php start 启动方式...

zhou2021 发表与 2021-01-18 3415 浏览 3 回答
mqtt 问题

在 $worker = new Worker(); 里面创建两个 $mqtt = new Workerman\Mqtt\Client() $mqtt_to = new Workerman\Mqtt\Client() 导致错误 Warning: Cannot declare class \Workerman\Protocols\Mqtt, because the name is already in use in E:...

zhou2021 发表与 2021-01-04 3594 浏览 2 回答

zhou2021

-16
积分
0
获赞数
0
粉丝数
2021-01-04 加入
×
🔝