捕捉Redis变化的实时监听（监听redis变化）

Redis，响应式Key-Value数据库，相比关系型数据库受到越来越多应用，无论是缓存存储或者是任务队列的异步处理都可以得到更加优秀的性能。但是因为Redis的原子性，要实现服务端的实时监听却是一个非常困难的问题。

当数据发生改变时，我们可以使用订阅的方式实现消息的持久化，进而让服务端得以实时监听Redis更新，实现服务端的实时更新。

在Redis中创建发布订阅信道，并设置频道名称；

`public void createRedisChannel() {

Jedis jedis = redisUtils.getJedis();

jedis.publish(“redis-channel”, “hello world!”);

jedis.close();

}`

在服务端订阅Redis中指定的频道，当发送过来的频道消息被客户端收到后，即可进行相应的处理：

`private Jedis jedis;

public void subRedisMsg() {

jedis = redisUtils.getJedis();

//客户端可以订阅特定的频道，当频道发送信息时，收到后执行相应的操作

jedis.subscribe( new JedisPubSub() {

@Override

public void onMessage(String channel, String message) {

super.onMessage(channel, message);

// 相应的业务处理

// …

}

},”redis-channel”);

jedis.close();

}`

此外，在某些特殊情况下，我们还可以结合Redis中的服务端事件推送技术实现对Redis数据变化的实时推送。该技术通过调用Redis中特定的API实现客户端发出订阅事件，服务端将事件提交给Redis，当Redis发生变化时，客户端将收到服务端的事件推送：

`public void subscribeEvent() {

Jedis jedis = redisUtils.getJedis();

//通过redis提供的特定API订阅指定的键发生变动时，提供的回调事件

jedis.psubscribe( new JedisPubSub() {

@Override

public void onPMessage(String pattern, String channel, String message) {

super.onPMessage(pattern, channel, message);

// 相应的业务处理

// …

}

}, “__keyevent@0__:expired”);

jedis.close();

}`

以上两种技术都可以用于实现Redis实时变动的监听，有效提升服务端性能。另外，Redis也增加了一种异步命令，即Redis哨兵，它可以实现多台Redis服务器的实时发现和失效的扩展，进而提高客户端的操作稳定性和可用性。