subscribe延時訂閱失敗

奔跑的蝸牛 2022-04-25

功能邏輯是點擊預約按鈕延時通知客戶端
為什么總是時而好使時而不好使呢,哪位大神可以幫我看看么

 1453  2 0

2個回答

Tinywan 2022-04-25

訂閱

public function onWorkerStart(Worker $worker)
{
    $redis = new \Workerman\Redis\Client('redis://127.0.0.1:6379');
    $redis->auth('123456');
    $redis->subscribe('resty',function ($channel, $message){
        echo ' [x] ' . $channel.'|'.$message, "\n";
    });
}

發(fā)布

public function publish()
{
    $redis = new \Workerman\Redis\Client('redis://127.0.0.1:6379');
    $redis->auth('123456');
    $redis->publish('resty','Welcome Tinywan publish '.date('Y-m-d H:i:s'));
}

訂閱截圖

奔跑的蝸牛 2022-04-25

看明白了,你這個是文檔上那個異步redis吧,但是怎么延時呀
Tinywan 2022-04-25

workerman/crontab 這個擴展

奔跑的蝸牛 2022-04-25

           //用戶發(fā)過來消息5分鐘后執(zhí)行預約通知
            $client = new Client('redis://127.0.0.1:6379');
            $client->send('chat',json_encode($chat_arr),300);

奔跑的蝸牛 2022-04-25

麻煩具體在問問你,crontab應該怎么寫沒用過

six 2022-04-25

估計是業(yè)務邏輯問題。延遲消費要用隊列，用這個 http://www.wtbis.cn/doc/workerman/components/workerman-redis-queue.html

先直接用手冊里的測試例子測試，不加業(yè)務邏輯。測試沒問題然后再一點一點加你的業(yè)務邏輯，這樣好定位。

奔跑的蝸牛 2022-04-25

我用的就是這個呀,這個問題已經困擾我好多天了
奔跑的蝸牛 2022-04-25

想實現的功能其實很簡單,用戶點擊一個按鈕發(fā)起預約,onMessage接收他的用戶信息后,來實現5分鐘,10分鐘各推一條預約通知提醒消息
six 2022-04-25

記錄日志看下，哪里執(zhí)行哪里沒執(zhí)行。別人美環(huán)境沒代碼不好定位你那句代碼有問題