网站建设买服务器价格,网络规划设计师最新教材,自动提卡的网站怎么做的,花80亿美元建空间站1.面试官提问#xff1a;你说你在项目中使用springsecurity jwt 实现了登录功能#xff0c;能简单讲一下怎么实现的吗#xff1f; 2.使用RabbitMQ实现订单超时取消功能 订单状态定义 首先#xff0c;我们需要定义订单的不同状态。在这个示例中#xff0c;我们可以定义以下…1.面试官提问你说你在项目中使用springsecurity jwt 实现了登录功能能简单讲一下怎么实现的吗 2.使用RabbitMQ实现订单超时取消功能 订单状态定义 首先我们需要定义订单的不同状态。在这个示例中我们可以定义以下订单状态 WAITING_FOR_PAYMENT待支付状态表示用户已下单但尚未完成支付。 PAID支付成功状态表示用户已成功完成支付。 CANCELLED已取消状态表示订单已被取消。 发送订单消息到队列 当用户下单时我们需要将订单信息发送到RabbitMQ队列中。在发送订单消息时我们需要设置消息的TTL为30分钟以便在30分钟后触发超时取消订单的逻辑。
java
Component
public class OrderProducer {Autowiredprivate 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 在RabbitMQ中我们需要创建一个交换机、一个队列和一个DLX死信交换机并将队列绑定到DLX上。同时我们也需要设置DLX的路由键以便将超时的订单消息发送到DLX中。
java
Configuration
public class RabbitMQConfig {Beanpublic DirectExchange orderExchange() {return new DirectExchange(order.exchange);}Beanpublic 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();}Beanpublic DirectExchange orderDeadLetterExchange() {return new DirectExchange(order.dead-letter.exchange);}Beanpublic Queue orderDeadLetterQueue() {return new Queue(order.dead-letter.queue);}Beanpublic Binding bindingOrder() {return BindingBuilder.bind(orderQueue()).to(orderExchange()).with(order.routingKey);}Beanpublic 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中。
3.使用RedisLua脚本实现秒杀功能后期用了Redisson锁进行优化处理。 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();ListObject result script.eval(RScript.Mode.READ_WRITE, luaScript, RScript.ReturnType.INTEGER, Collections.singletonList(productId), String.valueOf(quantity));// Lua脚本返回值为1表示秒杀成功0表示库存不足return result ! null result.size() 0 (int) result.get(0) 1;} finally {// 释放锁lock.unlock();}}
}构造方法初始化了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();ListObject result script.eval(RScript.Mode.READ_WRITE, luaScript, RScript.ReturnType.INTEGER, Collections.singletonList(productId), String.valueOf(quantity));// Lua脚本返回值为1表示秒杀成功0表示库存不足return result ! null result.size() 0 (int) result.get(0) 1;} finally {// 释放锁lock.unlock();}
}方法步骤 获取分布式锁使用redissonClient.getLock(productId)获取商品ID对应的分布式锁。 加锁使用lock.lock()方法加锁确保秒杀操作的原子性。 执行Lua脚本使用RScript执行预先加载的Lua脚本该脚本会检查商品库存是否充足并进行库存减少操作。 解析Lua脚本返回值根据Lua脚本的返回值判断秒杀操作是否成功。返回值为1表示秒杀成功返回值为0表示库存不足。 释放锁使用lock.unlock()释放锁。
4.使用elasticsearch来检索系统日志。 5.使用Redis十大类型实现点赞搜索附近店铺签到统计用户量等功能。
5.1Redis十大类型实现点赞
