编程以使用异步消息传递
您可以构建直接使用 Java™ 消息服务 (JMS) API 来提供异步消息传递服务的企业应用程序。 还可以将消息驱动的 Bean 用作异步消息使用者。如果您要编写在 WebSphere® Application Server 与 IBM MQ 之间进行互操作的消息传递程序,那么需要考虑一些环境差别。
关于此任务
企业应用程序可以直接使用 JMS API 在 JMS 目标上显式地轮询消息,然后检索业务逻辑 Bean(企业 Bean)要处理的消息。
还可以将消息驱动的 Bean 用作异步消息使用者。当消息到达目标时,应用程序不必显式轮询此目标,EJB 容器就会自动调用消息驱动的 Bean。
过程
异步 Bean - WebSphere Trader 样本应用程序
异步 Bean - WebSphere Trader
样本应用程序说明如何使用下列异步 Bean 和 Java Platform, Enterprise Edition (Java EE) 服务实现流式证券报价器服务器和客户机:
- Servlet
- Java 消息服务 (JMS)
- 会话企业 Bean
- 容器管理的持久性 (CMP) 2.0 企业 Bean
- 消息驱动的 Bean (MDB)
此样本使用几个部件以使服务器的利用率达到最高:
- 工作 - 在线程上运行 Java EE 上下文感知代码。
- 警报 - 在给定时间间隔内运行 Java EE 上下文感知代码。
- EventSource - 是一个将事件广播到注册的侦听器的方法。
- SubsystemMonitor - 是一个线程,它监视任何异步系统的状态并使用 EventSource 方法将系统状态通知给注册的侦听器。
- WorkManager - 供各种异步 Bean 部件使用的线程配置和 Java EE 上下文策略。
- AsynchScope - 警报、子系统监视器和支持各种关系的其他异步范围的集合。此集合使用单个 WorkManager 线程,并且它是事件源。
- 启动 Bean - 应用程序启动时支持自引导异步工作的专门的、有状态会话企业 Bean。
可从信息中心的“样本”部分中获取此样本。