分布式延时消息的另外一种选择 Redisson （推荐使用）

在Java中，使用Redisson进行分布式延时消息的处理可以通过RDelayedQueue接口实现。以下是一个简单的例子，展示如何使用Redisson发送和接收延时消息：

首先，添加Redisson的依赖到你的项目中（以Maven为例）：

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.XX.X</version> <!-- 使用最新的稳定版本 -->
</dependency>

然后，你可以使用以下代码发送一个延时消息：

import org.redisson.Redisson;
import org.redisson.api.RDelayedQueue;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
 
public class DelayedMessageExample {
 
    public static void main(String[] args) {
        // 1. 配置RedissonClient
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        RedissonClient redisson = Redisson.create(config);
 
        // 2. 获取延时队列
        RDelayedQueue<String> delayedQueue = redisson.getDelayedQueue();
 
        // 3. 发送延时消息
        long delayTime = 5000; // 延时5秒
        delayedQueue.offer("message", delayTime, TimeUnit.MILLISECONDS);
 
        // 4. 关闭RedissonClient
        redisson.shutdown();
    }
}

接收延时消息的代码如下：

import org.redisson.Redisson;
import org.redisson.api.RDelayedQueue;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
 
public class DelayedMessageConsumerExample {
 
    public static void main(String[] args) {
        // 1. 配置RedissonClient
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        RedissonClient redisson = Redisson.create(config);
 
        // 2. 获取延时队列
        RDelayedQueue<String> delayedQueue = redisson.getDelayedQueue();
 
        // 3. 消费延时消息
        delayedQueue.poll(10, TimeUnit.SECONDS); // 等待10秒
 
        // 4. 关闭RedissonClient
        redisson.shutdown();
    }
}

在上述代码中，发送方将消息发送到Redis的延时队列，并设置了一个延时时间，接收方则在指定的时间内轮询延时队列获取消息。这里的延时时间是以毫秒为单位。确保Redis服务器正在运行，并且配置中的地址与你的Redis服务器地址相匹配。