Spring如何使用redis实现消息队列呢?

spring 使用redis实现消息队列的实现思路

1.在Spring中引入相应的redisTemplate
2.定义 消息生产者
 3.定义 消息消费者

步骤一
配置Redis连接
   在application.properties
      或
     application.yml中
     配置Redis连接信息
       如:主机、端口和密码(如果有密码)

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

步骤二
  使用RedisTemplate实现消息生产者
   创建一个消息生产者
     使用RedisTemplate将消息发送到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("myQueueTest", message);
    }
}


步骤三
  使用MessagelistenerContainer实现消息消费者

  创建一个消息消费者
    使用MessageListenerContainer监听Redis队列并处理收到的消息

例：
import org.springframework.beans.factory.annotation.Autowired;
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;

@Configuration
public class RedisMessageListenerConfig {

    @Autowired
    private MessageListener messageListener;

    @Bean
    public MessageListenerAdapter messageListenerAdapter() {
        return new MessageListenerAdapter(messageListener);
    }

    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(
            RedisConnectionFactory connectionFactory,
            MessageListenerAdapter messageListenerAdapter) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(messageListenerAdapter, new ChannelTopic("myQueue"));
        return container;
    }
}


步骤四
  创建消息处理类
   创建一个消息处理类
    实现消息的处理逻辑
    这个类需要实现MessageListener接口：

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

public class MyMessageListener implements MessageListener {

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


步骤五
  使用消息生产者和消费者
   可使用MessageProducer发送消息
   然后MyMessageListener会监听并处理接收到的消息

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.commandlinerunner;
import org.springframework.stereotype.Component;

@Component
public class AppRunner implements CommandLineRunner {

    @Autowired
    private MessageProducer messageProducer;

    @Override
    public void run(String... args) {
        messageProducer.sendMessage("Hello, Redis Queue Test Java265.com!");
    }
}