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

了解一点ESB

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

如何进行系统集成?

点对点方式 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个服务接口,示例代码如下
@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结构如下:

<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;
}

相关推荐

全网最详细解决Windows下Mysql数据库安装后忘记初始root 密码方法

一、准备重置root的初始化密码Win+R键启动命令输入窗口;输入cmd打开命令执行窗口;##界面如下##输入命令:netstopmysqld#此操作会停止当前运行的...

Spring Boot数据库密码加密的配置方法

前言由于系统安全的考虑,配置文件中不能出现明文密码的问题,本文就给大家详细介绍下springboot配置数据库密码加密的方法,下面话不多说了,来一起看看详细的介绍吧...

Mysql 8.4数据库安装、新建用户和数据库、表单

1、下载MySQL数据库yuminstall-ywgetperlnet-toolslibtirpc#安装wget和perl、net-tools、libtirpcwgethtt...

mysql5.7安装教程

首先下载mysql的rpm包wgethttps://mirrors.ustc.edu.cn/mysql-ftp/Downloads/MySQL-5.7/mysql-community-client...

MySQL管理授权和数据库的备份和还原详解

一般管理用户和授权由DBA去执行,DBA为数据库管理员一、管理用户1.添加用户...

数据库迁移有什么技巧?|分享强大的database迁移和同步工具

概述DBConvertStudio是一款强大的跨数据库迁移和同步软件,可在不同数据库格式之间转换数据库结构和数据。它将成熟、稳定、久经考验的DBConvert和DBSync核心与改进的现代...

Mysql解压版安装过程

Mysql是目前软件开发中使用最多的关系型数据库,具体安装步骤如下:第一步:Mysql官网下载最新版(mysql解压版(mysql-5.7.17-winx64)),Mysql官方下载地址为:https...

MySQL5.7升级到8.0过程详解

前言:不知不觉,MySQL8.0已经有好多个GA小版本了。目前互联网上也有很多关于MySQL8.0的内容了,MySQL8.0版本基本已到稳定期,相信很多小伙伴已经在接触8.0了。本篇文章主要介绍从5....

10种常见的MySQL错误,你可中招?

【51CTO.com快译】如果未能对MySQL8进行恰当的配置,您非但可能遇到无法顺利访问、或调用MySQL的窘境,而且还可能给真实的应用生产环境带来巨大的影响。本文列举了十种MySQL...

忘记MySQL密码怎么办?一招教你搞定

在安装完MySQL或者是在使用MySQL时,最尴尬的就是忘记密码了,墨菲定律也告诉我们,如果一件事有可能出错,那么它一定会出错。那如果我们不小心忘记了MySQL的密码,该如何处理呢?别着急...

Windows 安装解压版本的 MySql

1、下载解压版本的MySql到https://downloads.mysql.com/archives/community/网站,根据自己需要安装的版本进行选择下载,这里下载不要选择MSII...

爆破SSH/MySQL账户竟如此简单

友情提示:初入安全,小白一个,本文重在学习与经验分享!背景使用Kali自带的MSF工具对SSH的账号密码进行爆破。1.实验环境本次实验通过MSF,可直接对SSH的账号密码进行爆破。KaliIP:1...

Mysql8忘记密码/重置密码

Mysql8忘记密码/重置密码UBUNTU下Mysql8忘记密码/重置密码步骤如下:先说下大概步骤:修改配置文件,使得用空密码可以进入mysql。然后置当前root用户为空密码。再次修改配置文件,不能...

wamp查看MySQL密码 MySQL console输入密码闪退 重置mysql密码

wampserver的MySQL数据库用户名为root初始密码为空,但是部分同学通过MySQLconsole访问数据库输入密码的时候出现窗口闪退,常见的问题是原来有改过密码或者你的配置文件要求密码不...

Mysql数据库操作指引(六)——账号密码及权限管理

简介:在MySQL数据库中,为了保证数据的安全性,数据管理员需要根据需要创建账户,并为每个账户赋予不同的权限,以满足不同用户的需求。...