在webman 中如何單獨(dú)啟動(dòng)worker 做redis 隊(duì)列消費(fèi)

thistle 更新于2022-11-11

問(wèn)題描述

windows 環(huán)境,想單獨(dú)啟動(dòng)一個(gè) worker 消費(fèi)其他項(xiàng)目的redis隊(duì)列的服務(wù)，第一次用 webman, 不知道怎么寫(xiě)

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

是寫(xiě)一個(gè)命令嗎，如果是該怎么調(diào) webman/redis-queue 這個(gè)插件寫(xiě)好的 consumer

 1446  2 1

2個(gè)回答

Gin 2022-11-11

一個(gè)worker搞定如果用webman 看這個(gè) http://www.wtbis.cn/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]);

    //物聯(lián)網(wǎng)
    $queueClient->subscribe('iot-queue', function($data){

    });
};

Worker::runAll();