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

成都創(chuàng)新互聯(lián)公司于2013年開始，是專業(yè)互聯(lián)網(wǎng)技術服務公司，擁有項目網(wǎng)站制作、成都網(wǎng)站制作網(wǎng)站策劃，項目實施與項目整合能力。我們以讓每一個夢想脫穎而出為使命，1280元萊蕪做網(wǎng)站,已為上家服務,為萊蕪各地企業(yè)和個人服務,聯(lián)系電話:028-86922220

1 什么是redis訂閱

Redis 發(fā)布訂閱(pub/sub)是一種消息通信模式：發(fā)送者(pub)發(fā)送消息，訂閱者(sub)接收消息。直接點，你可以理解為我關注了你，你發(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'); //設置密碼
    $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'); //設置密碼
$message = '測試一下';
$ret=$redis->publish('test',$message);

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

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

#獲取訂閱到的消息
創(chuàng)建laravel的php artisan命令在handle里執(zhí)行監(jiān)代碼
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);#調用其他方法執(zhí)行其他業(yè)務邏輯
                }
            }
        });
    }

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

1.首先將需要發(fā)送信息的手機號存入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']);
}

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

2.調用短信接口發(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);//從結尾處彈出一個值,超時時間為60s
    $phonenumber = $phone[1];
    $sendmsg = send($phonenumber);

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

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

看完上述內容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對創(chuàng)新互聯(lián)的支持。

文章題目：Redis如何實現(xiàn)訂閱發(fā)布與批量發(fā)送短信
文章網(wǎng)址：http://www.rwnh.cn/article48/jepsep.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供軟件開發(fā)、服務器托管、微信公眾號、網(wǎng)站排名、網(wǎng)站策劃、網(wǎng)站改版

廣告

聲明：本網(wǎng)站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)