SpringBoot报文转发
时间:2021-07-31
本文章向大家介绍SpringBoot报文转发,主要包括SpringBoot报文转发使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
SpringBoot
仿Zuul
报文转发
基于RestTemplate
从request
中提取出header
、body
等内容,构造一个RequestEntity
,后续可以用RestTemplate
来发送请求
请求入口RestController
public final static String DELEGATE_PREFIX = "/api";
public final static String TARGET_URL = "http://hlooc.cn";
@Autowired
private RoutingDelegate routingDelegate;
@RequestMapping(value = "/**", method = {RequestMethod.GET, RequestMethod.POST, RequestMethod.PUT, RequestMethod.DELETE}, produces = MediaType.TEXT_PLAIN_VALUE)
public ResponseEntity catchAll(HttpServletRequest request, HttpServletResponse response) {
return routingDelegate.redirect(request, response, TARGET_URL, DELEGATE_PREFIX);
报文处理RoutingDelegate
private static final Logger logger = LoggerFactory.getLogger(RoutingDelegate.class);
public ResponseEntity<String> redirect(HttpServletRequest request, HttpServletResponse response,String routeUrl, String prefix) {
try {
// build up the redirect URL
String redirectUrl = createRedictUrl(request,routeUrl, prefix);
RequestEntity requestEntity = createRequestEntity(request, redirectUrl);
return route(requestEntity);
} catch (Exception e) {
logger.error("处理异常:{}",e.getLocalizedMessage(),e);
return new ResponseEntity("REDIRECT ERROR", HttpStatus.INTERNAL_SERVER_ERROR);
}
}
private String createRedictUrl(HttpServletRequest request, String routeUrl, String prefix) {
String queryString = request.getQueryString();
return routeUrl + request.getRequestURI().replace(prefix, "") +
(queryString != null ? "?" + queryString : "");
}
private RequestEntity createRequestEntity(HttpServletRequest request, String url) throws URISyntaxException, IOException {
String method = request.getMethod();
HttpMethod httpMethod = HttpMethod.resolve(method);
MultiValueMap<String, String> headers = parseRequestHeader(request);
byte[] body = parseRequestBody(request);
return new RequestEntity<>(body, headers, httpMethod, new URI(url));
}
private ResponseEntity route(RequestEntity requestEntity) {
RestTemplate restTemplate = new RestTemplate();
// 乱码处理
// List<HttpMessageConverter<?>> messageConverters = restTemplate.getMessageConverters();
// for (HttpMessageConverter<?> messageConverter : messageConverters) {
// if (messageConverter instanceof StringHttpMessageConverter) {
// ((StringHttpMessageConverter) messageConverter).setDefaultCharset(StandardCharsets.UTF_8);
// }
// }
return restTemplate.exchange(requestEntity, Resource.class);
}
private byte[] parseRequestBody(HttpServletRequest request) throws IOException {
InputStream inputStream = request.getInputStream();
return StreamUtils.copyToByteArray(inputStream);
}
private MultiValueMap<String, String> parseRequestHeader(HttpServletRequest request) {
HttpHeaders headers = new HttpHeaders();
List<String> headerNames = Collections.list(request.getHeaderNames());
for (String headerName : headerNames) {
List<String> headerValues = Collections.list(request.getHeaders(headerName));
for (String headerValue : headerValues) {
headers.add(headerName, headerValue);
}
}
return headers;
}
restTemplate.exchange(requestEntity, Resource.class);
使用Resource
可以解决以下异常:
Could not extract response: no suitable HttpMessageConverter found for response type [class java.lang.Object] and content type [application/octet-stream;charset=GBK]
原文地址:https://www.cnblogs.com/hlooc/p/15084856.html
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释