资讯专栏INFORMATION COLUMN

Spring下Redis的响应式编程

wmui / 1842人阅读

摘要:从连接这个层次来做初始的响应式编程支持的,现在只支持因为它是唯一个支持响应式数据操作的驱动。因为一般用在非常低的抽象级别的,所以在现在这个版本上响应式编程的抽象是都是比较低级的接口的抽象。


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 set(ByteBuffer key, ByteBuffer value);                               Flux> set(Publisher commands);

}

传统的Spring Data Redis byte[]在其阻塞API上用于交换数据的。如果数据是在一个buffer(如ByteBuffer或Netty中的ByteBuf)中,那么这个byte[]数组会在buffer中进行强制数据复制。响应式支持很有很多是关于有效的资源使用,所以spring决定开放出了接收ByteBuffer参数的方法。

———— / END / ————

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/36969.html

相关文章

  • 华为官方首发Spring响应微服务,Spring+Boot+Cloud三管齐

    摘要:今天小编就来分享一份华为刚刚首发的响应式微服务实战这份主要包含响应式微服务架构实现过程中所应具备的技术体系和工程实践,在组织结构上分如下篇。 今天小编就来分享一份华为刚刚首发的Spring响应式微服务(Spring Boot 2+Spring 5+Spring Cloud实战)! 这份PDF...

    cangck_X 评论0 收藏0
  • Spring Boot 2.x 系列教程:WebFlux 系列教程大纲(一)

    摘要:使用则需要及以上版本。开发使用框架七系列教程目录系列教程大纲快速入门实践实践整合整合中和实践整合中实现缓存中实现通信集成测试及部署实战图书管理系统 WebFlux 系列教程大纲 一、背景 大家都知道,Spring Framework 是 Java/Spring 应用程序跨平台开发框架,也是 Java EE(Java Enterprise Edition) 轻量级框架,其 Spring ...

    jone5679 评论0 收藏0
  • Spring Boot 2 快速教程:WebFlux 快速入门(二)

    摘要:响应式编程是基于异步和事件驱动的非阻塞程序,只是垂直通过在内启动少量线程扩展,而不是水平通过集群扩展。三特性常用的生产的特性如下响应式编程模型适用性内嵌容器组件还有对日志消息测试及扩展等支持。 摘要: 原创出处 https://www.bysocket.com 「公众号:泥瓦匠BYSocket 」欢迎关注和转载,保留摘要,谢谢! 02:WebFlux 快速入门实践 文章工程: JDK...

    gaara 评论0 收藏0
  • 《 Kotlin + Spring Boot : 一代 Java 服务端开发 》

    摘要:下一代服务端开发下一代服务端开发第部门快速开始第章快速开始环境准备,,快速上手实现一个第章企业级服务开发从到语言的缺点发展历程的缺点为什么是产生的背景解决了哪些问题为什么是的发展历程容器的配置地狱是什么从到下一代企业级服务开发在移动开发领域 《 Kotlin + Spring Boot : 下一代 Java 服务端开发 》 Kotlin + Spring Boot : 下一代 Java...

    springDevBird 评论0 收藏0
  • Vert.x Blueprint 系列教程(一) | 待办事项服务开发教程

    摘要:本文章是蓝图系列的第一篇教程。是事件驱动的,同时也是非阻塞的。是一组负责分发和处理事件的线程。注意,我们绝对不能去阻塞线程,否则事件的处理过程会被阻塞,我们的应用就失去了响应能力。每个负责处理请求并且写入回应结果。 本文章是 Vert.x 蓝图系列 的第一篇教程。全系列: Vert.x Blueprint 系列教程(一) | 待办事项服务开发教程 Vert.x Blueprint 系...

    frank_fun 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<