Java消息服务(JMS)学习小结

红太狼 2022-07-15 14:48 202阅读 0赞

# 消息服务器 #

编辑

本词条缺少 名片图，补充相关内容使词条更完整，还能快速升级，赶紧来 编辑吧！

消息服务器，是一种功能单一的用来接受、传递、转发消息的服务器。

中文名

消息服务器

外文名

News server

性    质

服务器

体    现

高速度的运算能力

其实这个不是一个专业的定义词汇 。

消息服务器作为网络的节点，专门用来存储、转发网络上的数据、信息（例如：聊天信息）。做一个形象的比喻：消息服务器就像是邮局的 [交换机][Link 1]，而微机、笔记本、PDA、手机等固定或移动的 [网络终端][Link 2]，就如散落在家庭、各种办公场所、公共场所等处的电话机。我们与外界日常的生活、工作中的电话交流、沟通，必须经过 [交换机][Link 1]，才能到达目标电话；同样如此，我们利用个人电脑，PDA，手机等，发送消息，也必须经过消息服务器，因此也可以说是消息服务器在“组织”和“领导”这些接收消息设备。

它是网络上一种为 [客户端][Link 3]计算机提供各种消息服务的高性能的计算机。它的高性能主要体现在高速度的运算能力、长时间的可靠运行、强大的 [外部数据][Link 4]吞吐能力等方面。

词条标签：

计算机学 ，  科技

### [Java消息服务(JMS)学习小结][Java_JMS] ###

*  **博客分类：** 
 *  [IT技术][IT]

[JMS][] [Java][] [应用服务器][Link 5] [项目管理][Link 6] [JBoss][]

最近，有一个项目要用到JMS，故而稍微学习了一点。

消息服务是指，两个或者多个客户机能够通过发送和接受消息(以对等的方式)通信。消息是通过消息服务器有一个客户机发送到另一个客户机的"一块"数据，可以是文本的，也可是数值的，如果客户机是Java应用程序，数据还可以包括对象。其中客户机不需要同时运行。

使用消息服务的原因：

1.松散耦合但是高内聚。使用消息服务的客户机不需要实现通用接口，不需要了解对方。消息服务提供了标准接口。

2.不直接通信。客户机不直接对话，而通过中间媒介，消息服务扮演 缓冲区，并提供 安全控制。

3.保证消息传递。 JMS的提供者保持消息持久，直到客户机接受为止。

4.异步通信。

5.一对多、多对多和多对一通信。

JMS(Java 消息服务)是一组标准的API，能够用于访问多种消息服务器。使用JMS，可以使用一样的API访问IBM的MQSeries、JBossMQ等消息服务。

JMS API中有很多核心概念是映射到底层的消息服务器。其中：

1.受控对象(Administered Object)。它们是由管理者创建的供JMS客户机使用的对象。如 连接工厂(Connection Factory),它们用于与底层的消息服务器和目标(队列和主题)进行连接(注：不太理解，可能错了。)。管理通过JNDI对他们进行管理。JMS提供了JMS客户机和实际JMS提供者之间的缓冲区。JBoss就是这些对象的管理者。

2.JMS提供者。实现了JMS接口的消息服务器。（如 JBossMQ消息服务器）。

3.JMS客户机。消息的生产者和消费者。由于是对等的通信机制，所以没有客户机和服务器的概念。JMS既可以是消息创建者又是消息接收者。

4.消息(Message)。JMS客户机之间传送的一条条消息。

传统的消息服务一般支持点对点通信和发布/订阅通信两种通信模式的一种。JMS API 两种都支持。

Point-To-Point

点对点通信模式，有一个中心队列作为发布的目标(受控对象)。一个或多个消息生产者可以发送消息到这个队列。然后被消息的消费者选取。

Pub/Sub

发布/订阅通信模式是基于主题(Topic)概念的。主题是消息的发布目标(受控对象)。它和队列的不同就在于，可以有多个发送消息和接收消息的客户机，每个主题可以有多个发布者和多个订阅者。

JMS API

JMS API是在javax.jms包中定义的。要使用JMS API 需要创建一个提供连接对象的连接工厂。连接对象提供与消息服务器的链接。链接被用来创建会话，会话被用来创建消息，消息通过消息的生产者发送到目标(队列或主题)，然后消息传递到消息消费者。

<table> 
 <tbody> 
 <tr> 
 <td> JMS Parent </td> 
 <td> PTP Domain </td> 
 <td> Pub/Sub Domain </td> 
 </tr> 
 <tr> 
 <td> ConnectionFactory </td> 
 <td> QueueConnectionFactory </td> 
 <td> TopicConnectionFactory </td> 
 </tr> 
 <tr> 
 <td> Connection </td> 
 <td> QueueConnection </td> 
 <td> TopicConnection </td> 
 </tr> 
 <tr> 
 <td> Destination </td> 
 <td> Queue </td> 
 <td> Topic </td> 
 </tr> 
 <tr> 
 <td> Session </td> 
 <td> QueueSession </td> 
 <td> TopicSession </td> 
 </tr> 
 <tr> 
 <td> MessageProducer </td> 
 <td> QueueSender </td> 
 <td> TopicPublisher </td> 
 </tr> 
 <tr> 
 <td> MessageConsumer </td> 
 <td> QueueReceiver </td> 
 <td> TopicSubscriber </td> 
 </tr> 
 </tbody> 
</table>

以下是对这些接口的简单描述：

1.连接工厂(Connection Factory)

是客户机用来创建与JMD提供者的链接的对象。它是受控对象，可以通过JNDI查找。JMS API定义了两种类型的连接工厂。 QueueConnectionFactory 和 TopicConnectionFactory

2.连接(Connection)

连接对象是和JMS提供者通信的媒介。这个通信的具体实现依赖于JMS提供者。除了通用的借口，还有基于队列(QueueConnection)和基于主题(TopicConnection)专用接口。

3.会话(Session)

用于创建消息的生产者、消费者和消息。它们都是单线程，能参加事务。有QueueSession和TopicSession。

4.消息(Message)

消息是消息服务器在客户端之间发送的一条条信息。有五种接口，不同的类型消息。1. StreamMessage -- Java原始值的数据流  2. MapMessage--一组名/值对  3.TextMessage--一个字符串对象 4. ObjectMessage--一个序列化的 Java对象 5.BytesMessage--一个未解释字节的数据流。

消息由以下几部分组成：

消息头（header）：JMS消息头包含了许多字段，它们是消息发送后由JMS提供者或消息发送者产生，用来表示消息、设置优先权和失效时间等等，并且为消息确定路由。

属性（property）：由消息发送者产生，用来添加删除消息头以外的附加信息。

消息体（body）：由消息发送者产生。

5.目标(Destination)

目标是受控对象。在JMS中表示一个队列或者一个主题。

6.消息生产者(MessageProducer)

是用于将消息发送到目标的对象，由会话对象创建，有QueueSender、TopicPublisher.

7.消息消费者(MessageConsumer)

是由会话对象创建，用于从目标获取消息，有QueueReceiver、TopicSubscriber

一个JMS应用是几个JMS 客户端交换消息，开发JMS客户端应用由以下几步构成：

1) 用JNDI 得到ConnectionFactory对象；

2) 用ConnectionFactory创建Connection 对象；

3) 用Connection对象创建一个或多个JMS Session；

4) 用JNDI 得到目标队列或主题对象，即Destination对象；

5) 用Session 和Destination 创建MessageProducer和MessageConsumer；

6) 通知Connection 开始传递消息。

消息生产者程序如下

package org.jms.test;

import java.io.*;

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

//Look up administered objects

InitialContext initContext = new InitialContext();

ConnectionFactory factory =

(ConnectionFactory) initContext.lookup(factoryName);

Destination destination = (Destination) initContext.lookup(destinationName);

initContext.close();

//Create JMS objects

Connection connection = factory.createConnection();

Session session =

connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

MessageProducer sender = session.createProducer(queue);

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

}

//Exit

System.out.println("Exiting...");

reader.close();

connection.close();

System.out.println("Goodbye!");

} catch (Exception e) {

e.printStackTrace();

System.exit(1);

}

消息消费者程序如下

package compute;

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

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

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

}

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;

}

分享到：  ![sina.jpg][]  ![tec.jpg][]

[Proxool使用小结][Proxool] |  [转:Java的垃圾回收总结][Java 1]

[Link 1]: http://baike.baidu.com/view/1077.htm
[Link 2]: http://baike.baidu.com/view/1309496.htm
[Link 3]: http://baike.baidu.com/view/930.htm
[Link 4]: http://baike.baidu.com/view/1273932.htm
[Java_JMS]: http://roadytulip.iteye.com/blog/661279
[IT]: http://roadytulip.iteye.com/category/105839
[JMS]: http://www.iteye.com/blogs/tag/JMS
[Java]: http://www.iteye.com/blogs/tag/Java
[Link 5]: http://www.iteye.com/blogs/tag/%E5%BA%94%E7%94%A8%E6%9C%8D%E5%8A%A1%E5%99%A8
[Link 6]: http://www.iteye.com/blogs/tag/%E9%A1%B9%E7%9B%AE%E7%AE%A1%E7%90%86
[JBoss]: http://www.iteye.com/blogs/tag/JBoss
[sina.jpg]: http://roadytulip.iteye.com/images/sina.jpg
[tec.jpg]: /images/20220715/3be07e2356b9474caac8f11ab2266673.png
[Proxool]: http://roadytulip.iteye.com/blog/693242
[Java 1]: http://roadytulip.iteye.com/blog/659227