百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 文章教程 > 正文

了解一点ESB

xsobi 2025-01-08 18:16 8 浏览

如何进行系统集成?

点对点方式 VS 数据总线方式




企业服务总线,即ESB全称为Enterprise Service Bus

如上图所示,企业服务总线是将多个系统(一般是公司内部的多个系统)进行集成,避免服务之间各自调用。

假设系统A与系统B进行集成,系统B调用系统A的服务,即 系统A作为服务提供方,系统B作为服务调用方。一般的步骤如下

  1. 系统A与系统B 根据内部流程,申请接入到ESB
  2. 部署系统A、系统B 两个系统对应的URL分别是 http://xxxx:8080/aaa http://xxxx:8090/bbb
  3. 假设系统A提供2个服务接口,示例代码如下
Bash
@RestController
@RequestMapping(value = "/info")
public class InfoController {
   
     @GetMapping(value = "/location") 
     public ApiResult location() {
         return apiResult;
     } 

     @GetMapping(value = "/price") 
     public ApiResult price() {
         return apiResult;
     }    

}

为接入ESB 需要对接口进行改造

  1. ESB只需要知道系统的访问入口,不需要关心具体每个接口的url
  2. ESB会为每个接口提供一个serviceCode,即唯一代码 假设 location接口的服务代码是 060001,price接口的服务代码是 060002
  3. 接口的返回从ApiResult改成String(内容可以是XML)

设定接口请求与返回的数据格式为常用的XML,一般ESB会设定XML结构,假设最简单的XML结构如下:

Bash
<service>
     <SYS_HEAD>
          <SERVICE_CODE>060001</SERVICE_CODE>
          // ... 其它参数
     </SYS_HEAD>
     <BODY>
          <BIZ_CODE></BIZ_CODE>
          <USER_NAME>yiben</USER_NAME>
          // ... 业务字段
     </BODY>
</service>

改造后的InfoController如下:

@RestController
@RequestMapping(value = "/info")
public class InfoController {
     /**
       * ESB统一的入口
       */
     @GetMapping(value = "") 
     public String home(HttpServletRequest request) {
         // 获取xml请求
         String xml = getXml(request);
         // 通过dom4j解析SYS_HEAD  获得serviceCode
         String serviceCode = getServceCode(xml);

         // 根据ESB分配的serviceCode 调用不同的方法
         switch (serviceCode ) {
             case "060001": {
                 return location(xml, request);
             }
             case "060002": {
                 return price(request);
             }
             default : {
                 return "something";
            }
         }

         return "something";       
     } 

     // 不需要Mapping
     public String location(String xml, HttpServletRequest request) { 

         // 不能再从request中获取xml  流只能被消费一次
         // 解析xml  一般从BODY中获取对应的请求参数
         // 业务处理
         // 返回XML格式的结果
     } 

     public String price(HttpServletRequest request) {
         return "xml";
     }    

}

Postman测试 发送xml请求


解析XML

/**
 * 解析请求报文
 * @param request
 * @return
 */
public String parseReq(HttpServletRequest request) {
      int bytesRead = 0;
      byte[] buffer = new byte[8192];
      StringBuffer sb = new StringBuffer();
      try {
          InputStream fis = request.getInputStream();
          while ((bytesRead = fis.read(buffer, 0, 8192)) != -1) {
              sb.append(new String(buffer, 0, bytesRead));
          }
          fis.close();
      } catch (IOException e) {
          e.printStackTrace();
      }
      System.out.println("收到请求报文==>>>" + sb.toString());
      return sb.toString();
}

/**
 * 发送响应报文
 * @param rsp
 * @return
 */
public String sendMsg(HttpServletResponse response, String rsp) {
      response.setContentType("text/xml;charset=utf-8");
      response.setContentLength(rsp.length());
      try {
          response.getWriter().print(rsp);
      } catch (IOException e) {
          e.printStackTrace();
      }
      return rsp;
}

相关推荐

开源鸿蒙OpenHarmony 5.1.0(API 18)正式上线:进一步增强ArkUI

IT之家5月4日消息,开源鸿蒙OpenHarmony是由开放原子开源基金会孵化及运营的开源项目,目标是面向全场景、全连接、全智能时代,搭建一个智能终端设备操作系统的框架和平台,促进万物互联...

day57:jQuery事件

链式操作<p>111</p><p>222</p>"""一行代码将第一个p标签变成红色第二个p标签变成绿色""...

基础干货:Pandas-Data Frame基础知识点总结

熊猫数据框架可以从列表、字典和字典列表等中创建。通过从现有存储中加载数据集来创建PandasDataFrame,存储可以是SQL数据库、CSV文件和Excel文件。Dataframe是一种二维数据结构...

万字长文带你通俗理解LightGBM

GBDT(GradientBoostingDecisionTree)是机器学习中一个长盛不衰的模型,其主要思想是利用弱分类器(决策树)迭代训练以得到最优模型,该模型具有训练效果好、不易过拟合等...

数组(I) - 网络统计学(11)

数组是将相同类型的数据按照特定顺序组合在一起的集合。其中,每个独立的变量都被称为数组元素,有时也会被称作下标变量。而用于区分各个数组元素的数字编号,则被称为下标。通常各种计算机编程语言都具备一定的数值...

VUE业务中数据绑定无效-this.$set来帮忙

这个方法之前看文档肯定是看到了,但是从来没有遇到问题,就抛之脑后了!这不遇到问题了还得请它来帮忙!车祸现场问题剖析当你发现你给对象加了一个属性,在控制台能打印出来,但是却没有更新到视图上时,也许这个时...

JS数组Reduce的妙用,收藏等于学会

作者:前端发现者来源:前端发现本文转载自微信公众号「前端发现」,作者前端发现者。转载本文请联系前端发现公众号。说到处理数组的方法,想必大家都不陌生了,今天我们一起来学习下理数组常见场景下的方法。首先来...

Java 异常处理通关指南

前言在理想世界中,程序永远不会出现问题,用户输入的数据永远是正确的,逻辑没有任何问题,选择打开的文件也一定是存在的,内存永远是够用的……!但是现实世界里一旦出现这些问题,如果处理不好,程序就不能正常...

Python 数据类型 - 数组

Python数据类型-数组在本节中,你将学习如何在Python中创建和访问数组的元素。数组是相同数据类型的元素的集合。数组和列表之间的主要区别是列表可以具有不同数据类型的元素。在Pytho...

「Python系列」 Python 数据结构之数组

在大多数编程语言中,数组都是一个基础而又普遍的数据结构。在很多算法中都有广泛的应用。在本文中,我们将了解鲜为人知的Python数组实现,该实现仅使用Python标准库中包含的核心语言功能。我们将看到每...

COUNTIF函数用法大全

COUNTIF函数用于统计满足某个条件的单元格的数量,其基本用法为:COUNTIF(统计区域,指定的条件)如下图所示,要统计A列有几个5,可以使用以下公式:=COUNTIF(A2:A10,5)咱们把C...

强大到没有对手的Aggregate函数,碾压Sum等19个函数,你真的会吗

从前期的学习中,我们已经知道,Subtotal函数的功能非常强大,但还有一个函数,其功能强大到了没有对手,此函数就是Aggregate,可以实现Sum、Average、Count、Max、Min、Pr...

RISC-V并不完美?

本文最初完成于几年之前,彼时作者正在ARM公司担任执行核心验证工程师职位。作者当时的工作深入或围绕多种处理器核心,而文中提到的观点深受这些经验的影响,换句话说,这些观点存在不同程度的偏见。作者依旧...

MySQL索引解析(联合索引/最左前缀/覆盖索引/索引下推)

目录1.索引基础2.索引类型2.1哈希索引2.2有序数组2.3B+树索引(InnoDB)3.联合索引4.最左前缀原则5.覆盖索引6.索引下推总结:1.索引基础索引对查询的速度有着至...

是时候学习一下INDEX+MATCH这个超级查询神器了

【温馨提示】亲爱的朋友,阅读之前请您点击【关注】,您的支持将是我最大的动力!当我们在处理表格数据查询时,首先会想到一个超牛查询函数VLOOKUP()。如果你觉得VLOOKUP函数超牛的话,今天阿钟老师...