2. 程式人生 > >springmvc訂閱redis鍵過期訊息通知

springmvc訂閱redis鍵過期訊息通知

阿新 • • 發佈：2019-01-04

首先啟用redis通知功能（ubuntu下操作）：
編輯/etc/redis/redis.conf檔案，新增或啟用以下內容（過期通知）：

notify-keyspace-events Ex

或者登陸redis-cli之後，輸入以下命令：

config set notify-keyspace-events Ex

因鍵空間通知功能需要耗費一定的CPU時間，因此預設情況下，該功能是關閉的。可以通過修改配置檔案redis.conf，或者通過CONFIG SET命令，設定notify-keyspace-events選項，來啟用或關閉該功能。

         該選項的值為空字串時，該功能禁用，選項值為非空字串時，啟用該功能，非空字串由特定的多個字元組成，每個字元表示不同的意義：

K：keyspace事件，事件以[email protected]<db>__為字首進行釋出；

E：keyevent事件，事件以[email protected]<db>__為字首進行釋出；

g：一般性的，非特定型別的命令，比如del，expire，rename等；

$：字串特定命令；

l：列表特定命令；

s：集合特定命令；

h：雜湊特定命令；

z：有序集合特定命令；

x：過期事件，當某個鍵過期並刪除時會產生該事件；

e：驅逐事件，當某個鍵因maxmemore策略而被刪除時，產生該事件；

A：g$lshzxe的別名，因此”AKE”意味著所有事件。

         注意，該選項的值中至少需要包含K或者E，否則不會發布任何事件。比如，如果需要開啟針對列表的keyspace事件通知，則該選項需要配置為“Kl”；


expired事件通知的傳送時間

Redis 使用以下兩種方式刪除過期的鍵：

a：當一個鍵被訪問時，程式會對這個鍵進行檢查，如果鍵已過期，則刪除該鍵；

b：系統會在後臺定期掃描並刪除那些過期的鍵；

當過期鍵被以上兩種方式中的任意一種發現並且刪除時，才會產生expired事件通知。

Redis不保證生存時間（TTL）變為 0 的鍵會立即被刪除：如果沒有命令訪問這個鍵，或者設定生存時間的鍵非常多的話，那麼在鍵的生存時間變為0，到該鍵真正被刪除，這中間可能會有一段比較顯著的時間間隔。

因此，Redis產生expired事件通知的時間，是過期鍵被刪除的時候，而不是鍵的生存時間變為 0 的時候。

=========================================================

不同命令產生的事件通知

DEL 命令為每個被刪除的鍵產生一個 del 事件；

RENAME 產生兩個事件：為源鍵產生一個 rename_from 事件，併為目標鍵產生一個 rename_to 事件；

EXPIRE命令，在設定鍵的過期時間時產生一個 expire事件；當鍵因過期而被刪除時，產生一個 expired事件；

SORT命令，在帶有 STORE 引數時產生一個 sortstore事件。如果 STORE 指示的用於儲存排序結果的鍵已經存在，則原鍵會被刪除，因此還會產生一個 del 事件；

SET 以及它的所有變種(SETEX、SETNX和GETSET)都產生set事件。另外，SETEX命令還會產生expire 事件；

MSET 命令，為每個鍵產生一個 set 事件；

SETRANGE 產生一個 setrange 事件；

INCR 、DECR、INCRBY和DECRBY都產生 incrby 事件；

INCRBYFLOAT產生incrbyfloat事件；

APPEND產生append事件；

LPUSH和LPUSHX都產生單個 lpush 事件，即使有多個輸入元素時，也是如此；

RPUSH 和 RPUSHX 都產生單個rpush事件，即使有多個輸入元素時，也是如此；

RPOP 產生 rpop 事件，如果被彈出的元素是列表的最後一個元素，那麼還會產生一個 del 事件；

LPOP 產生 lpop 事件，如果被彈出的元素是列表的最後一個元素，那麼還會產生一個 del 事件；

LINSERT 產生一個 linsert 事件；

LSET 產生一個 lset 事件；

LREM產生一個lrem事件，如果該命令執行之後，列表鍵被清空，則還會產生一個 del 事件；

LTRIM 產生一個ltrim事件，如果該命令執行之後，列表鍵被清空，則還會產生一個 del 事件；

RPOPLPUSH 和 BRPOPLPUSH 產生一個 rpop 事件，以及一個 lpush 事件。兩個命令都保證rpop事件在 lpush 事件之前發出。如果彈出元素之後，列表鍵被清空，則還會產生一個 del 事件；

HSET 、 HSETNX 和 HMSET 都只產生一個 hset 事件；

HINCRBY 產生一個 hincrby 事件；

HINCRBYFLOAT 產生一個 hincrbyfloat 事件；

HDEL 產生一個 hdel 通知。如果執行該命令之後，雜湊鍵被清空，則還會產生一個del事件；

SADD 產生一個 sadd 事件，即使有多個輸入元素時，也是如此；

SREM 產生一個 srem 事件，如果執行該命令之後，集合鍵被清空，則還會產生一個 del 事件；

SMOVE 為源鍵產生一個 srem 事件，併為目標鍵產生一個sadd 事件；

SPOP 產生一個 spop 事件。如果執行該命令之後，集合鍵被清空，則還會產生一個 del 事件；

SINTERSTORE、SUNIONSTORE和SDIFFSTORE分別產生 sinterstore、sunionostore和sdiffstore 三種事件。如果用於儲存結果的鍵已經存在，則還會產生一個 del 事件；

ZINCR產生一個 zincr 事件；

ZADD 產生一個 zadd事件，即使有多個輸入元素時，也是如此；

ZREM 產生一個 zrem 通知，即使有多個輸入元素時，也是如此。如果執行 ZREM 之後，有序集合鍵被清空，則還會產生一個 del 事件；

ZREMEBYSCORE 產生一個 zrembyscore事件，如果用於儲存結果的鍵已經存在，則還會產生一個 del 事件。

ZREMBYRANK 產生一個 zrembyrank事件，如果用於儲存結果的鍵已經存在，則還會產生一個 del 事件。

ZINTERSTORE 和 ZUNIONSTORE 分別產生 zinterstore 和 zunionstore 兩種事件。如果用於儲存結果的鍵已經存在，那麼還會產生一個 del 事件。

每當一個鍵因為過期而被刪除時，產生一個 expired 事件。

每當一個鍵因為 maxmemory策略而被刪除並回收記憶體時，產生一個 evicted 事件。

注意：所有命令都只在鍵真的被改動了之後，才會產生事件通知。比如，當srem命令試圖刪除不存在於集合的元素時，刪除操作執行失敗，因為沒有真正的改動鍵，所以這一操作不會發送通知。


==========================================================

使用maven搭建好springmvc,和搭配好相應的redis的jar包,這個之前的部落格中有,這裡就不提了..

先寫好相應的java處理該訊息通知的類:

import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;

public class MyRedisKeyExpiredMessageDelegate    implements MessageListener {

	
	public void onMessage(Message message, byte[] pattern) {
		System.out.println("channel:" + new String(message.getChannel())
                + ",message:" + new String(message.getBody()));
    }
}
再在springmvc的xml配置裡面搭配好相應的監聽配置:
	<bean id="messageListener"
		class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter">
		<constructor-arg>
			<bean class="com.zww.common.redis.MyRedisKeyExpiredMessageDelegate" />
		</constructor-arg>
	</bean>
	<bean id="redisContainer"
		class="org.springframework.data.redis.listener.RedisMessageListenerContainer">
		<property name="connectionFactory" ref="connectionFactory" />
		<property name="messageListeners">
			<map>
				<entry key-ref="messageListener">
					<list>
						<!--  <bean class="org.springframework.data.redis.listener.ChannelTopic"> 
							<constructor-arg value="[email protected]__:expired" /> </bean>  -->
						<!-- <bean class="org.springframework.data.redis.listener.PatternTopic"> 
							<constructor-arg value="*" /> </bean> -->
						<bean class="org.springframework.data.redis.listener.PatternTopic">
							<constructor-arg value="__key*__:expired" />
						</bean>
					</list>
				</entry>
			</map>
		</property>
	</bean>

好了,這個時候可以啟動伺服器,隨便插入一個鍵,設定好過期時間,就會看到列印的日誌了

這裡我在弄的時候有遇到這樣一個坑,就是這個日誌列印了兩次,,仔細一看,是因為springmvc的配置載入了兩次,主要原因還是因為web.xml裡面的配置使springmvc載入兩次,配置好相應的配置就好了....

不過因此也說明了,這個 

MyRedisKeyExpiredMessageDelegate

 類最好是搞成單列,這樣才能防止通知兩次,使同樣的程式碼執行兩次,出現一些意外的情況,和耗費系統資源

此文參考 
http://blog.csdn.net/gqtcgq/article/details/50808729

http://www.bubuko.com/infodetail-1895361.html

相關推薦

springmvc訂閱redis鍵過期訊息通知

首先啟用redis通知功能（ubuntu下操作）： 編輯/etc/redis/redis.conf檔案，新增或啟用以下內容（過期通知）： notify-keyspace-events Ex 或者登陸redis-cli之後，輸入以下命令： config set n

Redis鍵過期和鍵遷移

鍵過期命令 expire key seconds expireat key timestamp ttl key pttl key pexpire key milliseconds pexpire key

springboot中使用redis實現非同步訊息通知

為什麼我要用redis來完成非同步訊息,而不是訊息佇列mq之類的? 因為很多的單體專案可能只需要需要一個略微簡單的訊息通知,而不需要如kafka那種完善的訊息佇列, 而且redis在正常的專案中基本都會引入而mq可能較少會引入,所以使用redis來實現訊息通知可以減少不必

redis鍵過期 （redis 2.6及以上)

發現 ash name 副本 文件 unix 刪除 所有 second EXPIRE key seconds 用來對一個鍵設置一個過期時間，第二個參數表示經過多少秒後鍵過期。 一個鍵過期後， 這個鍵將會被自動刪除。 在Redis術語中，帶有過期時間的鍵經常被稱作vola

python中的Redis鍵空間通知（過期回撥）

介紹 Redis是一個記憶體資料結構儲存庫，用於快取，高速資料攝取，處理訊息佇列，分散式鎖定等等。 使用Redis優於其他記憶體儲存的優點是Redis提供永續性和資料結構，如列表，集合，有序集和雜湊。 在本文中，我想簡要介紹一下Redis鍵空間通知。我將解釋鍵空間通知是什麼，並演示如何配置Redis以接

redis入門指南（三）—— 事務、過期時間、SORT命令、訊息通知與管道

寫在前面 　　學習《redis入門指南》筆記，結合實踐，只記錄重要，明確，屬於新知的相關內容。   事務 　　1、redis中的事務由一組命令的集合組成，要麼都執行，要麼都不執行，同時redis的事務還可以保證事務內的命令會依次執行不被其他命令插入。 　　2、命令MULTI開啟事務，之後傳送一些

Redis Key過期通知

概述 鍵空間通知使得客戶端可以通過訂閱頻道或模式， 來接收那些以某種方式改動了 Redis 資料集的事件。如Redis資料庫中鍵的過期事件也是通過訂閱功能實現。本文主要基於Azure PaaS Redis演示相關功能的具體實現。 配置 因為開啟鍵空間通知功能需要消耗一些 CPU ， 所以

Redis的過期鍵刪除策略

我們都知道資料庫鍵的過期時間都儲存在過期字典中，那麼如果一個鍵過期了，那麼什麼時候會被刪除呢？ 以下三種不同的刪除策略： 定時刪除： 在設定鍵的過期時間的同時，建立一個定時器（timer），讓定時器在鍵的過期時間來臨時，立即執行刪除鍵。 惰性刪除：放任過期

Redis學習筆記（十）進階之訊息通知

任務佇列 使用LPUSH和RPOP命令操作列表來實現佇列 BLPOP key [key ...] timeout(s) BRPOP key [key ...] timeout(s) BLPOP/BRPOP是阻塞式，同時檢測多個鍵，如果所有鍵都沒有元素則阻塞，如果其中有一個鍵

八Redis 鍵過期功能

前面介紹了Redis 的六種資料結構,它們分別是字串、列表、雜湊、集合、有序集合和 HyperLogLog。 除此之外,我們還介紹瞭如何使用資料庫命令來操作 Redis 的資料庫本身: 比如使用 DEL 命令刪除資料庫中的某個鍵, 使用 SCAN 命令漸進地遍歷整個資料庫, 使用 DBSIZE 返回

【redis學習之四】Redis的過期鍵處理及鍵淘汰策略

    在redis中可以通過如下命令設定鍵的生存時間或生命週期： EXPIRE KEY TTL 命令用於將key的生存時間設定為ttl秒 PEXPIRE KEY TTL 命令用於將key的生存時間設定為ttl毫秒 EXPIREAT KEY TIMESTAMP

Spring-data-redis: pub/sub訊息訂閱

 Redis中pub/sub特性，可以用來實現類似與JMS的“topic”功能，只不過這些訊息無法被持久化而已。spring-data-redis元件中對pub/sub提供了類似JMS的程式設計模式，我們通過例項來展示如何使用。     需要注意的是，在redis中訊息

探索Redis設計與實現9：資料庫redisDb與鍵過期刪除策略

一. 資料庫Redis的資料庫使用字典作為底層實現，資料庫的增、刪、查、改都是構建在字典的操作之上的。 redis伺服器將所有資料庫都儲存在伺服器狀態結構redisServer(redis.h/redisServer)的db陣列（應該是一個連結串列）裡：struct redisServer { //..

Redis訊息通知

訊息通知 任務佇列 使用任務佇列的好處 鬆耦合。生產者和消費者無需知道彼此的實現細節，只需要約定好任務的描述格式。這使得生產者和消費者可以由不同的團隊使用不同的程式語言編寫易於擴充套件。消費者可以有多個，而且可以分佈在不同的伺服器中, 藉此可以輕易地降低單臺伺服器的負

Redis中鍵過期命令

鍵過期命令EXPIRE key seconds 將鍵 key 的生存時間設定為指定的秒數。複雜度為O(1) PEXPIRE key milliseconds 將鍵 key 的生存時間

【redis】spring boot利用redis的Keyspace Notifications實現訊息通知

前言   需求：當redis中的某個key失效的時候，更新key對應資料在資料庫的狀態 1、修改redis.co

Redis系列(五)：Redis的過期鍵刪除策略

本篇部落格是Redis系列的第5篇，主要講解下Redis的過期鍵刪除策略。 本系列的前4篇可以點選以下連結檢視： Redis系列(一)：Redis簡介及環境安裝 Redis系列(二)：Redis的5種資料結構及其常用命令 Redis系列(三)：Redis的持久化機制(RDB、AOF) Redis系列(四)：R

Redis 數據變化通知服務實踐

裝包 ram ref lpush none hub .exe ssa 參數 從Redis 2.8.0版本起，Redis加入了“Keyspace notifications”（即“鍵空間通知”）的功能。鍵空間通知，允許Redis客戶端從“發布/訂閱”通道中建立訂閱關

redis學習一 （key）鍵，Python操作redis 鍵

lpad ren redis key lee 設置 amp res 列表 pex # -*- coding: utf-8 -*- import redis #這個redis 連接不能用，請根據自己的需要修改 r =redis.Redis(host="123.516.174

Redis 鍵(key)

tps 管理 targe str blog div rand set blank Redis 鍵(key) Redis 鍵命令用於管理 redis 的鍵。 語法 Redis 鍵命令的基本語法如下： redis 127.0.0.1:6379> COMMAND KEY_N