@RedisListener 注解怎么使用

@RedisListener 注解是 Spring Data Redis 提供的一个特性，它允许你方便地监听 Redis 的发布订阅消息。这个注解可以用来定义一个方法，当指定的频道或模式接收到消息时，该方法就会被调用。使用 @RedisListener 注解的基本步骤如下：

1. 确保你的项目中已经添加了 Spring Data Redis 的依赖。
2. 在 Spring 配置中启用 @RedisListener 注解的监听器，通常通过 `@EnableRedisHttpMessageConverter` 或者 `@EnableRedisHttpMessageListener` 注解来启用。
3. 在你希望处理消息的方法上使用 @RedisListener 注解。这个注解可以指定频道（channel），还可以配置多个监听器。
4. 方法的参数会自动填充为接收到的消息内容。

下面是一个简单的使用示例：

import org.springframework.data.redis.connection.Message;
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.stereotype.Component;

@Component
public class RedisMessageSubscriber {

    private final RedisMessageListenerContainer container;

    @Autowired
    public RedisMessageSubscriber(RedisMessageListenerContainer container) {
        this.container = container;
    }

    @RedisListener(channel = "my-channel")
    public void receiveMessage(Message message) {
        // 处理接收到的消息
        String msg = new String(message.getBody());
        System.out.println("Received message: " + msg);
    }
}

在上述代码中，`receiveMessage` 方法被标记为 @RedisListener，并指定了一个 channel 名称 "my-channel"。每当 "my-channel" 接收到消息时，`receiveMessage` 方法就会被调用。