`

rabbit mq&spring

 
阅读更多
xmlns:rabbit="http://www.springframework.org/schema/rabbit"
http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit.xsd

<rabbit:connection-factory id="rabbitmqConnectFactory" host="192.168.142.128" port="5672" username="rai" password="rai"/>
  	
  	<rabbit:admin connection-factory="rabbitmqConnectFactory"/>
  	
  	<rabbit:template id="rabbitTemplate" message-converter="jsonMessageConverter" connection-factory="rabbitmqConnectFactory"/>
  	
  	<bean id="jsonMessageConverter" class="org.springframework.amqp.support.converter.Jackson2JsonMessageConverter" /> 
  	
  	<rabbit:queue name="simpleQue" durable="true"/>
  	
  	<rabbit:direct-exchange name="directExchange" durable="true">
  		<rabbit:bindings>
  			<rabbit:binding queue="simpleQue" key="simpleQue"></rabbit:binding>
  		</rabbit:bindings>
  	</rabbit:direct-exchange>
  	
  	<rabbit:annotation-driven/>
  	
  	<bean id="rabbitListenerContainerFactory" class="org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory">
	    <property name="connectionFactory" ref="rabbitmqConnectFactory"/>
	    <property name="concurrentConsumers" value="3"/>
	    <property name="maxConcurrentConsumers" value="10"/>
	</bean>

public void mqprdtest(){
		rabbitTemplate.convertAndSend("simpleQue", new String("Hello Rabbit"));
	}
	
	@RabbitListener(queues = {"simpleQue"})
	public void mqcustest(Message message){
		System.out.println(new String(message.getBody()));
	}
分享到:
评论

相关推荐

    rabbit mq demo spring java

    docker 安裝 rabbit mq 並測試 http://knight-black-bob.iteye.com/blog/2395713

    spring boot 集成rabbit mq 成功demo

    spring boot 集成rabbit mq 成功demo,spring boot 集成rabbit mq 成功demo

    spring-cloud-starter-stream-rabbit MQ使用规范

    我们可以通过配置 `spring.cloud.stream.rabbit.bindings.input.consumer.bindingRoutingKey` 属性来设置 Routing-Key。例如,订单支付完成通知卡包的 Routing-Key 为 `order.paid.card`。 消息提供者(Provider) ...

    spring整合rabbit mq的jar包

    spring-rabbit-1.5.1.RELEASE.jar, spring-amqp-1.5.1.RELEASE.jar, rabbitmq-client.jar spring-retry-1.1.2.RELEASE.jar 四个包 之前的资源不好意思传错了一个

    RabbitMq与Spring整合实例

    &lt;bean id="rabbitConnectionFactory" class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory"&gt; &lt;bean id="rabbitTemplate" class="org.springframework.amqp.rabbit.core....

    简单封装spring-rabbit实现mq组件化

    本篇文章将围绕"简单封装spring-rabbit实现mq组件化"这一主题,探讨如何通过Spring框架和RabbitMQ来构建可复用的MQ组件。 首先,我们需要了解Spring框架的Spring AMQP模块,这是Spring对RabbitMQ的支持。它提供了...

    rabbit和spring整合实战

    RabbitMQ是一个广泛使用的开源MQ服务器,而Spring框架则是一个Java领域的全功能开发框架。本文将深入探讨如何将RabbitMQ与Spring进行整合,实现一个实战项目。 首先,我们需要了解RabbitMQ的基本概念。RabbitMQ基于...

    mq.rar springcloud整合rabbit java工程

    mq.rar springcloud对接rabbit java工程 RabbitMQ是一种消息中间件,用于处理来自客户端的异步消息。服务端将要发送的消息放入到队列池中。接收端可以根据RabbitMQ配置的转发机制接收服务端发来的消息。 RabbitMQ...

    介绍Spring Cloud Stream与RabbitMQ集成

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

    RabbitMQ与SpringMVC集成

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

    rabbitmq-advanced-spring-boot-starter:一个通用库,用于通过spring boot amqp上的扩展名与rabbit mq进行消息传递

    该项目的目的是为Rabbit MQ提供一个通用的Spring Boot Starter项目,用于消息传递解决方案。 通过简单地在yml中提供配置,这有助于我们自动配置Rabbit mq交换和队列以及绑定。 这也有助于在框架级别的单个位置更好地...

    RabbitMQ-SpringBoot-Project:这是一个有关如何使用Rabbit MQ和Spring Boot将消息从Producer发送到Consumer应用程序的项目

    在本文中,我们将深入探讨如何使用RabbitMQ和Spring Boot集成来实现消息队列系统,以便在Producer和Consumer之间高效地传递数据。首先,我们来理解RabbitMQ和Spring Boot的基本概念。 **RabbitMQ** 是一个开源的...

    spring之mysql读写分离

    Spring框架,作为Java领域广泛使用的轻量级框架,提供了强大的支持来实现这一目标。本文将深入探讨如何利用Spring AOP(面向切面编程)实现应用层的MySQL读写分离,并结合一主多从的配置来进行详细讲解。 首先,...

    Spring RabbitMQ demo

    **Spring RabbitMQ 概述** Spring RabbitMQ 是 Spring 框架的一部分,它提供了一种在 Java 应用程序中集成 RabbitMQ 消息代理的简单方式。RabbitMQ 是一个开源的消息队列系统,遵循 Advanced Message Queuing ...

    基于Spring Boot框架的AUTUMN管理系统.zip

    AUTUMN管理系统是一个基于JDK1.8、MySQL8.0、Spring Boot、Mybatis Plus、JWT、Spring Security、Redis、Rabbit MQ、Vue2.6、vuex、elementUI、sockJS的管理系统后端源码。它提供了丰富的功能和模块,适用于各种企业...

    RabbitMq整合使用

    import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org....

    RabbitMQ.pdf-详情

    例如,通过`@RabbitListener`注解定义消费者,`@RabbitTemplate`处理生产者,以及通过`rabbit:`配置元素配置RabbitMQ连接。 对于Spring Boot应用,集成RabbitMQ变得更加简单。只需要在`pom.xml`中添加Spring Boot的...

    rabbitmq 所需jar包

    2. spring-rabbit-1.7.5.RELEASE.jar:Spring Rabbit是Spring框架的一个模块,它提供了一种更高级别的API来简化与RabbitMQ的集成。它利用了Spring的依赖注入和配置模型,使得开发者可以方便地声明RabbitMQ组件,如...

    ssm-rabbit-mq-发送消息-接收消息

    SSM(Spring、SpringMVC、MyBatis)框架与RabbitMQ的集成是企业级应用中常见的一种技术组合,用于实现高效的消息通信。RabbitMQ是一个开源的消息代理和队列服务器,它允许应用程序之间通过异步处理进行解耦。在本...

    java rabbitmq动态注册,监听实现

    在这个场景中,"java rabbitmq动态注册,监听实现"涉及到的主要知识点是利用Spring Boot框架与RabbitMQ集成,动态配置消费者,并实现实时监听消息。 1. **Spring Boot与RabbitMQ集成**: Spring Boot简化了...

Global site tag (gtag.js) - Google Analytics