为什么subscribe过不去呢??
$worker = new Worker();
$worker->count = 100;
$worker->onWorkerStart = function ($worker) {
$client = Test::getServer();
// 订阅
$id = $worker->id;
$client->subscribe("task-{$id}", function($data)use($id) {
var_dump(66666);
try {
$person = new ProcessPerson();
$person->step1($data);
} catch (\Exception $e) {
var_dump($e->getMessage());
}
});
};
Worker::runAll();
到这里就不往下走了晕死了
2435 2 0
2个回答
相似问题
年代过于久远，无法发表回答
月贡献榜
赞助商
热门问答
workerman 里面的redis 队列是基于redis的什么特性实现的？
redis-queue 延迟队列不消费，使用的官方源码安装
联表一次查询和查询后循环内再查询别的表组装数据，哪个性能好呢？
webman想使用人大金仓数据库，如何处理？ 求方案
PHP8.4下webman直接用topthink/think-orm想了解数据库连接该写在哪里
微信SDK，关于webman里推荐的
redis-queue 延迟任务 可否延迟第二天触发？
/* * 注意这里进程数必须设置为1 */ $worker->count = 1;
是否需要用GatewayWorker来替换PhpSocket.io
127.0.0.1:1238地址显示已被占用?
redis 扩展的subscribe是阻塞操作，后面的代码不会执行，除非subscribe返回。
如果你要非阻塞subscribe，可以用 workerman/redis，参见手册 http://doc.workerman.net/components/workerman-redis.html
用的 redis-queue
http://doc.workerman.net/components/workerman-redis-queue.html
你先按照示例来，不要封装，有问题再来发帖。
我调试跟踪到这里就不行了。