快捷導(dǎo)航

基于Redis實現(xiàn)訂閱發(fā)布功能

更新時間：2026年05月12日 08:39:56 作者：Ricoh.

本文介紹了在SpringBoot項目中使用Redis實現(xiàn)異步解耦的方法,無需引入MQ中間件,首先引入Redis依賴并配置Redis,隨后創(chuàng)建Redis配置類來配置Redis連接工廠和監(jiān)聽器,接著創(chuàng)建消息訂閱者和發(fā)布者,通過RedisTemplate發(fā)送消息,最后強調(diào)了可以設(shè)置多個消息適配器來監(jiān)聽多個channel

背景

業(yè)務(wù)發(fā)展過程中，希望做到異步解耦，但是又不想引入MQ中間件，在中小型服務(wù)中，就可以考慮使用redis自帶的訂閱發(fā)布來解決這個問題。使用 Redis 實現(xiàn)消息的訂閱和發(fā)布時，可以通過 Spring Boot 集成 Redis 來方便地實現(xiàn)。

引入redis依賴

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

配置 Redis

在 application.properties 文件中，添加 Redis 配置：

spring.redis.host=localhost
spring.redis.port=6379

編寫代碼

Redis 配置

創(chuàng)建一個配置類來配置 Redis 的連接工廠和監(jiān)聽器：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
import org.springframework.data.redis.core.StringRedisTemplate;
@Configuration
public class RedisConfig {
    @Bean
    public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
                                                   MessageListenerAdapter listenerAdapter) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(listenerAdapter, topic());
        return container;
    }
    @Bean
    public MessageListenerAdapter listenerAdapter(RedisMessageSubscriber subscriber) {
        return new MessageListenerAdapter(subscriber, "onMessage");
    }
    @Bean
    public ChannelTopic topic() {
        return new ChannelTopic("messageQueue");
    }
    @Bean
    public StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
        return new StringRedisTemplate(connectionFactory);
    }
}

創(chuàng)建消息訂閱者

編寫一個類來處理收到的消息：

import org.springframework.stereotype.Service;
@Service
public class RedisMessageSubscriber {
    public void onMessage(String message, String channel) {
        System.out.println("Received message: " + message + " from channel: " + channel);
    }
}

創(chuàng)建消息發(fā)布者

編寫一個發(fā)布者通過 Redis 模板發(fā)送消息：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class MessagePublisher {
    @Autowired
    private StringRedisTemplate template;
    @Autowired
    private ChannelTopic topic;
    @GetMapping("/publish")
    public String publish(@RequestParam String message) {
        template.convertAndSend(topic.getTopic(), message);
        return "Message published: " + message;
    }
}

如果需要監(jiān)聽多個channel，可以通過RedisConfig中添加新的消息適配器。

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
import org.springframework.data.redis.core.StringRedisTemplate;
@Configuration
public class RedisConfig {
    @Bean
    public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
            MessageListenerAdapter listenerAdapter1,
            MessageListenerAdapter listenerAdapter2) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(listenerAdapter1, topic1());
        container.addMessageListener(listenerAdapter2, topic2());
        return container;
    }
    @Bean
    public MessageListenerAdapter listenerAdapter1(RedisMessageSubscriber subscriber) {
        return new MessageListenerAdapter(subscriber, "onMessage");
    }
    @Bean
    public MessageListenerAdapter listenerAdapter2(RedisMessageSubscriber subscriber) {
        return new MessageListenerAdapter(subscriber, "onMessage");
    }
    @Bean
    public ChannelTopic topic1() {
        return new ChannelTopic("channelOne");
    }
    @Bean
    public ChannelTopic topic2() {
        return new ChannelTopic("channelTwo");
    }
    @Bean
    public StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
        return new StringRedisTemplate(connectionFactory);
    }
}

同時RedisMessageSubscriber 也可以書寫多個來區(qū)分不同的業(yè)務(wù)場景下不同業(yè)務(wù)處理。

到此這篇關(guān)于Redis分布式系統(tǒng)的原理與實操的文章就介紹到這了,更多相關(guān)Redis分布式系統(tǒng)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: