1.面试官提问：你说你在项目中使用springsecurity + jwt 实现了登录功能，能简单讲一下怎么实现的吗？
2.使用RabbitMQ实现订单超时取消功能
redis实现的劣势
-
订单状态定义
首先，我们需要定义订单的不同状态。在这个示例中，我们可以定义以下订单状态：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.使用Redis+Lua脚本实现秒杀功能，后期用了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();List<Object> 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();List<Object> 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实现点赞
5.2搜索附近店铺
使用GEO
5.3签到
原文来源
5.4统计用户量
6.文件断点续传
6.1请说明记录已上传的分片这部分怎么实现？
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’ 的所有已上传分片信息。
6.2那这种断点续传的方式会有数据丢失的问题吗？
如果出现网络故障，那么我们如何保证数据不丢失
