`
songkaiang
  • 浏览: 4643 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

spring rabbitmq整合

 
阅读更多

由于种种原因,要在项目中使用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()));
	}

}

 

 

  • 大小: 2.8 KB
分享到:
评论

相关推荐

    RabbitMq与Spring整合实例

    将RabbitMQ与Spring整合,可以方便地在Spring应用中使用消息队列,实现异步通信和任务调度。 本实例主要介绍如何在Spring应用中集成RabbitMQ,构建一个完整的消息传递系统。首先,你需要确保已经安装了RabbitMQ...

    spring整合rabbitmq的实例

    本文将详细介绍如何整合Spring与RabbitMQ,以实现高效的消息传递。 首先,我们要理解Spring对RabbitMQ的支持主要体现在Spring AMQP项目中,它为RabbitMQ提供了一套高级抽象层,使得开发者能够更加便捷地使用...

    RabbitMq整合使用

    **RabbitMQ整合使用详解** RabbitMQ是一个开源的消息队列系统,基于AMQP(Advanced Message Queuing Protocol)协议,广泛应用于分布式系统中,用于处理异步任务、解耦组件以及实现流量控制。在Spring Boot框架中...

    RabbitMQ整合spring示例代码(java maven)

    将RabbitMQ与Spring整合,可以更好地管理和处理消息传递。 本示例代码基于Java和Maven构建,展示了如何在Spring项目中集成RabbitMQ。以下是集成过程的关键步骤和知识点: 1. **依赖管理**:首先,在Maven的`pom....

    spring整合rabbitmq需要的jar包(spring版本4.2.0)

    当我们将Spring与RabbitMQ整合时,可以利用Spring的IOC(Inversion of Control)和AOP(Aspect-Oriented Programming)特性来优雅地管理消息的生产与消费。 在"spring整合rabbitmq需要的jar包(spring版本4.2.0)...

    介绍Spring Cloud Stream与RabbitMQ集成

    介绍Spring Cloud Stream与RabbitMQ集成的代码示例。Spring Cloud Stream是一个建立在Spring Boot和Spring Integration之上的框架,有助于创建事件驱动或消息驱动的微服务。

    SpringBoot+redis+RabbitMq整合实例

    总的来说,Spring Boot+Redis+RabbitMq的整合提供了高效的数据缓存和消息传递机制,对于构建可扩展、高可用的分布式系统具有极大的价值。通过理解和掌握这些技术,开发者可以更好地应对复杂的企业级项目挑战。

    Spring-rabbitMQ整合消息队列RabbitMQ

    Spring boot整合消息队列RabbitMQ

    spring rabbitmq amqp

    Spring RabbitMQ AMQP 是一个基于Java的开源框架,它整合了RabbitMQ消息中间件,实现了高级消息队列协议(AMQP)。这个框架是Spring生态的一部分,为Spring Boot应用程序提供了强大的消息处理能力。AMQP是一种标准的...

    Spring整合RabbitMQ完整项目源码.rar

    此源码是在前人Demo的基础上自己改造的,主要讲了spring和rabbitMQ的整合与使用。其中包含两个项目,一个Producer,一个Consumer,能够分别运行。Producer生产并发送消息到RabbitMQ,Consumer从RabbitMQ接收并处理...

    22.Spring Cloud整合RabbitMQ或Kafka消息驱动

    在Spring Cloud框架中,整合RabbitMQ或Kafka作为消息驱动是常见的微服务间通信方式。这两种技术都是流行的消息中间件,用于实现异步处理、解耦和扩展性。下面将详细阐述它们在Spring Cloud中的应用。 首先,...

    Springboot整合RabbitMQ最简单demo

    Springboot整合RabbitMQ最简单demo,适用于springcloud项目,作为消息总线适用,需要安装RabbitMQ,Mac linux可以使用命令行一键安装,在项目配置文件配置好端口即可(已默认配置),启动项目访问8080端口,参数见controller.

    SpringCloudStream整合RabbitMq

    **SpringCloudStream与RabbitMQ整合详解** SpringCloudStream是一个框架,它允许应用程序以声明式方式定义输入和输出绑定,从而简化与消息中间件的集成。在这个场景中,我们将讨论如何将SpringCloudStream与...

    RabbitMQ与SpringMVC集成

    1. 引入依赖:在项目中添加RabbitMQ的Spring整合依赖,如`spring-amqp`库。 2. 配置RabbitMQ:在Spring的配置文件中,定义连接工厂、信道配置以及RabbitMQ服务器的相关属性。 3. 创建消息模板:使用`RabbitTemplate`...

    Spring整合RabbitMQ

    "Spring整合RabbitMQ实现商品数据同步" Spring框架整合RabbitMQ实现商品数据同步是一个非常重要的知识点。在本文中,我们将详细介绍如何使用Spring框架整合RabbitMQ实现商品数据同步。 首先,让我们了解什么是...

    RabbitMq整合SSM案例

    "RabbitMQ整合SSM案例"是一个示例项目,展示了如何将消息队列系统RabbitMQ与Spring、SpringMVC和MyBatis这三大流行Java框架进行整合,同时利用Maven作为项目构建工具。以下是对这个案例涉及的知识点的详细解释: **...

    Spring Bootg整合RabbitMQ

    Spring Boot与RabbitMQ的整合,内容非常简单,纯API的调用操作。 操作之间需要加入依赖Jar Message Broker是一种消息验证、传输、路由的架构模式,其设计目标主要应用于下面这些场景: 消息路由到一个或多个目的地 ...

Global site tag (gtag.js) - Google Analytics