订单幂等设计问题,希望通过一个数据结构存储 24 小时的订单号,希望存储在本地内存中,服务启动的时候可以自动预热加载,24 小时自动滚动。
作用:
- 新下单的时候判断这个订单号是否存在,如果不存在就可以下单。
- 如果存在就不能下单。
数据量大约 3w/s
24 小时大约 3 亿数据
订单幂等设计问题,希望通过一个数据结构存储 24 小时的订单号,希望存储在本地内存中,服务启动的时候可以自动预热加载,24 小时自动滚动。
作用:
数据量大约 3w/s
24 小时大约 3 亿数据
1、创建一个 Redis 数据库,并设置一个订单号集合(Set)。
2、在服务启动时,从 Redis 中获取24小时内的订单号,并将其存储在本地内存中。
3、当有新的订单时,先检查该订单号是否存在于本地内存中。如果存在,则表示该订单已存在,不能下单;如果不存在,则将订单号添加到本地内存中,并将其插入 Redis 订单号集合中。
4、每隔一段时间(例如1小时),将本地内存中的订单号滚动更新到 Redis 中,以保持数据的一致性。
import redis
# 创建 Redis 数据库连接
redis_client = redis.Redis(host='localhost', port=6379)
def store_order_id(order_id):
# 将订单号添加到 Redis 集合中
redis_client.sadd('order_ids', order_id)
def check_order_id(order_id):
# 检查订单号是否存在于 Redis 集合中
return redis_client.sismember('order_ids', order_id)
# 示例用法
order_id = 'your_order_id'
store_order_id(order_id)
if check_order_id(order_id):
print("Order ID exists, cannot place the order.")
else:
print("Order ID does not exist, you can place the order.")