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 / ————