[Java知识库] redisTemplate操作redis实现sub/sub发布订阅功能

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> Java知识库 -> redisTemplate操作redis实现sub/sub发布订阅功能 -> 正文阅读

[Java知识库]redisTemplate操作redis实现sub/sub发布订阅功能

当订阅了一个频道，向该频道里面发送消息，订阅这个频道的人就可以接收到消息，但是不支持持久化，redis宕机，网络错误就会消息丢失
需要四个类就可以了
第一步：初始化RedisTemplate

/**
 * @author Mr.zhou
 */
@Component
public class InitRedisTemplate {
    /**
     * 初始化RedisTemplate
     * @param connectionFactory
     * @return
     */
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(connectionFactory);
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new StringRedisSerializer());
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        // 这个地方不可使用 json 序列化，如果使用的是ObjectRecord传输对象时，可能会有问题，会出现一个 java.lang.IllegalArgumentException: Value must not be null! 错误
        redisTemplate.setHashValueSerializer(RedisSerializer.string());
        return redisTemplate;
    }
}

第二步：订阅频道，（频道写在配置文件当中，方便扩展）

/**
 * @author Mr.zhou
 */
@Slf4j
@RequiredArgsConstructor
@Configuration
public class Config {

    private final MessageListener messageListener;

    /**
     * 订阅三个频道
     * @param connectionFactory
     * @return
     */
    @Bean
    RedisMessageListenerContainer redisContainer(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        List<Topic> list = new ArrayList<>();
        list.add(new PatternTopic("ZHOU"));
        list.add(new PatternTopic("DA"));
        list.add(new PatternTopic("TOU"));
        container.addMessageListener(messageListener, list);
        return container;
    }
}

第三步：监听redis是否有数据进来

/**
 * @author Mr.zhou
 */
@Component
@Slf4j
public class RedisMessageListener implements MessageListener {
    /**
     * 监听redis是否有消息推送过来
     * @param message
     * @param pattern
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        log.info(message.toString());
    }
}

第四步：向指定的频道发送消息

@Controller
@RequestMapping("redis")
public class RedisController {

    @Autowired
    private RedisTemplate redisTemplate;

    @GetMapping(value = "send")
    public void send(){
        String message = "zhou";
        redisTemplate.convertAndSend("ZHOU", JSONObject.toJSONString(message));
        redisTemplate.convertAndSend("DA", JSONObject.toJSONString(message));
        redisTemplate.convertAndSend("TOU", JSONObject.toJSONString(message));
    }
}

结构图
pom.xml文件

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </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>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.72</version>
        </dependency>