Spring 整合 ActiveMQ

水深无声 2022-07-10 16:59 419阅读 0赞

Spring 是J2EE 最重要的框架，ActiveMQ 是Jms的框架，用于两个程序、系统中的异步通信，两者的用途都挺广泛。上一篇博文介绍的是发布-订阅形式，今次以点-点形式做一个案例。先看看效果：

这里写图片描述

这里写图片描述

环境准备：linux + jdk1.7 + myeclipse2014 + maven + tomcat8+ ActiveMQ-5.11.1 + Spring-4.1.6

源码在github上：https://github.com/fuckyourdick/myRegisterSystem/tree/master/SpringJms

项目结构：

这里写图片描述

1).pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <groupId>com.msayem</groupId>
  6.     <artifactId>spring-jms-with-activemq</artifactId>
  7.     <name>Spring JMS with ActiveMQ</name>
  8.     <version>0.0.1-SNAPSHOT</version>
  9.     <packaging>war</packaging>
  11.     <properties>
  12.         <org.springframework-version>4.1.6.RELEASE</org.springframework-version>
  13.         <org.apache.activemq-version>5.11.1</org.apache.activemq-version>
  14.         <log4j-version>1.2.17</log4j-version>
  15.         <org.slf4j-version>1.7.12</org.slf4j-version>
  16.         <junit-version>3.8.1</junit-version>
  17.         <org.mockito-version>1.10.19</org.mockito-version>
  18.         <servlet-api-version>3.1.0</servlet-api-version>
  19.     </properties>
  21.     <dependencies>
  22.         <!-- Spring -->
  23.         <dependency>
  24.             <groupId>org.springframework</groupId>
  25.             <artifactId>spring-webmvc</artifactId>
  26.             <version>${org.springframework-version}</version>
  27.         </dependency>
  29.         <!-- Spring JMS and ActiveMQ -->
  30.         <dependency>
  31.             <groupId>org.springframework</groupId>
  32.             <artifactId>spring-jms</artifactId>
  33.             <version>${org.springframework-version}</version>
  34.         </dependency>
  35.         <dependency>
  36.             <groupId>org.apache.activemq</groupId>
  37.             <artifactId>activemq-all</artifactId>
  38.             <version>${org.apache.activemq-version}</version>
  39.             <scope>compile</scope>
  40.         </dependency>
  42.         <!-- Logging -->
  43.         <dependency>
  44.             <groupId>log4j</groupId>
  45.             <artifactId>log4j</artifactId>
  46.             <version>${log4j-version}</version>
  47.         </dependency>
  48.         <dependency>
  49.             <groupId>org.slf4j</groupId>
  50.             <artifactId>slf4j-api</artifactId>
  51.             <version>${org.slf4j-version}</version>
  52.         </dependency>
  53.         <dependency>
  54.             <groupId>org.slf4j</groupId>
  55.             <artifactId>slf4j-log4j12</artifactId>
  56.             <version>${org.slf4j-version}</version>
  57.         </dependency>
  59.         <!-- Testing -->
  60.         <dependency>
  61.            <groupId>junit</groupId>
  62.            <artifactId>junit</artifactId>
  63.            <version>${junit-version}</version>
  64.            <scope>test</scope>
  65.       </dependency>
  66.       <dependency>    
  67.           <groupId>javax.servlet</groupId>    
  68.           <artifactId>javax.servlet-api</artifactId>    
  69.           <version>${servlet-api-version}</version>    
  70.       </dependency>    
  71.         <dependency>
  72.             <groupId>org.mockito</groupId>
  73.             <artifactId>mockito-core</artifactId>
  74.             <version>${org.mockito-version}</version>
  75.         </dependency>
  76.     </dependencies>
  77.     <build>
  78.     <finalName>spingAndJmsDemo</finalName>
  79.   </build>
  80. </project>

2).application-context.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <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:jms="http://www.springframework.org/schema/jms" xsi:schemaLocation="http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-4.1.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.1.xsd 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">
  4.     <!-- 扫描注解 -->
  5.     <context:component-scan base-package="com.hsp">
  6.         <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller" />
  7.     </context:component-scan>
  8.      <!-- 开启注解 -->
  9.     <context:annotation-config/>
  10.     <!-- 创建连接工厂 -->
  11.     <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
  12.         <property name="brokerURL">
  13.             <value>tcp://localhost:61616</value>
  14.         </property>
  15.     </bean>
  16.     <!-- 创建目的的（这里的ActiveMQQueue代表点对点，如果要使用发布/订阅的， 用ActiveMQTopic） -->
  17.     <bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
  18.         <constructor-arg value="amqMessageQueue"/>
  19.     </bean>
  20.     <!-- 创建消息发布者 -->
  21.     <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
  22.         <property name="connectionFactory" ref="connectionFactory" />
  23.         <property name="defaultDestination" ref="destination" />
  24.     </bean>
  25.     <!-- 设置监听者监听发布者 -->
  26.     <jms:listener-container connection-factory="connectionFactory">
  27.         <!-- method代表监听到发布者发布消息时做出的反应 -->
  28.         <jms:listener destination="amqMessageQueue" ref="listener" method="messageReceived" />
  29.     </jms:listener-container>
  31. </beans>

3).spring-mvc.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans:beans xmlns="http://www.springframework.org/schema/mvc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:beans="http://www.springframework.org/schema/beans" 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.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd">
  4.     <mvc:annotation-driven />   
  5.     <context:component-scan base-package="com.hsp.controller" />
  6.     <!-- 定义跳转的文件的前后缀 ，视图模式配置-->  
  7.     <beans:bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
  8.         <beans:property name="prefix" value="/WEB-INF/" />
  9.         <beans:property name="suffix" value=".jsp" />
  10.     </beans:bean>
  11. </beans:beans>

4).web.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <web-app version="3.1" xmlns="http://xmlns.jcp.org/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd">
  4.     <!-- 初始化application-context.xml --> 
  5.     <context-param>
  6.         <param-name>contextConfigLocation</param-name>
  7.         <param-value>
  8.             classpath:application-context.xml
  9.         </param-value>
  10.     </context-param>
  11.     <!-- spring-mvc 分派器-->
  12.     <servlet>
  13.         <servlet-name>dispatcherServlet</servlet-name>
  14.         <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
  15.         <init-param>
  16.             <param-name>contextConfigLocation</param-name>
  17.             <param-value>classpath:spring-mvc.xml</param-value>
  18.         </init-param>
  19.         <load-on-startup>1</load-on-startup>
  20.     </servlet>      
  21.     <servlet-mapping>
  22.         <servlet-name>dispatcherServlet</servlet-name>
  23.         <url-pattern>/</url-pattern>
  24.     </servlet-mapping>
  26.     <!-- 编码过滤器 -->  
  27.     <filter>  
  28.         <filter-name>encodingFilter</filter-name>  
  29.         <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>  
  30.         <async-supported>true</async-supported>  
  31.         <init-param>  
  32.             <param-name>encoding</param-name>  
  33.             <param-value>UTF-8</param-value>  
  34.         </init-param>  
  35.     </filter>  
  36.     <filter-mapping>  
  37.         <filter-name>encodingFilter</filter-name>  
  38.         <url-pattern>/*</url-pattern>  
  39.     </filter-mapping>  
  40.     <!-- Spring监听器 -->
  41.     <listener>
  42.         <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  43.     </listener>
  44. </web-app>

5).Talk.java

  1. package com.hsp.domain;
  3. public class Talk {
  5.     private String said;
  7.     public String getSaid() {
  8.         return said;
  9.     }
  11.     public void setSaid(String said) {
  12.         this.said = said;
  13.     }
  15.     public Talk(String said) {
  16.         this.said = said;
  17.     }
  18. }

6).Publisher.java

  1. package com.hsp.jms;
  3. import javax.jms.JMSException;
  4. import javax.jms.MapMessage;
  5. import javax.jms.Message;
  6. import javax.jms.Session;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.jms.core.JmsTemplate;
  10. import org.springframework.jms.core.MessageCreator;
  11. import org.springframework.stereotype.Service;
  13. import com.hsp.domain.Talk;
  16. @Service("publisher")
  17. public class Publisher {
  19.     @Autowired
  20.     private JmsTemplate jmsTemplate;
  22.     //发布
  23.     public void sendTalk(String said) {
  25.         Talk talk = new Talk(said);
  26.         sendMessage(talk);
  27.     }
  29.     public void sendMessage(final Talk talk) {
  30.         //内部类利用jmsTemplate创建session
  31.         jmsTemplate.send(
  33.             new MessageCreator() {
  35.                 public Message createMessage(Session session) throws JMSException {
  37.                     MapMessage mapMessage = session.createMapMessage();
  38.                     mapMessage.setString("said", talk.getSaid());
  39.                     return mapMessage;
  40.                 }
  41.             }
  42.         );
  43.         System.out.println("Publisher: " + talk.getSaid());
  44.     }
  45. }

7).Listener.java

  1. package com.hsp.jms;
  3. import java.util.Map;
  4. import org.springframework.jms.annotation.JmsListener;
  5. import org.springframework.stereotype.Service;
  8. @Service("listener")
  9. public class Listener { 
  11.     //监听
  12.     @JmsListener(destination="amqMessageQueue")
  13.     public void messageReceived(Map<String, Object> message) throws Exception {
  15.         String said = (String) message.get("said");
  16.         System.out.println( "Listener: " + said);
  17.     }
  18. }

8).ChattingAction.java

  1. package com.hsp.controller;
  3. import javax.servlet.http.HttpServletRequest;
  5. import org.slf4j.Logger;
  6. import org.slf4j.LoggerFactory;
  7. import org.springframework.context.ApplicationContext;
  8. import org.springframework.context.support.ClassPathXmlApplicationContext;
  9. import org.springframework.stereotype.Controller;
  10. import org.springframework.web.bind.annotation.RequestMapping;
  11. import org.springframework.web.bind.annotation.RequestMethod;
  13. import com.hsp.jms.Listener;
  14. import com.hsp.jms.Publisher;
  16. @Controller
  17. public class ChattingAction{
  19.     @RequestMapping(value = "/publish", method = RequestMethod.POST)
  20.     public String jmsMessagePublish(HttpServletRequest request) {
  22.         //从sring容器中取出publisher，执行发布的动作
  23.         ApplicationContext context = new ClassPathXmlApplicationContext("application-context.xml");
  24.         Publisher publisher = (Publisher) context.getBean("publisher");
  25.         String said = request.getParameter("said");
  26.         publisher.sendTalk(said);
  27.         //关闭ApplicationContext
  28.         ((ClassPathXmlApplicationContext)context).close();
  29.         return "redirect:/";
  30.     }
  32. }

9).chat.jsp

  1. <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
  2. <% String path = request.getContextPath(); String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/"; %>
  4. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  5. <html>
  6.   <head>
  7.     <base href="<%=basePath%>">
  8.     <title>chat</title>
  9.     </head>
  10.     <body>
  11.          <div>
  12.             <form action="/SpringJms/publish" method="post">
  13.                 <input type="text" name="said"/>
  14.                 <input type='submit' value='publish'/>     
  15.             </form>
  16.          </div>
  17.     </body>
  18. </html>

10).index.jsp

  1. <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
  2. <% String path = request.getContextPath(); String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/"; %>
  4. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
  5. <html>
  6.   <head>
  7.     <base href="<%=basePath%>">
  8.     <title>index</title>
  9.     </head>
  10.     <body>
  11.       <jsp:forward page="/WEB-INF/chat.jsp"></jsp:forward>
  12.     </body>
  13. </html>

11).在浏览器访问：http://localhost:8080/SpringJms/ 即可。

发表评论

表情：
评论列表 （有 0 条评论，419人围观）

还没有评论，来说两句吧...

相关阅读

    相关 Spring 整合 ActiveMQ

    Spring 是J2EE 最重要的框架，ActiveMQ 是Jms的框架，用于两个程序、系统中的异步通信，两者的用途都挺广泛。上一篇博文介绍的是发布-订阅形式，今次以点-点形式

    水深无声水深无声/ 0 赞/ 420 阅读