JavaEE第11次.doc

JavaEE企业级架构开发与技术案例教程实验报告实验名称演示EJB的消息驱动bean示例实验目的1. 开发消息驱动bean的相关概念2. 消息的传递模型3. Queue类型消息开发步骤1、 实验目的1.开发消息驱动bean的相关概念2.消息的传递模型3.Queue类型消息开发步骤2、 实验内容及结果(请将相应题目代码和结果截图写在相应题目下方)1. 开发消息驱动bean的相关概念(1).java消息驱动bean属于Java消息服务(Java Message Service，简称JMS)。(2)JMS是用于访问企业消息系统的开发商中心的API。企业消息系统可以协助应用软件通过网络进行消息交互。(3)JMS的编程过程简单概括为：应用程序A-(消息)-Jboss JMS-(消息)-应用程序B。应用程序A和应用程序B没有直接的代码关联，两者实现了解耦。消息传递系统的中心就是消息。消息驱动Bean(MDB)是设计用来专门处理基于消息请求的组件，它和无状态Session Bean一样也使用了实例池技术，容器可以使用一定数量的bean实例并发处理成百上千个JMS消息。正因为MDB具有处理大量并发消息的能力，所以非常适合应用在一些消息网关产品。如果一个业务执行的时间很长，而执行结果无需实时向用户反馈时，也很适合使用MDB。如订单成功后给用户发送一封电子邮件或发送一条短信等。消息有下面几种类型，他们都是派生自Message接口。StreamMessage：一种主体中包含Java基本值流的消息。其填充和读取均按顺序进行。MapMessage：一种主体中包含一组名-值对的消息。(没有定义条目顺序)TextMessage：一种主体中包含Java字符串的消息(例如：XML消息)ObjectMessage：一种主体中包含序列化Java对象的消息。BytesMessage：一种主体中包含连续字节流的消息。2. 消息的传递模型：JMS支持两种消息传递模型：点对点(point-to-point，简称PTP)和发布/订阅(publish/subscribe，简称pub/sub)。二者有以下区别：1.PTP 消息传递模型规定了一条消息只能传递给一个接收方。采用javax.jms.Queue表示。2.Pub/sub 消息传递模型允许一条消息传递给多个接收方。采用javax.jms.Topic表示。注意：每种模型都通过扩展公用基类来实现。例如，javax.jms.Queue 和javax.jms.Topic都扩展自javax.jms.Destination 类。3. Queue类型消息开发步骤:Xml代码：java 中发送消息的概括：(1).得到一个JNDI初始化上下文(Context)InitialContext ctx = new InitialContext();(2).根据上下文查找一个连接工厂ConnectionFactory，改连接工厂是由JMS提供的，不需我们自己创建，每个厂商都为它绑定了一个全局JNDI，我们通过它的全局JNDI便获取它；QueueConnectionFactory factory = (QueueConnectionFactory)ctx.lookup(ConnectionFactory);(3).从连接工厂得到一个连接QueueConnection。QueueConnection conn = factory.createQueueConnection();(4).通过连接来建立一个会话(Session);QueueSession session = conn.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);这句代码意思是：建立不需要事务的并且能自动确立消息已接收的会话。(5).查找目标地址：Destination destination=(Destination)ctx.lookup(queue/ztfQueue);(6).根据会话以及目标地址来建立消息生产者MessageProducer(QueueSender和TopicPublisher都扩展自MessageProducer接口)：MessageProducer producer = session.createProducer(destination);TextMessage msg = session.createTextMessage(您好：胡晓亮，这是我的第一个消息驱动Bean);producer.send(msg);3.建立一个java项目，把jboss的client目录下的jar包全部buildPath到编译路径中。4.写消息的发送端Java代码：5.写消息的接收端采用MessageDrivenBean接收消息。当容器检测到bean守候的目标地址有消息到达时，容器调用onMessage()方法，将消息作为参数传入MDB。MDB在onMessage()中决定如何处理改消息。你可以使用注解指定MDB监听哪一个目标地址(Destination)。当MDB部署时，容器将读取其中的配置信息。一个MDB通常要实现MessageListener接口，在接口定义了onMessage()方法。Bean通过它来处理收到的JMS消息。Java代码：6.打包部署：讲项目打成一个jar包，貌似netbC.jar,放在JBOSS的deploy目录下，启动jboss7.运行QueueSender.java 发送消息3、