Redisson 作为 Redis 的 Java 客户端，封装了多种数据结构与分布式并发组件。涵盖 RMap、RList、RSet 等基础存储类型，RLock、RReadWriteLock 等同步机制，以及 RQueue、RDelayedQueue 队列模型。此外还包括 RAtomicLong 计数器、RBloomFilter 布隆过滤器和 RRateLimiter 限流器。通过具体代码示例说明各组件的初始化、操作及典型应用场景，如用户缓存、订单超时处理、高并发计数等，助力解决分布式环境下的数据存储与并发控制问题。
Redisson 是 Redis 的 Java 客户端，封装了丰富的数据结构与分布式并发组件。
主要分为五类：
RMap<String, String> map = redissonClient.getMap("user:info");
map.put("name", "Tom");
map.get("name");
map.containsKey("name");
适合场景：
RList<String> list = redissonClient.getList("msg:list");
list.add("hello");
list.get(0);
适合场景：
RSet<Long> set = redissonClient.getSet("online:users");
set.add(1001L);
set.contains(1001L);
适合场景：
RSortedSet<String> zset = redissonClient.getSortedSet("rank:score");
zset.add(100, "Alice");
zset.add(80, "Bob");
适合场景：
RLock lock = redissonClient.getLock("lock:order");
lock.lock();
try {
// 临界区
} finally {
lock.unlock();
}
RReadWriteLock rwLock = redissonClient.getReadWriteLock("lock:product");
rwLock.readLock().lock();
// 读操作
rwLock.readLock().unlock();
rwLock.writeLock().lock();
// 写操作
rwLock.writeLock().unlock();
RSemaphore semaphore = redissonClient.getSemaphore("seckill");
semaphore.trySetPermits(10);
if (semaphore.tryAcquire()) {
// 抢到名额
}
RCountDownLatch latch = redissonClient.getCountDownLatch("task:done");
latch.trySetCount(3);
latch.await();
适合场景：分布式任务协调
RBlockingQueue<String> queue = redissonClient.getBlockingQueue("order:queue");
queue.put("order123");
queue.take();
RDelayedQueue<String> delayedQueue = redissonClient.getDelayedQueue(queue);
delayedQueue.offer("order123", 30, TimeUnit.MINUTES);
适合场景：订单超时 / 自动取消
RAtomicLong counter = redissonClient.getAtomicLong("order:id");
long id = counter.incrementAndGet();
RLongAdder adder = redissonClient.getLongAdder("pv:count");
adder.increment();
适合场景：高并发计数（比 AtomicLong 快）
RBitSet bitSet = redissonClient.getBitSet("sign:10086:202601");
bitSet.set(5);
bitSet.get(5);
bitSet.cardinality(); // 已签到天数
适合场景：签到统计
RBloomFilter<String> bloom = redissonClient.getBloomFilter("user:filter");
bloom.tryInit(100_000, 0.01);
bloom.add("user1");
bloom.contains("user1");
适合场景：防缓存穿透
RRateLimiter limiter = redissonClient.getRateLimiter("api:limit");
limiter.trySetRate(RateType.OVERALL, 10, 1, RateIntervalUnit.SECONDS);
if (limiter.tryAcquire()) {
// 允许访问
}
| 分类 | 结构 | 调用方式 |
|---|---|---|
| Map | RMap | getMap |
| List | RList | getList |
| Set | RSet | getSet |
| ZSet | RSortedSet | getSortedSet |
| 锁 | RLock | getLock |
| 读写锁 | RReadWriteLock | getReadWriteLock |
| 信号量 | RSemaphore | getSemaphore |
| 队列 | RBlockingQueue | getBlockingQueue |
| 延迟队列 | RDelayedQueue | getDelayedQueue |
| 计数器 | RAtomicLong | getAtomicLong |
| BitMap | RBitSet | getBitSet |
| 布隆 | RBloomFilter | getBloomFilter |
| 限流 | RRateLimiter | getRateLimiter |
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具，Keycode 信息在线工具，online
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。 在线工具，Escape 与 Native 编解码在线工具，online
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具，JavaScript / HTML 格式化在线工具，online
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。 在线工具，JavaScript 压缩与混淆在线工具，online
使用加密算法（如AES、TripleDES、Rabbit或RC4）加密和解密文本明文。 在线工具，加密/解密文本在线工具，online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online