国产+高潮+在线,国产 av 仑乱内谢,www国产亚洲精品久久,51国产偷自视频区视频,成人午夜精品网站在线观看

webman redis-queue 消費類中總是隔一分鐘被重復觸發(fā)一次,這是什么原因?

isgbuddy

確定消息只投遞了一次

<?php
namespace app\queue\redis;

use Webman\RedisQueue\Consumer;

class MyMailSend implements Consumer
{
    // 要消費的隊列名
    public $queue = 'test_send_mail';

    // 連接名,對應 config/redis_queue.php 里的連接`
    public $connection = 'default';

    // 消費
    public function consume($data)
    {
        var_dump('consume => '.date('Y-m-d H:i:s'));
        // 無需反序列化
        var_export($data); // 輸出 ['to' => 'tom@gmail.com', 'content' => 'hello']
    }
}
    'redis_consumer'  => [
        'handler'     => Webman\RedisQueue\Process\Consumer::class,
        'count'       => 1, // 可以設置多進程
        'constructor' => [
            // 消費者類目錄
            'consumer_dir' => app_path() . '/queue/redis'
        ]
    ]

string(30) "consume => 2021-12-17 16:36:20"
array (
'to' => 'tom@gmail.com',
'content' => 'hello',
'time' => '2021-12-17 16:36:20',
)string(30) "consume => 2021-12-17 16:37:20"
array (
'to' => 'tom@gmail.com',
'content' => 'hello',
'time' => '2021-12-17 16:36:20',
)

1401 2 0
2個回答

isgbuddy

另外同時清教一下:'count' => 1, // 可以設置多進程,這個設置多個是不是意味消息處理速度會更快?消息不會被重復在不同進程出現(xiàn)吧?

  • walkor 2021-12-17

    多進程處理速度會更快,不會重復處理。

  • isgbuddy 2021-12-17

    明白了,感謝

walkor 打賞

消費被觸發(fā)說明某個地方有投遞消息。具體哪個地方需要自己找下

  • isgbuddy 2021-12-17

    哦哦,明白了,是你的 文檔里 demo 代碼投遞了兩次

年代過于久遠,無法發(fā)表回答
??