Java EE：异步构造和功能

异步

介绍

Java EE具有许多API和构造以支持异步执行。 从可伸缩性和性能的角度来看，这是至关重要的。

让我们假设2个模块相互交互。 当模块A （发送方）以同步方式向模块B （接收方）发送消息时，通信将在单个线程的上下文中进行，即，从模块A发起通信的线程将被阻塞，直到模块B作出响应为止。

这是一个通用的声明，但可以扩展到一个简单的Java方法相互交融的背景下-在这种情况下，从了methodA到的methodB 同步调用将在同一个 线程执行这将被阻塞，直到的methodB返回或抛出一个异常。

为什么在基于Java EE的应用程序中需要异步行为？

我们可以进一步将这一点推算到Java EE领域-服务器之间的通信，例如Web层和EJB层（Servlet和EJB）之间的通信，或者是典型的客户端服务器交互-浏览器与RESTful端点，Servlet等的交互-服务器响应客户端请求的线程始终阻塞，直到服务器组件响应。

异步执行在这里发挥作用-如果可以释放/暂停处理客户请求的服务器线程 ，并且在单独的线程中执行实际的业务逻辑（与原始线程不同），则可以极大地提高性能和可伸缩性。 ！ 例如，如果分配给侦听客户端请求的HTTP侦听器线程被立即释放，则可以自由地处理来自其他客户端的请求，并且可以在单独的容器线程中执行业务逻辑，然后该容器线程可以通过适当的方法（例如， java.util.concurrent.Future对象或通过客户端注册的回调处理程序 。 从最终用户的角度考虑- 响应非常重要！

深入研究：Java EE中的异步构造和API

让我们看一下Java EE中的一些异步相关功能（API）。 这不是一个详尽的列表，但是应该是一个很好的起点。

不同的Java EE规范具有促进异步功能的典型方式和API。 让我们探索以下Java EE规范

  • JAX-RS 2.0（Java EE 7）
  • Websocket 1.0（Java EE 7）
  • 并发实用工具1.0（Java EE 7）
  • EJB 3.1（Java EE 6）
  • Servlet 3.0（Java EE 6）

注意 ：下面提供的代码为摘要形式（出于明显的原因）。 完整的样本可以在这里访问 。

JAX-RS 2.0

请求的异步处理是JAX-RS 2.0版 （Java EE 7中的新增功能 ）的一项新功能 。 为了使用JAX-RS API执行aysnc请求，需要在JAX-RS资源方法本身中注入对javax.ws.rs.container.AsyncResponse接口的引用。 此参数将请求执行置于异步模式，然后该方法继续执行。 业务逻辑执行完成后，需要从单独的线程中调用AsynResponse对象上的resume方法。 可以利用Java EE并发实用程序功能（稍后讨论），例如javax.enterprise.concurrent.ManagedExecutorService ，以将业务逻辑封装为Runnable对象，并将其提交给容器的执行者服务，其余部分由该服务执行。 无需自己产生不受管理的隔离线程。 

@Path("/{id}")@GET@Produces("application/xml")public void asyncMethod(@Suspended AsyncResponse resp, @PathParam("id") String input) {System.out.println("Entered MyAsyncRESTResource/asyncMethod() executing in thread: "+ Thread.currentThread().getName());mes.execute(() -> {System.out.println("Entered Async zone executing in thread: "+ Thread.currentThread().getName());System.out.println("Simulating long running op via Thread sleep() started on "+ new Date().toString());try {Thread.sleep(5000);} catch (InterruptedException ex) {Logger.getLogger(MyAsyncRESTResource.class.getName()).log(Level.SEVERE, null, ex);}System.out.println("Completed Long running op on "+new Date().toString());System.out.println("Exiting Async zone executing in thread: "+ Thread.currentThread().getName());//creating a dummy instance of our model class (Student)Student stud = new Student(input, "Abhishek", "Apr-08-1987");resp.resume(Response.ok(stud).build());});System.out.println("Exit MyAsyncRESTResource/asyncMethod() and returned thread "+Thread.currentThread().getName()+" back to thread pool");}

JAX-RS客户端API也具有异步功能，但本文未对此进行讨论。 他们绝对值得一看！

Websocket 1.0

Websocket API是Java EE工具库（Java EE 7中引入）的全新添加 。 它促进了双向 （服务器和客户端发起的）通信的本质上也是全双工的（客户端或服务器都可以在任何时候相互发送消息）。

为了使用Websocket API发送异步消息，需要使用javax.websocket.Session接口上可用的getAsyncRemote方法。 在内部，这不过是javax.websocket.RemoteEnpoint – javax.websocket.RemoteEnpoint.Async的嵌套接口的实例。 对此调用常规的sendXXX方法将导致发送过程在单独的线程中执行。 当您考虑交换大消息或处理需要向其发送消息的大量Websocket客户端时，这特别有用。 枯萎的方法返回一个java.util.concurrent.Future对象，或者可以以javax.websocket.SendHandler接口实现的形式注册一个回调。 

public void sendMsg(@Observes Stock stock) {System.out.println("Message receieved by MessageObserver --> "+ stock);System.out.println("peers.size() --> "+ peers.size());peers.stream().forEach((aPeer) -> {//stock.setPrice();aPeer.getAsyncRemote().sendText(stock.toString(), (result) -> {System.out.println("Message Sent? " + result.isOK());System.out.println("Thread : " + Thread.currentThread().getName());});});}

并发实用工具1.0

Java EE并发实用程序是Java EE 7的另一个重要补充 。 它提供了一种标准的生成线程的方式–好的方面是，这些线程是容器管理的 ， 而不仅仅是容器没有上下文信息的孤立/孤立线程 。

通常，并发实用工具1.0提供了一些用于在单独线程中执行异步任务的标准构造。 它们如下： javax.enterprise.concurrent.ManagedExecutorService 和 javax.enterprise.concurrent.ManagedScheduledExecutorService 。

为了在单独的线程中启动新任务，可以使用ManagedExecutorService接口提交Runnable 。 除了实现Runnable接口之外，类还可以实现javax.enterprise.concurrent.ManagedTask接口并提供javax.enterprise.concurrent.ManagedTaskListener实现，以便侦听通过ManagedExecutorService提交的任务的生命周期更改。 

@Overrideprotected void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {System.out.println("Enter AConcurrencyUtilsExample/doGet executing in thread "+ Thread.currentThread().getName());System.out.println("initiating task . . . ");mes.execute(new AManagedTask());System.out.println("Exit AConcurrencyUtilsExample/doGet and returning thread "+ Thread.currentThread().getName() +" back to pool");}

Servlet 3.0

Servlet 3.0（ Java EE 6的一部分）中引入了异步HTTP，它基本上提供了在单独的线程中执行请求并挂起处理客户端调用的原始线程的功能。

这里的关键角色是javax.servlet.AsyncContext接口。 为了启动异步处理，调用java.servlet.ServletRequest接口的startAsync方法。 为了执行核心逻辑，需要将java.lang.Runnable对象提交给AsyncContext接口的start方法。 可以选择通过实现javax.servlet.AsyncListener来附加侦听器，以便在Async任务执行的特定时间接收回调通知。 

@Overridepublic void doGet(HttpServletRequest req, HttpServletResponse resp) {PrintWriter writer = null;try {writer = resp.getWriter();} catch (IOException ex) {Logger.getLogger(MyAsyncServlet.class.getName()).log(Level.SEVERE, null, ex);}//System.out.println("entered doGet()");writer.println("ENTERING ... " + MyAsyncServlet.class.getSimpleName() + "/doGet()");writer.println("Executing in Thread: " + Thread.currentThread().getName());//step 1final AsyncContext asyncContext = req.startAsync();//step 2asyncContext.addListener(new CustomAsyncHandler(asyncContext));//step 3asyncContext.start(() -> {PrintWriter logger = null;try {logger = asyncContext.getResponse().getWriter();} catch (IOException ex) {Logger.getLogger(MyAsyncServlet.class.getName()).log(Level.SEVERE, null, ex);}logger.println("Long running Aync task execution started : " + new Date().toString());logger.println("Executing in Thread: " + Thread.currentThread().getName());try {Thread.sleep(5000);} catch (InterruptedException e) {Logger.getLogger(MyAsyncServlet.class.getName()).log(Level.SEVERE, null, e);}logger.println("Long task execution complete : " + new Date().toString());logger.println("Calling complete() on AsyncContext");//step 4asyncContext.complete();});writer.println("EXITING ... " + MyAsyncServlet.class.getSimpleName() + "/doGet() and returning initial thread back to the thread pool");}

EJB 3.1

通常，（在EJB 3.1之前）EJB消息驱动Bean用于满足与异步相关的要求。 MDB bean侦听发送到javax.jms.Destination （ 队列或Topic ）的消息，并执行所需的业务逻辑–从发送电子邮件到启动订单处理任务，这可能是任何事情。 要了解的重要一点是，首先将消息发送到Queue的客户端不知道 MDB（已解耦 ），并且不必等待/保持阻塞，直到作业结束（电子邮件收据或订单处理确认） ）。

EJB 3.1（ Java EE 6的一部分）引入了javax.ejb.Asynchronous批注。 可以将其放在EJB会话bean（无状态，有状态或单例） 类 （使所有方法异步）上，也可以放在方法级别本身上（以防需要精细控制）。 如果需要跟踪异步方法的结果，则带有@Asynchronous批注的方法可以返回void （失火并忘记）或java.util.concurrent.Future的实例–这可以通过调用Future.get（）来完成–需要注意的是， get方法本身实际上是阻塞的。 

@Asynchronouspublic Future<String> asyncEJB2(){System.out.println("Entered MyAsyncEJB/asyncEJB2()");System.out.println("MyAsyncEJB/asyncEJB2() Executing in thread: "+ Thread.currentThread().getName());System.out.println("Pretending as if MyAsyncEJB/asyncEJB2() is doing something !");try {Thread.sleep(5000);} catch (InterruptedException ex) {java.util.logging.Logger.getLogger(MyAsyncEJB.class.getName()).log(Level.SEVERE, null, ex);}System.out.println("Exiting MyAsyncEJB/asyncEJB2()");return new AsyncResult("Finished Executing on "+ new Date().toString());}

这是Java EE功能的相当简短的预览。 这些API和规范功能丰富，很难通过博客文章涵盖所有这些API和规范！ 我希望这能激起您的兴趣，并为您提供进一步探索的起点。

干杯!

翻译自: https://www.javacodegeeks.com/2014/08/java-ee-asynchronous-constructs-and-capabilities.html

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/362522.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

用 JA Transmenu 模块做多级弹出菜单

用 JA Transmenu 模块做多级弹出菜单

转自http://www.joomlagate.com “弹出菜单”这个说法本来不规范&#xff0c;尽管你我都明白这是什么意思&#xff0c;而实际上我们所理解的那个菜单样式英文说法是“Slide Menu”&#xff08;滑动菜单&#xff09;&#xff0c;如果要用“弹出菜单”就成了“Popup Menu”。当然…
阅读更多...
webpack入门 --初级压缩

webpack入门 --初级压缩

1、新建一个文件夹&#xff0c;再初始化npm&#xff1a; npm init 2、安装webpack&#xff0c;首先要全局安装&#xff0c;再本地安装&#xff1a; npm install webpack -g // 全局安装 npm install webpack-cli -g npm install --save-dev webpack 3、建一个文件&#x…
阅读更多...
模块和包

模块和包

在计算机程序的开发过程中&#xff0c;随着程序代码越写越多&#xff0c;在一个文件里代码就会越来越长&#xff0c;越来越不容易维护 为了编写可维护的代码&#xff0c;我们把很多函数分组&#xff0c;分别放到不同的文件里这样&#xff0c;每个文件包含的代码就相对较少&…
阅读更多...
关于HTML的面试题-html5/css3篇

关于HTML的面试题-html5/css3篇

1. html5 新增标签有哪些&#xff08;或者新增的语义标签&#xff09;&#xff1f;2. HTML5 中有哪些新特性&#xff1f;3. 视频有哪几种格式&#xff1f;这几种格式有什么区别&#xff1f;4. 写出你知道的层级选择符&#xff08;结构性伪类选择器&#xff09;5. 什么是渐进增强…
阅读更多...
鳞翅目动物的诅咒：玩java.time

鳞翅目动物的诅咒：玩java.time

流行测验&#xff1a;这个小程序的输出是什么&#xff1f; public class DateFun {public static void main(String[] args) {long hours getHoursOfDay(LocalDate.now(), ZoneId.systemDefault());System.out.println(hours);}private static long getHoursOfDay(LocalDate …
阅读更多...
jq 方法函数（淡入淡出，查找元素，过滤）遍历

jq 方法函数（淡入淡出，查找元素，过滤）遍历

淡入淡出&#xff1a;fadeIn fadeOut fadeToggle fadeTo 淡入&#xff1a;fadeIn&#xff08;speed[,callback]&#xff09; 速度和回调函数 回调函数可以写匿名函数&#xff0c;或者方法名不加括号。 speed 为‘slow’或 1000 毫秒数不加引号 淡出&#xff1a;fadeOut …
阅读更多...
Elasticsearch的用例：灵活的查询缓存

Elasticsearch的用例：灵活的查询缓存

在前两篇有关Elasticsearch用例的文章中&#xff0c;我们已经看到Elasticsearch 可用于存储甚至大量文档 &#xff0c;并且我们可以通过Query DSL使用Lucene的全文功能访问那些 文档 。 在这篇较短的文章中&#xff0c;我们将把两个用例放在一起&#xff0c;以了解读取繁重的应…
阅读更多...
Vue底层架构及其应用（上）转

Vue底层架构及其应用（上）转

https://mp.weixin.qq.com/s?__bizMzIzNjcwNzA2Mw&mid2247486427&idx1&sn61f9579bbe1dfe26da4b53eb538fee13&chksme8d28643dfa50f557c56ce8b5bc9b0597a157a20791e21b1812fe2a30ff4cf2c813608473b43&mpshare1&scene23&srcid#rd 一、前言 市面上有很…
阅读更多...
jquery笔记一：下载安装、语法、选择器、遍历选择元素的方法、jQuery动画

jquery笔记一：下载安装、语法、选择器、遍历选择元素的方法、jQuery动画

目前 jQuery 兼容于所有主流浏览器, 包括 IE 6&#xff01;开发时常用 jquery.js&#xff0c;上线用 jquery.min.js。 jq插件 目前jQuery有三个大版本&#xff1a; &#xff08;1&#xff09;1.x.x: 兼容ie6,7,8&#xff0c;使用最为广泛&#xff0c;官网只做BUG维护&#xff…
阅读更多...
jquery简介 each遍历 prop attr

jquery简介 each遍历 prop attr

一、JQ简介 jQuery是一个快速、简洁的JavaScript框架&#xff0c;它封装了JavaScript常用的功能代码&#xff0c;提供一种简便的JavaScript设计模式&#xff0c;优化HTML文档操作、事件处理、动画设计和Ajax交互。 装载的先后次序&#xff1a;　　jQuery封装库在上&#xff0…
阅读更多...
如何让Visitor变得可爱1

如何让Visitor变得可爱1

本文转自&#xff1a;http://www.cnblogs.com/idior/archive/2005/01/19/94280.html 在wayfarer的文章中提到了如何利用visitor模式实现添加新的功能。如他所说&#xff0c;在实际过程中显的不是那么可爱。不过他为我们提供了一个可行的解决方案&#xff0c;本文将在此基础上使…
阅读更多...
EJB 3.x：生命周期和并发模型（第1部分）

EJB 3.x：生命周期和并发模型（第1部分）

Java EE组件生命周期和与并发相关的详细信息对于经验丰富的专业人员而言可能不是新知识&#xff0c;但是对于初学者而言&#xff0c;这可能需要花费一些时间。 就EJB而言&#xff0c;了解其生命周期 &#xff08;以及相关的并发场景&#xff09;对于确保使用EJB的正确用法和解…
阅读更多...
链表定义

链表定义

public class Node {//节点内容&#xff0c;成员变量int data;//下一个节点&#xff0c;定义成员变量&#xff0c;类型为Node类型&#xff0c;不进行初始化Node next;//定义构造函数&#xff0c;获取参数data的值public Node(int data) {this.datadata;}//为节点追回节点public…
阅读更多...
单独使用 laydate 日期时间组件

单独使用 laydate 日期时间组件

layui 日期和时间组件官方文档 需要注意几点&#xff1a; 下载压缩包后&#xff0c;复制整个 laydate 文件夹放到项目中&#xff0c;里面的文件不要改动位置&#xff0c;否则会报错&#xff1b;在移动端使用时&#xff0c;要给 input 添加 readonly 属性&#xff0c;否则点击…
阅读更多...
从零开始学习SVG

从零开始学习SVG

1 什么是SVG&#xff1f; MDN中的定义是&#xff1a;SVG即可缩放矢量图形&#xff08;Scalable Vector Graphics&#xff0c;SVG)&#xff0c;是一种用来描述二维矢量图形的 XML 标记语言。 简单地说&#xff0c;SVG 面向图形&#xff0c;HTML 面向文本。SVG 与 Flash 类似&am…
阅读更多...
Flash/Flex学习笔记(39)：弹性运动

Flash/Flex学习笔记(39)：弹性运动

动画中的弹性运动 从视觉效果上接近 物理经典力学中的单摆运动或弹簧(胡克定律FKx)振动 先看下面的模拟演示&#xff1a; 规律&#xff1a; 小球先从出发点(初始为最左侧)向目标点(中心点)加速狂奔&#xff0c;奔的过程中速度越来越大&#xff0c;但加速度越来越小&#xff0c;…
阅读更多...
layui 关于layDate设置时间限制问题

layui 关于layDate设置时间限制问题

前面是尝试结果&#xff0c;有兴趣的可以康康&#xff0c;赶时间的可以直接翻到底下 ----->直达车 因为只有一个页面&#xff0c;没什么标准&#xff0c;所以自己就使用了layui的时间控件&#xff0c;并且作为独立组件。 第一次尝试 - 使用 min 一开始只想让结束时间有个…
阅读更多...
QQ聊天记录快速迁移

QQ聊天记录快速迁移

QQ聊天记录快速迁移 在工作中大家经常会用到QQ来沟通&#xff0c;但是很多时候在其它设备上登录QQ就无法查看到之前的聊天记录和图片&#xff0c;这是因为电脑上的QQ聊天记录一般都是保存在电脑本地硬盘里&#xff0c;所以我们在换设备登录QQ后&#xff0c;是无法查看到之前电脑…
阅读更多...
DOM相关知识点

DOM相关知识点

内容待补充。。。 DOM相关注意题目&#xff1a;DOM的最小组成单位叫做 //节点 NodeDOM 有自己的国际标准&#xff0c;目前的通用版本是 //DOM 3DOM 树的根节点 //HTML元素 Element 的 NodeType 值为 //1 和Node. ELEMENT_NODE<div idx></div> x的值 //就是这…
阅读更多...
Hawtio和Jolokia的休眠统计

Hawtio和Jolokia的休眠统计

企业Java的很大一部分处理数据。 在企业设置中使用数据的所有不同方式中&#xff0c;仍然存在使用任何种类的O / R映射的行之有效且广泛教授的方法。 JPA标准使每个人都可以轻松使用它&#xff0c;并且它也应该是可移植的。 但是&#xff0c;我们不要谈论迁移细节。 O / R映射的…
阅读更多...
最新文章

Copyright @ 2022~2023