redis訂閱php

① 用phpredis操作redis集群支持publish和subscribe嗎

用phpredis操作redis集群支持publish和subscribe
參數可選Redis::MULTI或Redis::PIPELINE. 默認是 Redis::MULTI
Redis::MULTI：將多個操作當成一個事務執行
Redis::PIPELINE:讓（多條）執行命令簡單的，更加快速的發送給伺服器，但是沒有任何原子性的保證
discard:刪除一個事務
返回值
multi()，返回一個redis對象，並進入multi-mode模式，一旦進入multi-mode模式，
以後調用的所有方法都會返回相同的對象，只到exec(）方法被調用。

watch, unwatch （代碼測試後，不能達到所說的效果）
監測一個key的值是否被其它的程序更改。如果這個key在watch 和 exec （方法）間被修改，
這個 MULTI/EXEC 事務的執行將失敗（return false）
unwatch 取消被這個程序監測的所有key

② redis發布訂閱模式

最近項目中，有個功能點是利用redis的發布訂閱機制，進行伺服器本地緩存數據同步。
由於redis發布訂閱功能的可靠性較差，在項目中出現了有伺服器沒有訂閱成功問題，以及伺服器訂閱消息不及時，導致部分業務受到影響。所以將redis通知本地緩存的機制改為了使用redis做二級緩存。

雖然Redis能夠實現發布/訂閱的功能,但是有如下缺點,所以選用前需謹慎考慮

和常規的MQ不同,redis實現的發布/訂閱模型消息無法持久化,一經發布,即使沒有任何訂閱方處理,該條消息就會丟失

即發布方不會確保訂閱方成功接收

廣播機制無法通過添加多個消費方增強消費能力,因為這和發布/訂閱模型本身的目的是不符的.廣播機制的目的是一個一個發布者被多個訂閱進行不同的處理

由於Redis發布/訂閱模型存在的缺陷,所以使用前需要考慮如下幾點

1.對於消息處理可靠性要求不強
2.消費能力無需通過增加消費方進行增強

————————————————
原文鏈接： https://blog.csdn.net/weixin_32394085/article/details/105006123

③ php 後台怎麼開一個進程監聽Redis的隊列消息呢用while

redis的subscribe用pconnect鏈接，執行這個腳本的進程會自動監聽所訂閱的頻道發送的消息

ini_set(『default_socket_timeout』, -1);

$redis = new \Redis();
$redis->pconnect('127.0.0.1', 6379);

//訂閱
$redis->subscribe(['msg'], 'callfun');

function callfun($redis, $channel, $msg)
{
var_mp([
'redis' => $redis,
'channel' => $channel,
'msg' => $msg
]);
}

④ php redis如何使用

開始在
PHP
中使用
Redis
前，要確保已經安裝了
redis
服務及
PHP
redis
驅動，且你的機器上能正常使用
PHP。
PHP安裝redis擴展
/usr/local/php/bin/phpize
#php安裝後的路徑
./configure
--with-php-config=/usr/local/php/bin/php-config
make
&&
make
install
修改php.ini文件
vi
/usr/local/php/lib/php.ini
增加如下內容:
extension_dir
=
"/usr/local/php/lib/php/extensions/no-debug-zts-20090626"
extension=redis.so
安裝完成後重啟php-fpm
或
apache。查看phpinfo信息，就能看到redis擴展。
連接到
redis
服務
<?php
//連接本地的
Redis
服務
$redis
=
new
Redis();
$redis->connect('127.0.0.1',
6379);
echo
"Connection
to
server
sucessfully";
//查看服務是否運行
echo
"Server
is
running:
"
.
$redis->ping();
?>
執行腳本，輸出結果為：
Connection
to
server
sucessfully
Server
is
running:
PONG
Redis
PHP
String(字元串)
實例
<?php
//連接本地的
Redis
服務
$redis
=
new
Redis();
$redis->connect('127.0.0.1',
6379);
echo
"Connection
to
server
sucessfully";
//設置
redis
字元串數據
$redis->set("tutorial-name",
"Redis
tutorial");
//
獲取存儲的數據並輸出
echo
"Stored
string
in
redis::
"
.
jedis.get("tutorial-name");
?>
執行腳本，輸出結果為：
Connection
to
server
sucessfully
Stored
string
in
redis::
Redis
tutorial
Redis
PHP
List(列表)
實例
<?php
//連接本地的
Redis
服務
$redis
=
new
Redis();
$redis->connect('127.0.0.1',
6379);
echo
"Connection
to
server
sucessfully";
//存儲數據到列表中
$redis->lpush("tutorial-list",
"Redis");
$redis->lpush("tutorial-list",
"Mongodb");
$redis->lpush("tutorial-list",
"Mysql");
//
獲取存儲的數據並輸出
$arList
=
$redis->lrange("tutorial-list",
0
,5);
echo
"Stored
string
in
redis::
"
print_r($arList);
?>
執行腳本，輸出結果為：
Connection
to
server
sucessfully
Stored
string
in
redis::
Redis
Mongodb
Mysql
Redis
PHP
Keys
實例
<?php
//連接本地的
Redis
服務
$redis
=
new
Redis();
$redis->connect('127.0.0.1',
6379);
echo
"Connection
to
server
sucessfully";
//
獲取數據並輸出
$arList
=
$redis->keys("*");
echo
"Stored
keys
in
redis::
"
print_r($arList);
?>
執行腳本，輸出結果為：
Connection
to
server
sucessfully
Stored
string
in
redis::
tutorial-name
tutorial-list

⑤ 如何用php+redis做訂單到時間自動完成功能

1、每分鍾內要完成的訂單id存到redis；
2、php做邏輯處理
3、配置crontab每分鍾執行一次php，讀取要完成的訂單id；

⑥ php怎麼使用 redis pub/sub

一.場景介紹
最近的一個項目需要用到發布/訂閱的信息系統，以做到最新實時消息的通知。經查找後發現了redis pub/sub(發布/訂閱的信息系統)可以滿足我的開發需求,而且學習成本和使用成本也比較低。 :grin:
二.什麼是redis pub/sub
資料查看
大家在看我的blog的同時可以打開redis官方對於redis pub/sub的介紹，感覺看英文文檔吃力的話 :cry: ，可以看redis中文網的翻譯介紹.
Pub/Sub功能（means Publish, Subscribe）即發布及訂閱功能
1> 基於事件的系統中，Pub/Sub是目前廣泛使用的通信模型，它採用事件作為基本的通信機制，提供大規模系統所要求的鬆散耦合的交互模式：訂閱者(如客戶端)以事件訂閱的方式表達出它有興趣接收的一個事件或一類事件；發布者(如伺服器)可將訂閱者感興趣的事件隨時通知相關訂閱者。
2> 消息發布者，即publish客戶端，無需獨占鏈接，你可以在publish消息的同時，使用同一個redis-client鏈接進行其他操作（例如：INCR等）
3> 消息訂閱者，即subscribe客戶端，需要獨占鏈接，即進行subscribe期間，redis-client無法穿插其他操作，此時client以阻塞的方式等待「publish端」的消息；這一點很好理解，因此subscribe端需要使用單獨的鏈接，甚至需要在額外的線程中使用。
三.redis pub/sub的使用
下面我將配著實圖(用我的本地機器環境)來為大家講解redis的pub/sub怎麼去使用 .
沒有安裝phpredis擴展的或者沒有redis服務的，請參考我的另一篇blog，有詳細的安裝介紹，這里不再贅述了。
1、啟動redis服務端:
[caption id="attachment_1777" align="alignnone" width="300"] php redis pub/sub(消息訂閱系統)經驗總結之一[/caption]
2、新開一個終端,啟動redis客戶端，並做為subscribe客戶端(消息訂閱者)，訂閱一個名字叫test的頻道的頻道信息：
3、啟動redis客戶端，並做為publish客戶端(消息發布者)，發布一個名字叫test的頻道,信息是:hello,world
4、再切換到2步驟中的redis客戶端窗口，會發現，已經訂閱到了剛才發布的 'hello,world'消息:
5、模式匹配訂閱
Redis 的Pub/Sub實現支持模式匹配。客戶端可以訂閱全風格的模式以便接收所有來自能匹配到給定模式的頻道的消息。
比如,將接收所有發到 test.name,test.phone,test.address...等等的消息，該這樣寫:
[shell]PUBSCRIBE test.*[/shell]
在終端回車後，同時再新的窗口裡分別發布兩個頻道的消息，名字分別為:test.name和test.phone,然後切換到訂閱端的窗口裡，結果如下圖所示:
由上圖可以看出,在訂閱了test.*頻道後,一共收到了 test.name和test.phone兩個頻道的消息，這就是模式匹配訂閱。
那麼取消訂閱匹配該模式的客戶端也比較簡單：
[shell]PUNSUBSCRIBE test.*[/shell]
6、好，以上的這些簡單的demo，就是關於redis pub/sub(Publish/Subscribe,發布/訂閱的信息系統)的最基本使用。說了這么多，跟php也沒有掛上什麼鉤，別著急，重要的都往往最後出場。 :lol:
四.php使用redis的pub/sub(發布/訂閱的信息系統)
這里我列出一些常用的命令:
phpredis的安裝
redis的客戶端連接支持多種語言。這里我用的是php的phpredis，它是用c語言編寫的,目前已經作為php的一個模塊擴展，沒有安裝的可以參考我的另一篇blog，已經安裝的可以忽略此步驟.
命令手冊
這里我列出一些常用的:
[shell]Redis::__construct構造函數
$redis = new Redis();
connect, open 鏈接redis服務
參數
host: string，服務地址
port: int,埠號
timeout: float,鏈接時長 (可選, 默認為 0 ，不限鏈接時間)
注: 在redis.conf中也有時間，默認為300
pconnect, popen 不會主動關閉的鏈接
參考上面
setOption 設置redis模式
getOption 查看redis設置的模式
ping 查看連接狀態
get 得到某個key的值（string值）
如果該key不存在，return false
set 寫入key 和 value（string值）
如果寫入成功，return ture
setex 帶生存時間的寫入值
$redis->setex('key', 3600, 'value'); // sets key → value, with 1h TTL.
setnx 判斷是否重復的，寫入值<br />$redis->setnx('key', 'value');
$redis->setnx('key', 'value');
delete 刪除指定key的值
返回已經刪除key的個數（長整數）
$redis->delete('key1', 'key2');
$redis->delete(array('key3', 'key4', 'key5'));
<span style="font-size: 16px; line-height: 24px;">
[/shell]
更詳細的使用請參考這里，我就不寫太多，因為我要直接摞代碼了. :lol:
publish(消息發布端):pub.php
[php]
/**
* redis sub(消息訂閱端)
* @ blog: phping.sinaapp.com
* @date 2016-04-24 15:00
*/
$redis = new Redis();
// 第一個參數為redis伺服器的ip,第二個為埠
$res = $redis->connect('127.0.0.1', 6379);
// test為發布的頻道名稱,hello,world為發布的消息
$res = $redis->publish('test','hello,world');
[/php]
subscribe(消息訂閱端): sub.php
[php]
/**
* redis sub(消息訂閱端)
* @ blog: phping.sinaapp.com
* @date 2016-04-24 15:00
*/
$redis = new Redis();
$res = $redis->pconnect('127.0.0.1', 6379,0);
$redis->subscribe(array('test'), 'callback');
// 回調函數,這里寫處理邏輯
function callback($instance, $channelName, $message) {
echo $channelName, "==>", $message,PHP_EOL;
}
[/php]
開始訂閱redis消息
前面已經提到過，消息訂閱者，即subscribe客戶端，需要獨占鏈接，即進行subscribe期間，redis-client無法穿插其他操作，此時client以阻塞的方式等待「publish端」的消息，所以我們用命令行來執行:
則 訂閱消息的redis客戶端已經啟動，隨時等待發布過來的消息並訂閱該消息.
發布redis消息
同樣，命令行執行消息發布端的腳本即可:
[shell]
php pub.php
[/shell]
切換到消息訂閱端的窗口發現終端有輸出,如下圖:
哈哈，是不是 收到了發布端發布的'hello,world'這條消息呢。
五.總結
在命令執行redis訂閱端腳本時，發現在終端會輸出:
[shell]
PHPFatalerror: Uncaughtexception'RedisException'withmessage'readerroronconnection'in…
[/shell]
這樣的錯誤是什麼原因呢？請看我下一篇blog，本篇主要是講一些基本的語法，在下一篇我會著重講解一些在實際開發中遇到過的哪些問題和跳過的哪些坑。。。 :mrgreen:
碼字不易，望轉載註明出處哈 ;)

⑦ Redis 發布訂閱功能

Redis 發布訂閱 (pub/sub) 是一種消息通信模式：訂閱者 (sub) 訂閱頻道，發送者 (pub) 向頻道發送消息，訂閱者通過該頻道接收消息。

不過發布訂閱模式有2點需要注意：

客戶端1輸入 SUBSCRIBE runoobChat 訂閱頻道 runoobChat

客戶端2 在 頻道 runoobChat 發布消息，訂閱者就能接收到消息。

客戶端1將會接收：

Redis 將所有頻道的訂閱關系保存在伺服器狀態的字典裡面，這個字典的健是某個被訂閱的頻道，而健的值則是一個鏈表，鏈表裡面記錄了所有訂閱這個頻道的客戶端。

每當客戶端執行``命令訂閱某些頻道的時候，伺服器斗湖將客戶端與被訂閱頻道在 字典中進行關聯。
按照頻道是否有訂閱者，關聯操作可以分為2種情況執行：

調用棧

伺服器將所有頻道的訂閱關系保存再伺服器狀態的，與此類似，伺服器也將所有模式的訂閱關系都保存在伺服器狀態的屬性裡面

pubsub_patterns 屬性是一個鏈表，鏈表中的每一個節點都包含著一個 pubsubPattern 結構，這個結構的屬性記錄了被訂閱的模式，而 client 性則記錄了訂閱模式的客戶端。

客戶端執行命令訂閱某些模式的時候，伺服器會對每個被訂閱的模式執行下列2個操作：

⑧ redis適合什麼場景

1、緩存。 緩存現在幾乎是所有中大型網站都在用的必殺技，合理的利用緩存不僅能夠提升網站訪問速度，還能大大降低資料庫的壓力。Redis提供了鍵過期功能，也提供了靈活的鍵淘汰策略，所以，現在Redis用在緩存的場合非常多。（推薦：《 Redis視頻教程 》）
2、排行榜。 很多網站都有排行榜應用的，如京東的月度銷量榜單、商品按時間的上新排行榜等。Redis提供的有序集合數據類構能實現各種復雜的排行榜應用。
3、計數器。 什麼是計數器，如電商網站商品的瀏覽量、視頻網站視頻的播放數等。為了保證數據實時效，每次瀏覽都得給+1，並發量高時如果每次都請求資料庫操作無疑是種挑戰和壓力。Redis提供的incr命令來實現計數器功能，內存操作，性能非常好，非常適用於這些計數場景。
4、分布式會話。 集群模式下，在應用不多的情況下一般使用容器自帶的session復制功能就能滿足，當應用增多相對復雜的系統中，一般都會搭建以Redis等內存資料庫為中心的session服務，session不再由容器管理，而是由session服務及內存資料庫管理。
5、分布式鎖。 在很多互聯網公司中都使用了分布式技術，分布式技術帶來的技術挑戰是對同一個資源的並發訪問，如全局ID、減庫存、秒殺等場景，並發量不大的場景可以使用資料庫的悲觀鎖、樂觀鎖來實現，但在並發量高的場合中，利用資料庫鎖來控制資源的並發訪問是不太理想的，大大影響了資料庫的性能。可以利用Redis的setnx功能來編寫分布式的鎖，如果設置返回1說明獲取鎖成功，否則獲取鎖失敗，實際應用中要考慮的細節要更多。

⑨ 訂單超時，活動過期解決方案：php監聽redis鍵重復觸發引發事件

訂單超時，活動過期解決方案：php監聽redis鍵重復觸發引發事件

Redis的2.8.0版本之後可用，鍵空間消息（Redis Keyspace Notifications），配合2.0.0版本之後的SUBSCRIBE 可以完成這個定時任務的操作了，定時的單位是秒。

1.我們先訂閱頻道稱為 redisChat

2.現在，我們重新開啟個redis客戶端，然後在同一個頻道redisChat發布消息，訂閱者可以接收到消息。

接收到的消息如下：

3.Key過期事件的Redis配置

需要這里配置notify-keyspace-events的參數為「EX」 .X代表了過期事件。notify-keyspace-events 「Ex」保存配置後，重啟Redis的服務，使配置生效。

PHP Redis實現訂閱鍵空間通知

redis實例化類：

redis.class.php

1個

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18歲

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

//遇到類別重復的報錯，所有叫Redis2

classRedis2  

{

    private$redis;

    publicfunction__construct($host= '127.0.0.1', $port= 6379)

    {

        $this->redis = newRedis();

        $this->redis->connect($host, $port);

    }

    publicfunctionsetex($key, $time, $val)

    {

        return$this->redis->setex($key, $time, $val);

    }

    publicfunctionset($key, $val)

    {

        return$this->redis->set($key, $val);

    }

    publicfunctionget($key)

    {

        return$this->redis->get($key);

    }

    publicfunctionexpire($key= null, $time= 0)

    {

        return$this->redis->expire($key, $time);

    }

    publicfunctionpsubscribe($patterns= array(), $callback)

    {

        $this->redis->psubscribe($patterns, $callback);

    }

    publicfunctionsetOption()

    {

        $this->redis->setOption(\Redis::OPT_READ_TIMEOUT, -1);

    }

}

過期事件的訂閱：

psubscribe.php

1個

2

3

4

5

6

7

8

9

10

11

12

13

14

15

require_once'./Redis.class.php';

$redis= new\Redis2();

// 解決Redis客戶端訂閱時候超時情況

$redis->setOption();

$redis->psubscribe(array('__keyevent@0__:expired'), 'keyCallback');

// 回調函數,這里寫處理邏輯

functionkeyCallback($redis, $pattern, $chan, $msg)

{

    echo"Pattern: $pattern\n";

    echo"Channel: $chan\n";

    echo"Payl

    oad: $msg\n\n";

    //keyCallback為訂閱事件後的回調函數，這里寫業務處理邏輯，

    //比如前面提到的商品不支付自動撤單，這里就可以根據訂單id,來實現自動撤單

}

設置過期事件：

index.php

1個

2

3

4

require_once'./Redis.class.php';

$redis= new\Redis2();

$order_id= 123;

$redis->setex('order_id',10,$order_id);

先用命令行模式執行 psubscribe.php

在瀏覽器訪問 index.php

效果如下：