Rabbitmq入门案例

Rabbitmq入门案例1创建一个maven项目配置资源pom.xml文件<projectxmlns=”http://maven.apache.org/POM/4.0.0″ xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance” xsi:schemaLocation=”http://maven.apache.org/POM/4…

大家好,又见面了,我是你们的朋友全栈君。

Rabbitmq入门案例

学习视频参考以下网址:https://www.bilibili.com/video/av49799767?p=7

1 创建一个maven项目

配置资源pom.xml文件

<project xmlns="http://maven.apache.org/POM/4.0.0"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>

	<groupId>cn.yunhe</groupId>
	<artifactId>springcloud-mq</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>jar</packaging>

	<name>springcloud-mq</name>
	<description>Demo project for Spring Boot</description>



	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.2.1.RELEASE</version>
		<relativePath />
	</parent>

	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
		<java.version>1.8</java.version>
		<maven-jar-plugin.version>3.1.1</maven-jar-plugin.version>

	</properties>

	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
		
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-amqp</artifactId>
		
		</dependency>
		
	</dependencies>

	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
			</plugin>
		</plugins>


	</build>


</project>

1.1在资源管理目录下里创建一个application.properties文件

在这里插入图片描述

spring.application.name=springcloud-mq

spring.rabbitmq.host=192.168.40.96
spring.rabbitmq.port=5672
spring.rabbitmq.username=rabbitmq
spring.rabbitmq.password=123456

1.2 在主目录下创建SpringbootServerApplication类

@SpringBootApplication
public class SpingbootServerApplication {

	public static void main(String[] args) {
		SpringApplication.run(SpingbootServerApplication.class, args);
	}
	
}

1.3 创建消息队列QueueConfig

/**
 *  创建消息队列
 * 
 * @author 85762
 *
 */


@Configuration//初始化
public class QueueConfig {

	@Bean
	public Queue createQueue() {
		
		return new Queue("hello-queue");
		
	}
	
	
	
}

1.4 创建消息发送者Sender

/**
 * 消息发送者
 * @author 85762
 *
 */


@Component
public class Sender {
	
	@Autowired
	private AmqpTemplate rabbAmqpTemplate;
	
	

	/*
	 * 发送消息的方法
	 * 
	 */
	public void send(String msg) {
		//向消息队列发送消息
		//参数一:队列的名称
		//参数二:消息
		this.rabbAmqpTemplate.convertAndSend("hello-queue",msg);
		
		
	}
	
}

创建消息接收者Receiver

/**
 * 
 * 消息接收者
 * @author 85762
 *
 */
@Component
public class Receiver {

	/*
	 * 接受消息的方法,采用消息队列监听机制
	 */
	@RabbitListener(queues="hello-queue")
	public void process(String msg) {
		
		System.out.println("receiver:"+msg);
		
	}
	
	
}

创建消息队列测试类QueueTest


/**
 * 消息队列测试类
 * @author 85762
 *
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes=SpingbootServerApplication.class)
public class QueueTest {

	@Autowired
	private Sender sender;
	
	@Test
	public void test1() throws InterruptedException {
		while(true) {
			
			Thread.sleep(1000);
			this.sender.send("Hello RabbitMQ");
		}
	
	}
	
	
	
}
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/126340.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • c语言里void什么作用,c语言中void的含义是什么?如何使用?

    c语言里void什么作用,c语言中void的含义是什么?如何使用?c语言中void的含义是什么?如何使用?发布时间:2020-04-2614:08:27来源:亿速云阅读:416作者:小新c语言中void的含义是什么?如何使用?相信有很多人都不太了解,今天小编为了让大家更加了解c语言中void,所以给大家总结了以下内容,一起往下看吧。c语言中void的含义1、void的含义:void的字面意思是“无类型”,void*则为“无类型指针”,void*可以指向任何…

  • Oracle 12.1.0.2 对JSON的支持

    Oracle 12.1.0.2 对JSON的支持

  • MPU9250传感器

    MPU9250内部包括3轴陀螺仪、3轴加速度计和3轴磁力计,这3个功能输出都是16位的数字量;可以通过常用的数据总线(IIC)接口和单片机进行数据交互,传输速率400kHz/s。陀螺仪的角速度测量范围±2000(°/s),具有良好的动态响应特性。加速度计的测量范围最大为±16g(g为重力加速度),静态测量精度高。磁力计采用高灵度霍尔型传感器进行数据采集,磁感应强度测量范围为±4800μT,可用于对偏航角的辅助测量。MPU9250自带的数字运动处理器DMP硬件加速引擎,可

  • @Table爆红

    @Table爆红

  • c# taskscheduler使用场合_hbase shell put

    c# taskscheduler使用场合_hbase shell put这里记录下TaskScheduler的简单用法。使用场景:在使用Task的时候,大家都知道用TaskFactory.StartNew可以用来创建一个Task。这里如果创建10个,那么这10个Task就各自放飞直接运行了。一般情况下是没什么大问题,如果这10个中的每个Task非常耗CPU或者内存,而公司的产品又是非常考验配置成本(比如一体机,移动设备等),就需要让这10个Task按照一定要求执行,比如串行执行,从而节省资源、让机器还可以顺畅去干别的事情。Task…

    2022年10月11日
  • 数据绑定之DataFormatString

    数据绑定之DataFormatString设定BoundField的DataFormatString,通常有以下几种DataFormatString='{0:C}’货币,货币的格式取决于当前Thread中Culture的设置DataF

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号