RedissonClientRedissonReactiveClientRedissonRxClient实例本身和Redisson提供的所有分布式对象都是线程安全的。

    Redisson为每个操作都提供了自动重试策略,当某个命令执行失败时,Redisson会自动进行重试。自动重试策略可以通过修改retryAttempts(默认值:3)参数和retryInterval(默认值:1000毫秒)参数来进行优化调整。当等待时间达到retryInterval指定的时间间隔以后,将自动重试下一次。全部重试失败以后将抛出错误。

    Redisson框架提供的几乎所有对象都包含了同步异步相互匹配的方法。这些对象都可以通过RedissonClient接口获取。同时还为大部分Redisson对象提供了满足异步流处理标准的程序接口RedissonReactiveClient。除此外还提供了RxJava2规范的RedissonRxClient程序接口。

    以下是关于使用RAtomicLong对象的范例:

    1. RedissonClient client = Redisson.create(config);
    2. RAtomicLong longObject = client.getAtomicLong('myLong');
    3. // 同步执行方式
    4. longObject.compareAndSet(3, 401);
    5. // 异步执行方式
    6. RFuture<Boolean> result = longObject.compareAndSetAsync(3, 401);
    7. RedissonReactiveClient client = Redisson.createReactive(config);
    8. RAtomicLongReactive longObject = client.getAtomicLong('myLong');
    9. // 异步流执行方式
    10. Mono<Boolean> result = longObject.compareAndSet(3, 401);
    11. RedissonRxClient client = Redisson.createRx(config);
    12. RAtomicLongRx longObject= client.getAtomicLong("myLong");
    13. // RxJava2方式
    14. Flowable<Boolean result = longObject.compareAndSet(3, 401);