Redis如何實現訂閱發布與批量發送短信

Redis如何實現訂閱發布與批量發送短信，很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細講解，有這方面需求的人可以來學習下，希望你能有所收獲。

1 什么是redis訂閱

Redis 發布訂閱(pub/sub)是一種消息通信模式：發送者(pub)發送消息，訂閱者(sub)接收消息。直接點，你可以理解為我關注了你，你發布了信息，文章等，我就可以立馬收的到。

2 發布訂閱的場景在哪里

比如以下幾個場景：

2.1 典型的網頁上的消息可以做到實時通知

2.2 訂單下單以后 通過redis訂閱實時通知庫存改變

2.3 接口需要做一些比如發送郵件 寫日志等功能的時候可以運用到redis訂閱了 這樣會加快接口返回時間

3 php如何實現 實時發布訂閱

知道了什么是訂閱，發布的場景，下面來看看如何用php與redis實現發布訂閱

3.1 cli.php，這個為訂閱端的代碼 主要注意的是這個代碼放在cli下執行 php

<?php
while (true){
    echo time();
    ini_set('default_socket_timeout', -1);  //不超時
    $redis = new Redis();
    $redis->connect('127.0.01', 6379, 3600);
    $redis->auth('123456'); //設置密碼
    $result = $redis->subscribe(['test'],'callback');
    print_r($result);
    sleep(0.1);
}


function callback($instance,$channelName,$message)
{
    print_r($message);
}

啟動以后接下來我們來個發布端的代碼

3.2 發布端的代碼，pub.php 這個代碼可以放在普通網頁下執行

<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379, 3600);
$redis->auth('123456'); //設置密碼
$message = '測試一下';
$ret=$redis->publish('test',$message);

到這里php redis訂閱發布成功,是不是很簡單，主要用到redis的subscribe方法，publish方法，當然這些代碼在實際使用過程中還是可以優化的比如cli.php，根據自己的需要去實現吧。

這里貼個laravel實現的發布訂閱的例子

#獲取訂閱到的消息
創建laravel的php artisan命令在handle里執行監代碼
laravel的php artisan list命令可以查看當前的任務，然后使用Linux的nohub命令在后臺常駐即可

    public function handle()
    {
      #訂閱消息redis
        $redis = new \Redis();
        $redis->pconnect(Config("host"), Config("port"));
        $redis->auth(Config("password"));
        //訂閱訂單id ORDERID
        $redis->subscribe(['ORDERID'], function($redis, $channel,$message) {
            if ($channel == 'ORDERID'){
                #這里$message為10002
                if ($message){
                    //存儲到自己的redis庫 這里配置了多連接
                    $redis2 = Redis::connection('driver_outset_time');
                    $redis2->set('ORDERID_'.$message,time());#value為時間time()
                    $redis2->EXPIRE('ORDERID_'.$message,time(), 24*60*60);#設置key過期時間為24小時
                    $this->xxxxx($message,xxx);#調用其他方法執行其他業務邏輯
                }
            }
        });
    }

接下來看看如何實現批量發送短信

1.首先將需要發送信息的手機號存入redis緩存

$redis = new \redis();
$conn = $redis->connect('localhost', 6379);
$auth = $redis->auth('*****'); //redis設置了密碼，需要認證
$list = Testuser::find()->asarray()->all();
for ($i=0; $i < count($list); $i++) { 
    $redis->lpush('list',$list[$i]['email']);
}

將所需發送的手機號存入到redis緩存中

2.調用短信接口發送短信

$redis = new \redis();
$conn = $redis->connect('localhost', 6379);
$auth = $redis->auth('*****');
$lenth = $redis->llen('list');

for ($i=0; $i < $lenth ; $i++) { 
    $phone = $redis->brpop('list',1,60);//從結尾處彈出一個值,超時時間為60s
    $phonenumber = $phone[1];
    $sendmsg = send($phonenumber);

    if($sendmsg){
        //處理發送成功的邏輯
    }else{
        //處理發送失敗的邏輯
    }
    usleep(500000);//微秒，調用第三方接口，需要注意頻率，
}

這里結合php的cli模式，通過函數exec觸發命令。直接后臺執行。

看完上述內容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注億速云行業資訊頻道，感謝您對億速云的支持。