原文:RabbitMQ入门教程(十六)：RabbitMQ与Spring集成

版权声明：本文为博主原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。

分享一个朋友的人工智能教程。比较通俗易懂，风趣幽默，感兴趣的朋友可以去看看。

简介

集成示例基本目录结构

一：引入相关依赖

引入Spring核心的依赖和spring-rabbit依赖，注意spring-rabbit依赖不要使用最新的版本，这里使用的1.7.5.RELEASE，使用2.0.0的会报错

<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">

  <modelVersion>4.0.0</modelVersion>

  <groupId>com.lin</groupId>

  <artifactId>rabbit_c2</artifactId>

  <version>0.0.1-SNAPSHOT</version>

  <properties>

    <spring.version>4.2.3.RELEASE</spring.version>

  </properties>

  <dependencies>

    <!-- 添加Spring依赖 -->

    <dependency>

      <groupId>org.springframework</groupId>

      <artifactId>spring-core</artifactId>

      <version>${spring.version}</version>

    </dependency>

    <dependency>

      <groupId>org.springframework</groupId>

      <artifactId>spring-webmvc</artifactId>

      <version>${spring.version}</version>

    </dependency>

    <dependency>

      <groupId>org.springframework</groupId>

      <artifactId>spring-context</artifactId>

      <version>${spring.version}</version>

    </dependency>

    <dependency>

      <groupId>org.springframework</groupId>

      <artifactId>spring-context-support</artifactId>

      <version>${spring.version}</version>

    </dependency>

    <dependency>

      <groupId>org.springframework</groupId>

      <artifactId>spring-aop</artifactId>

      <version>${spring.version}</version>

    </dependency>

    <dependency>

      <groupId>org.springframework</groupId>

      <artifactId>spring-aspects</artifactId>

      <version>${spring.version}</version>

    </dependency>

    <dependency>

      <groupId>org.springframework</groupId>

      <artifactId>spring-tx</artifactId>

      <version>${spring.version}</version>

    </dependency>

    <dependency>

      <groupId>org.springframework</groupId>

      <artifactId>spring-jdbc</artifactId>

      <version>${spring.version}</version>

    </dependency>

    <dependency>

      <groupId>org.springframework</groupId>

      <artifactId>spring-web</artifactId>

      <version>${spring.version}</version>

    </dependency>

    <!--单元测试依赖 -->

    <dependency>

      <groupId>junit</groupId>

      <artifactId>junit</artifactId>

      <version>4.12</version>

      <scope>test</scope>

    </dependency>

    <!--spring单元测试依赖 -->

    <dependency>

      <groupId>org.springframework</groupId>

      <artifactId>spring-test</artifactId>

      <version>${spring.version}</version>

      <scope>test</scope>

    </dependency>

    <!--rabbitmq依赖 1.7.5.RELEASE, 不要使用2.x.x版本会报错-->

    <dependency>

      <groupId>org.springframework.amqp</groupId>

      <artifactId>spring-rabbit</artifactId>

      <version>1.7.5.RELEASE</version>

    </dependency>

    <dependency>

      <groupId>javax.validation</groupId>

      <artifactId>validation-api</artifactId>

      <version>1.1.0.Final</version>

    </dependency>

    <dependency>

      <groupId>org.hibernate</groupId>

      <artifactId>hibernate-validator</artifactId>

      <version>5.0.1.Final</version>

    </dependency>

  </dependencies>

</project>





  • 1
    • 

  • 2
    • 

  • 3
    • 

  • 4
    • 

  • 5
    • 

  • 6
    • 

  • 7
    • 

  • 8
    • 

  • 9
    • 

  • 10
    • 

  • 11
    • 

  • 12
    • 

  • 13
    • 

  • 14
    • 

  • 15
    • 

  • 16
    • 

  • 17
    • 

  • 18
    • 

  • 19
    • 

  • 20
    • 

  • 21
    • 

  • 22
    • 

  • 23
    • 

  • 24
    • 

  • 25
    • 

  • 26
    • 

  • 27
    • 

  • 28
    • 

  • 29
    • 

  • 30
    • 

  • 31
    • 

  • 32
    • 

  • 33
    • 

  • 34
    • 

  • 35
    • 

  • 36
    • 

  • 37
    • 

  • 38
    • 

  • 39
    • 

  • 40
    • 

  • 41
    • 

  • 42
    • 

  • 43
    • 

  • 44
    • 

  • 45
    • 

  • 46
    • 

  • 47
    • 

  • 48
    • 

  • 49
    • 

  • 50
    • 

  • 51
    • 

  • 52
    • 

  • 53
    • 

  • 54
    • 

  • 55
    • 

  • 56
    • 

  • 57
    • 

  • 58
    • 

  • 59
    • 

  • 60
    • 

  • 61
    • 

  • 62
    • 

  • 63
    • 

  • 64
    • 

  • 65
    • 

  • 66
    • 

  • 67
    • 

  • 68
    • 

  • 69
    • 

  • 70
    • 

  • 71
    • 

  • 72
    • 

  • 73
    • 

  • 74
    • 

  • 75
    • 

  • 76
    • 

  • 77
    • 

  • 78
    • 

  • 79
    • 

  • 80
    • 

  • 81
    • 

  • 82
    • 

  • 83
    • 

  • 84
    • 

  • 85
    • 

  • 86
    • 

  • 87
    • 

  • 88
    • 

  • 89
    • 

  • 90
    • 

  • 91
    • 

  • 92
    • 

  • 93
    • 

  • 94
    • 

  • 95

二：配置Rabbit连接参数application.properties

rabbit.host=127.0.0.1

rabbit.port=5672

rabbit.username=guest

rabbit.password=guest

rabbit.vhost=/





  • 1
    • 

  • 2
    • 

  • 3
    • 

  • 4
    • 

  • 5

三：配置Spring的配置文件

applicationContext.xml Spring总的配置文件

<?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:aop="http://www.springframework.org/schema/aop"

       xsi:schemaLocation="http://www.springframework.org/schema/beans

						http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

					    http://www.springframework.org/schema/aop

	                    http://www.springframework.org/schema/aop/spring-aop-3.0.xsd

						http://www.springframework.org/schema/context

						http://www.springframework.org/schema/context/spring-context-3.0.xsd"

       default-lazy-init="false">

    <description>Spring总配置文件</description>

    <context:component-scan base-package="com.mengday.rabbitmq" />

    <context:annotation-config />

    <context:spring-configured />

    <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">

        <property name="ignoreResourceNotFound" value="true" />

        <property name="locations">

            <list>

                <value>classpath*:/application.properties</value>

            </list>

        </property>

    </bean>

    <import resource="applicationContext-rabbit.xml"/>

</beans>





  • 1
    • 

  • 2
    • 

  • 3
    • 

  • 4
    • 

  • 5
    • 

  • 6
    • 

  • 7
    • 

  • 8
    • 

  • 9
    • 

  • 10
    • 

  • 11
    • 

  • 12
    • 

  • 13
    • 

  • 14
    • 

  • 15
    • 

  • 16
    • 

  • 17
    • 

  • 18
    • 

  • 19
    • 

  • 20
    • 

  • 21
    • 

  • 22
    • 

  • 23
    • 

  • 24
    • 

  • 25
    • 

  • 26
    • 

  • 27
    • 

  • 28

Spring对应的rabbit配置文件 applicationContext-rabbit.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:rabbit="http://www.springframework.org/schema/rabbit"

       xsi:schemaLocation="http://www.springframework.org/schema/beans

     http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

     http://www.springframework.org/schema/beans

     http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

     http://www.springframework.org/schema/rabbit

     http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd">

    <!--配置connection-factory，指定连接rabbit server参数 -->

    <rabbit:connection-factory id="connectionFactory"

                               host="${rabbit.host}"

                               port="${rabbit.port}"

                               username="${rabbit.username}"

                               password="${rabbit.password}"

                               virtual-host="${rabbit.vhost}"/>

    <!--定义rabbit template用于数据的接收和发送 -->

    <rabbit:template id="amqpTemplate"  connection-factory="connectionFactory" exchange="exchangeTest"/>

    <!--通过指定下面的admin信息，当前producer中的exchange和queue会在rabbitmq服务器上自动生成 -->

    <rabbit:admin connection-factory="connectionFactory" />

    <!--定义queue -->

    <rabbit:queue name="queueTest" durable="true" auto-delete="false" exclusive="false" />

    <!-- 定义direct exchange，绑定queueTest -->

    <rabbit:direct-exchange name="exchangeTest" durable="true" auto-delete="false">

        <rabbit:bindings>

            <rabbit:binding queue="queueTest" key="queueTestKey"></rabbit:binding>

        </rabbit:bindings>

    </rabbit:direct-exchange>

    <!-- 消息接收者 -->

    <bean id="messageReceiver" class="com.mengday.rabbitmq.MessageConsumer"></bean>

    <!-- queue litener  自动监听队列，当有消息到达时会通知监听在对应的队列上的监听对象-->

    <rabbit:listener-container connection-factory="connectionFactory">

        <rabbit:listener queues="queueTest" ref="messageReceiver"/>

    </rabbit:listener-container>

</beans>





  • 1
    • 

  • 2
    • 

  • 3
    • 

  • 4
    • 

  • 5
    • 

  • 6
    • 

  • 7
    • 

  • 8
    • 

  • 9
    • 

  • 10
    • 

  • 11
    • 

  • 12
    • 

  • 13
    • 

  • 14
    • 

  • 15
    • 

  • 16
    • 

  • 17
    • 

  • 18
    • 

  • 19
    • 

  • 20
    • 

  • 21
    • 

  • 22
    • 

  • 23
    • 

  • 24
    • 

  • 25
    • 

  • 26
    • 

  • 27
    • 

  • 28
    • 

  • 29
    • 

  • 30
    • 

  • 31
    • 

  • 32
    • 

  • 33
    • 

  • 34
    • 

  • 35
    • 

  • 36
    • 

  • 37
    • 

  • 38
    • 

  • 39
    • 

  • 40
    • 

  • 41
    • 

  • 42

四：消息监听

MessageConsumer.java

package com.mengday.rabbitmq;

public class MessageConsumer implements MessageListener {

	public void onMessage(Message message) {

		System.out.println("Received:" + message);

	}

}





  • 1
    • 

  • 2
    • 

  • 3
    • 

  • 4
    • 

  • 5
    • 

  • 6
    • 

  • 7
    • 

  • 8
    • 

  • 9

五：发送消息

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration(locations = { "classpath:conf/spring/applicationContext.xml" })

public class SpringRabbitTest extends AbstractJUnit4SpringContextTests {

	@Autowired

	private AmqpTemplate amqpTemplate;

	@Test

	public void sendMessage(){

		Map<String, Object> log = new HashMap<String, Object>();

		log.put("level", "info");

		log.put("timestamp", new Date());

		log.put("operateId", 666);

		log.put("msg", "修改密码，修改前密码：123456，修改后密码：111111");

		amqpTemplate.convertAndSend("queueTestKey", log);

	}

}





  • 1
    • 

  • 2
    • 

  • 3
    • 

  • 4
    • 

  • 5
    • 

  • 6
    • 

  • 7
    • 

  • 8
    • 

  • 9
    • 

  • 10
    • 

  • 11
    • 

  • 12
    • 

  • 13
    • 

  • 14
    • 

  • 15
    • 

  • 16
    • 

  • 17
    • 

  • 18

六：运行结果

示例源码下载

http://download.csdn.net/download/vbirdbest/10158927

分享一个朋友的人工智能教程。比较通俗易懂，风趣幽默，感兴趣的朋友可以去看看。

我的微信公众号:

最新文章

  1. MongoDB - 在Windows上安装
  2. (C++) LNK2019: unresolved external symbol.
  3. iOS学习30之UITableView编辑
  4. 设计模式——&quot;simple Factory&quot;
  5. SharePoint 2013 使用PowerShell创建State Service
  6. How to Configure Nginx for Optimized Performance
  7. AeroSpike 资料
  8. R语言缺失值信息处理
  9. PHP 错误提示
  10. hdu 2829 Lawrence(斜率优化DP)
  11. cmapx 保存绘制好的图层
  12. Ubuntu中使用iptables
  13. java通过shield链接Elasticsearch
  14. python之 文件读与写
  15. iPhone全部设备分辨率速查
  16. EntityFramework Core笔记：保存数据（4）
  17. 微信小程序开发——点击按钮退出小程序的实现
  18. Windows 之 IP地址
  19. 树剖模板（洛谷P3384 【模板】树链剖分）（树链剖分，树状数组，树的dfn序）
  20. flask表单，orm,csrf

热门文章

  1. CF1213E Two Small Strings
  2. [笔记]MongoDB 二(Linux下MongoDB API C++编程)
  3. C++入门经典-例6.15-通过字符串函数连接两个字符数组
  4. 解决Cannot change version of project facet Dynamic Web Module to 3.1
  5. Centos6 源码安装mysql5.6
  6. SQL Server2016 AlwaysOn无域高可用
  7. Activity的onSaveinstaceState()保存fragment状态
  8. ControlTemplate in WPF —— Menu
  9. [Nova] Failed to get shared "write" lock Is another process using the image?
  10. 阶段3 2.Spring_10.Spring中事务控制_6 spring基于XML的声明式事务控制-配置步骤