主页 > 开源代码  > 

SpringBoot3整合RabbitMQ之一_消息生产者与消息消费者服务搭建

SpringBoot3整合RabbitMQ之一_消息生产者与消息消费者服务搭建

文章目录 SpringBoot3整合RabbitMQ之一_消息生产者与消息消费者服务搭建1. 消费发布者服务1. 新建工程2. pom.xml3. application.yml4. 主启动类 2. 消息消费者服务1. 新建工程2. pom.xml3. application.yml4. 主启动类

1. 消费发布者服务 1. 新建工程

新建名称为happy-cloud-message的工程

2. 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-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>3.2.4</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.happy</groupId> <artifactId>happy-cloud-message</artifactId> <version>1.0.0</version> <name>happy-cloud-message</name> <description>happy-cloud-message</description> <properties> <java.version>17</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-configuration-processor</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.83</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <configuration> <excludes> <exclude> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </exclude> </excludes> </configuration> </plugin> </plugins> </build> </project> 3. application.yml

application.yml配置如下

server: port: 2001 spring: application: name: happy-cloud-message rabbitmq: host: 127.0.0.1 port: 5672 username: guest password: guest listener: # 默认 simple,三种类型 simple | direct | stream type: simple 4. 主启动类 package com.happy.msg; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class HappyCloudMessageApplication { public static void main(String[] args) { SpringApplication.run(HappyCloudMessageApplication.class, args); } } 2. 消息消费者服务 1. 新建工程

新建名称为happy-cloud-message-consumer的工程

2. 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-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>3.2.4</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.happy</groupId> <artifactId>happy-cloud-message-consumer</artifactId> <version>1.0.0</version> <name>happy-cloud-message-consumer</name> <description>happy-cloud-message-consumer</description> <properties> <java.version>17</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.amqp</groupId> <artifactId>spring-rabbit-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.83</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <configuration> <excludes> <exclude> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </exclude> </excludes> </configuration> </plugin> </plugins> </build> </project> 3. application.yml server: port: 2002 spring: application: name: happy-cloud-message-consumer rabbitmq: host: 127.0.0.1 port: 5672 username: guest password: guest listener: # 默认 simple,三种类型 simple | direct | stream type: simple 4. 主启动类 package com.happy.msg; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class HappyCloudMessageConsumerApplication { public static void main(String[] args) { SpringApplication.run(HappyCloudMessageConsumerApplication.class, args); } }
标签:

SpringBoot3整合RabbitMQ之一_消息生产者与消息消费者服务搭建由讯客互联开源代码栏目发布,感谢您对讯客互联的认可,以及对我们原创作品以及文章的青睐,非常欢迎各位朋友分享到个人网站或者朋友圈,但转载请说明文章出处“SpringBoot3整合RabbitMQ之一_消息生产者与消息消费者服务搭建