当我们对配置内容做了修改，Spring Cloud Config怎么来进行实时更新呢？

• 我们使用前两节中创建的config-server和config-client两个服务来继续实现本节内容

现状

1.先把config-server和config-client都启动起来
然后访问：http://localhost:7001/config-client/test来获取我们之前配置的内容spring.datasource.url的值，内容如下：

image.png

image.png

image.png

先实现"手动"刷新配置

• 修改config-client工程

1. 编辑pom.xml，添加

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

2.修改application.yml文件，将endpoint信息全部暴露出来

management:
  endpoints:
    web:
      exposure:
        include: "*"

3.修改TestController，添加@RefreshScope实现配置和实例刷新

@RestController
@RefreshScope
@RequestMapping(value = "/config-client")
public class TestController {

    @Value("${spring.datasource.url}")
    private String url;

    @GetMapping(path = "/test")
    public String getSence() {
        return url;
    }
}

到这一步就已经实现手动刷新配置了。

测试

重启config-client，访问：http://localhost:7001/config-client/test

image.png

再次configtest-dev.properties文件修改一下，把值改为jdbc:mysql://dev:3309/，端口号变成3309，修改完后，Push到Git仓库中。

image.png

image.png

image.png

实现动态刷新

动态刷新的两种实现方式
1.基于Git的WebHooks
2.Spring Cloud Bus
本节使用基于Git的WebHooks的方式实现动态刷新，后边的章节在来使用Spring Cloud Bus来实现动态刷新。

使用Git仓库的WebHooks来实现动态刷新，避免手动刷新，当有Git提交变化时，就会给对应的配置主机发送/actuator/refresh请求来实现配置信息的实时更新。

image.png

踩坑

在Git WebHooks 发送通知的时候报错了

image.png

public class CustometRequestWrapper extends HttpServletRequestWrapper {
    public CustometRequestWrapper(HttpServletRequest request) {
        super(request);
    }

    @Override
    public ServletInputStream getInputStream() throws IOException {
        byte[] bytes = new byte[0];
        ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);

        return new ServletInputStream() {
            @Override
            public boolean isFinished() {
                return byteArrayInputStream.read() == -1 ? true:false;
            }

            @Override
            public boolean isReady() {
                return false;
            }

            @Override
            public void setReadListener(ReadListener readListener) {

            }

            @Override
            public int read() throws IOException {
                return byteArrayInputStream.read();
            }
        };
    }
}

2.添加Filter

@Component
public class Filter implements javax.servlet.Filter {

    @Override
    public void init(FilterConfig filterConfig) throws ServletException {

    }

    @Override
    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
        HttpServletRequest httpServletRequest = (HttpServletRequest)servletRequest;

        String url = httpServletRequest.getRequestURI();

        //只过滤/actuator/refresh请求
        if (!url.endsWith("/refresh")) {
            filterChain.doFilter(servletRequest, servletResponse);
            return;
        }

        //使用HttpServletRequest包装原始请求达到修改post请求中body内容的目的
        CustometRequestWrapper requestWrapper = new CustometRequestWrapper(httpServletRequest);

        filterChain.doFilter(requestWrapper, servletResponse);
    }

    @Override
    public void destroy() {

    }
}

测试

因为WebHooks的URL地址不能写localhost和127.0.0.1的这些地址，我把config-server和config-client两个服务打包，部署到了服务器上，来看效果。
1.先访问一下http://59.110.164.147:7001/config-client/test(59.110.164.147修改为自己的服务器地址)

image.png

image.png

image.png

image.png

image.png

如果后期系统发展到非常庞大的地步，维护这样的刷新清单将会成为一个非常大的负担，而且容易出错，针对这样的问题，可以通过Spring Cloud Bus来实现以消息总线的方式进行配置变更的通知，并完成集群上的批量配置更新，后续章节中会使用Spring Cloud Bus来实现动态刷新配置。