- 浏览: 413568 次
- 性别:
- 来自: 广州
文章分类
最新评论
-
liyuanhoa_:
...
struts2.0中struts.xml配置文件详解 -
chenmingde:
...
Velocity应用(一) -
weizhikai_ai:
第二十六,当一个线程进入一个对象的一个synchronized ...
Java常见面试题(含答案) -
Aurora_lr:
...
Spring宠物商店学习笔记(一) - -
zs911zs:
all copy from http://www.iteye ...
Mule入门文档
绍 第 1 页(共11 页)
在这一节中,我们将查看两个进行 JMS 客户机消息接发的程序——Sender.java 和 Receiver.java。
我们将按小节分析代码并描述每小节的作用。可以在附录中看到完整的清单:Sender.java 的代码清单 和 Receiver.java 的代码清单。
Sender:提示输入 JNDI 名 第 2 页(共11 页)
所有示例程序都是命令行程序,它们用 System.in 进行输入,用System.out 进行输出。
Sender 类有两个方法:main(String[]) 和 send()。main(String[]) 方法只是举例说明了 Sender 并调用了它的 send() 方法。
send() 方法的第一部分提示了将用来发送消息的受管理对象的 JNDI 名。
import java.io.*;
import javax.jms.*;
import javax.naming.*;
public class Sender {
public static void main(String[] args) {
new Sender().send();
}
public void send() {
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
try {
//Prompt for JNDI names
System.out.println("Enter ConnectionFactory name:");
String factoryName = reader.readLine();
System.out.println("Enter Destination name:");
String destinationName = reader.readLine();
。。。。。。。。。。。
Sender:查询管理对象 第 3 页(共11 页)
send() 方法的下一部分用前面输入的名字在 JNDI 中查询受管理的对象。
通过举例说明 InitialContext 对象访问了 JNDI,通过调用 lookup(String) 方法并传递要获取的对象的名字来检索受管理的对象。注意, lookup(String) 方法返回 Object,所以必须对返回的对象进行类型强制转换(typecast)。
Sender:创建 JMS 对象 第 4 页(共11 页)
现在,我们创建了发送消息所需要的 JMS 对象。注意,我们不用直接使用 new 举例说明这些对象。所有对象都是通过调用另一个对象的方法创建的。
首先,用 ConnectionFactory 创建一个 Connection。然后我们用这个 Connection 创建一个 Session。
Session 没有被处理(false) 并且它将使用自动确认(Session.AUTO_ACKNOWLEDGE)。
最后,创建 Sender ,向从 JNDI 中检索的 Destination 发送消息。
. . .
//Create JMS objects
Connection connection = factory.createConnection();
Session session =
connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer sender = session.createProducer(destination);
. . .
. . .
//Look up administered objects
InitialContext initContext = new InitialContext();
ConnectionFactory factory =
(ConnectionFactory) initContext.lookup(factoryName);
Destination destination = (Destination) initContext.lookup(destinationName);
initContext.close();
. . .
Sender:发送消息 第 5 页(共11 页)
现在我们已经可以发送消息了。在这一部分,我们进入一个循环,它提示了要发送消息的文本。如果用户输入 quit,就可以从循环就退出。
否则要在输入文本中建立一个 TextMessage ,用 MessageProducer 发送消息,然后返回到循环的开始部分。
. . .
//Send messages
String messageText = null;
while (true) {
System.out.println("Enter message to send or 'quit':");
messageText = reader.readLine();
if ("quit".equals(messageText))
break;
TextMessage message = session.createTextMessage(messageText);
sender.send(message);
}
. . .
Sender:退出 第 6 页(共11 页)
退出循环后,关闭 Connection。关闭Connection 会自动关闭 Session 和 MessageProducer。
. . .
//Exit
System.out.println("Exiting...");
reader.close();
connection.close();
System.out.println("Goodbye!");
} catch (Exception e) {
e.printStackTrace();
System.exit(1);
}
}
}
Receiver:提示输入 JNDI 的名称并查找受管理的对象 第 7 页(共11 页)
Receiver 类与 Sender 类非常类似,都有一个 main(String[]) 方法,它只是举例说明了 Receiver 并调用它的主要方法 receive()。
提示输入 JNDI 的名称并查找受管理对象的代码与 Sender 中的代码完全一样。
不过,在这个类中有两处不一样的地方:
boolean stop 实例变量用来指出程序应该退出。
Receiver 实现了 MessageListener 接口,为了异步接收消息。
import java.io.*;
import javax.jms.*;
import javax.naming.*;
public class Receiver implements MessageListener {
private boolean stop = false;
public static void main(String[] args) {
new Receiver().receive();
}
public void receive() {
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
try {
//Prompt for JNDI names
System.out.println("Enter ConnectionFactory name:");
String factoryName = reader.readLine();
System.out.println("Enter Destination name:");
String destinationName = reader.readLine();
reader.close();
//Look up administered objects
InitialContext initContext = new InitialContext();
ConnectionFactory factory =
(ConnectionFactory) initContext.lookup(factoryName);
Destination destination = (Destination) initContext.lookup(destinationName);
initContext.close();
. . .
Receiver:创建 JMS 对象 第 8 页(共11 页)
像在 Sender 中那样创建Connection 和 Session,然后创建一个 MessageConsumer。
接着,调用 setMessageListener(),传递 Receiver ——本地实例 this,您会重调用它来实现 MessageListener 接口。
最后,启动 Connection,允许接收消息。
. . .
//Create JMS objects
Connection connection = factory.createConnection();
Session session =
connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageConsumer receiver = session.createConsumer(queue);
receiver.setMessageListener(this);
connection.start();
. . .
Receiver:等待 stop 并退出 第 9 页(共11 页)
接着,程序进入一个循环,循环会在 stop 变量变为 true 时退出。在循环中,线程睡眠一秒钟。一旦退出循环, Connection 就会关闭,程序会终止。
. . .
//Wait for stop
while (!stop) {
Thread.sleep(1000);
}
//Exit
System.out.println("Exiting...");
connection.close();
System.out.println("Goodbye!");
} catch (Exception e) {
e.printStackTrace();
System.exit(1);
}
}
. . .
Receiver:onMessage(Message) 方法 第 10 页(共11 页)
需要包含 Receiver 类的 onMessage(Message) 方法,因为 Receiver 可以实现 MessageListener 接口。
收到消息时,就调用这个方法,并将 Message 作为参数传递。
在我们的实现中,我们得到消息的文字内容并将它打印到 System.out。然后检查消息是否等于 stop,如果是,那么就将 stop 变量设置为 true,这会使 receive() 方法中的循环终止。
. . .
public void onMessage(Message message) {
try {
String msgText = ((TextMessage) message).getText();
System.out.println(msgText);
if ("stop".equals(msgText))
stop = true;
} catch (JMSException e) {
e.printStackTrace();
stop = true;
}
}
}
返回程序 第 11 页(共11 页)
http://www6.software.ibm.com/developerworks/cn/education/java/j-jms/tutorial/j-jms-1-1.html
如 开始 中所述,编译 Sender 和 Receiver 程序需要 javax.naming 和 javax.jms 包。
在运行这个程序之前,需要使用 JMS 提供者提供的管理工具创建受管理对象 ConnectionFactory 和 Destination ,并将它们放到 JNDI 名字空间中。
还需要保证提供者的 JMS 实现类存在于 classpath 中。
然后,可以同时运行这两个程序,为 ConnectionFactory 和 Destination 提供同样的 JNDI 名称,并从 Sender 向 Receiver 发送消息。
在这一节中,我们将查看两个进行 JMS 客户机消息接发的程序——Sender.java 和 Receiver.java。
我们将按小节分析代码并描述每小节的作用。可以在附录中看到完整的清单:Sender.java 的代码清单 和 Receiver.java 的代码清单。
Sender:提示输入 JNDI 名 第 2 页(共11 页)
所有示例程序都是命令行程序,它们用 System.in 进行输入,用System.out 进行输出。
Sender 类有两个方法:main(String[]) 和 send()。main(String[]) 方法只是举例说明了 Sender 并调用了它的 send() 方法。
send() 方法的第一部分提示了将用来发送消息的受管理对象的 JNDI 名。
import java.io.*;
import javax.jms.*;
import javax.naming.*;
public class Sender {
public static void main(String[] args) {
new Sender().send();
}
public void send() {
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
try {
//Prompt for JNDI names
System.out.println("Enter ConnectionFactory name:");
String factoryName = reader.readLine();
System.out.println("Enter Destination name:");
String destinationName = reader.readLine();
。。。。。。。。。。。
Sender:查询管理对象 第 3 页(共11 页)
send() 方法的下一部分用前面输入的名字在 JNDI 中查询受管理的对象。
通过举例说明 InitialContext 对象访问了 JNDI,通过调用 lookup(String) 方法并传递要获取的对象的名字来检索受管理的对象。注意, lookup(String) 方法返回 Object,所以必须对返回的对象进行类型强制转换(typecast)。
Sender:创建 JMS 对象 第 4 页(共11 页)
现在,我们创建了发送消息所需要的 JMS 对象。注意,我们不用直接使用 new 举例说明这些对象。所有对象都是通过调用另一个对象的方法创建的。
首先,用 ConnectionFactory 创建一个 Connection。然后我们用这个 Connection 创建一个 Session。
Session 没有被处理(false) 并且它将使用自动确认(Session.AUTO_ACKNOWLEDGE)。
最后,创建 Sender ,向从 JNDI 中检索的 Destination 发送消息。
. . .
//Create JMS objects
Connection connection = factory.createConnection();
Session session =
connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer sender = session.createProducer(destination);
. . .
. . .
//Look up administered objects
InitialContext initContext = new InitialContext();
ConnectionFactory factory =
(ConnectionFactory) initContext.lookup(factoryName);
Destination destination = (Destination) initContext.lookup(destinationName);
initContext.close();
. . .
Sender:发送消息 第 5 页(共11 页)
现在我们已经可以发送消息了。在这一部分,我们进入一个循环,它提示了要发送消息的文本。如果用户输入 quit,就可以从循环就退出。
否则要在输入文本中建立一个 TextMessage ,用 MessageProducer 发送消息,然后返回到循环的开始部分。
. . .
//Send messages
String messageText = null;
while (true) {
System.out.println("Enter message to send or 'quit':");
messageText = reader.readLine();
if ("quit".equals(messageText))
break;
TextMessage message = session.createTextMessage(messageText);
sender.send(message);
}
. . .
Sender:退出 第 6 页(共11 页)
退出循环后,关闭 Connection。关闭Connection 会自动关闭 Session 和 MessageProducer。
. . .
//Exit
System.out.println("Exiting...");
reader.close();
connection.close();
System.out.println("Goodbye!");
} catch (Exception e) {
e.printStackTrace();
System.exit(1);
}
}
}
Receiver:提示输入 JNDI 的名称并查找受管理的对象 第 7 页(共11 页)
Receiver 类与 Sender 类非常类似,都有一个 main(String[]) 方法,它只是举例说明了 Receiver 并调用它的主要方法 receive()。
提示输入 JNDI 的名称并查找受管理对象的代码与 Sender 中的代码完全一样。
不过,在这个类中有两处不一样的地方:
boolean stop 实例变量用来指出程序应该退出。
Receiver 实现了 MessageListener 接口,为了异步接收消息。
import java.io.*;
import javax.jms.*;
import javax.naming.*;
public class Receiver implements MessageListener {
private boolean stop = false;
public static void main(String[] args) {
new Receiver().receive();
}
public void receive() {
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
try {
//Prompt for JNDI names
System.out.println("Enter ConnectionFactory name:");
String factoryName = reader.readLine();
System.out.println("Enter Destination name:");
String destinationName = reader.readLine();
reader.close();
//Look up administered objects
InitialContext initContext = new InitialContext();
ConnectionFactory factory =
(ConnectionFactory) initContext.lookup(factoryName);
Destination destination = (Destination) initContext.lookup(destinationName);
initContext.close();
. . .
Receiver:创建 JMS 对象 第 8 页(共11 页)
像在 Sender 中那样创建Connection 和 Session,然后创建一个 MessageConsumer。
接着,调用 setMessageListener(),传递 Receiver ——本地实例 this,您会重调用它来实现 MessageListener 接口。
最后,启动 Connection,允许接收消息。
. . .
//Create JMS objects
Connection connection = factory.createConnection();
Session session =
connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageConsumer receiver = session.createConsumer(queue);
receiver.setMessageListener(this);
connection.start();
. . .
Receiver:等待 stop 并退出 第 9 页(共11 页)
接着,程序进入一个循环,循环会在 stop 变量变为 true 时退出。在循环中,线程睡眠一秒钟。一旦退出循环, Connection 就会关闭,程序会终止。
. . .
//Wait for stop
while (!stop) {
Thread.sleep(1000);
}
//Exit
System.out.println("Exiting...");
connection.close();
System.out.println("Goodbye!");
} catch (Exception e) {
e.printStackTrace();
System.exit(1);
}
}
. . .
Receiver:onMessage(Message) 方法 第 10 页(共11 页)
需要包含 Receiver 类的 onMessage(Message) 方法,因为 Receiver 可以实现 MessageListener 接口。
收到消息时,就调用这个方法,并将 Message 作为参数传递。
在我们的实现中,我们得到消息的文字内容并将它打印到 System.out。然后检查消息是否等于 stop,如果是,那么就将 stop 变量设置为 true,这会使 receive() 方法中的循环终止。
. . .
public void onMessage(Message message) {
try {
String msgText = ((TextMessage) message).getText();
System.out.println(msgText);
if ("stop".equals(msgText))
stop = true;
} catch (JMSException e) {
e.printStackTrace();
stop = true;
}
}
}
返回程序 第 11 页(共11 页)
http://www6.software.ibm.com/developerworks/cn/education/java/j-jms/tutorial/j-jms-1-1.html
如 开始 中所述,编译 Sender 和 Receiver 程序需要 javax.naming 和 javax.jms 包。
在运行这个程序之前,需要使用 JMS 提供者提供的管理工具创建受管理对象 ConnectionFactory 和 Destination ,并将它们放到 JNDI 名字空间中。
还需要保证提供者的 JMS 实现类存在于 classpath 中。
然后,可以同时运行这两个程序,为 ConnectionFactory 和 Destination 提供同样的 JNDI 名称,并从 Sender 向 Receiver 发送消息。
发表评论
-
java关键字native,volatile,transient
2009-02-25 15:12 13661.volatile:为了获得最佳速度,java允许线程保存共 ... -
quartz+spring
2009-02-12 14:48 3359Quartz 是一个强大的企业级 Schedule 工具,也是 ... -
Java虚拟机(JVM)参数配置说明
2009-01-08 16:02 2594在Java、J2EE大型应用中,JVM非标准参数的配置直接关系 ... -
@SuppressWarnings 详解
2009-01-08 15:27 977@SuppressWarnings J2SE 提供的最后一个 ... -
批量反编译java类文件
2009-01-08 10:30 1562所使用的软件是 DJ Java Decompiler 3.7。 ... -
LDAP定义
2008-12-23 10:20 1180LDAP是轻量目录访问协议 ... -
JMS总结和参考资料
2008-12-22 17:33 1812结束语 第 1 页(共3 页) 本教程提供了对 Ja ... -
JMS--Pub/Sub编程
2008-12-22 17:27 1085相同又不同 第 1 页(共1 页) 附录中有这两个 ... -
JMS--Pub/Sub接口
2008-12-22 17:24 1888介绍 第 1 页(共7 页) 现在让我们来查看 Pub/s ... -
JMS点对点编程
2008-12-22 17:15 1632介绍 第 1 页(共10 页) ... -
JMS点对点接口
2008-12-22 17:03 1484介绍 第 1 页(共8 页) ... -
JMS公用接口
2008-12-19 18:01 1072在这一节中,我们将介绍 JMS 客户机编程的每一个重要 JMS ... -
JMS学习教程概述
2008-12-19 17:55 3119应用程序 第 1 页(共15 页) http://liy ... -
JNDI定义
2008-12-19 09:56 1051Java术语 英文全称是:Java Naming and ... -
Java 编程的动态性,第 8 部分: 用代码生成取代反射
2008-12-18 11:52 1000运行时代码生成为获得 ... -
Java 编程的动态性,第 7 部分: 用 BCEL 设计字节码
2008-12-18 11:51 1250Apache BCEL 让您深入 JVM 汇编语言进行类操作的 ... -
Java 编程的动态性,第 6 部分: 利用 Javassist 进行面向方面的更改
2008-12-18 11:50 1121用 Javassist 进行字节码 ... -
Java 编程的动态性,第 5 部分: 动态转换类
2008-12-18 11:48 1050学习如何在使用 Javassist ... -
Java 编程的动态性, 第四部分: 用 Javassist 进行类转换
2008-12-18 11:47 1048用 Javassist 转换字节码中的方法 文档 ... -
Java 编程的动态性,第3部分: 应用反射
2008-12-18 11:18 829为命令行参数构建一个框架 文档选项 打印本 ...
相关推荐
**JMS 公用接口详解** Java Message Service(JMS)是Java平台中用于企业级应用间异步通信的一种标准接口。它为分布式系统提供了一种可靠的消息传递机制,允许应用程序创建、发送、接收和读取消息。在JMS中,有两个...
文件"基于Spring的JMS编程-1"可能包含了关于如何在Spring环境中配置和使用JMS的详细步骤,包括XML配置、代码示例以及可能的实战项目案例。进一步学习这些内容,你将能够熟练掌握Spring框架下的JMS编程技巧,从而在...
JMS583编程器固件备份,用于USB-NVME的固态硬盘桥接方案。nvme USB硬盘盒JMS583方案在市面上占有率很高,出现掉固件的情况可能会有,可以用编程器烧录试试。
API的目的是允许程序员在不了解底层实现细节的情况下,通过预定义的函数、类或方法进行编程。API的使用大大降低了开发的复杂性,提高了代码的可复用性和可维护性。 另一方面,接口也指人与软件之间的交互界面,如...
JMS(Java Message Service)是Java平台中用于企业级应用之间进行异步消息传递的一种标准API。在JMS 1.1版本中,它提供了一套接口和模型,使得开发人员能够创建、发送、接收和读取消息。JMS允许应用程序在不关心彼此...
`javax.jms`包是JMS规范的核心部分,包含了各种与消息传递相关的接口和类,这些接口和类为开发人员提供了一种在分布式环境中进行异步通信的标准方式。 1. **JMS接口**:`javax.jms`包中定义了几个关键接口,包括`...
### 用JMS编程 #### 一、JMS概述与重要性 Java消息服务(JMS)是一项重要的技术,用于实现分布式系统中的消息传递。它为开发者提供了一套标准的API,使得Java应用能够与消息中间件进行交互,无论后者是由哪家厂商...
Java消息服务(JMS,Java Message Service)是一种用于在分布式环境中进行异步通信的应用程序接口。JMS允许应用程序创建、发送、接收和读取消息,有效地处理系统间的解耦和消息传递。以下是对JMS的一些关键知识点的...
官方jar,用于JMS queue和topic开发
2. **JMS 使用 ActiveMQ 传送文件.doc** - 这个文档应该直接涵盖了如何使用ActiveMQ进行文件传输的具体步骤,可能包括了创建消息、设置目的地、发送和接收文件的代码示例,以及如何处理错误和异常的情况。...
JMS583作为桥接芯片,它的核心功能是将USB 3.1 Gen 2接口的数据信号转换为PCIe Gen3x2接口可识别的形式,实现两个不同协议间的通信,使得外接的USB设备(如存储设备)能够通过M.2接口与主板进行高速数据交换。...
为了在Jboss上进行JMS编程,你需要将一系列Spring相关的JAR文件放入服务的lib目录中,包括`spring-aop.jar`, `spring-beans.jar`, `spring-context.jar`, `spring-context-support.jar`, `spring-core.jar`, `spring...
标题中的“国产化中间件产品对接,jms的接口参考”指的是在信息技术领域,特别是中国国内,使用本土化的中间件产品进行系统间的通信,而这里的通信机制是基于Java消息服务(Java Message Service,简称JMS)。JMS是...
本资源"用Java编写客户机_服务器端应用程序.zip"包含了一份关于如何使用Java进行此类开发的详细指南,主要文件为"用Java编写客户机_服务器端应用程序.pdf"。 一、Java客户机-服务器架构基础 客户机-服务器(Client-...
datasheet通常包含电气特性、引脚定义、操作条件、接口协议、硬件布局指南和软件编程接口等关键信息。 总结来说,JMS583芯片是现代高速存储解决方案的重要组成部分,它利用先进的USB 3.1 Gen 2和PCIe Gen3x2技术,...
4. **管理对象**:这些是预定义的JMS对象,客户使用它们进行消息的发送和接收。 #### 四、JMS的高级接口 JMS定义了一系列高级接口来封装各种消息的概念。这些接口根据PTP和Pub/Sub两个消息域进行了进一步的定义和...
javax.jms包,sun的JMS接口规范包 2018年6月4日17:05:30
Java消息服务(Java Message Service,简称JMS)是Java平台中用于企业级应用集成的API,它定义了一种标准的接口,使得应用程序可以与各种消息中间件进行交互,实现异步的消息传递。JMS允许应用程序创建、发送、接收...
这对于那些仍然需要使用光盘进行数据交换或安装软件的用户来说至关重要。固件升级可以改善光驱的兼容性、稳定性和读写速度,确保用户能够顺畅地使用各类光盘。 **固件版本** 在提供的资源中,有两个固件版本可供...