webman的redis-queue,windows下如何消费

adminadmin

1、安装
composer require webman/redis-queue
2、配置好redis
3、投递好消息

use Webman\RedisQueue\Redis;

class Index
{

    public function queue(Request $request)
    {
        // 队列名
        $queue = 'send-mail';
        // 数据,可以直接传数组,无需序列化
        $data = ['to' => 'tom@gmail.com', 'content' => 'hello'];
        // 投递消息
        Redis::send($queue, $data);
        // 投递延迟消息,消息会在60秒后处理
        $r=Redis::send($queue, $data, 60);

        return response('redis queue test:'.$r);
    }

4、消费者写好

<?php

namespace app\queue\redis;

use Webman\RedisQueue\Consumer;

class MyMailSend implements Consumer
{
    // 要消费的队列名
    public $queue = 'send-mail';

    // 连接名,对应 plugin/webman/redis-queue/redis.php 里的连接`
    public $connection = 'default';

    // 消费
    public function consume($data)
    {
        // 无需反序列化
        var_export($data); // 输出 ['to' => 'tom@gmail.com', 'content' => 'hello']
    }
}

接下来windows下如何消费呀 新手 麻烦了 实在是抱歉

1449 1 1
1个回答

静默

启动webman就消费了啊,windows系统启动webman用命令 php windows.php 或者 双击 windows.bat
linux系统用 php start.php start

年代过于久远,无法发表回答
×
🔝