在webman 中如何单独启动worker 做redis 队列消费

thistle 更新于2022-11-11

问题描述

windows 环境,想单独启动一个 worker 消费其他项目的redis队列的服务，第一次用 webman, 不知道怎么写

为此你搜索到了哪些方案及不适用的原因

是写一个命令吗，如果是该怎么调 webman/redis-queue 这个插件写好的 consumer

 1124  2 1

2个回答

Gin 2022-11-11

一个worker搞定如果用webman 看这个 https://www.workerman.net/q/8596

<?php

require __DIR__ . '/../../../vendor/autoload.php';

use Workerman\Worker;
use Workerman\RedisQueue\Client as QueueClient;

$worker = new Worker();
$worker->name = 'QueueWorker';
$worker->count = 8;
$worker->onWorkerStart = function () {

    $apiHost = 'http://www.baidu.com';
    $queueClient = new QueueClient('redis://127.0.0.1:6379',['auth' => '123','db' => 0,'retry_seconds' => 2,'max_attempts' => 2]);

    //物联网
    $queueClient->subscribe('iot-queue', function($data){

    });
};

Worker::runAll();