3.2. 异步流执行方式

Redisson为大多数分布式数据结构提供了满足Reactor项目的异步流处理标准的程序接口。该接口通过两种方式实现：

  1. 基于Project Reactor标准的实现方式。使用范例如下：
  1. RedissonReactiveClient client = Redisson.createReactive(config);
  2. RAtomicLongReactive atomicLong = client.getAtomicLong("myLong");
  3. Mono<Boolean> cs = longObject.compareAndSet(10, 91);
  4. Mono<Long> get = longObject.get();
  6. Publisher<Long> getPublisher = longObject.get();
  1. 基于RxJava2标准的实现方式。使用范例如下：
  1. RedissonRxClient client = Redisson.createRx(config);
  2. RAtomicLongRx atomicLong = client.getAtomicLong("myLong");
  3. Single<Boolean> cs = longObject.compareAndSet(10, 91);
  4. Single<Long> get = longObject.get();