RabbitMQ学习笔记7-Spring集成RabbitMQ
2019-06-29 16:34
169 查看
Spring集成RabbitMQ
pom引入
引入spring的rabbitmq的jar:
<dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit</artifactId> <version>1.7.5.RELEASE</version> </dependency>
配置spring文件
在resources目录下建立spring文件:spring-rabbitmq.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/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd"> <description>rabbitmq 连接服务配置</description> <!-- 定义rabbitmq服务器连接 --> <rabbit:connection-factory id="connectionFactory" host="127.0.0.1" username="linwu" password="linwu" port="5672" virtual-host="/vhost_linwu" /> <rabbit:admin connection-factory="connectionFactory" /> <!-- 生产者 --> <!-- spring template声明 --> <rabbit:template exchange="spring-exchange" id="amqpTemplate" connection-factory="connectionFactory" /> <!-- 申明一个消息队列Queue --> <rabbit:queue name="spring-queue" durable="false" auto-delete="false" exclusive="false" /> <!-- 交换机定义 --> <rabbit:fanout-exchange name="spring-exchange" durable="false" auto-delete="false"> <rabbit:bindings> <rabbit:binding queue="spring-queue" /> </rabbit:bindings> </rabbit:fanout-exchange> <!-- 消费者 --> <!-- 配置监听 acknowledeg = "manual" 设置手动应答 当消息处理失败时:会一直重发 直到消息处理成功 --> <rabbit:listener-container connection-factory="connectionFactory" acknowledge="manual"> <!-- 配置监听器 --> <rabbit:listener queues="spring-queue" ref="springConsumer" method="listen"/> </rabbit:listener-container> <!-- 监听bean --> <bean id="springConsumer" class="com.lin.rabbit.spring.SpringConsumer" /> </beans>
生产者
package com.lin.rabbit.spring; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.context.support.AbstractApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; public class SpringProvider { public static void main(String[] args) throws InterruptedException { // 启动spring AbstractApplicationContext context = new ClassPathXmlApplicationContext("spring-rabbitmq.xml"); // 获取RabbitTemplate作为生产者 RabbitTemplate rabbitTemplate = context.getBean(RabbitTemplate.class); // 发送信息 String msg = "this is spring msg!"; rabbitTemplate.convertAndSend(msg); System.out.println("发送消息:" + msg); Thread.sleep(500); context.close(); } }
消费者
package com.lin.rabbit.spring; public class SpringConsumer { public void listen(String msg) { System.out.println("消费者:"+msg); } }
演示效果
1) 直接运行SpringProvider。
相关文章推荐
- mybatis学习笔记四(与spring3集成)
- SpringBoot学习笔记之Druid集成
- SpringBoot学习笔记之CXF集成(实现用户验证)
- Mybatis学习笔记-Spring集成Mybatis
- RabbitMQ学习以及与Spring的集成(三)
- springcloud学习笔记(八)SpringCloud集成zuul路由(一)
- 【学习笔记】Spring-3.2.4 + Quartz-2.2.0集成实例
- SSH学习笔记---struts2 spring集成时action的class的值
- redis 学习笔记(5)-Spring与Jedis的集成
- SpringBoot学习笔记之mybatis分页插件集成
- SpringBoot学习笔记-集成其他组件框架记录
- Apache Shiro学习笔记(九)Spring集成
- MyBatis学习笔记-Spring集成DAO层实现方式记录
- Ehcache学习笔记(1)--spring集成
- Quartz Spring集成学习笔记
- spring boot学习笔记之与servlet、Filter、Listener集成
- 【推荐】springboot学习笔记-6 springboot整合RabbitMQ
- SpringBoot学习笔记(4) Spring Boot 集成 Mybatis
- redis 学习笔记(5)-Spring与Jedis的集成
- RabbitMQ学习以及与Spring的集成(二)