springboot实现redis消息队列

在 Spring Boot 中实现 Redis 消息队列，你可以使用 Spring Data Redis 提供的功能来实现。下面是一个示例代码，演示了如何在 Spring Boot 中创建一个基于 Redis 的消息队列：

首先，确保已经添加了 Spring Data Redis 依赖到你的项目中。

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

然后，在你的配置文件（例如 application.properties 或 application.yml）中配置 Redis 连接信息。

application.properties:

spring.redis.host=your_redis_host
spring.redis.port=your_redis_port

或者 application.yml:

spring:
  redis:
    host: your_redis_host
    port: your_redis_port

接下来，创建一个消息生产者和一个消息消费者。

首先，创建一个消息生产者类，用于发送消息到 Redis 队列。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

@Component
public class MessageProducer {

    private final RedisTemplate<String, String> redisTemplate;

    @Autowired
    public MessageProducer(RedisTemplate<String, String> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    public void sendMessage(String message) {
        redisTemplate.convertAndSend("your_queue_name", message);
    }
}

在上述代码中，我们使用 RedisTemplate 来执行 Redis 操作，通过 convertAndSend() 方法向指定队列发送消息。

然后，创建一个消息消费者类，用于接收并处理消息。

import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.stereotype.Component;

@Component
public class MessageConsumer implements MessageListener {

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String receivedMessage = message.toString();
        System.out.println("Received message: " + receivedMessage);
        // 处理消息逻辑
    }
}

在上述代码中，我们实现了 MessageListener 接口，并重写了 onMessage() 方法来处理接收到的消息。

最后，配置 Redis 消息监听器和消息队列。

import org.springframework.context.annotation.Bean;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
import org.springframework.data.redis.serializer.StringRedisSerializer;

@Configuration
public class RedisMessageQueueConfig {

    @Autowired
    private MessageConsumer messageConsumer;

    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(new MessageListenerAdapter(messageConsumer, new StringRedisSerializer()), new PatternTopic("your_queue_name"));
        return container;
    }
}

在上述配置中，我们创建了一个 RedisMessageListenerContainer 对象，并设置了 Redis 连接工厂。然后，通过调用 addMessageListener() 方法将消息监听器 MessageConsumer 和队列名称注册到容器中。

这样就完成了 Redis 消息队列的实现。你可以在其他组件或服务中注入 MessageProducer 类，使用 sendMessage() 方法发送消息到队列。当有新消息到达队列时，MessageConsumer 类的 onMessage() 方法将被调用来处理消息。

请注意，示例代码中的 “your_queue_name” 是你自己定义的 Redis 队列名称，需要根据实际情况进行修改。