Redis 是最流行的 NoSQL 数据库解决方案之一,而 Java 是世界上最流行(注意,我没有说“最好”)的编程语言之一。虽然二者看起来很天然地在一块儿“工做”,可是要知道,Redis 其实并无对 Java 提供原生支持。git
相反,做为 Java 开发人员,咱们若想在程序中集成 Redis,必须使用 Redis 的第三方库。而 Redisson 就是用于在 Java 程序中操做 Redis 的库,它使得咱们能够在程序中轻松地使用 Redis。Redisson 在 java.util
中经常使用接口的基础上,为咱们提供了一系列具备分布式特性的工具类。github
在这篇文章里,我会给大家介绍 Redisson 的一些常见用例,请跟随我一块儿来看看吧。redis
安装 Redisson 最便捷的方法是使用 Maven 或者 Gradle:数据库
<dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version>3.11.4</version> </dependency> 复制代码
compile group: 'org.redisson', name: 'redisson', version: '3.11.4' 复制代码
目前 Redisson 最新版是 3.11.4,固然你也能够经过搜索 Maven 中央仓库 mvnrepository 来找到 Redisson 的各类版本。编程
安装 Redisson 后,只需使用 Java 编译器便可编译和运行 Redisson 代码:api
javac RedissonExamples.java
java RedissonExamples
复制代码
下面的代码简单演示了如何在 Redisson 中使用 RList
对象。RList
是 Java 的 List 集合的分布式并发实现。考虑如下代码:bash
import org.redisson.Redisson; import org.redisson.api.RList; import org.redisson.api.RedissonClient; public class ListExamples { public static void main(String[] args) { // 默认链接上 127.0.0.1:6379 RedissonClient client = Redisson.create(); // RList 继承了 java.util.List 接口 RList<String> nameList = client.getList("nameList"); nameList.clear(); nameList.add("bingo"); nameList.add("yanglbme"); nameList.add("https://github.com/yanglbme"); nameList.remove(-1); boolean contains = nameList.contains("yanglbme"); System.out.println("List size: " + nameList.size()); System.out.println("Is list contains name 'yanglbme': " + contains); nameList.forEach(System.out::println); client.shutdown(); } } 复制代码
运行上面的代码时,能够得到如下输出:微信
List size: 2 Is list contains name 'yanglbme': true bingo yanglbme 复制代码
Redisson 还包括 RMap,它是 Java Map 集合的分布式并发实现,考虑如下代码:markdown
import org.redisson.Redisson; import org.redisson.api.RMap; import org.redisson.api.RedissonClient; public class MapExamples { public static void main(String[] args) { // 默认链接上127.0.0.1:6379 RedissonClient client = Redisson.create(); // RMap 继承了 java.util.concurrent.ConcurrentMap 接口 RMap<String, String> map = client.getMap("personalInfo"); map.put("name", "yanglbme"); map.put("address", "Shenzhen"); map.put("link", "https://github.com/yanglbme"); boolean contains = map.containsKey("link"); System.out.println("Map size: " + map.size()); System.out.println("Is map contains key 'link': " + contains); String value = map.get("name"); System.out.println("Value mapped by key 'name': " + value); boolean added = map.putIfAbsent("link", "https://doocs.github.io") == null; System.out.println("Is value mapped by key 'link' added: " + added); client.shutdown(); } } 复制代码
运行上面的代码时,将会看到如下输出:
Map size: 3 Is map contains key 'link': true Value mapped by key 'name': yanglbme Is value mapped by key 'link' added: false 复制代码
RLock 是 Java 中可重入锁的分布式实现,下面的代码演示了 RLock 的用法:
import org.redisson.Redisson; import org.redisson.api.RLock; import org.redisson.api.RedissonClient; public class LockExamples { public static void main(String[] args) throws InterruptedException { // 默认链接上127.0.0.1:6379 RedissonClient client = Redisson.create(); // RLock 继承了 java.util.concurrent.locks.Lock 接口 RLock lock = client.getLock("lock"); lock.lock(); System.out.println("lock acquired"); Thread t = new Thread(() -> { RLock lock1 = client.getLock("lock"); lock1.lock(); System.out.println("lock acquired by thread"); lock1.unlock(); System.out.println("lock released by thread"); }); t.start(); t.join(1000); lock.unlock(); System.out.println("lock released"); t.join(); client.shutdown(); } } 复制代码
此代码将产生如下输出:
lock acquired
lock released
lock acquired by thread
lock released by thread
复制代码
RAtomicLong 是 Java 中 AtomicLong 类的分布式“替代品”,用于在并发环境中保存长值。如下示例代码演示了 RAtomicLong 的用法:
import org.redisson.Redisson; import org.redisson.api.RAtomicLong; import org.redisson.api.RedissonClient; public class AtomicLongExamples { public static void main(String[] args) { // 默认链接上127.0.0.1:6379 RedissonClient client = Redisson.create(); RAtomicLong atomicLong = client.getAtomicLong("myLong"); System.out.println("Init value: " + atomicLong.get()); atomicLong.incrementAndGet(); System.out.println("Current value: " + atomicLong.get()); atomicLong.addAndGet(10L); System.out.println("Final value: " + atomicLong.get()); client.shutdown(); } } 复制代码
此代码的输出将是:
Init value: 0
Current value: 1
Final value: 11
复制代码
怎么样,你学会了吗?更多 Redisson 相关文章,将在后续更新。有什么想法,欢迎留言区与我互动。
欢迎关注个人微信公众号“Doocs开源社区”,原创技术文章第一时间推送。