您的位置:首页 > 编程语言 > Java开发

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。

内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: