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

spring:
  redis:
    host: localhost
    port: 6379

@Configuration
public class RedisConfig {
    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(redisConnectionFactory);
        return template;
    }
}

@Service
public class MessageProducer {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    private static final String MESSAGE_QUEUE = "message:queue";

    public void produce(String message) {
        redisTemplate.opsForList().leftPush(MESSAGE_QUEUE, message);
    }
}

@Service
public class MessageConsumer {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    private static final String MESSAGE_QUEUE = "message:queue";

    @Scheduled(fixedRate = 5000) // 每5秒檢查一次隊(duì)列
    public void consume() {
        String message = (String) redisTemplate.opsForList().rightPop(MESSAGE_QUEUE);
        if (message != null) {
            System.out.println("Consumed message: " + message);
            // 模擬處理消息
        }
    }
}

@Service
public class PubSubProducer {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    public void publishMessage(String channel, String message) {
        redisTemplate.convertAndSend(channel, message);
    }
}

@Service
public class PubSubConsumer implements MessageListener {

    @Override
    public void onMessage(Message message, byte[] pattern) {
        System.out.println("Received message: " + new String(message.getBody()));
    }
}

@Configuration
public class RedisPubSubConfig {

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

    @Bean
    public RedisMessageListenerContainer redisContainer(RedisConnectionFactory connectionFactory,
                                                        MessageListenerAdapter listenerAdapter) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(listenerAdapter, new PatternTopic("pubsub:channel"));
        return container;
    }
}

@RestController
@RequestMapping("/queue")
public class QueueController {

    @Autowired
    private MessageProducer messageProducer;

    @Autowired
    private PubSubProducer pubSubProducer;

    // 將消息放入隊(duì)列
    @PostMapping("/produce")
    public ResponseEntity<String> produceMessage(@RequestParam String message) {
        messageProducer.produce(message);
        return ResponseEntity.ok("Message produced");
    }

    // 發(fā)布消息
    @PostMapping("/publish")
    public ResponseEntity<String> publishMessage(@RequestParam String message) {
        pubSubProducer.publishMessage("pubsub:channel", message);
        return ResponseEntity.ok("Message published");
    }
}