spring-cloud Finchley 微服务架构从入门到精通【六】BUS RabbitMQ 配置刷新

淡淡的烟草味﹌ 2023-10-17 21:11 26阅读 0赞

上篇文章介绍了高可用的配置中心，如何在不重启服务器的情况下对配置文件进行更新呢？请看下面的介绍  
\#\#一、安装rabbitMq \#\#  
\#\#\#1、下载地址\#\#\#  
http://www.rabbitmq.com/download.html  
\#\#\#2、运行\#\#\#  
输入http://localhost:15672，出下以下界面，说明安装成功

![这里写图片描述][70]

\#\#\#3、cloud整合配置说明\#\#\#

*  默认端口： 5672
 *  默认用户名：guest
 *  默认密码：guest

\#\#二、代码实现\#\#  
\#\#\#1、添加依赖\#\#\#  
config 服务端：commonservice-config 添加如下依赖：

<dependency>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-actuator</artifactId>
                </dependency>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
                </dependency>

在config 客户端：bussnessservice-user添加

<dependency>  
    		    <groupId>org.springframework.boot</groupId>  
    		    <artifactId>spring-boot-starter-web</artifactId>  
    		</dependency> 
           <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
           </dependency>
           <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-bus-amqp</artifactId>
            </dependency>

\#\#\#2、修改配置\#\#\#  
修改两个项目的yml文件，加入以下配置：

spring:
      rabbitmq: 
        host: localhost
        port: 5672
        username: guest
        password: guest
    management: 
      endpoints:
        web:
          exposure: 
            include: "*"
          cors:
            allowed-origins: "*"
            allowed-methods: "*"

配置说明：

*  rabbitmq配置
 *  默认关闭了bus请求url，因此需要打开才能使用

在客户端bussnessservice-user的配置文件中添加一个属性server.time=update version1，用来测试属性的变更  
\#\#\#3、在需要刷新配置的类上添加@RefreshScope注解\#\#\#

package com.mayi.springcloud.controller;
    
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.cloud.context.config.annotation.RefreshScope;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @RefreshScope
    public class UserManagementController {
        
    	
    	@Value("${server.port}")
    	String serverPort;
    	
    	@Value("${server.time}")
    	String testValue;
    	@GetMapping("/listUsers")
    	public String ListUsers(){
        
    		
    		/**
    		 * 模拟从数据库查询
    		 */
    		List<Map<String, Object>> users = new ArrayList<Map<String, Object>>();
    		for(int i=1; i< 5; i++){
        
    			Map<String, Object> user = new HashMap<String, Object>();
    			user.put("id", i);
    			user.put("name", "小明" + i);
    			users.add(user);
    		}
    		return "服务器端口号：   " + serverPort + "   |   用户信息：   " + users.toString();
    	}
    	
    	@GetMapping("/getTestValue")
    	public String getTestValue(){
        
    		return testValue;
    	}
    }

\#\#三、测试\#\#  
依次启动eureka server、config server 和 config client（启动两个端口，以测试批量更新配置文件）三个项目  
启动配置中心时可以看到如下日志：

![这里写图片描述][70 1]

*  /actuator/refresh ：刷新单个节点
 *  /actuator/bus-refresh: 刷新所有节点

启动完成：

![这里写图片描述][70 2]

使用postman测试：  
发送Post请求 **http://localhost:8801/getTestValue** 和 **http://localhost:8802/getTestValue**

![这里写图片描述][70 3]

![这里写图片描述][70 4]

修改配置文件：

server:
      port: 8802
      time: update version100

发送post请求 http://localhost:8801/actuator/bus-refresh

![这里写图片描述][70 5]

![这里写图片描述][70 6]

注意：添加 spring-boot-starter-amqp 依赖有时会报错，这是因为maven里面有多个版本，需要删除，再重新maven - update project

github: https://github.com/tianyana/springcloud

接下来，我会依次更新文章，直至整个架构完成，如有兴趣的朋友关注作者 或 加我微信 拉你进入spring cloud社区群

![这里写图片描述][70 7]

微信公众号：java架构师修行

![这里写图片描述][70 8]

本公众号将要按照JAVA高级软件架构师实战培训的路线发布一期完整的架构文章，难度由浅入深，适合有一定开发基础想转架构和正在做初级架构开发的人员学习

[70]: https://img-blog.csdn.net/20180428113123144?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3djYmxvZw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 1]: https://img-blog.csdn.net/20180428113138356?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3djYmxvZw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 2]: https://img-blog.csdn.net/20180428113146942?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3djYmxvZw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 3]: https://img-blog.csdn.net/20180428113157546?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3djYmxvZw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 4]: https://img-blog.csdn.net/2018042811320530?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3djYmxvZw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 5]: https://img-blog.csdn.net/20180428113215230?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3djYmxvZw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 6]: https://img-blog.csdn.net/20180428113224310?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3djYmxvZw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 7]: https://img-blog.csdn.net/20180428113238119?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3djYmxvZw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70
[70 8]: https://img-blog.csdn.net/20180428113245989?watermark/2/text/aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3djYmxvZw==/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70