由于种种原因,要在项目中使用rabbit mq。
现将springmvc形式的接口换掉。采用rabbitmq队列形式来接收请求。
现将rabbitmq整合入项目中。如果项目时使用maven结构,在项目文件中添加:
<dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit</artifactId> <version>${spring.amqp.version}</version> </dependency>
如果没有采用maven结构,这需要添加,
下面是spring 整合rabbitmq的配置代码:
rabbit-mq.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:p="http://www.springframework.org/schema/p" 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"> <!-- rabbitMq连接服务配置 --> <rabbit:connection-factory id="connectionFactory" host="localhost" username="guest" password="guest" port="5672" /> <rabbit:admin connection-factory="connectionFactory" /> <!-- queue 队列声明 --> <rabbit:queue id="mq-queue" durable="true" auto-delete="false" exclusive="false" name="test_queue" /> <!-- exchange queue binging key 绑定 --> <rabbit:direct-exchange id="mq-exchange" name="test_exchange" durable="true" auto-delete="false"> <rabbit:bindings> <rabbit:binding queue="mq-queue" key="test_key" /> </rabbit:bindings> </rabbit:direct-exchange> <!-- mq 模板 --> <rabbit:template id="amqpTemplate" exchange="mq-exchange" connection-factory="connectionFactory" /> <bean id="mqClientListener" class="xx.xx.services.mq.MqClientListener"/> <!-- mq 客户端(消费端) --> <!-- queue litener 观察 监听模式 当有消息到达时会通知监听在对应的队列上的监听对象 --> <rabbit:listener-container connection-factory="connectionFactory" acknowledge="auto"> <rabbit:listener queues="mq-queue" ref="mqClientListener" /> </rabbit:listener-container> </beans>
MqClientListener.java
import org.springframework.amqp.core.Message; import org.springframework.amqp.core.MessageListener; public class MqClientListener implements MessageListener{ @Override public void onMessage(Message message) { System.out.println(new String(message.getBody())); } }
相关推荐
RabbitMq与Spring整合实例,整个工程采用maven,具体过程看博文: http://blog.csdn.net/evankaka/article/details/50495437
RabbitMQ整合spring示例代码(java maven)
https://www.jianshu.com/p/3841059f7ca3 整合spring和rabbitmq
RabbitMq的spring boot整合使用,测试成功,简单易懂哈
介绍Spring Cloud Stream与RabbitMQ集成的代码示例。Spring Cloud Stream是一个建立在Spring Boot和Spring Integration之上的框架,有助于创建事件驱动或消息驱动的微服务。
Spring boot整合消息队列RabbitMQ
spring整合rabbitmq需要的jar包(spring版本4.2.0)
Spring boot+redis+rabbitMq实例整合的简单例子,可用来参考学习
此源码是在前人Demo的基础上自己改造的,主要讲了spring和rabbitMQ的整合与使用。其中包含两个项目,一个Producer,一个Consumer,能够分别运行。Producer生产并发送消息到RabbitMQ,Consumer从RabbitMQ接收并处理...
Springboot整合RabbitMQ最简单demo,适用于springcloud项目,作为消息总线适用,需要安装RabbitMQ,Mac linux可以使用命令行一键安装,在项目配置文件配置好端口即可(已默认配置),启动项目访问8080端口,参数见controller.
Spring Boot与RabbitMQ的整合,内容非常简单,纯API的调用操作。 操作之间需要加入依赖Jar Message Broker是一种消息验证、传输、路由的架构模式,其设计目标主要应用于下面这些场景: 消息路由到一个或多个目的地 ...
简单介绍了如何在Spring Cloud中使用RabbitMQ和Kafka来完成消息发送与接收
Spring Boot 整合 RabbitMQ 案例.zipSpring Boot 整合 RabbitMQ 案例.zipSpring Boot 整合 RabbitMQ 案例.zipSpring Boot 整合 RabbitMQ 案例.zipSpring Boot 整合 RabbitMQ 案例.zipSpring Boot 整合 RabbitMQ 案例...
Spring整合RabbitMQ
spring-cloud之spring-cloud-stream,底层为rabbitmq实现,简单栗子,仅供参考。生产者、消费者配置及生产者、消费者代码实现。
RabbitMQ入门到进阶(Spring整合RabbitMQ&SpringBoot整合RabbitMQ).doc
SpringBoot整合RabbitMQ 实现消息发送确认与消息接收确认机制 源码及教材 可以参考博客: https://blog.csdn.net/qq_29914837/article/details/93376741