(转)RabbitMQ学习之spring整合发送同步消息
http://blog.csdn.net/zhu_tianwei/article/details/40890543
以下实现使用Exchange类型为DirectExchange. routingkey的名称默认为Queue的名称。
1.所需jar包依赖
- <properties>
- <rabbitmq.version>3.0.4</rabbitmq.version>
- <spring.amqp.version>1.1.1.RELEASE</spring.amqp.version>
- <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
- <spring.version>3.1.2.RELEASE</spring.version>
- </properties>
- <dependencies>
- <dependency>
- <groupId>com.rabbitmq</groupId>
- <artifactId>amqp-client</artifactId>
- <version>${rabbitmq.version}</version>
- </dependency>
- <dependency>
- <groupId>org.springframework.amqp</groupId>
- <artifactId>spring-rabbit</artifactId>
- <version>${spring.amqp.version}</version>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-core</artifactId>
- <version>${spring.version}</version>
- <exclusions>
- <!-- Exclude Commons Logging in favor of SLF4j -->
- <exclusion>
- <groupId>commons-logging</groupId>
- <artifactId>commons-logging</artifactId>
- </exclusion>
- </exclusions>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-context</artifactId>
- <version>${spring.version}</version>
- </dependency>
- <dependency>
- <groupId>org.springframework</groupId>
- <artifactId>spring-test</artifactId>
- <version>${spring.version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <version>4.8.1</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.springframework.amqp</groupId>
- <artifactId>spring-amqp</artifactId>
- <version>${spring.amqp.version}</version>
- <classifier>sources</classifier>
- <scope>compile</scope>
- </dependency>
- <dependency>
- <groupId>commons-lang</groupId>
- <artifactId>commons-lang</artifactId>
- <version>2.6</version>
- </dependency>
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-api</artifactId>
- <version>1.5.10</version>
- </dependency>
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>jcl-over-slf4j</artifactId>
- <version>1.5.10</version>
- <scope>runtime</scope>
- </dependency>
- <dependency>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-log4j12</artifactId>
- <version>1.5.10</version>
- <scope>runtime</scope>
- </dependency>
- <dependency>
- <groupId>log4j</groupId>
- <artifactId>log4j</artifactId>
- <version>1.2.14</version>
- <scope>runtime</scope>
- </dependency>
- <dependency>
- <groupId>org.aspectj</groupId>
- <artifactId>aspectjweaver</artifactId>
- <version>1.6.9</version>
- </dependency>
- </dependencies>
2.application.properties配置
- #============== rabbitmq config ====================
- rabbit.hosts=192.168.101.210
- rabbit.username=admin
- rabbit.password=admin
- rabbit.virtualHost=/
- rabbit.queue=spring.queue.sync
- rabbit.routingKey=spring.queue.sync
3.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: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="cn.slimsmart.rabbitmq.demo.spring" />
- <aop:aspectj-autoproxy />
- <!-- 定义受环境影响易变的变量 -->
- <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
- <property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE" />
- <property name="ignoreResourceNotFound" value="true" />
- <property name="locations">
- <list>
- <!-- 标准配置 -->
- <value>classpath*:/application.properties</value>
- </list>
- </property>
- </bean>
- <import resource="applicationContext-rabbitmq-sync.xml"/>
- </beans>
4.applicationContext-rabbitmq-sync.xml配置
- <?xml version="1.0" encoding="UTF-8"?>
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:context="http://www.springframework.org/schema/context"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
- http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd">
- <!-- 创建connectionFactory -->
- <bean id="rabbitConnectionFactory"
- class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">
- <constructor-arg value="${rabbit.hosts}"/>
- <property name="username" value="${rabbit.username}"/>
- <property name="password" value="${rabbit.password}"/>
- <property name="virtualHost" value="${rabbit.virtualHost}"/>
- <property name="channelCacheSize" value="5"/>
- </bean>
- <!-- 创建rabbitAdmin 代理类 -->
- <!-- <bean id="rabbitAdmin" -->
- <!-- class="org.springframework.amqp.rabbit.core.RabbitAdmin"> -->
- <!-- <constructor-arg ref="rabbitConnectionFactory" /> -->
- <!-- </bean> -->
- <!-- 创建rabbitTemplate 消息模板类 -->
- <bean id="rabbitTemplate"
- class="org.springframework.amqp.rabbit.core.RabbitTemplate">
- <constructor-arg ref="rabbitConnectionFactory"></constructor-arg>
- <property name="queue" value="${rabbit.queue}"></property>
- <property name="routingKey" value="${rabbit.routingKey}"></property>
- </bean>
- <!-- 声明Queue并设定Queue的名称 -->
- <!-- <bean id="helloWorldQueue" -->
- <!-- class="org.springframework.amqp.core.Queue"> -->
- <!-- <constructor-arg value="${rabbit.queue}"></constructor-arg> -->
- <!-- </bean> -->
- </beans>
5.生产者Producer.java
- import org.springframework.amqp.core.AmqpTemplate;
- import org.springframework.amqp.rabbit.core.RabbitTemplate;
- import org.springframework.context.ApplicationContext;
- import org.springframework.context.support.ClassPathXmlApplicationContext;
- //生产者
- public class Producer {
- public static void main(String[] args) {
- ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
- AmqpTemplate amqpTemplate = context.getBean(RabbitTemplate.class);
- amqpTemplate.convertAndSend("test spring sync");
- }
- }
6.消费者Consumer.java
- import org.springframework.amqp.core.AmqpTemplate;
- import org.springframework.amqp.rabbit.core.RabbitTemplate;
- import org.springframework.context.ApplicationContext;
- import org.springframework.context.support.ClassPathXmlApplicationContext;
- //消费者
- public class Consumer {
- public static void main(String[] args) {
- ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
- AmqpTemplate amqpTemplate = context.getBean(RabbitTemplate.class);
- System.out.println("Received: " + amqpTemplate.receiveAndConvert());
- }
- }
运行生产者向队列中发送一条消息,再运行消费者消费消息。
转载于:https://www.cnblogs.com/telwanggs/p/7124741.html
(转)RabbitMQ学习之spring整合发送同步消息相关推荐
- (转) RabbitMQ学习之spring整合发送同步消息(注解实现)
http://blog.csdn.net/zhu_tianwei/article/details/40918477 上一篇文章通过xml配置rabbitmq的rabbitTemplate,本节将使用注 ...
- (转) RabbitMQ学习之spring整合发送异步消息
http://blog.csdn.net/zhu_tianwei/article/details/40919031 实现使用Exchange类型为DirectExchange. routingkey的 ...
- (转)RabbitMQ学习之spring整合发送异步消息(注解实现)
http://blog.csdn.net/zhu_tianwei/article/details/40919249 实现使用Exchange类型为DirectExchange. routingkey的 ...
- RocketMQ 实战-SpringBoot整合RocketMQ同步消息、异步消息、单向消息
官方样例:https://gitee.com/apache/rocketmq/blob/master/docs/cn/RocketMQ_Example.md 1. 同步消息 producer向 bro ...
- Spring整合ActiveMQ完成消息队列MQ编程
<–start–> 第一步:新建一个maven,将工程命名为activeMQ_spring.在pom.xml文件中导入相关jar包. ①spring开发和测试相关的jar包: spring ...
- Spring整合JMS(二)——消息监听器
消息监听器 在Spring整合JMS的应用中我们在定义消息监听器的时候一共能够定义三种类型的消息监听器,各自是MessageListener.SessionAwareMessageListener和M ...
- RocketMQ发送延迟消息时报错,发送同步消息却正常
延时消息代码如下: Message<Mdds> message = MessageBuilder.withPayload(mdds).build(); // 延迟第3级发送(延迟10秒) ...
- RabbitMQ学习之spring配置文件rabbit标签的使用
下面我们通过一个实例看一下rabbit的使用. 1.实现一个消息监听器ReceiveMessageListener.Java [java] view plaincopy print? package ...
- 文件用户Apache shiro学习笔记+ spring整合shiro (一)
改章节朋友在青岛游玩的时候突然想到的...这两天就有想写几篇关于文件用户的博客,所以回家到之后就奋笔疾书的写出来发表了 Apache Shiro官网:http://shiro.apache.org/ ...
最新文章
- Linux的完全免费特性
- viso 画背景框_3分钟漫画教程 | Q版漫画少女线稿,画完暖暖的
- WinCE 和Win Mobile的关系
- DuckChat聊天系统PHP,部署自己的聊天系统 DuckChat(鸭信)仿微信 PHP源码
- 归并排序及C语言实现
- 从LASSO回归到结构性稀疏:线性回归的正则项都带来了什么?
- Python 发送邮件 和 发送带附件邮件
- 生产者消费者_【线程通信】生产者消费者模型
- ireport 无法打开问题
- SQL 用一个表的数据更新另一张表
- (47)System Verilog 类中变量随机激励inside运算符
- [转一下]未来卫星通信发展趋势
- “关起门来搞开源,做不了开源世界的Leader”
- HCIE Security AC的准入技术 备考笔记(幕布)
- user32.dll 函数说明小结
- uniapp 日期插件_日期时间选择器
- 手把手一步步用DataGridView 控件编写属于自己的日历
- GIS当中矢量数据、影像数据、地形数据等常见数据格式的介绍
- 有线网络、无线网络、蜂窝网络、移动网络到底是啥?
- CSP认证-201809-1-卖菜