《计算概论》课程第十九讲 C 程序设计语言应用

Size: px

Start display at page:

Download "《计算概论》课程第十九讲 C 程序设计语言应用"

驿舞项
5 years ago
Views:

1 Java 高级技术课程 Java EE (3) 李戈北京大学信息科学技术学院软件研究所 2009 年 5 月 30 日

2 Java EE 服务器和容器

3 Enterprise Bean What Is an Enterprise Bean? An enterprise bean is a server-side component that encapsulates the business logic of an application. Characteristic portable extendable simple

4 EJB2.X 定义三种类型 EJB EJB 2.X Session Bean 对应用的业务逻辑的封装 ; Entity Bean 对企业数据访问的封装 ; Message-Driven Bean 进行异步消息通信的封装 ;

5 Session Bean Session Bean 根据在会话过程中是否保存客户端信息 ; Stateful Session Bean 可以保存客户端的状态, 客户端可以在多次访问之间可以共享状态 ; Stateless Session Bean 不保存客户端状态客户端在调用无状态会话 Bean 时通过参数传递所有需要的信息 ;

6 Message-Driven Bean Message-Driven Bean is an enterprise bean that allows Java EE applications to process messages asynchronously. It normally acts as a JMS message listener, which is similar to an event listener except that it receives JMS messages instead of events. The messages can be sent by any Java EE component; an application client, another enterprise bean, or a web component; or by a JMS application or system that does not use Java EE technology. The most visible difference between message-driven beans and session beans is that clients do not access message-driven beans through interfaces.

7 会话 Bean 的组成编写一个会话 Bean 需要提供如下文件 : Bean 类 ( 完成所有处理过程 ) 需要实现 javax.ejb.sessionbean 接口 ; 实现 Bean 类中包含的所有业务方法 ; 实现 ejbcreate 方法 ( 创建 Bean 实例时调用 ) 实现 ejbactive,ejbpassivate 等生命周期方法 ; 配置描述器 (ejb-jar.xml 文件 ) 描述 EJB 由哪些文件组成, 对服务器有何要求 ; 与特定服务器相关的信息 weblogic-ejb-jar.xml

8 会话 Bean 的组成供远程访问的接口远程客户端通过两个接口访问 EJB 业务接口继承 javax.ejb.ejbobject 接口 home 接口继承 javax.ejb.ejbhome 接口供本地访问的接口本地客户端通过两个接口访问 EJB 本地业务接口继承 javax.ejb.ejblocalobject 本地 Home 接口继承 javax.ejb.ejblocalhome

9 消息驱动 Bean 消息驱动 Bean Bean 类需要实现 javax.ejb.messagedrivenbean 接口 ; 需要实现 javax.jms.messagelistener 接口 ; 实现消息接收方法 onmessage 方法 ; 为什么没有本地 / 远程访问接口主要是作为消息的监听者, 没有相应客户端

10 对 EJB 的访问访问 EJB 的客户端 Applet Java Application JSP Servlet EJB EJB 的管理方式 EJB 对象由 home 对象创建 ; home 对象被绑定到 JNDI 树 ; EJB 的访问流程创建上下文创建一个从应用程序到 JNDI 树的连接 ; 在上下文环境中查找 home 对象, 并获得其引用 ; 调用 home 对象的 create 方法创建 EJB 对象并获得 EJB 对象的引用 ; 调用 EJB 对象的业务方法 EJB 对象调用 Bean 实例的方法并将执行结果返回给客户端 ;

11 会话 Bean 的构成 Session Bean Bean 类 Bean 实例 EJBHome home 接口 home 对象 EJBObject remote 接口 EJB 对象 EJBLocalHome local home 接口 local home 对象 EJBLocalObject 服务器提供商提供 local remote 接口 Bean 作者提供 local EJB 对象 EJB 容器实现

12 package stateless.sessionbeans.java.ss.pku.edu.cn; import javax.ejb.sessionbean; import javax.ejb.sessioncontext; import javax.ejb.createexception; public class HelloWorldBean implements SessionBean { SessionContext sessioncontext; public void ejbcreate() throws CreateException { public void ejbremove( ) { public void ejbactivate( ) { public void ejbpassivate( ) { public void setsessioncontext(sessioncontext sessioncontext) { this.sessioncontext = sessioncontext; public String helloworld() { return "Hello World!";

13 package stateless.sessionbeans.java.ss.pku.edu.cn; import javax.ejb.ejbobject; import java.rmi.remoteexception; public interface HelloWorld extends EJBObject { public String helloworld() throws RemoteException;

14 package stateless.sessionbeans.java.ss.pku.edu.cn; import javax.ejb.ejbhome; import javax.ejb.createexception; import java.rmi.remoteexception; public interface HelloWorldHome extends EJBHome { public HelloWorld create() throws CreateException, RemoteException;

15 <?xml version="1.0" encoding="utf-8"?> <!DOCTYPE ejb-jar PUBLIC "-//Sun Microsystems, Inc.//DTD Enterprise JavaBeans 2.0//EN" " <ejb-jar> <display-name>hello</display-name> <enterprise-beans> <session> <display-name>helloworld</display-name> <ejb-name>helloworld</ejb-name> <home>stateless.sessionbeans.java.ss.pku.edu.cn.helloworldhome</home> <remote>stateless.sessionbeans.java.ss.pku.edu.cn.helloworld</remote> <ejb-class>stateless.sessionbeans.java.ss.pku.edu.cn.helloworldbean</ejb-class> <session-type>stateless</session-type> <transaction-type>container</transaction-type> </session> </enterprise-beans> <assembly-descriptor> <container-transaction> <method> <ejb-name>helloworld</ejb-name> <method-name>*</method-name> </method> <trans-attribute>required</trans-attribute> </container-transaction> </assembly-descriptor> </ejb-jar>

16 <?xml version="1.0" encoding="utf-8"?> <!DOCTYPE weblogic-ejb-jar PUBLIC "-//BEA Systems, Inc.//DTD WebLogic EJB//EN" " <weblogic-ejb-jar> <weblogic-enterprise-bean> <ejb-name>helloworld</ejb-name> <jndi-name>helloworld</jndi-name> </weblogic-enterprise-bean> </weblogic-ejb-jar>

17 package stateless.sessionbeans.java.ss.pku.edu.cn; import javax.naming.*; import java.util.properties; import javax.rmi.portableremoteobject; import java.util.*; import javax.naming.*; public class HelloWorldTestClient1 extends Object { public static void main(string[] args) { Hashtable ht = new Hashtable(); ht.put(context.initial_context_factory,"weblogic.jndi.wlinitialcontextfac tory"); ht.put(context.provider_url,"t3://localhost:7001"); Context ctx; try {ctx = new InitialContext(ht); // 创建上下文环境 HelloWorldHome Home = (HelloWorldHome) ctx.lookup("helloworld"); // 查找 home 对象, 并得到 home 对象的引用 HelloWorld hello = Home.create(); // 调用 home 对象的 create 方法创建 ejb 对象, 得到 ejb 对象的引用 System.out.println(hello.helloWorld()); // 调用 ejb 对象的方法, 从而调用 Bean 实例的方法 hello.remove(); catch(exception e) {System.out.println(e.toString());

18 Java 语言元注释的使用 EJB3 的新特性削减开发者需要实现的接口的数量 ; 开发者不再需要提供部署描述符 ; 所有配置信息利用源代码中的元注释表达 ; 例如 : 对于 stateless bean, EJB2.x 中需要实现 javax.ejb.sessionbean, 并在配置描述器中声明这个 Session 的类型是 stateless EJB3 即可

19 EJB3 的新特性支持 EJB 实现的的默认设置放弃对共有程序的重复, 使开发者专注于业务逻辑的实现例如 EJB2.x 中,SessionBean 的 Bean 类不管是否使用生命周期回调方法 ( 如 ejbpassivate, ejbactivate 等 ), 都必须在 Bean 类中定义 ; EJB3 中, 只需要实现特定的业务逻辑 ;

20 简化了对环境资源的访问 EJB3 的新特性 EJB2.x ctx = new InitialContext(ht); HelloWorldHome Home = (HelloWorldHome) ctx.lookup("helloworld"); HelloWorld hello = Home.create(); System.out.println(hello.helloWorld()); hello.remove(); private static PersonalRevenue personalrevenue; personalrevenue.getpersonalrevenue(3000, 1600);

21 EJB3 的新特性降低了对 SessionBean 的 EJB 接口的要求 EJB2.x 中需要为 Bean 编写专门的 EJBObject 接口或 EJBLocalObject 接口 ;EJB3 则不需要 ; 消除了对 SessioinBean 的 Home 接口的要求 EJB3 不再要求为 Bean 编写 home 和 local home 接口, 代之以元注释解决 ;

22 简化 EJB 的类型 EJB3 的新特性不再包含 CMP 实体 Bean 与 BMP 实体 Bean 代之以 Java 持久性 API 简化对持久性的开发 EJB2.x 依赖 Entity Bean 封装对数据的访问, 管理对象关系的映射 ; EJB3 利用持久性 API 完成对象关系映射, 实体对象与普通对象基本相同 ; 消除了开发实体所需要的所有接口 ;

23 EJB3 的新特性简化了实体 Bean 关系的管理 EJB2.x 中, 对象与表的映射关系, 属性与字段的映射, 对象之间的映射都需要在部署描述符中描述 ;EJB3 则采用元注释 ; 增强了 EJB QL 的功能, 使其更接近标准 SQL EJB3 规范与 EJB2 的关联兼容性要求互操作要求客户端通用

24 EJB 的类型有状态无状态会话 Bean 消息驱动 Bean Bean 类的开发规则 EJB3 中的 Bean 若 Bean 实现了一个接口, 则认为该接口为业务接口 ; 注释, 则被认为是本地接口 ; 若 Bean 类有多个接口, 则必须使用 Local 或 Remote 标识清楚 ; 同一业务接口不能即是 Bean 本地接口又是 Bean 的远程接口 ;

25 Public class CalculatorBean implements Calculator{ public float add(int a, int b) { return a + b; public float subtract(int a, int b) { return a b; Public interface Calculator{ public float add(int a, int b) public float subtract (int a, int b)

26 Stateless Session Bean 实例计算个人所得税 State Session Bean 实例网上书店的购物车 Web Service 实例 EJB3 规范下的 Bean 利用无状态会话 Bean 实现 Web Service

27 业务接口 Stateless Session Bean 实例业务接口用于定义客户端可以访问的方法 package stateless.sessionbeans.java.ss.pku.edu.cn; import public interface PersonalRevenue { public float getpersonalrevenue(float salary,float start);

28 package stateless.sessionbeans.java.ss.pku.edu.cn; import public class PersonalRevenueBean implements PersonalRevenue { public float getpersonalrevenue(float salary,float start){ float revenue = 0; float revenuesalary; // 应纳税工资 revenuesalary = salary - start; if(revenuesalary<0) revenue = 0; else if(revenuesalary < 500) revenue = revenuesalary * 5 /100; else if(revenuesalary < 2000) revenue = revenuesalary * 10 /100-25; else if(revenuesalary < 5000) revenue = revenuesalary * 15 / ; else if(revenuesalary < 20000) revenue = revenuesalary * 20 / ; else if(revenuesalary < 40000) revenue = revenuesalary * 25 / ; return revenue ; 创建 Bean 类

29 package stateless.sessionbeans.java.ss.pku.edu.cn; import javax.ejb.ejb; public class PersonalRevenueClient private static PersonalRevenue personalrevenue; public PersonalRevenueClient (String[] args) { public static void main(string[] args) { 创建应用客户端 PersonalRevenueClient client = new PersonalRevenueClient (args); client.dogetpersonalrevenue(); public void dogetpersonalrevenue () { try { float revenue = personalrevenue.getpersonalrevenue(3000,1600); System.out.println(" 工资为 :3000 元的人需要缴纳的个人所得税为 :" + revenue+ " 元 "); catch (Exception ex) { System.err.println(" 产生未知异常!"); ex.printstacktrace();

30 page import=" com.neu.javaee.ejb,javax.naming.*"%> // 利用 page 指令导入要用到的类 ; <%! // 声明中 : 查找业务接口并创建 EJB private PersonalRevenue personalrevenue= null; public void jspinit() { try { InitialContext ic = new InitialContext(); personalrevenue = (PersonalRevenue) ic.lookup(personalrevenue.class.getname()); catch (Exception ex) { System.out.println(" 不能创建 personalrevenue bean "+ ex.getmessage()); public void jspdestroy() { personalrevenue = null; %> <html> <head> <title> 个人所得税计算器 </title> 创建 Web 客户端 1

31 <html> <head> <title> 个人所得税计算器 </title> 创建 Web 客户端 2 </head> <body bgcolor="white"> <% 调用业务方法的代码 %> <h1> 计算个人所得税 </h1> <hr> <form method="get"> <p> 请输入应纳税工资 :</p> <input type="text" name="salary" size="8"> <br> <p> 请输入起征点 :</p> <input type="text" name="start" size="8"> <p> <input type="submit" value="submit"> <input type="reset" value="reset"> </form> </body> </html>

32 <% String salary = request.getparameter("salary"); String start = request.getparameter("start"); if ( salary!= null && salary.length() > 0 && start!= null && start.length() > 0) { try{ float fsalary = Float.parseFloat(salary); float fstart = Float.parseFloat(start); float revenue = personalrevenue.getpersonalrevenue(fsalary,fstart); out.println("<p>"); out.println(" 你应缴纳的个人所得税为 :"+revenue); out.println("<p>"); catch(exception ex){ out.println(" 应该输入大于 0 的数字!"); else{ out.println(" 请输入应纳税工资和起征点!"); %> 创建 Web 客户端 3 调用业务方法的代码

33 业务接口 State Session Bean 实例 package stateful.sessionbeans.java.ss.pku.edu.cn; import java.util.list; import public interface Cart { public void initialize(string person) throws BookException; public void initialize(string person, String id)throws BookException; public void addbook(string title); public void removebook(string title) throws BookException; public List<String> getcontents(); public void remove();

34 package stateful.sessionbeans.java.ss.pku.edu.cn; import // 表明这是有状态会话 Bean public class CartBean implements Cart{ public void initialize(string person, String id) throws BookException { if (person == null) { throw new BookException(" 不允许没有用户!"); else { customername = person; IdVerifier idchecker = new IdVerifier(); if (idchecker.validate(id)) { customerid = id; 创建 Bean 类 else { throw new BookException(" 无效的 ID: " + id); contents = new ArrayList<String>( );

35 public void initialize(string person) throws BookException { if (person == null) { throw new BookException(" 不允许没有用户!"); else { customername = person; customerid = "0"; contents = new ArrayList<String>(); public void addbook(string title) { contents.add(title); public void removebook(string title) throws BookException { boolean result = contents.remove(title); if (result == false) { throw new BookException(title + " 不在购物车中 "); public List<String> getcontents() { return // 客户端调用该方法, 则容器强制删除 EJB public void remove() { contents = null; 创建 Bean 类

36 Web Service 实例 package stateless.sessionbeans.java.ss.pku.edu.cn; import javax.ejb.stateless; import javax.jws.webmethod; public class HelloServiceBean { private String hello = " 您好,"; public void HelloServiceBean() public String sayhello(string username) { return hello + username + " ";

37 消息驱动 Bean 消息驱动 Bean 由 Java 消息服务驱动的一种 EJB; JMS 消息 JMS 消息是由消息头字段消息属性和消息体组成的信息体 ; Java 消息服务 (JMS) 一组 API, 定义了客户端程序如何以一种标准的方式与底层的消息提供者进行交互 ;

38 关于 JMS 消息服务的分类点对点消息处理处理 (PTP,Point-to-Point) 利用一个消息队列, 消息生产者向队列写入消息, 消费者从队列读取消息 ; 发布 - 订阅消息处理模型消息被发送给一个主题 (Topic), 消息服务器将消息发布给订阅该主题的订阅者 ;

39 消息的发送 / 接收过程关于 JMS 获得服务器的一个上下文引用 ; 创建连接工厂, 利用工厂创建一个连接 ; 利用连接创建一个会话 ; 使用会话创建消息的发送 / 接受者 ; 使用连接创建一个消息实例 ; 利用消息发送 / 接受者发送 / 接收消息 ;

40 package jms.sessionbeans.java.ss.pku.edu.cn; import java.util.*; import javax.jms.*; import javax.naming.*; public class MsgQueueSender { private QueueSender sender; private TextMessage msg; public MsgQueueSender (String[] argv) throws NamingException, JMSException { // 初始化上下文环境 String url = "t3://localhost:7001"; Properties p = new Properties(); p.put(context.initial_context_factory, "weblogic.jndi.wlinitialcontextfactory"); p.put(context.provider_url, url); Context ctx = new InitialContext(p); // 创建一个连接工厂 QueueConnectionFactory qconfactory = (QueueConnectionFactory) ctx.lookup("weblogic.jms.connectionfactory"); // 创建一个队列 javax.jms.queue messagequeue = (javax.jms.queue) ctx.lookup("tyyqueue"); // 创建一个链接 QueueConnection qcon = qconfactory.createqueueconnection(); // 创建一个会话 QueueSession session = qcon.createqueuesession( false, /* not a transacted session */ Session.AUTO_ACKNOWLEDGE ); // 创建一个发送者 sender = session.createsender(messagequeue); // 创建一个消息 msg = session.createtextmessage(); 点对点模型下发送消息

41 package jms.sessionbeans.java.ss.pku.edu.cn; import java.util.*; import javax.jms.*; import javax.naming.*; public class MsgQueueSender { private QueueSender sender; private TextMessage msg; public MsgQueueSender (String[] argv) throws NamingException, JMSException { // 初始化上下文环境 String url = "t3://localhost:7001"; Properties p = new Properties(); p.put(context.initial_context_factory, "weblogic.jndi.wlinitialcontextfactory"); p.put(context.provider_url, url); Context ctx = new InitialContext(p); // 创建一个连接工厂 QueueConnectionFactory qconfactory = (QueueConnectionFactory) ctx.lookup("weblogic.jms.connectionfactory"); // 创建一个队列 javax.jms.queue messagequeue = (javax.jms.queue) ctx.lookup("tyyqueue"); // 创建一个链接 QueueConnection qcon = qconfactory.createqueueconnection(); // 创建一个会话 QueueSession session = qcon.createqueuesession( false, /* not a transacted session */ Session.AUTO_ACKNOWLEDGE ); // 创建一个发送者 sender = session.createsender(messagequeue); // 创建一个消息 msg = session.createtextmessage(); 点对点模型下发送消息

42 public void runclient(string str) throws JMSException { msg.settext("hello"); sender.send(msg); msg.settext("welcome to JMS"); sender.send(msg); msg.settext(str); sender.send(msg); public static void main(string[] argv) throws Exception { try { msgqueuesender mqs = new msgqueuesender (argv); mqs.runclient(argv[0]); System.out.print("success"); catch (NamingException ne) { System.err.println(""); System.err.println("** Please ensure that you have setup the" + " JMS Server properly. The JMS Server and the appropriate " + "JMS Destinations must be configured before running the " + "examples."); System.err.println(""); throw ne; 点对点模型下发送消息

43 package jms.sessionbeans.java.ss.pku.edu.cn; import javax.jms.jmsexception; import javax.jms.queue; import javax.jms.queueconnection; import javax.jms.queueconnectionfactory; import javax.jms.queuereceiver; import javax.jms.queuesession; import javax.jms.session; import javax.jms.textmessage; import javax.naming.context; import javax.naming.initialcontext; import javax.naming.namingexception; import java.util.properties; public final class SyncMesConsumer{ private QueueReceiver receiver; private TextMessage msg; 点对点模型下同步接收消息 public SyncMesConsumer() throws JMSException, NamingException {

44 public SyncMesConsumer() throws JMSException, NamingException { // 初始化上下文环境 String url = "t3://localhost:7001"; Properties p = new Properties(); p.put(context.initial_context_factory, "weblogic.jndi.wlinitialcontextfactory"); p.put(context.provider_url, url); Context ctx = new InitialContext(p); // 创建一个连接工厂消息队列连接会话 QueueConnectionFactory qconfactory = (QueueConnectionFactory) ctx.lookup("weblogic.jms.connectionfactory"); Queue messagequeue = (Queue) ctx.lookup("tyyqueue"); QueueConnection qcon = qconfactory.createqueueconnection(); QueueSession session = qcon.createqueuesession( false, /* not a transacted session */ Session.AUTO_ACKNOWLEDGE ); // 创建消息接收者 receiver = session.createreceiver(messagequeue); // 启动消息传递 ( 在此之前禁止 ) qcon.start(); 点对点模型下同步接收消息

45 public void runclient() throws JMSException { // 利用 receive 方法询问是否有新消息 msg = (TextMessage) receiver.receive(); System.err.println("Received: "+msg.gettext()); msg = (TextMessage) receiver.receive(); System.err.println("Received: "+msg.gettext()); msg = (TextMessage) receiver.receive(); System.err.println("Received: "+msg.gettext()); public static void main(string [] argv) throws Exception { syncmesconsumer consumer = new syncmesconsumer(); consumer.runclient(); 点对点模型下同步接收消息

46 发布 / 订阅模式下的发布

47 package jms.sessionbeans.java.ss.pku.edu.cn; import javax.jms.jmsexception; import javax.jms.session; import javax.jms.textmessage; import javax.jms.topic; import javax.jms.topicconnection; import javax.jms.topicconnectionfactory; import javax.jms.topicpublisher; import javax.jms.topicsession; import javax.naming.context; import javax.naming.initialcontext; import javax.naming.namingexception; import java.util.properties; public final class MsgTopicProducer{ private TopicPublisher publisher; private TextMessage msg; 发布 / 订阅模式下的发布 public MsgTopicProducer() throws NamingException, JMSException {

48 public MsgTopicProducer() throws NamingException, JMSException { // 初始化上下文环境 String url="t3://localhost:7001"; Properties p=new Properties(); 发布 / 订阅模式下的发布 p.put(context.initial_context_factory,"weblogic.jndi.wlinitialcon textfactory"); p.put(context.provider_url, url); Context ctx = new InitialContext(p); // 创建一个链接工厂 TopicConnectionFactory tconfactory = (TopicConnectionFactory) ctx.lookup("weblogic.jms.connectionfactory"); // 创建一个主题 Topic messagetopic = (Topic) ctx.lookup("tyytopic"); // 创建一个连接 TopicConnection tcon = tconfactory.createtopicconnection(); // 创建一个会话 TopicSession session = tcon.createtopicsession( false, /* not a transacted session */ Session.AUTO_ACKNOWLEDGE); // 创建主题发布者 publisher = session.createpublisher(messagetopic); // 创建一个需要发送的消息类型的实例 msg = session.createtextmessage();

49 // 设定消息的内容, 并发布消息 public void runclient() throws JMSException { msg.settext("hello"); publisher.publish(msg); msg.settext("welcome to JMS"); publisher.publish(msg); System.out.println("sucess"); public static void main(string [] argv) throws Exception { msgtopicproducer mp = new msgtopicproducer(); mp.runclient(); 发布 / 订阅模式下的发布

50 public AsyncMessageTopicReceiver() throws JMSException, NamingException { package jms.sessionbeans.java.ss.pku.edu.cn; import javax.jms.jmsexception; import javax.jms.message; import javax.jms.messagelistener; import javax.jms.session; import javax.jms.textmessage; import javax.jms.topic; import javax.jms.topicconnection; import javax.jms.topicconnectionfactory; import javax.jms.topicsession; import javax.jms.topicsubscriber; import javax.naming.context; import javax.naming.initialcontext; import javax.naming.namingexception; import java.util.*; public final class AsyncMessageTopicReceiver implements MessageListener { private int EXPECTED_MESSAGE_COUNT = 2; private int messagecount = 0; private TopicSubscriber subscriber; private TextMessage msg; 发布 / 订阅模式下的异步接收

51 public AsyncMessageTopicReceiver() throws JMSException, NamingException { // 初始化上下文环境 Properties p=new Properties(); p.put(context.initial_context_factory, "weblogic.jndi.wlinitialcontextfactory"); p.put(context.provider_url,"t3://localhost:7001"); Context ctx = new InitialContext(p); // 创建一个连接工厂消息队列连接会话 TopicConnectionFactory tconfactory = (TopicConnectionFactory) ctx.lookup("weblogic.jms.connectionfactory"); Topic messagetopic = (Topic) ctx.lookup("tyytopic"); TopicConnection tcon = tconfactory.createtopicconnection(); TopicSession session = tcon.createtopicsession( false, /* not a transacted session */ Session.AUTO_ACKNOWLEDGE ); // 创建一个订阅者 subscriber = session.createsubscriber(messagetopic); // 订阅者是监听者 subscriber.setmessagelistener(this); // 启动消息传递 tcon.start(); 发布 / 订阅模式下的异步接收

52 public boolean expectmoremessages() { return messagecount < EXPECTED_MESSAGE_COUNT; //JMS 服务器用异步方式把消息传递给 onmessage() 方法 public void onmessage(message m) { System.out.println("onMessage"); try { TextMessage msg = (TextMessage) m; System.err.println("Received: "+msg.gettext()); catch (JMSException e) { System.out.println(" 真的错了!"); e.printstacktrace(); messagecount++; 发布 / 订阅模式下的异步接收

53 public static void main(string [] argv) throws Exception { int MAX_TRIES = 30; int trycount = 0; AsyncMessageTopicReceiver consumer = new AsyncMessageTopicReceiver(); while (consumer.expectmoremessages() && (trycount < MAX_TRIES)) { try { System.out.println(tryCount); Thread.sleep(1000); catch (InterruptedException ignore) { trycount++; 发布 / 订阅模式下的异步接收

54 package mdbean.sessionbeans.java.ss.pku.edu.cn; import javax.annotation.resource; import javax.ejb.activationconfigproperty; import javax.ejb.messagedriven; import javax.ejb.messagedrivencontext; import javax.jms.message; import javax.jms.messagelistener; import javax.jms.textmessage; import javax.jms.jmsexception; // 设定 MessageDriven 元注释的值 ( 参考 MessageDriven 元注释文档 = "jms/simplemessagebean", activationconfig = = "acknowledgemode", propertyvalue = = "destinationtype", propertyvalue = "javax.jms.queue") ) public class SimpleMessageBean implements MessageListener { 发布 / 订阅模式下的异步接收

55 public class SimpleMessageBean implements MessageListener private MessageDrivenContext mdc; public SimpleMessageBean() { public void onmessage(message inmessage) { TextMessage msg = null; try { if (inmessage instanceof TextMessage) { msg = (TextMessage) inmessage; System.out.print(" 消息驱动 Bean: 接收到的消息 " + msg.gettext()); else { System.out.println(" 消息的类型不正确 : " + inmessage.getclass().getname()); catch (JMSException e) { e.printstacktrace(); mdc.setrollbackonly(); catch (Throwable te) { te.printstacktrace(); 发布 / 订阅模式下的异步接收

56 消息驱动 Bean package mdbean.sessionbeans.java.ss.pku.edu.cn; import java.util.*; import javax.jms.*; import = jms/connectionfactory ) Private static ConnectionFactory = jms/queue ) Private static Queue queue; connection = connectionfactory.createconnection(); session = connection.createsession(false, Session.AUTO_ACKNOWLEDGE); messageproducer = session.createproducer(queue); message = session.createtextmessage() for(int I =0;i<NUM_MSGS;i++) message.settext( 这是第 +(i+1)+ 个消息 ); Sytem.out.println( 发送消息 : +message.gettext()); messageproducer.send(message);..

57 好好想想, 有没有问题? 谢谢!

EJB-Programming-4-cn.doc

EJB-Programming-4-cn.doc EJB (4) : (Entity Bean Value Object ) JBuilder EJB 2.x CMP EJB Relationships JBuilder EJB Test Client EJB EJB Seminar CMP Entity Beans Session Bean J2EE Session Façade Design Pattern Session Bean Session

《计算概论》课程 第十九讲 C 程序设计语言应用

《计算概论》课程第十九讲 C 程序设计语言应用