溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

springcloud 中 zuul 修改請(qǐng)求參數(shù)信息的方法

發(fā)布時(shí)間:2020-10-20 20:51:36 來(lái)源:腳本之家 閱讀:251 作者:礦泉 欄目:編程語(yǔ)言

Zuul是Netflix出品的一個(gè)基于JVM路由和服務(wù)端的負(fù)載均衡器.

  Zuul功能:

  • 認(rèn)證
  • 壓力測(cè)試
  • 金絲雀測(cè)試
  • 動(dòng)態(tài)路由
  • 負(fù)載削減
  • 安全
  • 靜態(tài)響應(yīng)處理
  • 主動(dòng)/主動(dòng)交換管理

Zuul的規(guī)則引擎允許通過(guò)任何JVM語(yǔ)言來(lái)編寫規(guī)則和過(guò)濾器, 支持基于Java和Groovy的構(gòu)建。

配置屬性 zuul.max.host.connections 已經(jīng)被兩個(gè)新的配置屬性替代, zuul.host.maxTotalConnections (總連接數(shù))和 zuul.host.maxPerRouteConnections,(每個(gè)路由連接數(shù)) 默認(rèn)值分別是200和20.

一. 為什么要用到這個(gè)

  在基于 springcloud 構(gòu)建的微服務(wù)系統(tǒng)中,通常使用網(wǎng)關(guān)zuul來(lái)進(jìn)行一些用戶驗(yàn)證等過(guò)濾的操作,比如 用戶在 header 或者 url 參數(shù)中存放了 token ,網(wǎng)關(guān)層需要 用該 token 查出用戶 的 userId ,并存放于 request 中,以便后續(xù)微服務(wù)可以直接使用而避免再去用 token 查詢。

二.基礎(chǔ)知識(shí)

    在 zuul 中最大的用法的除了路由之外,就是過(guò)濾器了,自定義過(guò)濾器需實(shí)現(xiàn)接口 ZuulFilter ,在 run() 方法中,可以用

RequestContext ctx = RequestContext.getCurrentContext(); 
HttpServletRequest request = ctx.getRequest(); 

獲取到 request,但是在 request 中只有 getParameter() 而沒(méi)有 setParameter() 方法,所以直接修改 url 參數(shù)不可行,另外在 reqeust 中可以雖然可以使用 setAttribute() ,但是可能由于作用域的不同,在這里設(shè)置的 attribute 在后續(xù)的微服務(wù)中是獲取不到的,因此必須考慮另外的方式。

三.具體做法

   最后確定的可行的方法是,用

ctx.setRequest(new HttpServletRequestWrapper(request) {}) 

的方式,重新構(gòu)造上下文中的 request ,代碼如下:

import javax.servlet.http.HttpServletRequestWrapper; 
 // 在json參數(shù)中添加 userId 
try { 
 InputStream in = ctx.getRequest().getInputStream(); 
 String body = StreamUtils.copyToString(in, Charset.forName("UTF-8")); 
 System.out.println("body:" + body); 
 JSONObject json = JSONObject.fromObject(body); 
 json.put("userId", userId); 
 String newBody = json.toString(); 
 System.out.println("newBody:" + newBody); 
 final byte[] reqBodyBytes = newBody.getBytes(); 
 ctx.setRequest(new HttpServletRequestWrapper(request){  
 @Override 
 public ServletInputStream getInputStream() throws IOException { 
  return new ServletInputStreamWrapper(reqBodyBytes); 
 } 
 @Override 
 public int getContentLength() { 
  return reqBodyBytes.length; 
 } 
 @Override 
 public long getContentLengthLong() { 
  return reqBodyBytes.length; 
 } 
 }); 
} catch (IOException e) { 
 e.printStackTrace(); 
} 

思路就是,獲取請(qǐng)求的輸入流,并重寫,即重寫json參數(shù)。

在后續(xù)的微服務(wù)的 controller 中,可以用 形似

@RequestBody Map<String,Object> body 
======= 
body.get("userId"); 

這樣的方式,去獲取在 zuulFilter 傳入的 userId

四.一些嘗試

 在重寫  HttpServletRequestWrapper 的時(shí)候,我嘗試過(guò) 重寫 getParameterNames() getParameterMap() 方法,希望重寫 url 參數(shù),但是并沒(méi)有生效。

總結(jié)

以上所述是小編給大家介紹的springcloud 中 zuul 修改請(qǐng)求參數(shù)信息的方法,希望對(duì)大家有所幫助,如果大家有任何疑問(wèn)請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)億速云網(wǎng)站的支持!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI