springboot nacos rabbitmq

### 如何在 Spring Boot 项目中读取 Nacos 配置 #### 添加依赖项 为了使 Spring Boot 能够连接到 Nacos 并从中获取配置信息，在项目的 `pom.xml` 文件里需加入如下依赖： ```xml <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId> </dependency> ``` 此操作允许应用程序通过 Spring Cloud Alibaba 提供的支持来访问 Nacos 的功能[^1]。 #### 配置引导文件 创建或编辑名为 `bootstrap.yml` 或者 `bootstrap.properties` 的引导配置文件，用于指定 Nacos Server 地址及其他必要参数。下面是一个典型的 YML 格式的例子: ```yaml spring: application: name: example-service # 应用名称 cloud: nacos: config: server-addr: localhost:8848 # Nacos服务器地址 file-extension: yaml # 配置文件扩展名，默认为properties, 可选值有 properties/yaml/json/xml 等 ``` 上述设置指定了应用的名字以及它应该去哪里寻找其外部化的属性定义。 #### 使用 @Value 注解注入配置 一旦完成了上面两步工作之后就可以像平常那样利用 `@Value("${property.key}")` 这样的方式去加载来自 Nacos 的键/值对了；当然也可以借助于更高级别的工具类如 `ConfigurationProperties` 来批量映射一组相关的选项至 Java Bean 实体上。 例如： ```java @RestController public class HelloController { private final String message; public HelloController(@Value("${message:Hello default}") String message){ this.message=message; } @GetMapping("/hello") public String hello(){ return "Message from Nacos:" + message ; } } ``` 这段代码展示了如何将一个简单的字符串类型的配置项绑定给控制器中的字段，并且当该路径被请求时返回这条消息的内容。 #### 动态刷新配置 (可选) 如果希望修改后的配置能够不重启服务即刻生效，则还需要引入额外的技术支持——比如结合使用 Actuator 和 Bus 组件实现所谓的“配置推送”。这背后的工作机制涉及到监听器模式的应用，每当检测到远程存储里的数据发生变化就会触发本地缓存的同步更新过程[^2]。 对于想要启用这项特性的开发者来说，除了前面提到的基础组件外还需增加两个 Maven 插件： ```xml <!-- 引入 spring-boot-starter-actuator --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <!-- 引入 spring-cloud-bus --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bus-kafka</artifactId><!-- 或者 rabbitmq 版本 --> </dependency> ``` 最后一步是在主启动类上加上 `@RefreshScope` 注释以便让受管 bean 支持按需重新初始化的能力。

使用Nacos动态修改Spring Boot下的RabbitTemplate配置可以采用以下步骤： 1. 在Nacos上创建一个配置集和配置文件，例如命名为“rabbitmq.properties”。 2. 在配置文件中添加RabbitMQ的配置信息，例如： ``` spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.virtual-host=/ spring.rabbitmq.username=guest spring.rabbitmq.password=guest ``` 3. 在Spring Boot应用启动时，通过Nacos Config客户端加载配置文件，例如： ```java @SpringBootApplication public class DemoApplication { public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); } @Value("${spring.cloud.nacos.config.server-addr}") private String nacosServerAddr; @Value("${spring.cloud.nacos.config.namespace}") private String nacosNamespace; @Value("${spring.cloud.nacos.config.group}") private String nacosGroup; @Value("${spring.cloud.nacos.config.file-extension}") private String nacosFileExtension; @PostConstruct public void init() { ConfigService configService = NacosFactory.createConfigService(nacosServerAddr); String config = ""; try { config = configService.getConfig("rabbitmq.properties", nacosGroup, 5000); } catch (NacosException e) { e.printStackTrace(); } Properties properties = new Properties(); try { properties.load(new StringReader(config)); // 修改RabbitTemplate的配置 RabbitTemplate rabbitTemplate = (RabbitTemplate) applicationContext.getBean("rabbitTemplate"); rabbitTemplate.setConnectionFactory(connectionFactory()); rabbitTemplate.setExchange(properties.getProperty("spring.rabbitmq.template.exchange")); rabbitTemplate.setRoutingKey(properties.getProperty("spring.rabbitmq.template.routing-key")); rabbitTemplate.setReplyAddress(properties.getProperty("spring.rabbitmq.template.reply-address")); rabbitTemplate.setReplyTimeout(Long.parseLong(properties.getProperty("spring.rabbitmq.template.reply-timeout"))); } catch (IOException e) { e.printStackTrace(); } } @Bean public ConnectionFactory connectionFactory() { CachingConnectionFactory connectionFactory = new CachingConnectionFactory(); connectionFactory.setHost(properties.getProperty("spring.rabbitmq.host")); connectionFactory.setPort(Integer.parseInt(properties.getProperty("spring.rabbitmq.port"))); connectionFactory.setVirtualHost(properties.getProperty("spring.rabbitmq.virtual-host")); connectionFactory.setUsername(properties.getProperty("spring.rabbitmq.username")); connectionFactory.setPassword(properties.getProperty("spring.rabbitmq.password")); return connectionFactory; } } ``` 4. 在代码中使用RabbitTemplate发送消息，例如： ```java @Autowired private RabbitTemplate rabbitTemplate; public void sendMessage(String message) { rabbitTemplate.convertAndSend("exchange", "routingKey", message); } ``` 5. 在Nacos上修改RabbitMQ的配置信息时，Nacos Config客户端会自动监听并更新配置信息，应用无需重启即可生效。 注意：使用Nacos动态修改Spring Boot下的RabbitTemplate配置需要确保应用已经正确引入Nacos Config客户端，并且在应用启动时已经加载了配置文件。同时需要注意修改RabbitTemplate的配置后，需要重新设置连接工厂、交换机、路由键、回复地址和回复超时时间等信息。