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觸發命令。直接後臺執行。

以上內容但願幫助到你們， 不少PHPer在進階的時候總會遇到一些問題和瓶頸，業務代碼寫多了沒有方向感，不知道該從那裏入手去提高，對此我整理了一些資料，包括但不限於：分佈式架構、高可擴展、高性能、高併發、服務器性能調優、TP6，laravel，Redis，Swoole、Swoft、Kafka、Mysql優化、shell腳本、Docker、微服務、Nginx等多個知識點高級進階乾貨須要的能夠免費分享給你們 ，須要戳這裏 PHP進階架構師>>>實戰視頻、大廠面試文檔免費獲取