订单超时设计（1）--- 如何使用redis实现订单超时实时关闭功能

准备工作

首先，需要确保你的Redis服务器已经开启了Keyspace Notifications功能。你可以在Redis的配置文件中设置以下参数，或者在Redis CLI中执行命令：

# 在redis.conf中设置
notify-keyspace-events Ex

或者在Redis CLI中执行：

CONFIG SET notify-keyspace-events Ex

实现步骤

1. 创建订单并设置过期时间：当用户创建订单时，将订单信息存储在Redis中，并设置一个过期时间（例如30分钟）。

2. 监听订单过期事件：使用Redis的Keyspace Notifications功能监听订单的过期事件，当订单过期时执行相应的关闭操作。

3. 处理订单关闭逻辑：在订单过期时，将订单状态设置为已取消，并进行相应的业务处理。

下面是一个简单的Java示例，使用Jedis库来实现：

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

public class OrderService {
    private static final String REDIS_HOST = "localhost";
    private static final int REDIS_PORT = 6379;
    private static final int ORDER_EXPIRE_TIME = 30 * 60; // 30 minutes in seconds

    private Jedis jedis;

    public OrderService() {
        this.jedis = new Jedis(REDIS_HOST, REDIS_PORT);
    }

    // 创建订单
    public void createOrder(String orderId) {
        // 存储订单信息到Redis，并设置过期时间
        jedis.setex("order:" + orderId, ORDER_EXPIRE_TIME, "PENDING");
        System.out.println("Order " + orderId + " created and will expire in 30 minutes.");
    }

    // 监听订单过期事件
    public void startOrderExpirationListener() {
        new Thread(() -> {
            try (Jedis jedis = new Jedis(REDIS_HOST, REDIS_PORT)) {
                jedis.psubscribe(new JedisPubSub() {
                    @Override
                    public void onPMessage(String pattern, String channel, String message) {
                        if (channel.equals("__keyevent@0__:expired")) {
                            handleOrderExpiration(message);
                        }
                    }
                }, "__keyevent@0__:expired");
            }
        }).start();
    }

    // 处理订单过期
    private void handleOrderExpiration(String orderKey) {
        if (orderKey.startsWith("order:")) {
            String orderId = orderKey.substring(6);
            System.out.println("Order " + orderId + " has expired and will be cancelled.");
            // 更新订单状态为已取消（在实际应用中，这里可以是数据库操作）
            // updateOrderStatus(orderId, "CANCELLED");
        }
    }

    public static void main(String[] args) throws InterruptedException {
        OrderService orderService = new OrderService();
        orderService.startOrderExpirationListener();

        // 创建一个示例订单
        orderService.createOrder("12345");

        // 保持主线程运行一段时间以便观察过期事件
        Thread.sleep(35 * 60 * 1000);
    }
}

解释

1. 创建订单：在 createOrder 方法中，我们将订单信息存储在Redis中，并使用 setex 方法设置订单的过期时间为30分钟。

2. 监听订单过期事件：在 startOrderExpirationListener 方法中，我们使用 psubscribe 方法监听Redis的过期事件。当订单过期时，Redis会发布一个过期事件，我们可以在 onPMessage 方法中处理这个事件。

3. 处理订单过期：在 handleOrderExpiration 方法中，我们处理订单过期的逻辑，例如将订单状态设置为已取消。在实际应用中，这里可以是数据库操作。

4. 运行示例：在 main 方法中，我们创建一个示例订单，并保持主线程运行一段时间以便观察过期事件。

这个示例展示了如何使用Redis实现订单超时实时关闭功能。在实际应用中，你可能需要根据具体需求进行扩展和优化，例如处理并发、错误处理和日志记录等。

注意事项（重点）

== 1.Keyspace Notifications无法实现事件的可靠通知。==
Keyspace Notifications功能是Redis从2.8.0版本开始支持的一项功能，它基于订阅/发布(Pub/Sub)机制，允许客户端接收Redis数据空间中键变化的事件通知‌。
Keyspace Notifications可以监控Redis中的键和值的变化，包括键的过期事件。当库中的键发生改变时，如添加、修改、删除或过期等，订阅了相应事件的客户端可以立即接收到通知。这一功能通过Pub/Sub频道实现，客户端需要订阅特定的频道来感知事件的发生。
值得注意的是，Redis的Pub/Sub功能是“触发后不管(Fire and Forget)”的，即如果发布/订阅的客户端断开连接，然后再重新连接，那么在客户端断开连接的期间内传递的所有事件都会丢失。因此，Keyspace Notifications无法实现事件的可靠通知。不过，Redis的未来版本可能会计划支持事件的可靠通知功能‌。
2.在分布式环境下要注意不能重复处理订单。