Gateway网关拦截器的ServerWebExchange

这篇具有很好参考价值的文章主要介绍了Gateway网关拦截器的ServerWebExchange。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

 ServerWebExcahnge的解释如下:

Contract for an HTTP request-response interaction. Provides access to the HTTP request and response and also exposes additional server-side processing related properties and features such as request attributes.

大概是说:ServerWebExchange是一个HTTP请求-响应交互的契约。提供对HTTP请求和响应的访问,并公开额外的服务器端处理相关属性和特性,如请求属性,有点像Context的角色。

在 HTTP 协议中,请求头和请求体是请求的重要组成部分,ServerWebExchange 提供了丰富的方法来对其进行处理。

请求数据读取

例如,可以通过 ServerWebExchange.getRequest().getHeaders() 方法获取请求头:

ServerHttpRequest request = exchange.getRequest();
HttpHeaders headers = request.getHeaders();
String userAgent = headers.getFirst(HttpHeaders.USER_AGENT);

可以通过 ServerWebExchange.getRequest().getBody() 方法获取请求体:

ServerHttpRequest request = exchange.getRequest();
Mono<String> requestBody = request.getBody().map(dataBuffer -> {
    byte[] buffer = new byte[dataBuffer.readableByteCount()];
    dataBuffer.read(buffer);
    DataBufferUtils.release(dataBuffer);
    Charset charset = Charset.forName("UTF-8");
    return new String(buffer, charset);
});

这里使用 BodyExtractors.toMono(String.class) 也可以获取请求体,但是这种方式只适用于请求体是 JSON、XML 等文本格式的情况。而如果请求体是二进制文件,则需要使用上面的方式来获取。

简单的理解是,ServerWebExcahnge包含了http请求的请求数据(ServerHttpRequest),返回数据(ServerHttpResponse)。

从新封装请求

       ServerHttpRequest是一个只读类,对于读多写少的场景,这种设计模式是值得借鉴的。但是有时候我们也需要修改。则可以通过以下实现修改:

ServerHttpRequest serverHttpRequest = exchange.getRequest().mutate().path(newPath).method(HttpMethod.GET).build();
ServerWebExchange serverWebExchange = exchange.mutate().request(serverHttpRequest).build();
return chain.filter(exchange);

     但是请求中的body参数流(inputstream)只能被读取一次,但是,我们通常由很多个过滤器,所以可能需要读取多次消息。解决这个办法需要用到官方提供的:ContentCachingRequestWrapper类。

public ContentCachingRequestWrapper(HttpServletRequest request) {
    super(request);
    int contentLength = request.getContentLength();
    this.cachedContent = new ByteArrayOutputStream(contentLength >= 0 ? contentLength : 1024);
    this.contentCacheLimit = null;
}

包装ContentCachingRequestWrapper,主要就做了一件事儿,感知request里面内容的长度,为自己开一个同样大小的输出流cachedContent。然后重写其中的方法:

//重写方法getInputStream
@Override
public ServletInputStream getInputStream() throws IOException {
    if (this.inputStream == null) {
        this.inputStream = new ContentCachingInputStream(getRequest().getInputStream());
    }
    return this.inputStream;
}

//重写java.io.InputStream#read()方法
@Override
public int read() throws IOException {
	int ch = this.is.read();
	if (ch != -1 && !this.overflow) {
		if (contentCacheLimit != null && cachedContent.size() == contentCacheLimit) {
			this.overflow = true;
			handleContentOverflow(contentCacheLimit);
		}
		else {
			cachedContent.write(ch);
		}
	}
	return ch;
}

//重写方法inputStream中的read(byte b[], int off, int len)
@Override
public int read(final byte[] b, final int off, final int len) throws IOException {
	int count = this.is.read(b, off, len);
	writeToCache(b, off, count);
	return count;
}

总之,ContentCachingRequestWrapper通过覆盖inpuStream方法,通过移花接木的方式,将每次调用inputStream读的时候都将其放置到输出流当中。这样后续inputStream流被关闭了,我们还可以通过使用cachedContent内容读取入参内容。

构造返回数据

private void doResponse(ServletResponse servletResponse) throws IOException{
     servletResponse.setContentType(MediaType.APPLICATION_JSON_UTF8_VALUE);
     HttpServletResponse httpServletResponse = (HttpServletResponse)servletResponse;
     httpServletResponse.setStatus(401);
     PrintWriter writer = servletResponse.getWriter();
     writer.write("xxxxx");
}
    
private void doFileResponse(ServletResponse servletResponse) throws IOException{
    //1. 用于读取文件
    FileInputStream fis = new FileInputStream("d://xxx/xxx/a.jpg");
    //2. 获取response字节输出流
    ServletOutputStream os = servletResponse.getOutputStream();
    //3. 完成流的复制
    byte[] buff = new byte[1024];
    int len = 0;
    while ((len = fis.read(buff))!= -1){
       os.write(buff,0,len);
    }
    fis.close();
}

读取返回数据:

https://www.cnblogs.com/fdzang/p/11812348.html文章来源地址https://www.toymoban.com/news/detail-846222.html

到了这里,关于Gateway网关拦截器的ServerWebExchange的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • VUE3 请求拦截器 响应拦截器

    1,导入axios  (使用axios进行接口的请求,页面发送http请求,很多情况我们要对请求和其响应进行特定的处理,如:判断token,设置请求头。如果请求数非常多,单独对每一个请求进行处理会变得非常麻烦,程序的优雅性也会大打折扣。所以axios为开发者提供了这样一个API:拦

    2024年02月16日
    浏览(49)
  • SpringBoot加入拦截器——登录拦截器的实现

            拦截器 Interceptor 在 Spring MVC 中的地位等同于 Servlet 规范中的过滤器 Filter,拦截的是处理器的执行,由于是全局行为,因此常用于做一些通用的功能,如请求日志打印、权限控制等。         核心原理:AOP思想 preHandle:  预先处理,在目标的controller方法执行之前,进行

    2024年02月15日
    浏览(43)
  • 自定义注解与拦截器实现不规范sql拦截(拦截器实现篇)

    最近考虑myBatis中sql语句使用规范的问题,如果漏下条件或者写一些不规范语句会对程序性能造成很大影响。最好的方法就是利用代码进行限制,通过拦截器进行sql格式的判断在自测环节就能找到问题。写了个简单情景下的demo,并通过idea插件来将myBatis的mapper方法都打上拦截器

    2024年01月22日
    浏览(45)
  • 【SpringBoot篇】Interceptor拦截器 | 拦截器和过滤器的区别

    拦截器(Interceptor)是一种软件设计模式,用于在应用程序处理请求或响应时对其进行拦截和修改。拦截器可以在整个应用程序中使用,用于执行跨越多个层的通用任务,如身份验证、授权、缓存、日志记录、性能计量等。 在Web开发中,拦截器通常用于在请求到达控制器之前

    2024年02月04日
    浏览(63)
  • WebService 客户端增加Header头、并且指定命名空间、添加拦截器(日志拦截器,自定义拦截器)、soap:Envelope 添加命名空间

    1.增加Header头 生成XML结果如下 2.添加拦截器 3.soap:Envelope 添加命名空间 生成XML结果如下

    2024年02月10日
    浏览(50)
  • 微信小程序封装request请求,包含请求拦截器,响应拦截器和请求重试功能

    在发送请求之前,先判断用户是否有token,没有就执行登陆请求,将token保存,然后再执行原来请求; 拥有token,就直接执行请求;但是用户的这个token可能是过期的,如果执行请求发现用户登陆过期,就统一返回40001,然后对40001的响应统一处理,执行登陆请求,再执行原来请

    2024年02月13日
    浏览(50)
  • 分布式项目 16 购物车系统,dubbo框架(重点是拦截器),优化userId,配合拦截器

    01.创建jt-cart项目 第一步: 第二步: 第三步: 第四步: 在pom.xml文件中添加jt-common的依赖,如图所示: 第五步: 添加插件 第六步:创建pojo实体类对象 说明:在jt-common项目下的com.jt.pojo创建Cart实体类 第七步:创建Dubbo接口 说明:在jt-common项目com.jt.service包下创建DubboCartSer

    2024年02月09日
    浏览(49)
  • SpringMVC 拦截器

    Spring MVC 拦截器是Spring框架中的一种机制,用于在请求到达处理器之前和渲染视图之前拦截请求,并允许开发者在这两个时间点进行自定义的处理逻辑。拦截器与过滤器(Filter)类似,但更加专注于对请求的处理器的拦截,比如对访问权限进行控制、日志记录、性能监控等。

    2024年01月19日
    浏览(45)
  • springMVC之拦截器

    拦截器 SpringMVC中的拦截器用于拦截控制器方法的执行 SpringMVC中的拦截器需要实现HandlerInterceptor SpringMVC的拦截器必须在SpringMVC的配置文件中进行配置: FirstIntercepor类: SecondInterceptor类: SpringMVC中的拦截器有三个抽象方法: preHandle:控制器方法执行之前执行preHandle(),其bool

    2024年02月10日
    浏览(38)
  • SpringMVC:拦截器

    一般我们会做一些统一的操作这个时候我们需要使用springmvc提供的拦截器,例如token的验证,字段必填的操作,接口超时判断,签名验证,字段加密等操作,所以我们需要了解执行先后顺序。 我们来简单介绍下实现过程及对应代码,执行结果: 1、定义自己的spring mvc拦截器需

    2024年01月24日
    浏览(45)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包