EJB3.0学习笔记---MDBbean--区分P2P模式和Pub/Sub模式的示例

1.注意在写MDB程序的时候,如果是使用的P2P方式的话,可能你写了多个同样的MDBbean,但是

只会有一个MDBbean被调用,至于是哪一个被调用是随机的,这时候其他的将不会起作用;

一个消息的发送者,只会有一个消息的接收者

2.注意在写MDB程序的时候,如果是使用PubSub模式的访问服务器方式的话,那么如果有多个相

同的MDBBean,都会被调用,也就是一个消息的发送者,可以有很多个消息的订阅者收到消息

3.示例程序

新建EJB3.0项目:EJBTestP2PANDPubSub_05

a.编写客户端的MDBbean

在com.credream.ejb包下写:

MyQueueMDBBean.java

MyQueueMDBBean02.java

注意:这两个MDBbean的区别在于:System.out.println(" MyQueueMDBBean02被调用了

package com.credream.ejb;

import javax.ejb.ActivationConfigProperty;

import javax.ejb.MessageDriven;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.TextMessage;

@MessageDriven(//通过这个说明这是mdbbean

activationConfig={//值是一个数组;

@ActivationConfigProperty

(propertyName="destinationType",propertyValue="javax.jms.Queue"),

@ActivationConfigProperty

(propertyName="destination",propertyValue="queue/myqueue")//没有这个名词的queue的

时候,就会创建一个,

//就是通过这个名词得到destination;

}

)

public class MyQueueMDBBean implements MessageListener {

public void onMessage(Message msg) {

TextMessage textMessage=(TextMessage)msg;

try {

System.out.println(" MyQueueMDBBean被调用了:[["

+textMessage.getText()+"]]");

} catch (JMSException e) {

e.printStackTrace();

}

--------------------------------------------------------

MyTopicMDBBean.java

MyTopicMDBBean02.java

MyTopicMDBBean03.java

这三个的结果区别在于:System.out.println(" MyTopicMDBBean02/ MyTopicMDBBean03被调

用了:[["

package com.credream.ejb;

import javax.ejb.ActivationConfigProperty;

import javax.ejb.MessageDriven;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageListener;

import javax.jms.TextMessage;

@MessageDriven(//通过这个说明这是mdbbean

activationConfig={//值是一个数组;

@ActivationConfigProperty

(propertyName="destinationType",propertyValue="javax.jms.Topic"),

@ActivationConfigProperty

(propertyName="destination",propertyValue="topic/mytopic")//没有这个名词的queue的

时候,就会创建一个,

//就是通过这个名词得到destination;

}

)

public class MyTopicMDBBean implements MessageListener {

public void onMessage(Message msg) {

TextMessage textMessage=(TextMessage)msg;

try {

System.out.println(" MyTopicMDBBean被调用了:[["

+textMessage.getText()+"]]");

} catch (JMSException e) {

e.printStackTrace();

}

-----------------------------------------------------------------------

EJB3.0学习笔记---MDBbean--区分P2P模式和Pub/Sub模式的示例相关推荐

EJB3.0学习笔记---MDB--第一个MDBBean程序:
第一个MDBBean程序: P2P方式传递消息: 1.创建EJB项目:EJBTestP2P_05 2.在com.credream.ejb包下: MyQueueMDBBean.java package ...
EJB3.0学习笔记---多接口的时,实现类处理方法:
EJB学习笔记--- 1.胖客户端:指的是定义的接口太多了,接口做的工作太多; 胖接口: 2.EJB实现类型的定义,用注解的方式,当一个EJBbean,实现了多个接口的时候, 需要用注解的方式指明哪一 ...
EJB3.0学习笔记---JMS/MDB/Pub/Sub/P2P
JMS: 1.jms是java的消息服务,jms的客户端之间可以通过jms服务进行异步的消息传输,jms支持两种消息模型,Point--to--Point(P2P)和Publish/Subscri ...
EJB3.0学习笔记--SOAP-AXIS--深入Soap引擎
1.SOAP: 简单对象访问协议,简单对象访问协议(SOAP)是一种轻量的.简单的.基于 XML 的协议,它被设计成在 WEB 上交换结构化的和固化的信息. SOAP 可以和现存的许多因特网 ...
EJB3.0学习笔记---理解远程调用服务端和本地调用服务端的区别
项目目的:理解远程调用服务端和本地调用服务端的区别 1.异常: javax.ejb.EJBException: Local and Remote Interfaces cannot hav ...
EJB3.0学习笔记---JBOSS 7.1.1 Final版本安装与配置
一, 下载安装程序由于JBOSS是免费开源软件,所以可以去官网直接下载即可. 下载地址:(目前最新版本是jboss-as-7.1.1.Final) http://download.jboss.org ...
EJB3.0学习笔记---定义客户端访问接口:
定义客户端访问接口: 1.回顾:有状态的EJB每次都是一个新的,可以区分客户端状态,无状态的EJB可以看成是单例的 2.客户端仅通过业务逻辑Bean所定义的接口来访问业务逻辑(跟具体实现无关) 3. ...
EJB3.0学习笔记---Stateless Session Bean的原理:
新年啦:开通自己的CSDN博客:http://blog.csdn.net/lidew521/ 1.Stateless Session Bean的原理:不是说EJB不可以有状态,而是说EJB不对他的状 ...
EJB3.0学习笔记---Bean实现多个接口的情况下定义,访问方式:
2.EJB实现类型的定义,用注解的方式,当一个EJBbean,实现了多个接口的时候, 需要用注解的方式指明哪一个接口是用Remote方式访问,哪一个接口使用 local方式访问 3.实现多个接口的情况 ...

EJB3.0学习笔记---MDBbean--区分P2P模式和Pub/Sub模式的示例

EJB3.0学习笔记---MDBbean--区分P2P模式和Pub/Sub模式的示例相关推荐

最新文章

热门文章