大家好,又见面了,我是你们的朋友全栈君。
学习视频参考以下网址:https://www.bilibili.com/video/av49799767?p=7
配置资源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>
spring.application.name=springcloud-mq
spring.rabbitmq.host=192.168.40.96
spring.rabbitmq.port=5672
spring.rabbitmq.username=rabbitmq
spring.rabbitmq.password=123456
@SpringBootApplication
public class SpingbootServerApplication {
public static void main(String[] args) {
SpringApplication.run(SpingbootServerApplication.class, args);
}
}
/**
* 创建消息队列
*
* @author 85762
*
*/
@Configuration//初始化
public class QueueConfig {
@Bean
public Queue createQueue() {
return new Queue("hello-queue");
}
}
/**
* 消息发送者
* @author 85762
*
*/
@Component
public class Sender {
@Autowired
private AmqpTemplate rabbAmqpTemplate;
/*
* 发送消息的方法
*
*/
public void send(String msg) {
//向消息队列发送消息
//参数一:队列的名称
//参数二:消息
this.rabbAmqpTemplate.convertAndSend("hello-queue",msg);
}
}
/**
*
* 消息接收者
* @author 85762
*
*/
@Component
public class Receiver {
/*
* 接受消息的方法,采用消息队列监听机制
*/
@RabbitListener(queues="hello-queue")
public void process(String msg) {
System.out.println("receiver:"+msg);
}
}
/**
* 消息队列测试类
* @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");
}
}
}
发布者:全栈程序员栈长,转载请注明出处:https://javaforall.cn/126340.html原文链接:https://javaforall.cn