springboot2.0 bus总线实现config自动刷新

1
2
3
4
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

1
2
3
4
5
rabbitmq:
      host: 192.168.0.100
      port: 5672
      username: 用户名
      password: 密码

1
2
3
4
5
management:
  endpoints:
    web:
      exposure:
        include: "*"

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
spring:
  cloud:
    config:
      # enabled: true
      server:
        git:
          uri: https://github.com/bjxPolestar/config-repo.git
          search-paths: config-repo/dev-*
          #临时存储路径
          basedir: ../config-repo-temp
          username: *****
          password: ****
          force-pull: true #配置中心通过git从远程git库，有时本地的拷贝被污染，这时配置中心无法从远程库更新本地配置,设置force-pull=true，则强制从远程库中更新本地库
          default-label: master
    bus:
      enabled: true
      trace:
        enabled: true
  rabbitmq:
      host: 192.168.0.100
      port: 5672
      username: ***
      password: ***

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
server:
  port: 8090 #${random.int(8090,8099)}
spring:
  application:
    name: cloud-config-server
  profiles:
    active: ${profileActive} #本地开发配置
eureka:
  client:
    serviceUrl:
      defaultZone: ${defaultZone}
  instance:
    prefer-ip-address: true
    instance-id: ${spring.application.name}:${spring.application.instance_id:${server.port}}
    appname: cloud-config-server
management:
  endpoints:
    web:
      exposure:
        include: "*"

1
2
3
4
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

1
2
3
4
5
rabbitmq:
      host: 192.168.0.100
      port: 5672
      username: 用户名
      password: 密码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@RestController
@RefreshScope
@RequestMapping("/stu/student")
@Api(value = "/stu/student",tags="学生控制器")
public class GtStuStudentInfoRest extends BaseRest{
	
	
	@Value("${spring.datasource.initialSize}")
	private String driverClassName;
	
	@GetMapping("/getInitialSize")
	public String getDriver() {
		return driverClassName;
	}
}

1
2
3
4
5
6
7
8
Headers
Connection: close
Content-Length: 495
Content-Type: application/json;charset=UTF-8
Date: Wed, 19 Dec 2018 03:33:32 GMT
Transfer-Encoding: chunked
Body
{"timestamp":"2018-12-19T03:33:32.185+0000","status":400,"error":"Bad Request","message":"JSON parse error: Cannot deserialize instance of `java.lang.String` out of START_ARRAY token; nested exception is com.fasterxml.jackson.databind.exc.MismatchedInputException: Cannot deserialize instance of `java.lang.String` out of START_ARRAY tokenn at [Source: (PushbackInputStream); line: 1, column: 295] (through reference chain: java.util.LinkedHashMap["commits"])","path":"/actuator/bus-refresh"}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
import java.io.ByteArrayInputStream;
import java.io.IOException;

import javax.servlet.ReadListener;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;

/**
 * 解决使用spring cloud config bus使用webhook自动刷新出现的400问题
 * 
 * @auther lzp
 */
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();
			}
		};
	}

}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
import java.io.IOException;

import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.annotation.WebFilter;
import javax.servlet.http.HttpServletRequest;

import com.polestar.cloud.config.wrapper.CustometRequestWrapper;

/**
 * 过滤器
 * @auther lzp
 */
@WebFilter(filterName = "JsonFilter",urlPatterns = "/*")
public class JsonFilter implements 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 = new String(httpServletRequest.getRequestURI());

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

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

		filterChain.doFilter(requestWrapper, servletResponse);
	}

	@Override
	public void destroy() {

	}

}