代码编织梦想

  • 依赖引入

<dependency>
	<groupId>org.springframework.amqp</groupId>
	<artifactId>spring-rabbit</artifactId>
	<version>1.7.10.RELEASE</version>
</dependency>
  • 生产者

package com.adiao.rabbitmq.spring;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Send {
	
	public static void main(String[] args) throws InterruptedException {
		AbstractApplicationContext ctx = new ClassPathXmlApplicationContext("classpath:content.xml");
		
		//获取RabbitMQ模板
		RabbitTemplate template = ctx.getBean(RabbitTemplate.class);
		
		//发送消息
		String msg="Hello World!";
		template.convertAndSend(msg);
		Thread.sleep(1000);
		ctx.destroy();
	}
}
  • 消费者

package com.adiao.rabbitmq.spring;

public class Recv {

	public void listen(String sss){
		System.out.println("消费者:"+sss);
	}
}
  • Spring配置文件

<?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/rabbit https://www.springframework.org/schema/rabbit/spring-rabbit.xsd
		http://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd">

	<!-- 定义RabbitMQ连接工厂 -->
	<rabbit:connection-factory id="connectionFactory" host="127.0.0.1"  port="5672"  username="" password="" virtual-host="/"/>
	
	
	<!-- 定义RabbitMQ模板  指定连接工厂 -->
	<rabbit:template id="amqpTemplate" connection-factory="connectionFactory" exchange="fanoutExchange"/>
	
	
	<rabbit:admin connection-factory="connectionFactory"/>
	
	
	<rabbit:queue name="queue_name" auto-declare="true" durable="true"/>
	
	<rabbit:fanout-exchange name="fanoutExchange" auto-declare="true">
		<rabbit:bindings>
			<rabbit:binding  queue="queue_name" />
		</rabbit:bindings>
	</rabbit:fanout-exchange>
	
	<rabbit:listener-container connection-factory="connectionFactory">
		<rabbit:listener ref="sss" method="listen" queue-names="queue_name"/>
	</rabbit:listener-container>
	<!-- 配置消费者的类-->
	<bean id="sss" class=""></bean>
	
</beans>

 

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/q1075988537/article/details/102754269

spring 集成的 rabbitmq 的练习-爱代码爱编程

入门练习 1 pom.xml 文件配置: <dependency> <groupId>org.springframework.amqp</groupId> <ar

spring-rabbit的使用_qianjiayinuo的博客-爱代码爱编程_spring-rabit

目前mq中,spring对rabbit做了很好的封装。 rabbit有5种队列:简单队列、work队列、订阅模式、路由模式、通配符模式。 简单队列:生产者将消息发送到队列,消费者从队列中获取消息。 work队列:一个生产者、多个消费者。一个消息只能被一个消费者获取。 订阅模式:一个生产者、多个消费者。每一个消费者都有自己的一个队列,生产者没有将消息

rabbitmq与spring结合之spring-rabbit使用(三)_向前一丢丢的博客-爱代码爱编程

RabbitMQ的使用相对简单,但是当我们在实际开发过程中同样会感觉麻烦,所以spring团队对RabbitMQ进行了封装,使其使用更加简单,更适合生产环境使用。 构建maven工程 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001

spring 集成 rabbitmq 的几种方式练习_zz775854904的博客-爱代码爱编程

入门练习 1 pom.xml 文件配置: <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit</artifactId> <version>1.4

spring和rabbitmq的整合_wangbiao007的博客-爱代码爱编程

这篇博客只是起到一个记录的作用 pom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-i

rabbitmq与spring的整合及常见三种消息模式使用_划船一哥的博客-爱代码爱编程

一. 概念 定义:     RabbitMQ是流行的开源消息队列系统,用erlang语言开发。RabbitMQ是AMQP(高级消息队列协议)的标准实现。 消息生产与消费机制如下: 常见MQ横向比较:     RabbitMQ:它比kafka成熟,支持AMQP事务处理,在可靠性上,RabbitMq超过kafka,在性能方面超过ActiveMQ;

spring 集成rabbitmq 遇到的问题:版本配置-爱代码爱编程

版本配置时,遇到了一个小问题,记录一下; pom.xml配置文件中,依赖的组件比较旧了,需要更新; <!--消息队列--> <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artif

springboot整合rabbitmq-爱代码爱编程

目录   一、配置文件 1、pom.xml 2、application.yml 二、创建好了交换器、消息等并关联了 三、测试单播 1、发送消息 2、接收消息 3、自定义MessageConverter  四、测试广播 五、监听消息队列 1、@EnableRabbit开启基于注解的rabbitmq模式 2、@RabbitListen

spring集成RabbitMQ配置文件详细解读(生产者和消费者)-爱代码爱编程

引入jar包 <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</artifactId> <version>4.0.0</version>

5、SpringAMQP整合RabbitMq-爱代码爱编程

  POM文件中 <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit-test</artifactId> <scope>test</scope>

(二)Spring与SpringBoot对RabbitMQ的整合篇-爱代码爱编程

Spring与SpringBoot对RabbitMQ的整合篇 Spring 整合RabbitMQ 搭建生产者工程 创建maven项目,添加依赖 重点是spring-rabbit依赖 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache

Spring 整合RabbitMQ-爱代码爱编程

目录 1. 搭建生产者工程1.1. 创建工程1.2. 添加依赖1.3. 配置整合1.4. 发送消息2. 搭建消费者工程2.1. 创建工程2.2. 添加依赖2.3. 配置整合2.4. 消息监听器1)队列监听器2)广播监听器13)广播监听器24)星号通配符监听器5)井号通配符监听器6)井号通配符监听器2 1. 搭建生产者工程 1.1. 创建工程

Spring中配置多个RabbitMQ的步骤-爱代码爱编程

最近在开发Spring项目,其中用到了多个RabbitMQ,现在总结如下。 如果要配置多个RabbitMQ,就将rabbitMq相关的xml中的配置再复制一份,然后创建对应的生产者消费者类即可。 1.pom.xml中进行配置,导入jar包: <dependency> <groupId>org.springframework

MySQL数据库:1200页文档笔记,附赠课程+题库-爱代码爱编程

前言 数据库相关的面试题早已成为了一线互联网大厂面试的家常菜,如果你对数据库不太熟悉,我劝你不要轻易面试大厂。那么,为什么数据库成了大厂面试的家常菜呢?主要原因当然还是海量数据。 无论对于刚入行的小白还是有几年Java开发经验的从业而言,面试不仅是你必须要面对的事情,更是你升职加薪的一个途径。许多朋友面试了几家公司也没拿到一个满意的薪资,究其根还是在于