厲害了，原來 Redisson 這麼好用！

本文由 yanglbme 原創，首發於公衆號「Doocs開源社區」，歡迎轉載。

Redis 是最流行的 NoSQL 數據庫解決方案之一，而 Java 是世界上最流行（注意，我沒有說「最好」）的編程語言之一。雖然二者看起來很天然地在一塊兒「工做」，可是要知道，Redis 其實並無對 Java 提供原生支持。

相反，做爲 Java 開發人員，咱們若想在程序中集成 Redis，必須使用 Redis 的第三方庫。而 Redisson 就是用於在 Java 程序中操做 Redis 的庫，它使得咱們能夠在程序中輕鬆地使用 Redis。Redisson 在 java.util 中經常使用接口的基礎上，爲咱們提供了一系列具備分佈式特性的工具類。

在這篇文章裏，我會給大家介紹 Redisson 的一些常見用例，請跟隨我一塊兒來看看吧。

如何安裝 Redisson

安裝 Redisson 最便捷的方法是使用 Maven 或者 Gradle：

• Maven

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.11.4</version>
</dependency>
複製代碼

• Gradle

compile group: 'org.redisson', name: 'redisson', version: '3.11.4'
複製代碼

目前 Redisson 最新版是 3.11.4，固然你也能夠經過搜索 Maven 中央倉庫 mvnrepository 來找到 Redisson 的各類版本。

如何編譯運行 Redisson

安裝 Redisson 後，只需使用 Java 編譯器便可編譯和運行 Redisson 代碼：

javac RedissonExamples.java

java RedissonExamples
複製代碼

使用 RList 操做 Redis 列表

下面的代碼簡單演示瞭如何在 Redisson 中使用 RList 對象。RList 是 Java 的 List 集合的分佈式併發實現。考慮如下代碼：

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
複製代碼

使用 RMap 操做 Redis 哈希

Redisson 還包括 RMap，它是 Java Map 集合的分佈式併發實現，考慮如下代碼：

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 實現 Redis 分佈式鎖

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 實現 Redis 原子操做

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開源社區」，原創技術文章第一時間推送。