Spring下Redis的响应式编程

Spring5支持响应式编程方式，能大大提升系统的吞吐量，可是要想实现整个系统的响应式编程须要每一个环节都要实现，今天就来说讲Spring是如何实现Redis的响应编程的。

Spring Data Redis从链接这个层次来作初始的响应式编程支持的，如今只支持Lettuce,由于它是惟一个支持响应式数据操做的Redis驱动。由于Redis通常用在很是低的抽象级别的，因此在如今这个版本上响应式编程的抽象是都是比较低级的接口的抽象。LettuceConnectionFactory容许依次访问ReactiveRedisConnection链接，并依次提供Redis的响应式的命令。

以响应式编程的风格，使用操做方法的函数链来建立链条去操做Redis中的数据，并且，全部I / O都是异步的。

ReactiveKeyCommands keyCommands =connection.keyCommands(); keyCommands.randomKey()

.flatMap(keyCommands::type)

.flatMap(System.out::println)

.subscribe();

以上代码获取随机密钥并打印了它的数据类型。不存在的随机密钥会输出为空Mono。

响应式Redis命令有两种形式：接受普通参数和接受命令发布者。命令发布者发出特定的Redis命令以将数据直接传输到Redis。执行命令后，每一个发出的命令都会发出命令响应。

public interface ReactiveStringCommands {

Mono<Boolean> set(ByteBuffer key, ByteBuffer value);                               Flux<BooleanResponse<SetCommand>> set(Publisher<SetCommand> commands);

}

传统的Spring Data Redis byte[]在其阻塞API上用于交换数据的。若是数据是在一个buffer（如ByteBuffer或Netty中的ByteBuf）中，那么这个byte[]数组会在buffer中进行强制数据复制。响应式支持颇有不少是关于有效的资源使用，因此spring决定开放出了接收ByteBuffer参数的方法。

———— / END / ————