用微信怎么做商城网站吗,如何创建微信小程序下单,英国设计网站,安徽工程信息网官网首页java ee打印功能介绍 Java EE具有许多API和构造以支持异步执行。 从可伸缩性和性能的角度来看#xff0c;这是至关重要的。 让我们假设2个模块相互交互。 当模块A #xff08;发送方#xff09;以同步方式向模块B #xff08;接收方#xff09;发送消息时#xff0c;通信… 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.0Java EE 7 Websocket 1.0Java EE 7 并发实用工具1.0Java EE 7 EJB 3.1Java EE 6 Servlet 3.0Java 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})GETProduces(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的另一个重要补充 。 它提供了一种标准的生成线程的方式–好的方面是这些线程是容器管理的 而不仅仅是容器没有上下文信息的孤立/孤立线程 。 通常Concurrency Utilities 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 FutureString 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.htmljava ee打印功能
