SpringBoot中使用redis发布订阅的学习

1、引入POM文件：

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

2、Redis配置（在application.yml文件中配置）：

spring:
    redis:
        database: 0   # Redis数据库索引（默认为0）
        host: localhost  # Redis服务器地址
        port: 6379  # Redis服务器连接端口
        password:    # Redis服务器连接密码（默认为空）
        timeout: 5000  # 连接超时时间（毫秒）

3、实现消息生产者：

@RestController
public class SampleController {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    @GetMapping(value = "/send1")
    public String send1(String message) {
        redisTemplate.convertAndSend("TextChannel", message);
        return "send1 success";
    }

    @GetMapping(value = "send2")
    public String send2(String message) {
        redisTemplate.convertAndSend("kafkaChannel", message);
        return "send2 success";
    }
}

4、实现消息消费者：

@Component
public class RedisSubscriber extends MessageListenerAdapter {

    @Override
    public void onMessage(Message message, byte[] pattern) {
        System.out.println(message);
    }
}

5、配置消费者连接的Bean：

@Bean
public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
                                               MessageListenerAdapter listenerAdapter) {
    RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.addMessageListener(listenerAdapter, new PatternTopic("TextChannel"));
    container.addMessageListener(listenerAdapter, new PatternTopic("kafkaChannel"));//配置要订阅的订阅项
    return container;
}

6、测试：

http://localhost:8080/send1?message=111111
http://localhost:8080/send2?message=2222222