SpringBoot如何监控Redis中某个Key的变化（⾃定义）⽬录
SpringBoot 监控Redis中某个Key的变化
1.声明
2.基本理念
3.实现和创建监听
4.基本demo的其他配置
5.基本测试
6.⼩结⼀下spring boot选择题
SpringBoot⾃定义
原理
⽰例
SpringBoot 监控Redis中某个Key的变化
1.声明
当前内容主要为本⼈学习和基本测试，主要为监控redis中的某个key的变化（感觉⽹上的都不好，所以⾃⼰看Spring源码直接写⼀个）
个⼈参考：
Redis官⽅⽂档
Spring-data-Redis源码
2.基本理念
⽹上的demo的缺点
使⽤继承KeyExpirationEventMessageListener只能监听当前key消失的事件
使⽤KeyspaceEventMessageListener只能监听所有的key事件
总体来说，不能监听某个特定的key的变化（某个特定的redis数据库），具有缺陷
直接分析获取可以操作的步骤
查看KeyspaceEventMessageListener的源码解决问题
基本思想
创建⾃⼰的主题（⽤来监听某个特定的key）
创建实现MessageListener
注⼊⾃⼰的配置信息
查看其中的⽅法（init⽅法）
public void init() {
if (StringUtils.hasText(keyspaceNotificationsConfigParameter)) {
RedisConnection connection = ConnectionFactory().getConnection();
try {
Properties config = Config("notify-keyspace-events");
if (!StringUtils.Property("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的官⽅⽂档到如下内容
所以直接选择的是：__keyspace@0__:myKey，使⽤的模式为KEA
所有的⼯作全部完毕后开始实现监听
3.实现和创建监听
创建监听类：RedisKeyChangeListener
本类中主要监听redis中数据库0的myKey这个key
import java.nio.charset.Charset;
import java.util.Properties;
import org.tion.Message;
import org.tion.MessageListener;
import org.tion.RedisConnection;
import org.dis.listener.KeyspaceEventMessageListener;
import org.dis.listener.PatternTopic;
import org.dis.listener.RedisMessageListenerContainer;
import org.dis.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 = ConnectionFactory().getConnection();
try {
Properties config = Config("notify-keyspace-events");
if (!StringUtils.Property("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 = Body();
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.MaxIdle());
config.MaxTotal());
config.MaxWaitMillis());
config.TestOnBorrow());
return config;
}
/**
* @description 创建redis连接⼯⼚
*/
@SuppressWarnings("deprecation")
private JedisConnectionFactory jedisConnectionFactory() {
JedisConnectionFactory factory = new JedisConnectionFactory(
new Host(), Port()));
factory.Password());
factory.Timeout());
factory.setPoolConfig(jedisPoolConfig());
factory.UsePool());
factory.Database());
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;
// 省略get\set⽅法
}
省略其他代码
5.基本测试
创建⼀个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>at.embed</groupId>
<artifactId>tomcat-embed-jasper</artifactId>
<scope>compile</scope>
</dependency>
<dependency>
<groupId&piler</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
部署项⽬，运⾏查看效果：
以上为个⼈经验，希望能给⼤家⼀个参考，也希望⼤家多多⽀持。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。