Redis如何實現(xiàn)訂閱發(fā)布與批量發(fā)送短信

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

1 什么是redis訂閱

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

2 發(fā)布訂閱的場景在哪里

比如以下幾個場景：

2.1 典型的網(wǎng)頁上的消息可以做到實時通知

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

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

3 php如何實現(xiàn) 實時發(fā)布訂閱

知道了什么是訂閱，發(fā)布的場景，下面來看看如何用php與redis實現(xiàn)發(fā)布訂閱

3.1 cli.php，這個為訂閱端的代碼 主要注意的是這個代碼放在cli下執(zhí)行 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'); //設(shè)置密碼
    $result = $redis->subscribe(['test'],'callback');
    print_r($result);
    sleep(0.1);
}


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

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

3.2 發(fā)布端的代碼，pub.php 這個代碼可以放在普通網(wǎng)頁下執(zhí)行

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

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

這里貼個laravel實現(xiàn)的發(fā)布訂閱的例子

#獲取訂閱到的消息
創(chuàng)建laravel的php artisan命令在handle里執(zhí)行監(jiān)代碼
laravel的php artisan list命令可以查看當(dāng)前的任務(wù)，然后使用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);#設(shè)置key過期時間為24小時
                    $this->xxxxx($message,xxx);#調(diào)用其他方法執(zhí)行其他業(yè)務(wù)邏輯
                }
            }
        });
    }

接下來看看如何實現(xiàn)批量發(fā)送短信

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

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

將所需發(fā)送的手機號存入到redis緩存中

2.調(diào)用短信接口發(fā)送短信

$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);//從結(jié)尾處彈出一個值,超時時間為60s
    $phonenumber = $phone[1];
    $sendmsg = send($phonenumber);

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

這里結(jié)合php的cli模式，通過函數(shù)exec觸發(fā)命令。直接后臺執(zhí)行。

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