Удивительно, оказалось, что Redisson так прост в использовании!

Redis
Удивительно, оказалось, что Redisson так прост в использовании!

Эта статья написанаyanglbmeОригинал, впервые опубликованный в публичном аккаунте"Сообщество открытого исходного кода Doocs", добро пожаловать на перепечатку.

Redis — одно из самых популярных решений для баз данных NoSQL, а Java — один из самых популярных (заметьте, я не сказал «лучших») языков программирования в мире. Хотя кажется, что они естественным образом «работают» вместе, имейте в виду, что Redis на самом деле не обеспечивает встроенную поддержку Java.

Напротив, как разработчики Java, если мы хотим интегрировать Redis в нашу программу, мы должны использовать стороннюю библиотеку для Redis. И Redisson — это библиотека для работы Redis в программах Java, которая позволяет нам легко использовать Redis в наших программах. Редиссон вjava.utilОсновываясь на обычно используемых интерфейсах в Китае, он предоставляет нам серию классов инструментов с распределенными характеристиками.

В этом посте я познакомлю вас с некоторыми распространенными вариантами использования 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 просто используйте компилятор Java для компиляции и запуска кода Redisson:

javac RedissonExamples.java

java RedissonExamples

Управление списками Redis с помощью RList

Следующий код просто демонстрирует, как использовать его в Redisson.RListобъект.RListЯвляется распределенной параллельной реализацией коллекции List Java. Рассмотрим следующий код:

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

Манипулирующий хэси redis с rmap

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

Атомарные операции Redis с использованием RAtomicLong

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, будут обновлены в будущем. Если у вас есть какие-либо идеи, добро пожаловать в общение со мной в области сообщений.

Добро пожаловать в мою общедоступную учетную запись WeChat «Сообщество открытого исходного кода Doocs». ​​Оригинальные технические статьи будут опубликованы как можно скорее.