分布式锁的应用场景：
一个在线考试的系统中，使用Kafka进行异步的答题记录的提交。
在这个过程中，由于各种原因（网络、或者是重试过程中）可能会导致Kafka重新消费同一条消息。
这时候会出现幂等性的问题。
要解决幂等性的问题，可以在send数据之前首先进行数据库的查询操作。
这时候在查询和send数据的两个动作需要是一个原子性的操作
在这里使用一个分布式锁。
同时可以进一步优化，当一个请求进来的时候就开启一个子线程？或者开启一个异步任务来操作上述的代码。

  1. setnx

  2. redisson分布式锁

 private static final String LOCK_KEY = "myLock"; @Resource private RedissonClient redissonClient; public void doSomething() { RLock lock = redissonClient.getLock(LOCK_KEY); try { // 获取分布式锁，设置超时时间为10秒 boolean acquired = lock.tryLock(10, TimeUnit.SECONDS); if (acquired) { // 获取锁成功，执行具体操作 // ... } else { // 获取锁失败，执行其他逻辑 // ... } } catch (InterruptedException e) { Thread.currentThread().interrupt(); } finally { // 释放锁 lock.unlock(); } }

此外Redisson还提供了读写锁的实现，用来实现读写操作的并发控制

private static final String LOCK_KEY = "myReadWriteLock";@Resourceprivate RedissonClient redissonClient;public void writeData() {RReadWriteLock lock = redissonClient.getReadWriteLock(LOCK_KEY);Lock writeLock = lock.writeLock();writeLock.lock();try {// 写操作// ...} finally {writeLock.unlock();}}public void readData() {RReadWriteLock lock = redissonClient.getReadWriteLock(LOCK_KEY);Lock readLock = lock.readLock();readLock.lock();try {// 读操作// ...} finally {readLock.unlock();}}