1.选择Maven项目，然后选择maven-archetype-site，最后点击Next
2.填好自己的GAV，Next
3.选好自己的Maven配置
选择完Maven依赖后，一直Next直至Finish即可.
4.字符编码配置
5.注解生效激活
6.修改JAVA编译版本为8
7.修改父工程的POM文件
4.0.0 com.rabbitmq.nacos rabbitmq-nacos-2021 1.0-SNAPSHOT UTF-8 1.8 1.8 2.2.2.RELEASE 2.1.0.RELEASE 2.2.2.RELEASE com.alibaba.cloud spring-cloud-alibaba-dependencies ${spring.cloud.alibaba.version} pom import org.springframework.boot spring-boot-starter-amqp ${spring.amqp.rabbit.version} org.springframework.boot spring-boot-dependencies ${spring.boot.version} pom import nexus-aliyun Nexus aliyun http://maven.aliyun.com/nexus/content/groups/public true false
至此，父工程的搭建已经结束。下面开始其他模块的搭建工作。
创建 消费者子工程:cloud-rabbit-consumer1.在父工程名上右键后选择如下图红框所示:
2.和父工程不同的是，此处要选择maven-archetype-quickstart(maven jar项目)，不能再选择site聚合工程.
3.其余步骤请参考父工程创建步骤的2、3步。
4.修改子工程的POM文件
子工程:cloud-rabbit-consumer POM依赖rabbitmq-nacos-2021 com.rabbitmq.nacos 1.0-SNAPSHOT 4.0.0 cloud-rabbit-consumer com.alibaba.cloud spring-cloud-starter-alibaba-nacos-discovery org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-amqp
5.写yml配置
# 本服务端口
server:
port: 56723
# 本服务应用名称
spring:
application:
name: cloud-rabbit-consumer
# Nacos配置地址
cloud:
nacos:
discovery:
server-addr: localhost:8848
#RabbitMq配置
rabbitmq:
username: admin
password: admin
virtual-host: /
host: 此处写你的RabbitMq服务地址
port: 此处写你的RabbitMq端口
6.编写服务主启动类
package com.rabbitmq.nacos;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@SpringBootApplication
@EnableDiscoveryClient
public class ConsumerMain56723 {
public static void main(String[] args) {
SpringApplication.run(ConsumerMain56723.class, args);
}
}
7.编写RabbitMq交换机绑定配置类
package com.rabbitmq.nacos.config;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitMqBindConfig {
@Bean
public FanoutExchange fanoutExchange(){
//参数说明:
//name:交换机的名称
//durable:true、false 服务器重启是否会保留下来Exchange。警告：仅设置此选项，不代表消息持久化。即不保证重启后消息还在。原文：true if we are declaring a durable exchange (the exchange will survive a server restart)
//autoDelete:true、false. 当已经没有消费者时，服务器是否可以删除该Exchange。原文1：true if the server should delete the exchange when it is no longer in use。
return new FanoutExchange("rabbit-fanout-exchange",true,false);
}
@Bean
public Queue emailQueue(){
//参数说明:
//name:交换机的名称
//durable:true、false 服务器重启是否会保留下来Exchange。警告：仅设置此选项，不代表消息持久化。即不保证重启后消息还在。原文：true if we are declaring a durable exchange (the exchange will survive a server restart)
return new Queue("email.queue",true);
}
@Bean
public Binding emailBinding(){
//该bind方法意思是，将某队列绑定(bind)到(to)某交换机上
return BindingBuilder.bind(emailQueue()).to(fanoutExchange());
}
}
8.编写消费者Service，消费端的监听方式有三种，基于配置类的有两种，不需要配置类的一种:如下。
8.1 基于配置类，使用@RabbitListener注解的方式进行监听
package com.rabbitmq.nacos.consumer;
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@Component
public class ConsumerConfigListener {
//queues中填写想要监听的队列名称，注意，请勿写错，否则无法获取消息
@RabbitListener(queues = "email.queue")
public void smsConsumerListener(Message message, Channel channel) {
String msg = new String(message.getBody());
System.out.println("email.queue-------------->" + msg);
}
}
8.2 基于配置类，使用@RabbitListener与@RabbitHandler注解的方式进行监听
package com.rabbitmq.nacos.consumer;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@Component
@RabbitListener(queues = "email.queue")
public class ConsumerConfigListenerTwo {
@RabbitHandler
public void smsConsumer(String msg) {
System.out.println("email.queue-------------->" + msg);
}
}
8.2 舍弃配置类，使用@RabbitListener与@RabbitHandler注解的方式进行监听,
之所以不需要配置类，是因为在@RabbitListener就已经使用注解的属性进行了队列的声明和绑定。
package com.rabbitmq.nacos.consumer;
import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.stereotype.Component;
// bindings其实就是用来确定队列和交换机绑定关系
@RabbitListener(bindings =@QueueBinding(
// email.queue 是队列名字，这个名字你可以自定随便定义。
value = @Queue(value = "email.queue",autoDelete = "false"),
// rabbit-fanout-exchange 是交换机的名字 必须和生产者保持一致
exchange = @Exchange(value = "rabbit-fanout-exchange",
// 这里是确定的rabbitmq模式是：fanout 是以广播模式 、 发布订阅模式
// 还有Topic与Direct模式
type = ExchangeTypes.FANOUT)))
@Component
public class ConsumerConfigListenerThree {
@RabbitHandler
public void smsConsumer(String msg) {
System.out.println("email.queue-------------->" + msg);
}
}
方法三的验证结果如下图，可明显看到控制台无异常，RabbitMq的管理界面也新建了对应的交换机与队列:
消费者搭建完毕后的工程结构请看图:
以上三种监听的方式，根据业务场景自行选择。
至此，消费者服务搭建完毕，下面开始搭建生产者。
创建 生产者子工程:cloud-rabbit-producer1.子工程创建步骤请参考消费者的步骤，此处不再赘述。
2.POM依赖与消费者一致，注意，请勿Ctrl-a全部复制POM文件到生产者，因为artifactId不同。不要太懒，多动手多动脑总是好的，复制所需依赖就够啦。
3.写yml配置,与消费者服务不同的是，只改了本服务的端口号与应用名称.
# 本服务端口
server:
port: 56722
# 本服务应用名称
spring:
application:
name: cloud-rabbit-producer
# Nacos配置地址
cloud:
nacos:
discovery:
server-addr: localhost:8848
#RabbitMq配置
rabbitmq:
username: admin
password: admin
virtual-host: /
host: 此处写你的RabbitMq服务地址
port: 此处写你的RabbitMq端口
4.生产者主启动类
package com.rabbitmq.nacos;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@SpringBootApplication
@EnableDiscoveryClient
public class ProducerMain56722 {
public static void main(String[] args) {
SpringApplication.run(ProducerMain56722.class, args);
}
}
5.生产者消息生产Service
package com.rabbitmq.nacos.producer;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.UUID;
@Service
public class ProducerMsgService {
@Resource
private RabbitTemplate rabbitTemplate;
public void productToPushEmailQueue() {
// 模拟发送邮件
String emailmsg = UUID.randomUUID().toString();
System.out.println("发送消息:" + emailmsg);
rabbitTemplate.convertAndSend( "rabbit-fanout-exchange", "", emailmsg);
}
}
6.生产者消息生产Controller
package com.rabbitmq.nacos.controller;
import com.rabbitmq.nacos.producer.ProducerMsgService;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@RestController
public class ProducerMsgController {
@Resource
private ProducerMsgService producerMsgService;
@GetMapping("/mq/producer")
public void rabbitMqProducer() {
producerMsgService.productToPushEmailQueue();
}
}
生产者最后的工程结构请看图:
7.通过PostMan发送请求后成功推送消息:
RabbitMq中也有对应的消息
下面来看消费情况,可以看到启动后成功在控制台打印了队列中的消息:
nacos中服务情况:
服务:rabbitmqnacos2021的整体结构如图:
以上就是RabbitMq + Nacos整合的搭建过程。
