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為10002if ($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ā)送信息的手機(jī)號存入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ā)送的手機(jī)號存入到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í)行。

如果你喜歡我寫的技術(shù)文章以及面試總結(jié)，歡迎關(guān)注收看我的視頻，并且點贊、收藏、關(guān)注我哦。

我是luke，感謝你的關(guān)注！

很多小伙伴在進(jìn)階的時候總會遇到一些問題和瓶頸，業(yè)務(wù)代碼寫多了沒有方向感，不知道該從那里入手去提升，對此我整理了一些資料，希望能夠去幫助到小伙伴們，可以關(guān)注我。并且加入到我的圈子一起學(xué)習(xí)成長哦【架構(gòu)師之路】點擊鏈接申請加入圈子

架構(gòu)師之路 - 知乎?www.zhihu.com

總結(jié)

以上是生活随笔為你收集整理的4che3 scu发送超时设置_Redis实现订阅发布与批量发送短信的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。