關于jms概念以及activemq這里不做具體贅述沮稚，activemq是apache的一款項目东帅，介紹里號稱是最方便最強大的jms實現(xiàn)方式。其實jms與webservice功能是一樣的，側重點不同而已。都是提供多系統(tǒng)之間的交互通信方式辟灰，前者相對于后者更加輕量級，可以實現(xiàn)延遲通信篡石，避免系統(tǒng)高峰期交互通信芥喇，也不需要暴露接口等，開發(fā)起來更加方便凰萨，但是如果項目要求即時性很高那么就選擇后者继控，當然他們兩者也可以整合起來一起使用，本文重點介紹的是spring框架整合activemq實現(xiàn)點對點模式胖眷，關于activemq具體概念百度武通。
1：下載activemq中間件，地址：http://activemq.apache.org/
下載好壓縮到本地珊搀，可以看到這個目錄
從它的目錄來說冶忱，還是很簡單的：
bin存放的是腳本文件
conf存放的是基本配置文件
data存放的是日志文件
docs存放的是說明文檔
examples存放的是簡單的實例
lib存放的是activemq所需jar包
webapps用于存放項目的目錄
其中conf里面有個activemq.xml里面有個配置<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">默認是localhost，這個是可以修改食棕，比如可以換成本機ip地址或是局域網另一臺電腦ip,這樣把中間件部署到同事電腦你也可以訪問朗和，同理部署到linux服務器上只需要把localhost換成服務器ip地址错沽，關于這一段的修改用意在代碼里面會提及。修改完后進入bin文件夾選擇32或64位文件夾后點擊activemq.bat批處理命令后中間件啟動了起來眶拉。該項目還提供了一個管理頁面千埃，訪問地址是http://(localhost或是你前面修改的同事ip或服務器ip地址):8161/admin 默認的用戶名密碼都是admin,見下圖。我們主要點擊Queues欄忆植，里面會顯示你的發(fā)送消息和接收消息的具體信息放可，也可以做刪除等操作。
2：進行項目的搭建
pom.xml配置
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<springframework>4.1.8.RELEASE</springframework>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
<version>3.1.0</version>
</dependency>
<dependency>
<groupId>javax.servlet.jsp</groupId>
<artifactId>javax.servlet.jsp-api</artifactId>
<version>2.3.1</version>
</dependency>
<!-- spring -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${springframework}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${springframework}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>${springframework}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${springframework}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${springframework}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>${springframework}</version>
</dependency>
<!-- xbean 如<amq:connectionFactory /> -->
<dependency>
<groupId>org.apache.xbean</groupId>
<artifactId>xbean-spring</artifactId>
<version>3.16</version>
</dependency>
<!-- activemq -->
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-core</artifactId>
<version>5.7.0</version>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-pool</artifactId>
<version>5.12.1</version>
</dependency>
<!--實現(xiàn)日志 -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.22</version>
</dependency>
<!--處理json -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.0</version>
</dependency>
</dependencies>
applicationContext.xml配置
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.1.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-4.1.xsd">
<!-- 配置掃描路徑 -->
<context:component-scan base-package="com.qqw">
<!-- 只掃描Service朝刊，也可以添加Repostory耀里，但是要把Controller排除在外，Controller由spring-mvc.xml去加載 -->
<!-- <context:include-filter type="annotation" expression="org.springframework.stereotype.Service" /> -->
<!-- <context:include-filter type="annotation" expression="org.springframework.stereotype.Repository" /> -->
<!-- <context:include-filter type="annotation" expression="org.springframework.stereotype.Component" /> -->
<context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
</context:component-scan>
<!-- <mvc:annotation-driven /> -->
</beans>
spring-mvc.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.1.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-4.1.xsd">
<!-- 啟用MVC注解 -->
<mvc:annotation-driven />
<!-- 靜態(tài)資源文件拾氓，不會被Spring MVC攔截 -->
<mvc:resources location="/resources/" mapping="/resources/**"/>
<!-- 指定Sping組件掃描的基本包路徑 -->
<context:component-scan base-package="com.qqw" >
<!-- 這里只掃描Controller冯挎，不可重復加載Service -->
<context:include-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
</context:component-scan>
<!-- JSP視圖解析器-->
<bean id="viewResolver" class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<property name="viewClass" value="org.springframework.web.servlet.view.JstlView"/>
<!-- <property name="prefix" value="/WEB-INF/jsp/"/> -->
<property name="prefix" value="/"/>
<property name="suffix" value=".jsp"/>
<!-- 定義其解析視圖的order順序為1 -->
<property name="order" value="1" />
</bean>
</beans>
接下來就是重要的spring-activemq.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:amq="http://activemq.apache.org/schema/core"
xmlns:jms="http://www.springframework.org/schema/jms"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.1.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-4.1.xsd
http://www.springframework.org/schema/jms
http://www.springframework.org/schema/jms/spring-jms-4.1.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core-5.12.1.xsd"
>
//這里的是用默認的localhost，如果做了修改或是項目上線咙鞍，這個要換成網絡ip地址房官，具體見上面的配置提到
<amq:connectionFactory id="amqConnectionFactory"
brokerURL="tcp://localhost:61616"
userName="admin"
password="admin" />
<!-- 配置JMS連接工長 -->
<bean id="connectionFactory"
class="org.springframework.jms.connection.CachingConnectionFactory">
<constructor-arg ref="amqConnectionFactory" />
<property name="sessionCacheSize" value="100" />
</bean>
<!-- 定義消息隊列（Queue） -->
<bean id="demoQueueDestination" class="org.apache.activemq.command.ActiveMQQueue">
<!-- 設置消息隊列的名字 -->
<constructor-arg>
<value>gzframe.demo</value>
</constructor-arg>
</bean>
<!-- 配置JMS模板（Queue），Spring提供的JMS工具類续滋，它發(fā)送翰守、接收消息。 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory" />
<property name="defaultDestination" ref="demoQueueDestination" />
<property name="receiveTimeout" value="10000" />
<!-- true是topic疲酌，false是queue蜡峰，默認是false，此處顯示寫出false -->
<property name="pubSubDomain" value="false" />
</bean>
<!--加入監(jiān)聽器 -->
<bean id="queueMessageListener" class="com.qqw.active.QueueMessageListener" />
<!-- 顯示注入消息監(jiān)聽容器（Queue）朗恳，配置連接工廠湿颅，監(jiān)聽的目標是demoQueueDestination，監(jiān)聽器是上面定義的監(jiān)聽器 -->
<bean id="queueListenerContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory" />
<property name="destination" ref="demoQueueDestination" />
<property name="messageListener" ref="queueMessageListener" />
</bean>
</beans>
3：邏輯代碼
（1）消息發(fā)送者
package com.qqw.active;
import javax.annotation.Resource;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Service;
@Service
public class ProducerService {
@Resource(name="jmsTemplate")
private JmsTemplate jmsTemplate;
/**
* 向指定隊列發(fā)送消息
*/
public void sendMessage(Destination destination, final String msg) {
System.out.println("向隊列" + destination.toString() + "發(fā)送了消息------------" + msg);
jmsTemplate.send(destination, new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage(msg);
}
});
}
/**
* 向默認隊列發(fā)送消息
*/
public void sendMessage(final String msg) {
String destination = jmsTemplate.getDefaultDestination().toString();
System.out.println("向隊列" +destination+ "發(fā)送了消息------------" + msg);
jmsTemplate.send(new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage(msg);
}
});
}
}
（2）消息接受者
package com.qqw.active;
import javax.annotation.Resource;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.TextMessage;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;
import com.alibaba.fastjson.JSON;
@Service
public class ConsumerService {
@Resource(name="jmsTemplate")
private JmsTemplate jmsTemplate;
/**
* 接收消息
*/
public TextMessage receive(Destination destination) {
TextMessage tm = (TextMessage) jmsTemplate.receive(destination);
try {
System.out.println("從隊列" + destination.toString() + "收到了消息：\t"
+ tm.getText());
/*Gson gson = new Gson();*/
Person fromJson = JSON.parseObject(tm.getText(), Person.class);
System.out.println(fromJson.toString());
} catch (JMSException e) {
e.printStackTrace();
}
return tm;
}
}
（3）傳遞的實體類
package com.qqw.active;
public class Person {
private String name;
private String sex;
private int age;
public Person() {
super();
// TODO Auto-generated constructor stub
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
@Override
public String toString() {
return "Person [name=" + name + ", sex=" + sex + ", age=" + age + "]";
}
}
（4）為接受者定義監(jiān)聽器僻肖，這樣消息一發(fā)到中間件會自動接收處理肖爵，如果不需要自動卢鹦，這段不用寫臀脏，并且把activemq.xml后兩個bean注釋掉
package com.qqw.active;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
public class QueueMessageListener implements MessageListener {
//當收到消息后，自動調用該方法
@Override
public void onMessage(Message message) {
TextMessage tm = (TextMessage) message;
try {
System.out.println("QueueMessageListener監(jiān)聽到了文本消息：\t"
+ tm.getText());
Person fromJson = JSON.parseObject(tm.getText(), Person.class);
System.out.println(fromJson.toString());
//do something ...
} catch (JMSException e){ e.printStackTrace();
}
}
}
}
（5）具體業(yè)務邏輯
//發(fā)送queue消息
@RequestMapping(value="/onsend",method=RequestMethod.POST)
public ModelAndView producer(@RequestParam("message") String message) {
System.out.println("------------send to jms");
com.alibaba.fastjson.JSONObject jsonObj = new com.alibaba.fastjson.JSONObject();
jsonObj.put("name", "張三");
jsonObj.put("sex", "男");
jsonObj.put("age", 20);
String resultjson=JSON.toJSONString(jsonObj);
ModelAndView mv = null;
producer.sendMessage(demoQueueDestination, resultjson);
mv=new ModelAndView("index");
return mv;
}
//如果不需要監(jiān)聽器想手動去接收消息的方式
@RequestMapping(value="/receive",method=RequestMethod.GET)
public ModelAndView queue_receive() throws JMSException {
System.out.println("------------receive message");
ModelAndView mv = new ModelAndView();
TextMessage tm = consumer.receive(demoQueueDestination);
mv.addObject("textMessage", tm.getText());
mv.setViewName("queue_receive");
return mv;
}
(6)本地運行截圖
以上就介紹完了冀自，參考了網上資料以及自己的一些實踐揉稚，大家互相交流學習！０敬帧搀玖！
