电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

Java 實現分布式服務的調用鏈跟蹤

瀏覽:88日期:2022-08-11 10:03:53
目錄為什么要實現調用鏈跟蹤?如何實現?第一步,看圖、看場景,用戶瀏覽器的一次請求行為所走的路徑是什么樣的第二步,實現。不想看代碼可直接拉最后看結果和原理測試一下結果:為什么要實現調用鏈跟蹤?

隨著業務的發展,所有的系統最終都會走向服務化體系,微服務的目的一是提高系統的穩定性,二是提高持續交付的效率,為什么能提高這兩項不是今天討論的內容。

當然這也不是絕對的,如果業務還在MVP驗證,團隊規模小個人覺得完全沒必要微服務化、單體應用是比較好的選擇。作者是有經歷過從單體應用到1000+應用的增長經歷,也是見證了公司從初創到上市的過程,對于系統階段和業務階段的匹配還是有比較深的感受的。

服務拆分后帶來的問題是什么呢?服務的依賴關系復雜后,對于問題的排查也增加了復雜度,當然站在更高的角度來看拆分帶來的不只是排錯復雜性的提升,工程效率、組織協作也都會帶來新的挑戰。

回到主題,如何快速查詢整個請求鏈路上的日志并呈現出來是解決排查問題復雜度的根本方法,這就是今天我們要講的內容,如何自己來實現一個全鏈路跟蹤。

如何實現?第一步,看圖、看場景,用戶瀏覽器的一次請求行為所走的路徑是什么樣的

Java 實現分布式服務的調用鏈跟蹤

如上圖、省略了4層和7層的LB,請求直接到gateway->A->B 那如何把個request關聯起來呢?從時序上來看我們只要在gateway生成一個traceId然后層層透傳,那么每一次的request的我們就能通過traceid關聯查詢出來了。如何透傳、如何記錄呢?或者說如何透傳、如何記錄讓各應用的開發人員無需關注呢?

第二步,實現。不想看代碼可直接拉最后看結果和原理

如何傳遞,這里我們使用定義統一的Request類,所有的api層需要使用這個規范,代碼如下:

public class Request<T> implements Serializable { //header:攜帶需要傳遞的信息 private RequestHeader header; //業務參數 private T bizModel; //...省略get set}public class RequestHeader implements Serializable { //調用鏈唯一ID private String traceId; //當前用戶Id private String userId; //上游調用方appId private String callAppId; //...省略get set}

有了這個Request之后,我們在網關層每次都生成traceId, 然后在各服務之間傳遞就能做到調用鏈的關聯了。我們繼續看個各應用應該如何定義服務和使用

@ApiMethod @PostMapping('/test') @ApiOperation(value = 'test', notes = '', response = String.class) public Response<ExampleRespDTO> test(@RequestBody Request<ExampleReqDTO> req) {ExampleRespDTO exampleRespDTO = new ExampleRespDTO();exampleRespDTO.setName(req.getBizModel().getName());//輸出當前應用的header信息 System.out.println('上游的traceId:'+RequestContext.getHeader().getTraceId());System.out.println('上游的callAppId:'+RequestContext.getHeader().getCallAppId());System.out.println('上游的userId:'+RequestContext.getHeader().getUserId());/*** * 模擬調用其他應用服務 * 通過RPCRequest 來構建request對象 */Request<OtherAppServiceReqDTO> otherAppServiceReqDTORequest =RPCRequest.createRequest(new OtherAppServiceReqDTO());//輸出下游應用的header信息System.out.println('調用下游的traceId:'+otherAppServiceReqDTORequest.getHeader().getTraceId());System.out.println('調用下游的callAppId:'+otherAppServiceReqDTORequest.getHeader().getCallAppId());System.out.println('調用下游的userId:'+otherAppServiceReqDTORequest.getHeader().getUserId());return Response.successResponse(exampleRespDTO); }

看完上面代碼的同學,應該看到了有一個模擬調用其他服務的地方,這里主要解決的是服務和服務之間的調用header傳遞的問題,這里封裝了一個createRequest的方法,其主要內容還是把當前應用的requestHeader 賦值給請求其他服務的request上。這也是一個測試接口,最后面有測試的結果

public class RPCRequest { public static <T> Request<T> createRequest(T requestData){Request<T> request = new Request();RequestHeader requestHeader=new RequestHeader();requestHeader.setTraceId(RequestContext.getHeader().getTraceId());requestHeader.setUserId(RequestContext.getHeader().getUserId());requestHeader.setCallAppId(AppConfig.CURRENT_APP_ID);request.setHeader(requestHeader);request.setBizModel(requestData);return request; }}

當前request中的header存在什么地方呢,我們看一下RequestContext的代碼

public class RequestContext { private static ThreadLocal<RequestHeader> threadLocal=new ThreadLocal<>(); public static void setHeader(RequestHeader header){ threadLocal.set(header); } public static RequestHeader getHeader(){ return threadLocal.get(); } public static void clear(){ threadLocal.remove(); }}

header是什么時候放進去的呢?這里就是AOP該發揮作用的時候了,直接看代碼

public class ApiHandler { public ApiHandler() { } public Response handleApiMethod(ProceedingJoinPoint pjp, ApiMethod apiMethod) {//獲取上游調用方的request headerObject[] args = pjp.getArgs();Request request = (Request) args[0];RequestHeader header = request.getHeader();//將header加入到當前request 到ThreadLocal保存RequestContext.setHeader(header);Response response = null;try { //構建response header ResponseHeader responseHeader = new ResponseHeader(); responseHeader.setTraceId(RequestContext.getHeader().getTraceId()); //執行service方法 response = (Response) pjp.proceed(args); response.setHeader(responseHeader);} catch (Throwable throwable) { throwable.printStackTrace();}finally { //清除ThreadLocal中當前請求的header 對象 RequestContext.clear();}return response; }}

不想看代碼的,直接看下圖,原理比較簡單,淺黃色為AOP作用,接口執行前和執行后,其中reqeuest和header的定義在第1段代碼

Java 實現分布式服務的調用鏈跟蹤

這里沒有介紹如何收集數據和查詢展示,比較簡單的辦法是使用logback打本地日志,然后通過agent抽到集中式日志進行查詢展示,例如ELK。

測試一下結果:

1、接口文檔

Java 實現分布式服務的調用鏈跟蹤

2、執行結果

Java 實現分布式服務的調用鏈跟蹤

Java 實現分布式服務的調用鏈跟蹤

以上就是Java 實現分布式服務的調用鏈跟蹤的詳細內容,更多關于Java 分布式服務的調用鏈跟蹤的資料請關注好吧啦網其它相關文章!

標簽: Java
相關文章:
主站蜘蛛池模板: 成都热收缩包装机_袖口式膜包机_高速塑封机价格_全自动封切机器_大型套膜机厂家 | 专业的新乡振动筛厂家-振动筛品质保障-环保振动筛价格—新乡市德科筛分机械有限公司 | 成都治疗尖锐湿疣比较好的医院-成都治疗尖锐湿疣那家医院好-成都西南皮肤病医院 | 钢骨架轻型板_膨石轻型板_钢骨架轻型板价格_恒道新材料 | 滑石粉,滑石粉厂家,超细滑石粉-莱州圣凯滑石有限公司 | 专注提供国外机电设备及配件-工业控制领域一站式服务商-深圳市华联欧国际贸易有限公司 | 慈溪麦田广告公司,提供慈溪广告设计。 | 雨水收集系统厂家-雨水收集利用-模块雨水收集池-徐州博智环保科技有限公司 | 分子蒸馏设备(短程分子蒸馏装置)_上海达丰仪器 | 卫生纸复卷机|抽纸机|卫生纸加工设备|做卫生纸机器|小型卫生纸加工需要什么设备|卫生纸机器设备多少钱一台|许昌恒源纸品机械有限公司 | 矿用履带式平板车|探水钻机|气动架柱式钻机|架柱式液压回转钻机|履带式钻机-启睿探水钻机厂家 | 升降机-高空作业车租赁-蜘蛛车-曲臂式伸缩臂剪叉式液压升降平台-脚手架-【普雷斯特公司厂家】 | 电线电缆厂家|沈阳电缆厂|电线厂|沈阳英联塑力线缆有限公司 | 制冷采购电子商务平台——制冷大市场| 沧州友城管业有限公司-内外涂塑钢管-大口径螺旋钢管-涂塑螺旋管-保温钢管生产厂家 | 老城街小面官网_正宗重庆小面加盟技术培训_特色面馆加盟|牛肉拉面|招商加盟代理费用多少钱 | 水轮机密封网 | 水轮机密封产品研发生产厂家 | 快速卷帘门_硬质快速卷帘门-西朗门业 | 吸音板,隔音板,吸音材料,吸音板价格,声学材料 - 佛山诺声吸音板厂家 | X光检测仪_食品金属异物检测机_X射线检测设备_微现检测 | 淋巴细胞分离液_口腔医疗器材-精欣华医疗器械(无锡)有限公司 | 温控器生产厂家-提供温度开关/热保护器定制与批发-惠州市华恺威电子科技有限公司 | 成都APP开发-成都App定制-成都app开发公司-【未来久】 | 企业微信scrm管理系统_客户关系管理平台_私域流量运营工具_CRM、ERP、OA软件-腾辉网络 | 离子色谱自动进样器-青岛艾力析实验科技有限公司 | 大倾角皮带机-皮带输送机-螺旋输送机-矿用皮带输送机价格厂家-河南坤威机械 | 齿式联轴器-弹性联轴器-联轴器厂家-江苏诺兴传动联轴器制造有限公司 | 上海公司注册-代理记账-招投标审计-上海昆仑扇财税咨询有限公司 上海冠顶工业设备有限公司-隧道炉,烘箱,UV固化机,涂装设备,高温炉,工业机器人生产厂家 | 铜镍-康铜-锰铜-电阻合金-NC003 - 杭州兴宇合金有限公司 | 120kv/2mA直流高压发生器-60kv/2mA-30kva/50kv工频耐压试验装置-旭明电工 | 磁力链接搜索神器_BT磁力狗_CILIMAO磁力猫_高效磁力搜索引擎2024 | 中图网(原中国图书网):网上书店,尾货特色书店,30万种特价书低至2折! | 铝单板_铝窗花_铝单板厂家_氟碳包柱铝单板批发价格-佛山科阳金属 | 双杰天平-国产双杰电子天平-美国双杰-常熟双杰仪器 | 金属波纹补偿器厂家_不锈钢膨胀节价格_非金属伸缩节定制-庆达补偿器 | 周口市风机厂,周鼓风机,河南省周口市风机厂 | 氧氮氢联合测定仪-联测仪-氧氮氢元素分析仪-江苏品彦光电 | 氢氧化钾厂家直销批发-济南金昊化工有限公司 | 航空障碍灯_高中低光强航空障碍灯_民航许可认证航空警示灯厂家-东莞市天翔航天科技有限公司 | 青岛空压机,青岛空压机维修/保养,青岛空压机销售/出租公司,青岛空压机厂家电话 | POM塑料_PBT材料「进口」聚甲醛POM杜邦原料、加纤PBT塑料报价格找利隆塑料 |