Spring Cloud 集成 WebHook 1.配置 WebHook 地址登录 GitHub，点击 GitHub 的 WebHook 菜单，右侧面板中 Payload URL 填写 <配置中心 url>/actuator/bus-refresh, Content-type 选择 applicaton/json，保存即可。因为需要用到外网，这里使用natapp外网穿透做外网映射设置 WebHook 操作： 2.修改config-server添加：import org.springframework.stereotype.Component;import javax.servlet.*;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletRequestWrapper;import java.io.ByteArrayInputStream;import java.io.IOException;@Componentpublic class WebHookFilter implements Filter {    @Override     public void init(FilterConfig filterConfig) throws ServletException {     }    @Override     public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)             throws IOException, ServletException {         HttpServletRequest httpServletRequest = (HttpServletRequest) request;         String url = new String(httpServletRequest.getRequestURI());        // 只过滤 /actuator/bus-refresh 请求         if (!url.endsWith("/actuator/bus-refresh")) {             chain.doFilter(request, response);            return;         }        // 使用 HttpServletRequest 包装原始请求达到修改 post 请求中 body 内容的目的         CustometRequestWrapper requestWrapper = new CustometRequestWrapper(httpServletRequest);         chain.doFilter(requestWrapper, response);     }    @Override     public void destroy() {     }    private 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();                 }             };         }     } }  3.测试 完成以上配置后，重启项目 修改github文件 再执行 http://localhost/test/getConfigInfo 因为网络原因，等几秒钟加载几次就能拉去新的数据了        

Spring Cloud 整合 Bus（附源码） 一、前言本篇笔者是根据上篇进行修改，若有不懂，转《Spring Cloud 入门 之 Config（六）附源码》了解二、介绍Spring Cloud Bus 是 Spring Cloud 家族中的一个子项目，用于实现微服务之间的通信。它整合 Java 的事件处理机制和消息中间件消息的发送和接受，主要由发送端、接收端和事件组成。针对不同的业务需求，可以设置不同的事件，发送端发送事件，接收端接受相应的事件，并进行相应的处理。三、配置3.1config-server3.1.1添加依赖：        <dependency>             <groupId>org.springframework.cloud</groupId>             <artifactId>spring-cloud-starter-bus-amqp</artifactId>             <version>2.1.0.RELEASE</version>         </dependency> 3.1.2 修改 application.yml：添加了 rabbitmq 配置和 management 的配置server:   port: 10000spring:   application:     name: CONFIG   cloud:     config:       server:         git:           uri: https://github.com/Uncle-LiuY/config.git           username: ******           password: ******   rabbitmq:     host: 127.0.0.0     port: 5672     username: admin     password: admin management:   endpoints:     web:       exposure:         include: '*' # 暴露接口 eureka:   instance:     instance-id: config-api   client:     service-url:       defaultZone: http://localhost:9000/eureka/  # 注册中心访问地址 3.2 api3.2.1 添加依赖;        <!-- bus -->         <dependency>             <groupId>org.springframework.cloud</groupId>             <artifactId>spring-cloud-starter-bus-amqp</artifactId>             <version>2.1.0.RELEASE</version>         </dependency> 3.2.2 修改 bootstrap.yml：添加 rabbitmq 配置spring:   application:     name: api   cloud:     config:       discovery:         enabled: true         service-id: CONFIG  # config-server 在注册中心的名称       profile: dev  # 指定配置文件的环境   rabbitmq:     host: 127.0.0.0     port: 5672     username: admin     password: admin eureka:   client:     service-url:       defaultZone: http://localhost:9000/eureka/  # 注册中心访问地址 3.2.3 修改TestController添加 @RefreshScope 注解，顺序一定不能错@RestController@RequestMapping("/test")@RefreshScopepublic class TestController {    @Value("${env}")    private String env; // 从配置中心获取     @RequestMapping("/getConfigInfo")    public String getConfigInfo() {        return env;     } }  4.测试依次启动 eureka-server、config-server、api4.1 参数原来的值：4.2 修改文件值为：dev1234.3 POST执行http://localhost:10000/actuator/bus-refresh间隔几秒再执行 http://localhost/test/getConfigInfo 就会发现获取的值变了。5.项目地址源码下载 到这里还是需要手动调用才能更新，下篇《Spring Cloud 集成 WebHook》讲解在线更新