乐趣区

关于springboot:SpringBoot-DB-系列Redis-高级特性之发布订阅

jiezi

【SpringBoot DB 系列】Redis 高级个性之公布订阅

通常来讲，当咱们业务存在音讯的业务逻辑时更多的是间接应用成熟的 rabbitmq,rocketmq，然而一些简略的业务场景中，真的有必要额定的引入一个 mq 么？本文将介绍一下 redis 的公布订阅形式，来实现繁难的音讯零碎逻辑

<!– more –>

I. 根本应用

1. 配置

咱们应用 SpringBoot 2.2.1.RELEASE来搭建我的项目环境，间接在 pom.xml 中增加 redis 依赖

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

如果咱们的 redis 是默认配置，则能够不额定增加任何配置；也能够间接在 application.yml 配置中，如下

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password:

2. 应用姿态

redis 的公布 / 订阅，次要就是利用两个命令publish/subscribe; 在 SpringBoot 中应用公布订阅模式比较简单，借助 RedisTemplate 能够很不便的实现

a. 音讯公布

@Service
public class PubSubBean {
    @Autowired
    private StringRedisTemplate redisTemplate;

    public void publish(String key, String value) {redisTemplate.execute(new RedisCallback<Object>() {
            @Override
            public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {redisConnection.publish(key.getBytes(), value.getBytes());
                return null;
            }
        });
    }
}

b. 订阅音讯

音讯订阅这里，须要留神咱们借助 org.springframework.data.redis.connection.MessageListener 来实现生产逻辑

public void subscribe(MessageListener messageListener, String key) {redisTemplate.execute(new RedisCallback<Object>() {
        @Override
        public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {redisConnection.subscribe(messageListener, key.getBytes());
            return null;
        }
    });
}

c. 测试 case

写一个简略的测试 case，来验证一下下面的公布订阅，顺带了解一下这个 MessageListener 的应用姿态；咱们创立一个简略的 WEB 工程，提供两个 rest 接口

@RestController
@RequestMapping(path = "rest")
public class DemoRest {
    @Autowired
    private PubSubBean pubSubBean;

    // 公布音讯
    @GetMapping(path = "pub")
    public String pubTest(String key, String value) {pubSubBean.publish(key, value);
        return "over";
    }

    // 新增消费者
    @GetMapping(path = "sub")
    public String subscribe(String key, String uuid) {pubSubBean.subscribe(new MessageListener() {
            @Override
            public void onMessage(Message message, byte[] bytes) {System.out.println(uuid + "==> msg:" + message);
            }
        }, key);
        return "over";
    }
}

上面通过一个动图来演示一下 case

咱们先创立了两个消费者，而后发送音讯时，两个都收到；再新增一个消费者，发送音讯时，三个都能收到

3. 应用阐明与利用场景

redis 的公布订阅，只实用于比较简单的场景，从下面的应用阐明也能看出，它就是一个简略的公布订阅模型，反对 1 对 N，而且发送的音讯，只有在线的消费者能力 get 到（至于不在线的，那就只能说遗憾了）而且对于 redis 而言，音讯推出去之后就完事了，至于消费者能不能失常生产，那就不 care 了

划重点：

  • 只有在线的消费者能接管到音讯
  • 对于消费者一个音讯只能拿到一次

接下来的问题就来了，什么样的场景下能够应用 redis 的公布订阅呢？

基于内存的缓存生效

利用 reids + 内存做二级缓存，能够说是比拟常见的形式了，借助基于内存的缓存，能够无效的进步零碎的负载，然而问题也很显著，内存中缓存数据生效是个问题，特地是当一个利用部署多台服务器时，如果我心愿同时生效所有服务器的某个内存缓存，应用 redis 的公布 / 订阅就是一个比拟好的抉择

SpringCloud Config 配置刷新

应用 SpringCloud Config 做配置核心的小伙伴可能会常常遇到这个问题，配置批改之后的动静刷新是个问题（当然官网是反对通过 mq 走 bus 总线来同步，也能够通过 spring boot admin 来强刷）

借助 redis 公布 / 订阅，实现配置动静刷新也是一个不错的备选计划（前面给出一个具体的实现 demo，如有趣味请继续关注一灰灰 Blog）

redis key 生效订阅

咱们在应用 redis 做缓存时，通常会设置一个过期工夫，redis 提供了一个过期的事件，当然默认是不开启的；咱们也是能够通过 subscribe 来订阅缓存生效的事件

批改配置，开启 key 生效事件

notify-keyspace-events Ex

重启 redis 之后，订阅生效事件即可

subscribe __keyevent@0__:expired

II. 其余

0. 我的项目

系列博文

  • 【DB 系列】Redis 高级个性之 Bitmap 应用姿态及利用场景介绍
  • 【DB 系列】Redis 之管道 Pipelined 应用姿态
  • 【DB 系列】Redis 集群环境配置
  • 【DB 系列】借助 Redis 搭建一个简略站点统计服务（利用篇）
  • 【DB 系列】借助 Redis 实现排行榜性能（利用篇）
  • 【DB 系列】Redis 之 ZSet 数据结构应用姿态
  • 【DB 系列】Redis 之 Set 数据结构应用姿态
  • 【DB 系列】Redis 之 Hash 数据结构应用姿态
  • 【DB 系列】Redis 之 List 数据结构应用姿态
  • 【DB 系列】Redis 之 String 数据结构的读写
  • 【DB 系列】Redis 之 Jedis 配置
  • 【DB 系列】Redis 之根本配置

工程源码

  • 工程：https://github.com/liuyueyi/spring-boot-demo
  • 我的项目源码: https://github.com/liuyueyi/spring-boot-demo/tree/master/spring-boot/122-redis-template

1. 一灰灰 Blog

尽信书则不如，以上内容，纯属一家之言，因集体能力无限，不免有疏漏和谬误之处，如发现 bug 或者有更好的倡议，欢送批评指正，不吝感谢

上面一灰灰的集体博客，记录所有学习和工作中的博文，欢送大家前去逛逛

  • 一灰灰 Blog 集体博客 https://blog.hhui.top
  • 一灰灰 Blog-Spring 专题博客 http://spring.hhui.top

退出移动版