redis实现的劣势
订单状态定义
首先,我们需要定义订单的不同状态。在这个示例中,我们可以定义以下订单状态:
WAITING_FOR_PAYMENT:待支付状态,表示用户已下单但尚未完成支付。
PAID:支付成功状态,表示用户已成功完成支付。
CANCELLED:已取消状态,表示订单已被取消。
发送订单消息到队列
当用户下单时,我们需要将订单信息发送到RabbitMQ队列中。在发送订单消息时,我们需要设置消息的TTL为30分钟,以便在30分钟后触发超时取消订单的逻辑。
java
@Component public class OrderProducer { @Autowired private RabbitTemplate rabbitTemplate; public void sendOrderMessage(String orderId) { OrderMessage orderMessage = new OrderMessage(); orderMessage.setOrderId(orderId); orderMessage.setStatus(OrderStatus.WAITING_FOR_PAYMENT); rabbitTemplate.convertAndSend("order.exchange", "order.routingKey", orderMessage, message -> { message.getMessageProperties().setExpiration("1800000"); // 设置消息的TTL为30分钟 return message; }); } }
创建一个消费者,监听DLX所指定的交换机,并根据订单状态的不同进行相应的处理。在这个示例中,我们将根据订单状态执行不同的逻辑,如果订单在30分钟内未支付,则执行取消订单的操作。
java
@Component public class OrderConsumer { @RabbitListener(queues = "order.dead-letter.queue") public void processExpiredOrder(OrderMessage orderMessage) { if (orderMessage.getStatus() == OrderStatus.WAITING_FOR_PAYMENT) { // 30分钟后未支付,取消订单 cancelOrder(orderMessage.getOrderId()); } } private void cancelOrder(String orderId) { // 执行取消订单的逻辑 System.out.println("Canceling order: " + orderId); // 更新订单状态为已取消 // orderService.cancelOrder(orderId); } }
在RabbitMQ中,我们需要创建一个交换机、一个队列和一个DLX(死信交换机),并将队列绑定到DLX上。同时,我们也需要设置DLX的路由键,以便将超时的订单消息发送到DLX中。
java
@Configuration public class RabbitMQConfig { @Bean public DirectExchange orderExchange() { return new DirectExchange("order.exchange"); } @Bean public Queue orderQueue() { return QueueBuilder.durable("order.queue") .withArgument("x-dead-letter-exchange", "order.dead-letter.exchange") .withArgument("x-dead-letter-routing-key", "order.dead-letter.routing-key") .build(); } @Bean public DirectExchange orderDeadLetterExchange() { return new DirectExchange("order.dead-letter.exchange"); } @Bean public Queue orderDeadLetterQueue() { return new Queue("order.dead-letter.queue"); } @Bean public Binding bindingOrder() { return BindingBuilder.bind(orderQueue()) .to(orderExchange()) .with("order.routingKey"); } @Bean public Binding bindingOrderDeadLetter() { return BindingBuilder.bind(orderDeadLetterQueue()) .to(orderDeadLetterExchange()) .with("order.dead-letter.routing-key"); } }
在以上配置中,我们定义了一个名为order.exchange的直连交换机,以及一个名为order.queue的队列。我们还定义了一个DLX,名为order.dead-letter.exchange,并将队列order.queue绑定到DLX上。当订单消息在30分钟内未被消费时,将会被发送到DLX中。
public class SeckillService { private final RedissonClient redissonClient; private final String luaScript; public SeckillService(RedissonClient redissonClient) { this.redissonClient = redissonClient; // 加载Lua脚本 this.luaScript = "local count = redis.call('get', KEYS[1])\n" + "if tonumber(count) >= tonumber(ARGV[1]) then\n" + " redis.call('decrby', KEYS[1], ARGV[1])\n" + " return 1\n" + "else\n" + " return 0\n" + "end"; } public boolean seckill(String productId, int quantity) { RLock lock = redissonClient.getLock(productId); try { // 加锁 lock.lock(); // 执行Lua脚本 RScript script = redissonClient.getScript(); List
构造方法初始化了SeckillService对象,并加载了Lua脚本。
luaScript:这个Lua脚本从Redis获取指定商品的库存数量,如果库存充足,则减少库存数量,并返回1表示秒杀成功;如果库存不足,则返回0表示秒杀失败。
方法:seckill
这个方法用于执行秒杀操作。
public boolean seckill(String productId, int quantity) { RLock lock = redissonClient.getLock(productId); try { // 加锁 lock.lock(); // 执行Lua脚本 RScript script = redissonClient.getScript(); List
方法步骤:
获取分布式锁:使用redissonClient.getLock(productId)获取商品ID对应的分布式锁。
加锁:使用lock.lock()方法加锁,确保秒杀操作的原子性。
执行Lua脚本:使用RScript执行预先加载的Lua脚本,该脚本会检查商品库存是否充足,并进行库存减少操作。
解析Lua脚本返回值:根据Lua脚本的返回值判断秒杀操作是否成功。返回值为1表示秒杀成功,返回值为0表示库存不足。
释放锁:使用lock.unlock()释放锁。
使用GEO
原文来源
SELECT chunk_number FROM uploaded_chunks WHERE file_id = 'file123' ORDER BY chunk_number DESC LIMIT 1;
这条查询语句会返回文件 ‘file123’ 最新上传的分片序号。
4.删除已上传的分片:
当文件上传完成后,可以根据需要删除已上传的分片信息。可以使用如下 SQL 删除语句:
DELETE FROM uploaded_chunks WHERE file_id = 'file123';
这条删除语句会删除文件 ‘file123’ 的所有已上传分片信息。
如果出现网络故障,那么我们如何保证数据不丢失
上一篇:二刷大数据(一)- Hadoop