免费在线黄色片,99视频免费,欧美性猛交一区二区三区精品

SpringBoot 監控Redis中某個Key的變化

1.聲明

當前內容主要為本人學習和基本測試，主要為監控redis中的某個key的變化（感覺網上的都不好，所以自己看Spring源碼直接寫一個監聽器）

個人參考：

Redis官方文檔
Spring-data-Redis源碼

2.基本理念

網上的demo的缺點

使用繼承KeyExpirationEventMessageListener只能監聽當前key消失的事件
使用KeyspaceEventMessageListener只能監聽所有的key事件

總體來說，不能監聽某個特定的key的變化（某個特定的redis數據庫），具有缺陷

直接分析獲取可以操作的步驟

查看KeyspaceEventMessageListener的源碼解決問題

SpringBoot如何監控Redis中某個Key的變化(自定義監聽器)

基本思想

創建自己的主題（用來監聽某個特定的key）
創建監聽器實現MessageListener
注入自己的配置信息

查看其中的方法（init方法）

public void init() {
		if (StringUtils.hasText(keyspaceNotificationsConfigParameter)) {
			RedisConnection connection = listenerContainer.getConnectionFactory().getConnection();
			try {
				Properties config = connection.getConfig("notify-keyspace-events");
				if (!StringUtils.hasText(config.getProperty("notify-keyspace-events"))) {
					connection.setConfig("notify-keyspace-events", keyspaceNotificationsConfigParameter);
				}
			} finally {
				connection.close();
			}
		}
		doRegister(listenerContainer);
	}
	/**
	 * Register instance within the container.
	 *
	 * @param container never {@literal null}.
	 */
	protected void doRegister(RedisMessageListenerContainer container) {
		listenerContainer.addMessageListener(this, TOPIC_ALL_KEYEVENTS);
	}

主要操作如下

向redis中寫入配置notify-keyspace-events并設置為EA
向RedisMessageListenerContainer中添加本身這個監聽器并指定監聽主題

所以本人缺少的就是這個主題表達式和監聽的notify-keyspace-events配置

直接來到redis的官方文檔找到如下內容

SpringBoot如何監控Redis中某個Key的變化(自定義監聽器)

所以直接選擇的是：__keyspace@0__:myKey,使用的模式為KEA

所有的工作全部完畢后開始實現監聽

3.實現和創建監聽

創建監聽類：RedisKeyChangeListener

本類中主要監聽redis中數據庫0的myKey這個key

import java.nio.charset.Charset;
import java.util.Properties;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.connection.RedisConnection;
import org.springframework.data.redis.listener.KeyspaceEventMessageListener;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.Topic;
import org.springframework.util.StringUtils;
/**
 * 
 * @author hy
 * @createTime 2021-05-01 08:53:19
 * @description 期望是可以監聽某個key的變化，而不是失效
 *
 */
public class RedisKeyChangeListener implements MessageListener/* extends KeyspaceEventMessageListener */ {
	private final String listenerKeyName; // 監聽的key的名稱
	private static final Topic TOPIC_ALL_KEYEVENTS = new PatternTopic("__keyevent@*"); //表示只監聽所有的key 
	private static final Topic TOPIC_KEYEVENTS_SET = new PatternTopic("__keyevent@0__:set"); //表示只監聽所有的key
	private static final Topic TOPIC_KEYNAMESPACE_NAME = new PatternTopic("__keyspace@0__:myKey"); // 不生效
	// 監控
	//private static final Topic TOPIC_KEYEVENTS_NAME_SET_USELESS = new PatternTopic("__keyevent@0__:set myKey");
	private String keyspaceNotificationsConfigParameter = "KEA";
	public RedisKeyChangeListener(RedisMessageListenerContainer listenerContainer, String listenerKeyName) {
		this.listenerKeyName = listenerKeyName;
		initAndSetRedisConfig(listenerContainer);
	}
	public void initAndSetRedisConfig(RedisMessageListenerContainer listenerContainer) {
		if (StringUtils.hasText(keyspaceNotificationsConfigParameter)) {
			RedisConnection connection = listenerContainer.getConnectionFactory().getConnection();
			try {
				Properties config = connection.getConfig("notify-keyspace-events");
				if (!StringUtils.hasText(config.getProperty("notify-keyspace-events"))) {
					connection.setConfig("notify-keyspace-events", keyspaceNotificationsConfigParameter);
				}
			} finally {
				connection.close();
			}
		}
		// 注冊消息監聽
		listenerContainer.addMessageListener(this, TOPIC_KEYNAMESPACE_NAME);
	}
	@Override
	public void onMessage(Message message, byte[] pattern) {
		System.out.println("key發生變化===》" + message);
		byte[] body = message.getBody();
		String string = new String(body, Charset.forName("utf-8"));
		System.out.println(string);
	}
}

其實就改了幾個地方…

4.基本demo的其他配置

1.RedisConfig配置類

@Configuration
@PropertySource(value = "redis.properties")
@ConditionalOnClass({ RedisConnectionFactory.class, RedisTemplate.class })
public class RedisConfig {
	@Autowired
	RedisProperties redisProperties;
	/**
	 * 
	 * @author hy
	 * @createTime 2021-05-01 08:40:59
	 * @description 基本的redisPoolConfig
	 * @return
	 *
	 */
	private JedisPoolConfig jedisPoolConfig() {
		JedisPoolConfig config = new JedisPoolConfig();
		config.setMaxIdle(redisProperties.getMaxIdle());
		config.setMaxTotal(redisProperties.getMaxTotal());
		config.setMaxWaitMillis(redisProperties.getMaxWaitMillis());
		config.setTestOnBorrow(redisProperties.getTestOnBorrow());
		return config;
	}
	/**
	 * @description 創建redis連接工廠
	 */
	@SuppressWarnings("deprecation")
	private JedisConnectionFactory jedisConnectionFactory() {
		JedisConnectionFactory factory = new JedisConnectionFactory(
				new JedisShardInfo(redisProperties.getHost(), redisProperties.getPort()));
		factory.setPassword(redisProperties.getPassword());
		factory.setTimeout(redisProperties.getTimeout());
		factory.setPoolConfig(jedisPoolConfig());
		factory.setUsePool(redisProperties.getUsePool());
		factory.setDatabase(redisProperties.getDatabase());
		return factory;
	}
	/**
	 * @description 創建RedisTemplate 的操作類
	 */
	@Bean
	public StringRedisTemplate getRedisTemplate() {
		StringRedisTemplate redisTemplate = new StringRedisTemplate();
		redisTemplate.setConnectionFactory(jedisConnectionFactory());
		redisTemplate.setEnableTransactionSupport(true);
		return redisTemplate;
	}
	
	@Bean
	public RedisMessageListenerContainer redisMessageListenerContainer() throws Exception {
		RedisMessageListenerContainer container = new RedisMessageListenerContainer();
		container.setConnectionFactory(jedisConnectionFactory());		
		return container;
	}
	// 創建基本的key監聽器
	/*  */
	@Bean
	public RedisKeyChangeListener redisKeyChangeListener() throws Exception {
		RedisKeyChangeListener listener = new RedisKeyChangeListener(redisMessageListenerContainer(),"");
		return listener;
	}
}

其中最重要的就是RedisMessageListenerContainer 和RedisKeyChangeListener

2.另外的RedisProperties類，加載redis.properties文件成為對象的

/**
 * 
 * @author hy
 * @createTime 2021-05-01 08:38:26
 * @description 基本的redis的配置類
 *
 */
@ConfigurationProperties(prefix = "redis")
public class RedisProperties {
	private String host;
	private Integer port;
	private Integer database;
	private Integer timeout;
	private String password;
	private Boolean usePool;
	private Integer maxTotal;
	private Integer maxIdle;
	private Long maxWaitMillis;
	private Boolean testOnBorrow;
	private Boolean testWhileIdle;
	private Integer timeBetweenEvictionRunsMillis;
	private Integer numTestsPerEvictionRun;
	// 省略getset方法
}

省略其他代碼

5.基本測試

創建一個key，并修改發現變化

SpringBoot如何監控Redis中某個Key的變化(自定義監聽器)

可以發現返回的是這個key執行的方法（set），如果使用的是keyevent方式那么返回的就是這個key的名稱

6.小結一下

1.監聽redis中的key的變化主要利用redis的機制來實現（本身就是發布/訂閱）

2.默認情況下是不開啟的，原因有點耗cpu

3.實現的時候需要查看redis官方文檔和SpringBoot的源碼來解決實際的問題

SpringBoot自定義監聽器

原理

Listener按照監聽的對象的不同可以劃分為：

監聽ServletContext的事件監聽器，分別為：ServletContextListener、ServletContextAttributeListener。Application級別，整個應用只存在一個，可以進行全局配置。
監聽HttpSeesion的事件監聽器，分別為：HttpSessionListener、HttpSessionAttributeListener。Session級別，針對每一個對象，如統計會話總數。
監聽ServletRequest的事件監聽器，分別為：ServletRequestListener、ServletRequestAttributeListener。Request級別，針對每一個客戶請求。

示例

第一步：創建項目，添加依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-tomcat</artifactId>
    <scope>provided</scope>
</dependency>
<dependency>
    <groupId>javax.servlet</groupId>
    <artifactId>jstl</artifactId>
    <version>1.2</version>
    <scope>compile</scope>
</dependency>
<dependency>
    <groupId>org.apache.tomcat.embed</groupId>
    <artifactId>tomcat-embed-jasper</artifactId>
    <scope>compile</scope>
</dependency>
<dependency>
    <groupId>org.eclipse.jdt.core.compiler</groupId>
    <artifactId>ecj</artifactId>
    <version>4.6.1</version>
</dependency>

第二步：自定義監聽器

@WebListener
public class MyServletRequestListener implements ServletRequestListener {
    @Override
    public void requestDestroyed(ServletRequestEvent sre) {
        System.out.println("Request監聽器，銷毀");
    }
    @Override
    public void requestInitialized(ServletRequestEvent sre) {
        System.out.println("Request監聽器，初始化");
    }
}

第三步：定義Controller

@RestController
public class DemoController {
    @RequestMapping("/fun")
    public void fun(){
        System.out.println("fun");
    }
}

第四步：在程序執行入口類上面添加注解

@ServletComponentScan

部署項目，運行查看效果：

SpringBoot如何監控Redis中某個Key的變化(自定義監聽器)

以上為個人經驗，希望能給大家一個參考，也希望大家多多支持服務器之家。

原文鏈接：https://blog.csdn.net/weixin_45492007/article/details/116326073

激情久久久_欧美视频区_成人av免费_不卡视频一二三区_欧美精品在欧美一区二区少妇_欧美一区二区三区的

SpringBoot如何監控Redis中某個Key的變化(自定義監聽器)

目錄

SpringBoot 監控Redis中某個Key的變化

1.聲明

2.基本理念

3.實現和創建監聽

4.基本demo的其他配置

5.基本測試

6.小結一下

SpringBoot自定義監聽器

原理

示例

延伸 · 閱讀

小米推送Java代碼

Java BufferWriter寫文件寫不進去或缺失數據的解決

xml與Java對象的轉換詳解

Java實現搶紅包功能

20個非常實用的Java程序代碼片段

升級IDEA后Lombok不能使用的解決方法

Java8中Stream使用的一個注意事項

Java使用SAX解析xml的示例

云服務器是什么，云主機干什么用的？

2020最新好用的web服務器軟件推薦

服務器操作系統有哪些?

web服務器配置（圖文詳解）

企業如何選擇阿里云服務器配置?

五大免費主機管理系統優缺點對比及推薦

2019最新三款Windows下連接Linux的ssh軟件下載推薦

服務器常用管理軟件盤點

Nginx服務器究竟是怎么執行PHP項目