JMS——Spring+ActiveMQ

JMS即Java消息服务（Java
Message Service），是一种提供应用程序之间信息交互的规范。其类似于JDBC，JDBC是Java官方提供的用于访问不同关系型数据库的API，需要不同的数据库厂商实现它；JMS也提供了API，许多第三方Provider都支持它，这里要介绍的ActiveMQ就是由Apache出品的消息总线。接下来介绍一下JMS的主要接口：

1.ConnectionFactory/Connection 接口：ConnectionFactory（连接工厂）用于提供Connection，其类似于JDBC的Connection。JDBC的Connection适用于连接数据库，而JMS的Connection是用于连接第三方Provider，这里即ActiveMQ。

2.Session
接口：表示一次会话，也可以说是一个线程。

3.Destination
接口：表示消息要发送到的目标；可以是一个主题（Topic）或者一个队列（Queue）。打个比方，就好比是一个消息的通道，发送消息的人需要把消息发送到这个通道，阅读消息的人需要从这个通道读取消息。他是通过Session创建，比如Destination destination = session.createQueue("MyQueue"); 

4.MessageProducer
接口：表示发送消息的人，也是由Session创建的，需要把消息目标传入，如MessageProducer producer = session.createProducer(destination);

5.MessageConsumer
接口：表示接收消息的人，由Session创建，MessageConsumer consumer
= session.createProducer(destination);

6.Message
接口：表示所要发的消息，也是由Session创建。

了解了JMS的主要接口，接下来要用到ActionMQ。官方下载地址：http://activemq.apache.org/activemq-580-release.html，解压以后直接运行apache-activemq-5.8.0\bin\activemq.bat，你可以通过http://localhost:8161/admin/queues.jsp查看自己已经创建的队列通道和发送消息。刚开始登录的用户名和密码为admin。需要用到的springjar包不一一列举，还需要spring-jms.jar，还有ActiveMQ的jar包activemq-all-5.8.0.jar，这个jar包在下载的activemq包中有。

下面是Spring的配置文件applicationContext.xml:

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"/>
</bean>

<!-- Spring提供的JMS模板，封装了JMS的主要对象和方法 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"/>
</bean>

<!-- ActiveMQQueue实现的JMS的接口 -->
<bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
<!-- MyQueue是给消息通道取的名字，通过这个消息通道收发消息 -->
<constructor-arg index="0" value="MyQueue"/>
</bean>
</beans>

下面是用于发送信息的MessageSender.java:

package com.xxx.jms;

import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

public class MessageSender extends Thread {

public static void main(String args[]) throws Exception {
ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("jmsTemplate");
Destination destination = (Destination) context.getBean("destination");
jmsTemplate.send(destination, new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage("Hello ActiveMQ!");
}
});
}
}

下面是用于接收消息的MessageReciver.java:

package com.xxx.jms;

import javax.jms.Destination;
import javax.jms.TextMessage;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;

public class MessageReciver {

public static void main(String args[]) throws Exception {
ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("jmsTemplate");
Destination destination = (Destination) context.getBean("destination");

TextMessage msg = (TextMessage)jmsTemplate.receive(destination);
System.out.println(msg.getText());
}
}