相关推荐recommended
面试总结------20240404---项目
作者:mmseoamin日期:2024-04-29

1.面试官提问:你说你在项目中使用springsecurity + jwt 实现了登录功能,能简单讲一下怎么实现的吗?

面试总结------20240404---项目,在这里插入图片描述,第1张

2.使用RabbitMQ实现订单超时取消功能

redis实现的劣势

面试总结------20240404---项目,在这里插入图片描述,第2张

面试总结------20240404---项目,在这里插入图片描述,第3张

面试总结------20240404---项目,在这里插入图片描述,第4张

  1. 订单状态定义

    首先,我们需要定义订单的不同状态。在这个示例中,我们可以定义以下订单状态:

    WAITING_FOR_PAYMENT:待支付状态,表示用户已下单但尚未完成支付。

    PAID:支付成功状态,表示用户已成功完成支付。

    CANCELLED:已取消状态,表示订单已被取消。

  2. 发送订单消息到队列

    当用户下单时,我们需要将订单信息发送到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;
        });
    }
}
  1. 创建订单状态转换的消费者

    创建一个消费者,监听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);
    }
}
  1. 配置RabbitMQ

    在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中。

面试总结------20240404---项目,在这里插入图片描述,第5张

3.使用Redis+Lua脚本实现秒杀功能,后期用了Redisson锁进行优化处理。

面试总结------20240404---项目,在这里插入图片描述,第6张

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 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 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()释放锁。

面试总结------20240404---项目,在这里插入图片描述,第7张

4.使用elasticsearch来检索系统日志。

面试总结------20240404---项目,在这里插入图片描述,第8张

5.使用Redis十大类型实现点赞,搜索附近店铺,签到,统计用户量等功能。

5.1Redis实现点赞

面试总结------20240404---项目,第9张

面试总结------20240404---项目,在这里插入图片描述,第10张

5.2搜索附近店铺

使用GEO

面试总结------20240404---项目,在这里插入图片描述,第11张

5.3签到

原文来源

面试总结------20240404---项目,在这里插入图片描述,第12张

面试总结------20240404---项目,在这里插入图片描述,第13张

5.4统计用户量

面试总结------20240404---项目,在这里插入图片描述,第14张

面试总结------20240404---项目,在这里插入图片描述,第15张

6.文件断点续传

面试总结------20240404---项目,在这里插入图片描述,第16张

6.1请说明记录已上传的分片这部分怎么实现?

面试总结------20240404---项目,在这里插入图片描述,第17张

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那这种断点续传的方式会有数据丢失的问题吗?

面试总结------20240404---项目,在这里插入图片描述,第18张

如果出现网络故障,那么我们如何保证数据不丢失

面试总结------20240404---项目,在这里插入图片描述,第19张

面试总结------20240404---项目,在这里插入图片描述,第20张