最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

spring boot+redis 監(jiān)聽過(guò)期Key的操作方法

 更新時(shí)間:2020年08月14日 14:55:46   作者:毅大師  
這篇文章主要介紹了spring boot+redis 監(jiān)聽過(guò)期Key,本文通過(guò)示例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下

前言:

在訂單業(yè)務(wù)中,有時(shí)候需要對(duì)訂單設(shè)置有效期,有效期到了后如果還未支付,就需要修改訂單狀態(tài)。對(duì)于這種業(yè)務(wù)的實(shí)現(xiàn),有多種不同的辦法,比如:

1、使用querytz,每次生成一個(gè)訂單,就創(chuàng)建一個(gè)定時(shí)任務(wù),到期后執(zhí)行業(yè)務(wù)代碼;

2、rabbitMq中的延遲隊(duì)列;

3、對(duì)Redis的Key進(jìn)行監(jiān)控;

 1、引入依賴

 <dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-redis</artifactId>
  </dependency>

2、修改boot的redis配置

spring:
 #redis
 redis:
 database: 0
 host: 127.0.0.1
 password: redis_123456
 port: 6379

3、在服務(wù)器中 修改redis.conf配置文件(原來(lái)notify-keyspace-events 屬性是" " 空的,我們只需要填上“Ex”就行了)

notify-keyspace-events "Ex"

4、創(chuàng)建一個(gè)Redis監(jiān)控類,用于監(jiān)控過(guò)期的key,該類需繼承KeyExpirationEventMessageListener

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
 
import java.nio.charset.StandardCharsets;
 
/**
 * @program: SpringCloud
 * @description: redis Key過(guò)期監(jiān)聽
 * @author: zhang yi
 * @create: 2020-03-24 14:14
 */
public class KeyExpiredListener extends KeyExpirationEventMessageListener {
 
 public KeyExpiredListener(RedisMessageListenerContainer listenerContainer) {
  super(listenerContainer);
 }
 
 @Override
 public void onMessage(Message message, byte[] pattern) {
  System.out.println("過(guò)期key:" + message.toString());
 }
}

5、創(chuàng)建Redis配置類

import com.zy.rabbitmq.base.Listener.KeyExpiredListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
 
/**
 * @program: SpringCloud
 * @description: redis配置類
 * @author: zhang yi
 * @create: 2020-03-24 14:17
 */
@Configuration
public class RedisConfiguration {
 
 @Autowired
 private RedisConnectionFactory redisConnectionFactory;
 
 @Bean
 public RedisMessageListenerContainer redisMessageListenerContainer() {
  RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
  redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
  return redisMessageListenerContainer;
 }
 
 @Bean
 public KeyExpiredListener keyExpiredListener() {
  return new KeyExpiredListener(this.redisMessageListenerContainer());
 }
 
}

6、這里提供一個(gè)redis工具類,用于存儲(chǔ)值,獲取值,獲取過(guò)期時(shí)間等操作。

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
 
import javax.annotation.Resource;
import java.util.concurrent.TimeUnit;
/**
 * redis 工具類
 * @Author ZhangYi
 */
@Component
public class RedisUtil {
 
	@Resource
	private RedisTemplate<String, Object> redisTemplate;
 
	/**
	 * 指定緩存失效時(shí)間
	 * 
	 * @param key 鍵
	 * @param time 時(shí)間(秒)
	 * @return
	 */
	public boolean expire(String key, long time) {
		try {
			if (time > 0) {
				redisTemplate.expire(key, time, TimeUnit.SECONDS);
			}
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}
	}
 
	/**
	 * 根據(jù)key 獲取過(guò)期時(shí)間
	 * 
	 * @param key 鍵 不能為null
	 * @return 時(shí)間(秒) 返回0代表為永久有效
	 */
	public long getExpire(String key) {
		return redisTemplate.getExpire(key, TimeUnit.SECONDS);
	}
 
	/**
	 * 判斷key是否存在
	 * 
	 * @param key 鍵
	 * @return true 存在 false不存在
	 */
	public boolean hasKey(String key) {
		try {
			return redisTemplate.hasKey(key);
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}
	}
 
	/**
	 * 刪除緩存
	 * 
	 * @param key 可以傳一個(gè)值 或多個(gè)
	 */
	@SuppressWarnings("unchecked")
	public void del(String... key) {
		if (key != null && key.length > 0) {
			if (key.length == 1) {
				redisTemplate.delete(key[0]);
			} else {
				redisTemplate.delete(CollectionUtils.arrayToList(key));
			}
		}
	}
 
	// ============================String=============================
	/**
	 * 普通緩存獲取
	 * 
	 * @param key 鍵
	 * @return 值
	 */
	public Object get(String key) {
		return key == null ? null : redisTemplate.opsForValue().get(key);
	}
 
	/**
	 * 普通緩存放入
	 * 
	 * @param key 鍵
	 * @param value 值
	 * @return true成功 false失敗
	 */
	public boolean set(String key, Object value) {
		try {
			redisTemplate.opsForValue().set(key, value);
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}
 
	}
 
	/**
	 * 普通緩存放入并設(shè)置時(shí)間
	 * 
	 * @param key 鍵
	 * @param value 值
	 * @param time 時(shí)間(秒) time要大于0 如果time小于等于0 將設(shè)置無(wú)限期
	 * @return true成功 false 失敗
	 */
	public boolean set(String key, Object value, long time) {
		try {
			if (time > 0) {
				redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
			} else {
				set(key, value);
			}
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			return false;
		}
	}
}

7、測(cè)試。(這里開放兩個(gè)接口,一個(gè)set值,并設(shè)置過(guò)期時(shí)間為10秒,一個(gè)獲取值和過(guò)期時(shí)間,當(dāng)?shù)竭_(dá)過(guò)期時(shí)間,看是否回去到過(guò)期Key)

@GetMapping("/put")
 public String demo(){
  redisUtil.set("name","zhangyi",10);
  return "aaa";
 }
 
 @GetMapping("/get")
 public Map<String,Object> get(){
  Map<String,Object> m =new HashMap<>();
  m.put("time",redisUtil.getExpire("name"));
  m.put("val",redisUtil.get("name"));
  return m;
 }

成功獲取到了過(guò)期Key,這里亂碼是因?yàn)閎oot集成的Redis存key或者value的時(shí)候,沒(méi)有配置字符串序列化。沒(méi)有配置的話是默認(rèn)使用jdk本身的序列化的。

到此這篇關(guān)于spring boot+redis 監(jiān)聽過(guò)期Key的文章就介紹到這了,更多相關(guān)spring boot+redis 監(jiān)聽過(guò)期Key內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

  • SpringBoot定時(shí)監(jiān)聽RocketMQ的NameServer問(wèn)題及解決方案

    SpringBoot定時(shí)監(jiān)聽RocketMQ的NameServer問(wèn)題及解決方案

    這篇文章主要介紹了SpringBoot定時(shí)監(jiān)聽RocketMQ的NameServer問(wèn)題及解決方案,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友參考下吧
    2023-12-12
  • 詳解如何讓Spring MVC顯示自定義的404 Not Found頁(yè)面

    詳解如何讓Spring MVC顯示自定義的404 Not Found頁(yè)面

    這篇文章主要介紹了詳解如何讓Spring MVC顯示自定義的404 Not Found頁(yè)面,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2018-10-10
  • Java實(shí)戰(zhàn)之在線租房系統(tǒng)的實(shí)現(xiàn)

    Java實(shí)戰(zhàn)之在線租房系統(tǒng)的實(shí)現(xiàn)

    這篇文章主要介紹了利用Java實(shí)現(xiàn)的在線租房系統(tǒng),文中用到了SpringBoot、Redis、MySQL、Vue等技術(shù),文中示例代碼講解詳細(xì),需要的可以參考一下
    2022-02-02
  • Spring Security 自定義短信登錄認(rèn)證的實(shí)現(xiàn)

    Spring Security 自定義短信登錄認(rèn)證的實(shí)現(xiàn)

    這篇文章主要介紹了Spring Security 自定義短信登錄認(rèn)證的實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2021-03-03
  • springMVC+jersey實(shí)現(xiàn)跨服務(wù)器文件上傳

    springMVC+jersey實(shí)現(xiàn)跨服務(wù)器文件上傳

    這篇文章主要介紹了springMVC+jersey實(shí)現(xiàn)跨服務(wù)器文件上傳,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2019-08-08
  • Java中FileWriter類的常用方法說(shuō)明

    Java中FileWriter類的常用方法說(shuō)明

    這篇文章主要介紹了Java中FileWriter類的常用方法說(shuō)明,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-07-07
  • Java 對(duì) Cookie增刪改查的實(shí)現(xiàn)示例

    Java 對(duì) Cookie增刪改查的實(shí)現(xiàn)示例

    這篇文章主要介紹了Java 對(duì) Cookie增刪改查的實(shí)現(xiàn)示例,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2019-05-05
  • 基于jenkins實(shí)現(xiàn)發(fā)布node.js項(xiàng)目

    基于jenkins實(shí)現(xiàn)發(fā)布node.js項(xiàng)目

    這篇文章主要介紹了基于jenkins實(shí)現(xiàn)發(fā)布node.js項(xiàng)目,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-07-07
  • Java匿名類,匿名內(nèi)部類實(shí)例分析

    Java匿名類,匿名內(nèi)部類實(shí)例分析

    這篇文章主要介紹了Java匿名類,匿名內(nèi)部類,結(jié)合實(shí)例形式分析了Java匿名類,匿名內(nèi)部類相關(guān)原理、用法及操作注意事項(xiàng),需要的朋友可以參考下
    2020-04-04
  • 最新評(píng)論

    德令哈市| 蛟河市| 上犹县| 日土县| 平定县| 景谷| 高碑店市| 治县。| 枣庄市| 天长市| 海丰县| 都江堰市| 新龙县| 庆云县| 南乐县| 郴州市| 余干县| 元氏县| 广州市| 顺平县| 甘孜县| 富川| 呼图壁县| 丽江市| 乌审旗| 自治县| 柳林县| 小金县| 红桥区| 弋阳县| 金沙县| 丰台区| 镇赉县| 莲花县| 精河县| 孟州市| 泾源县| 霸州市| 宁河县| 芮城县| 莎车县|