返回顶部
首页 > 资讯 > 精选 >java9新特性Reactive Stream响应式编程API怎么用
  • 871
分享到

java9新特性Reactive Stream响应式编程API怎么用

2023-06-29 12:06:21 871人浏览 八月长安
摘要

这篇文章主要介绍“java9新特性Reactive Stream响应式编程api怎么用”,在日常操作中,相信很多人在java9新特性Reactive Stream响应式编程API怎么用问题上存在疑惑,小编查阅了各式资料,

这篇文章主要介绍“java9新特性Reactive Stream响应式编程api怎么用”,在日常操作中,相信很多人在java9新特性Reactive Stream响应式编程API怎么用问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”java9新特性Reactive Stream响应式编程API怎么用”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

一、Java9 Reactive Stream API

Java 9提供了一组定义响应式流编程的接口。所有这些接口都作为静态内部接口定义在java.util.concurrent.Flow类里面。

java9新特性Reactive Stream响应式编程API怎么用

下面是Java 响应式编程中的一些重要角色和概念,先简单理解一下

发布者(Publisher)是潜在的无限数量的有序数据元素的生产者。 它根据收到的需求(subscription)向当前订阅者发布一定数量的数据元素。

订阅者(Subscriber)从发布者那里订阅并接收数据元素。与发布者建立订阅关系后,发布者向订阅者发送订阅令牌(subscription),订阅者可以根据自己的处理能力请求发布者发布数据元素的数量。

订阅令牌(subscription)表示订阅者与发布者之间建立的订阅关系。 当建立订阅关系后,发布者将其传递给订阅者。 订阅者使用订阅令牌与发布者进行交互,例如请求数据元素的数量或取消订阅。

二、Java响应式编程四大接口

2.1.Subscriber Interface(订阅者订阅接口)

public static interface Subscriber<T> {    public void onSubscribe(Subscription subscription);    public void onNext(T item);    public void onError(Throwable throwable);    public void onComplete();}

onSubscribe:在发布者接受订阅者的订阅动作之后,发布任何的订阅消息之前被调用。新创建的Subscription订阅令牌对象通过此方法传递给订阅者。

onNext:下一个待处理的数据项的处理函数

onError:在发布者或订阅遇到不可恢复的错误时调用

onComplete:当没有订阅者调用(包括onNext()方法)发生时调用。

2.2.Subscription Interface (订阅令牌接口)

订阅令牌对象通过Subscriber.onSubscribe()方法传递

public static interface Subscription {    public void request(long n);    public void cancel();}

request(long n)是无阻塞背压概念背后的关键方法。订阅者使用它来请求n个以上的消费项目。这样,订阅者控制了它当前能够接收多少个数据。cancel()由订阅者主动来取消其订阅,取消后将不会在接收到任何数据消息。

2.3.Publisher Interface(发布者接口)

@FunctionalInterfacepublic static interface Publisher<T> {    public void subscribe(Subscriber<? super T> subscriber);}

调用该方法,建立订阅者Subscriber与发布者Publisher之间的消息订阅关系。

2.4.Processor Interface(处理器接口)

处理者Processor 可以同时充当订阅者和发布者,起到转换发布者&mdash;&mdash;订阅者管道中的元素的作用。用于将发布者T类型的数据元素,接收并转换为类型R的数据并发布。

public static interface Processor<T,R> extends Subscriber<T>, Publisher<R> {}

二、实战案例

现在我们要去实现上面的四个接口来完成响应式编程

Subscription Interface订阅令牌接口通常不需要我们自己编程去实现,我们只需要在知道request()方法和cancle()方法含义即可。

Publisher Interface发布者接口,Java 9 已经默认为我们提供了实现SubmissionPublisher,该实现类除了实现Publisher接口的方法外,提供了一个方法叫做submit()来完成消息数据的发送。

Subscriber Interface订阅者接口,通常需要我们自己去实现。因为在数据订阅接收之后,不同的业务有不同的处理逻辑。

Processor实际上是 Publisher Interface和Subscriber Interface的集合体,有需要数据类型转换及数据处理的需求才去实现这个接口

下面的例子实现的式字符串的数据消息订阅处理

实现订阅者Subscriber Interface

import java.util.concurrent.Flow;public class MySubscriber implements Flow.Subscriber<String> {  private Flow.Subscription subscription;  //订阅令牌  @Override  public void onSubscribe(Flow.Subscription subscription) {      System.out.println("订阅关系建立onSubscribe: " + subscription);      this.subscription = subscription;      subscription.request(2);  }  @Override  public void onNext(String item) {      System.out.println("item: " + item);      // 一个消息处理完成之后,可以继续调用subscription.request(n);向发布者要求数据发送      //subscription.request(n);  }  @Override  public void onError(Throwable throwable) {      System.out.println("onError: " + throwable);  }  @Override  public void onComplete() {      System.out.println("onComplete");  }}

SubmissionPublisher消息发布者

import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Flow;import java.util.concurrent.SubmissionPublisher;public class SubmissionPublisherExample {  public static void main(String[] args) throws InterruptedException {      ExecutorService executor = Executors.newFixedThreadPool(1);      SubmissionPublisher<String> sb = new SubmissionPublisher<>(executor, Flow.defaultBufferSize());      sb.subscribe(new MySubscriber());   //建立订阅关系,可以有多个订阅者      sb.submit("数据 1");  //发送消息1      sb.submit("数据 2"); //发送消息2      sb.submit("数据 3"); //发送消息3      executor.shutdown();  }}

控制台打印输出结果

订阅关系建立
onSubscribe: java.util.concurrent.SubmissionPublisher$BufferedSubscription@27e81a39
item: 数据 1
item: 数据 2

请注意:即使发布者submit了3条数据,MySubscriber也仅收到了2条数据进行了处理。是因为我们在MySubscriber#onSubscribe()方法中使用了subscription.request(2);。这就是“背压”的响应式编程效果,我有能力处理多少数据,就会通知消息发布者给多少数据。

到此,关于“java9新特性Reactive Stream响应式编程API怎么用”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注编程网网站,小编会继续努力为大家带来更多实用的文章!

--结束END--

本文标题: java9新特性Reactive Stream响应式编程API怎么用

本文链接: https://www.lsjlt.com/news/324826.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • java9新特性Reactive Stream响应式编程 API
    目录一、Java9 Reactive Stream API二、Java响应式编程四大接口2.1.Subscriber Interface(订阅者订阅接口)2.2.Subscripti...
    99+
    2024-04-02
  • java9新特性Reactive Stream响应式编程API怎么用
    这篇文章主要介绍“java9新特性Reactive Stream响应式编程API怎么用”,在日常操作中,相信很多人在java9新特性Reactive Stream响应式编程API怎么用问题上存在疑惑,小编查阅了各式资料,...
    99+
    2023-06-29
  • Spring5新特性之Reactive响应式编程
    目录1 什么是响应式编程2 回顾Reactor2.1 什么是Reactor2.2 为什么是Reactor2.3 Reactor模式的经典实现—Netty3 Spring5...
    99+
    2024-04-02
  • Spring5的Reactive响应式编程是什么
    本篇内容介绍了“Spring5的Reactive响应式编程是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!1 什么是响应式编程一句话总结...
    99+
    2023-06-29
  • 熟练掌握Java8新特性之Stream API的全面应用
    1.写在前面 关于Stream API的内容,已经基本上说完了。大家可以参考我的这两篇文章: 深入理解Java8新特性之Stream API的创建方式和中间操作步骤、深入理解Java...
    99+
    2024-04-02
  • Spring响应式编程:Java API中的新趋势?
    随着现代化Web应用程序的不断发展,对于高吞吐量和低延迟的需求越来越高。在这样的需求下,异步编程和响应式编程成为了重要的解决方案。Spring框架一直以来都是Java开发中最受欢迎的框架之一,而现在,Spring框架也引入了响应式编程模型...
    99+
    2023-09-21
    api spring 响应
  • Java8新特性Stream流怎么使用
    本文小编为大家详细介绍“Java8新特性Stream流怎么使用”,内容详细,步骤清晰,细节处理妥当,希望这篇“Java8新特性Stream流怎么使用”文章能帮助大家解决疑惑,下面跟着小编的思路慢慢深入,一起来学习新知识吧。Stream流的概...
    99+
    2023-07-02
  • Vue3响应式的ref与reactive怎么使用
    这篇文章主要讲解了“Vue3响应式的ref与reactive怎么使用”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Vue3响应式的ref与reactive怎么使用”吧!ref:定义基本数据类...
    99+
    2023-07-04
  • Reactive反应式编程是什么及如何使用
    这篇文章主要介绍了Reactive反应式编程是什么及如何使用的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇Reactive反应式编程是什么及如何使用文章都会有所收获,下面我们一起来看看吧。反应式编程简介Reac...
    99+
    2023-06-29
  • 如何使用更新的特性进行响应式设计
    这篇文章主要介绍“如何使用更新的特性进行响应式设计”,在日常操作中,相信很多人在如何使用更新的特性进行响应式设计问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”如何使用更新的特...
    99+
    2024-04-02
  • Java8 Stream流式编程怎么使用
    这篇文章主要介绍了Java8 Stream流式编程怎么使用的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇Java8 Stream流式编程怎么使用文章都会有所收获,下面我们一起来看看吧。一、S...
    99+
    2023-07-05
  • Java响应式编程之handle怎么使用
    这篇文章主要介绍“Java响应式编程之handle怎么使用”,在日常操作中,相信很多人在Java响应式编程之handle怎么使用问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Java响应式编程之handle怎...
    99+
    2023-07-04
  • 怎么理解ADO.NET的应用程序新特性
    这篇文章主要介绍“怎么理解ADO.NET的应用程序新特性”,在日常操作中,相信很多人在怎么理解ADO.NET的应用程序新特性问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”怎么理解ADO.NET的应用程序新特性...
    99+
    2023-06-17
  • Java8新特性Optional类怎么应用
    这篇“Java8新特性Optional类怎么应用”文章的知识点大部分人都不太理解,所以小编给大家总结了以下内容,内容详细,步骤清晰,具有一定的借鉴价值,希望大家阅读完这篇文章能有所收获,下面我们一起来看看这篇“Java8新特性Optiona...
    99+
    2023-06-29
  • vue3怎么使用ref和reactive定义和修改响应式数据
    这篇文章主要介绍“vue3怎么使用ref和reactive定义和修改响应式数据”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“vue3怎么使用ref和reactive定义和修改响应式数据”文章能帮助大...
    99+
    2023-07-04
  • Python线程编程怎么突出语言的新特性
    本篇内容主要讲解“Python线程编程怎么突出语言的新特性”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Python线程编程怎么突出语言的新特性”吧!使用 Python 线程编程通过将线程和队列...
    99+
    2023-06-17
  • 如何在PHP编程算法中使用响应式框架来提高响应性能?
    PHP是一种流行的编程语言,常用于Web开发。在编写PHP算法时,优化响应性能是非常关键的。在本文中,我们将讨论如何使用响应式框架来提高PHP编程算法的响应性能。 什么是响应式框架? 响应式框架是一种前端框架,它可以自适应不同的设备和分辨率...
    99+
    2023-08-20
    编程算法 响应 框架
  • Java响应式编程模型:如何使用Spring框架构建高性能应用程序?
    随着现代应用程序的复杂性不断增加,对于高性能和可扩展性的需求也越来越高。Java响应式编程模型是一种可以满足这些需求的方式。本文将介绍Java响应式编程模型,并展示如何使用Spring框架构建高性能应用程序。 什么是Java响应式编程模型...
    99+
    2023-11-06
    响应 并发 spring
  • Node.js中怎么应用反应式编程
    本篇内容主要讲解“Node.js中怎么应用反应式编程”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Node.js中怎么应用反应式编程”吧!反应式编程提供了先进的...
    99+
    2024-04-02
  • 【Java基础教程】(三十)Java新特性篇 · 第十讲: Stream流——释放流式编程的效率与优雅,狂肝万字只为透彻讲清 Stream流!~
    Java基础教程之新特性 · Stream流 1️⃣ 概念及特征2️⃣ 优势和缺点3️⃣ 使用3.1 语法3.2 常用API详解3.3 案例 4️⃣ 应用场景5️⃣ 使用技巧6️⃣ 并行流 ParallelStream...
    99+
    2023-08-16
    java 开发语言 jvm java-ee 大数据
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作