厲害了,原來 Redisson 這麼好用!

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

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

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

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

如何安裝 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 代碼:api

javac RedissonExamples.java

java RedissonExamples
複製代碼

使用 RList 操做 Redis 列表

下面的代碼簡單演示瞭如何在 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
複製代碼

使用 RMap 操做 Redis 哈希

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

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 相關文章,將在後續更新。有什麼想法,歡迎留言區與我互動。

相關文章
相關標籤/搜索