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)
blank

相关推荐

  • Java课程设计之 学生成绩管理系统「建议收藏」

    Java课程设计之 学生成绩管理系统「建议收藏」实现内容:设计开发一个学生成绩管理系统(1)根据实现的功能,划分出合理的对象类,明确各个对象类之间的关系。为各个对象类设计正确的域和方法,为每个方法设计合理的方法体。同时,为对象类及内部的域和方法运用正确的修饰符。功能要求:(1)录入成绩(2)查询成绩(3)成绩排序(4)修改成绩(5)删除成绩(6)将数据保存在数据库表中该课程设计涉及MySQL数据库,建表操作,java操作SQL语句(JDBC数据库操作)以及JavaS

  • 基础篇:数据库 SQL 入门教程

    超全SQL教程,收藏就完事了!

  • pycharm配置tensorflow环境_python3.6对应的tensorflow版本

    pycharm配置tensorflow环境_python3.6对应的tensorflow版本说明:如果只是为了入门学习TensorFlow框架,个人觉得,没必要上来就整GPU版本(主要是那个太复杂,安装真让人劝退),所以本文记录的是直接在pycharm里安装tensorflow,并运行demo。安装3.5或3.6版本的python,3.7及以上的版本貌似还不支持TensorFlow,博主用的是3.6.8版本,特别注意python还要求得是64位的,否则后面安装TensorFlow会…

  • 14个简单有用的android源码,适合初学者

    1:查看是否有存储卡插入String status=Environment.getExternalStorageState();if(status.equals(Enviroment.MEDIA_MOUNTED)){ ;//说明有SD卡插入}2:让某个Activity透明在OnCreate 中不设Layout,然后this.setTheme(R.style.Th

  • Android HandlerThread 详解

    Android HandlerThread 详解概述HandlerThread相信大家都比较熟悉了,从名字上看是一个带有Handler消息循环机制的一个线程,比一般的线程多了消息循环的机制,可以说是Handler+Thread的结合

  • 在win7下安装VC6.0

    在win7下安装VC6.0

    2021年11月14日

发表回复

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

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