EJB3.0学习笔记---MDB--第一个MDBBean程序:

第一个MDBBean程序:

P2P方式传递消息:

1.创建EJB项目:EJBTestP2P_05

2.在com.credream.ejb包下:

MyQueueMDBBean.java

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();

}

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

3.创建JAVAProject项目:EJBTest05_client

com.credream.ejb

MyQueueMDBBeanClient.java

package com.credream.ejb;

import javax.jms.Queue;

import javax.jms.QueueConnection;

import javax.jms.QueueConnectionFactory;

import javax.jms.QueueSender;

import javax.jms.QueueSession;

import javax.jms.TextMessage;

import javax.naming.InitialContext;

public class MyQueueMDBBeanClient {

/**

* @param args

public static void main(String[] args)throws Exception {

InitialContext context=new InitialContext();

//获取QueueConnectionFactory对象

QueueConnectionFactory factory=(QueueConnectionFactory)context.lookup

("ConnectionFactory");

//创建QueueConnection

QueueConnection connection=factory.createQueueConnection();

//创建QueueSession对象

QueueSession session=connection.createQueueSession(false,

QueueSession.AUTO_ACKNOWLEDGE);//第一个true表示

//需要事物,就是说最后需要commit(),false的时候需要自动的提交,第二个参数是响应模式:

对方收到消息后,自动向服务器响应

//获取Destination对象

Queue queue=(Queue) context.lookup("queue/myqueue");

//创建文本消息

TextMessage msg=session.createTextMessage("hello world!!");

//创建发送者

QueueSender sender=session.createSender(queue);

//发送消息

sender.send(msg);

//关闭会话

session.close();

connection.close();

System.out.println("消息已经发送");

}

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

4.引入EJB3.0的jar包

5.写入:jndi.properties

EJB3.0学习笔记---MDB--第一个MDBBean程序:相关推荐

MyBatis学习笔记2 ——第一个MyBatis程序
MyBatis学习笔记2 --第一个MyBatis程序参考教程B站狂神https://www.bilibili.com/video/BV1NE411Q7Nx 环境搭建建立一个mybatis数据库用 ...
Spark学习笔记1——第一个Spark程序：单词数统计
Spark学习笔记1--第一个Spark程序:单词数统计笔记摘抄自 [美] Holden Karau 等著的<Spark快速大数据分析> 添加依赖通过 Maven 添加 Spark-c ...
C#.NET学习笔记2---C#.第一个C#程序
C#.NET学习笔记2---C#.第一个C#程序技术qq交流群:JavaDream:251572072 教程下载,在线交流:创梦IT社区:__________以前的网站现在不弄了,抱歉 6.第一个 ...
EJB3.0学习笔记---JMS/MDB/Pub/Sub/P2P
JMS: 1.jms是java的消息服务,jms的客户端之间可以通过jms服务进行异步的消息传输,jms支持两种消息模型,Point--to--Point(P2P)和Publish/Subscri ...
EJB3.0学习笔记---第一个EJB程序:
第一个EJB程序: 开发服务端程序: 1.新建一个EJB project:EJBTest_01 2.在src下建包:com.credream.ejb 3.写接口:FirstEjb.java pac ...
EJB3.0学习笔记--第一个EJB程序:
第一个EJB程序: 开发服务端程序: 1.新建一个EJB project:EJBTest_01 2.在src下建包:com.credream.ejb 3.写接口:FirstEjb.java pac ...
EJB3.0学习笔记---MDBbean--区分P2P模式和Pub/Sub模式的示例
1.注意在写MDB程序的时候,如果是使用的P2P方式的话,可能你写了多个同样的MDBbean,但是只会有一个MDBbean被调用,至于是哪一个被调用是随机的,这时候其他的将不会起作用; 一个消息 ...
EJB3.0学习笔记---多接口的时,实现类处理方法:
EJB学习笔记--- 1.胖客户端:指的是定义的接口太多了,接口做的工作太多; 胖接口: 2.EJB实现类型的定义,用注解的方式,当一个EJBbean,实现了多个接口的时候, 需要用注解的方式指明哪一 ...
EJB3.0学习笔记---定义客户端访问接口:
定义客户端访问接口: 1.回顾:有状态的EJB每次都是一个新的,可以区分客户端状态,无状态的EJB可以看成是单例的 2.客户端仅通过业务逻辑Bean所定义的接口来访问业务逻辑(跟具体实现无关) 3. ...

EJB3.0学习笔记---MDB--第一个MDBBean程序:

EJB3.0学习笔记---MDB--第一个MDBBean程序:相关推荐

最新文章

热门文章