使用Redis的SETNX命令实现分布式锁，确保队列操作的原子性：String redisTemplate = new StringRedisTemplate(redisConnectionFactory); redisTemplate.opsForValue().setIfAbsent(lockKey, "locked", Duration.ofSeconds(30)); try { // 队列操作：LPUSH queueKey, value; // 原子执行 } finally { redisTemplate.delete(lockKey); } 这避免了高并发下多个进程同时pop或push导致数据丢失。

来源1

在高并发场景下，Redis队列如果不加锁，会出现数据竞争问题。比如多个消费者同时执行RPOP，可能会导致同一个元素被取出两次，或者队列状态混乱。解决方案是使用Redis的SETNX加锁：SET lock_key "value" NX PX 30000，先设置锁，超时30秒，然后执行队列操作，完成后DEL锁。但要用Lua脚本原子删除锁：if redis.call('get',KEYS[1])==ARGV[1] then return redis.call('del',KEYS[1]) else return 0 end。

来源2

Redis作为缓存队列时，痛点在于非原子操作，如检查队列长度再决定push，会被并发覆盖。使用MULTI/EXEC事务包裹LPUSH和检查：MULTI; LLEN queue; LPUSH queue item; EXEC; 但事务不保证原子性，最好用单个原子命令或锁。分布式锁用Redisson：RLock lock = redisson.getLock(lockKey); lock.lock(30, TimeUnit.SECONDS); 执行后unlock。

来源3

高并发下队列一致性问题常见于生产者消费者模型。无锁时，A进程LPUSH后B进程立即RPOP，可能丢失。加锁方案：基于Redis的红锁（Redlock），用多个Redis实例多数派投票加锁。代码：RedLock redLock = new RedLock(nodes); redLock.lock(lockName, ttl); //操作队列 redLock.unlock(lockName); 确保即使单点故障也安全。

来源4

数据并发安全痛点：Redis单线程但网络延迟导致伪并发。队列LPOP阻塞模式BRPOP可减少轮询，但多消费者仍竞争。用锁保护：public boolean processQueue() { String lockKey = "queue:lock"; if (redis.setnx(lockKey, "1")) { redis.expire(lockKey, 10); String item = redis.rpop(queueKey); redis.del(lockKey); return item != null; } return false; } 简单有效避免状态混乱。

来源5

确保原子性用管道（Pipeline）批量操作队列，但仍需锁防并发。Lua脚本最佳：local queue = KEYS[1]; local item = ARGV[1]; redis.call('lpush', queue, item); return redis.call('llen', queue); EVAL脚本原子执行push并返回长度，避免中间状态不一致。高并发测试QPS可达10w+。

来源6

避免数据竞争：不要用INCR做队列计数，改用LIST结构加锁。完整流程：获取锁-检查空-弹出处理-释放锁。异常时续锁或自动过期。Redlock库推荐用于金融级高一致性场景。

FAQ
Q: 为什么不用Redis事务而用锁？
A: 事务WATCH不防网络延迟失效，锁更可靠。
Q: 锁超时怎么设置？
A: 业务时间1.5倍，如操作5s设锁10s。
Q: Redlock和SETNX区别？
A: Redlock多节点容错，SETNX单节点。
Q: 队列空时锁怎么处理？
A: 快速释放或用BRPOP阻塞无锁竞争。