重庆分公司,新征程启航

为企业提供网站建设、域名注册、服务器等服务

Node调用dubbo服务的探索及实践-创新互联

创新互联公司专业IDC数据服务器托管提供商,专业提供成都服务器托管,服务器租用,服务器托管服务器托管,成都多线服务器托管等服务器托管服务。

Node 调用 dubbo 服务的探索及实践

2.Dubbo简介

2.1 什么是dubbo

Dubbo是一款高性能、轻量级的开源Java RPC框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。

2.2 流程图

Node 调用 dubbo 服务的探索及实践

  • Provider  : 暴露服务的服务提供方。
  • Consumer  : 调用远程服务的服务消费方。
  • Registry  : 服务注册与发现的注册中心。
  • Monitor  : 统计服务的调用次调和调用时间的监控中心。
  • Container  : 服务运行容器。

3. 具体实现

3.1 协议选择


连接个数 连接方式 传输协议 传输方式 序列化 适用范围 适用场景
dubbo 单连接 长连接 TCP NIO 异步传输 Hessian 二进制序列化 传入传出参数数据包较小,消费者比提供者个数多,单一消费者无法压满提供者 常规远程服务方法调用
rmi 多连接 短连接 TCP 同步传输 Java 标准二进制序列化 传入传出参数数据包大小混合,消费者与提供者个数差不多,可传文件。 常规远程服务方法调用,与原生RMI服务互操作
hessian 多连接 短连接 HTTP 同步传输 Hessian二进制序列化 传入传出参数数据包较大,提供者比消费者个数多,提供者压力较大,可传文件。 页面传输,文件传输,或与原生hessian服务互操作
http 多连接 短连接 HTTP 同步传输 表单序列化 传入传出参数数据包大小混合,提供者比消费者个数多,可用浏览器查看,可用表单或URL传入参数 需同时给应用程序和浏览器 JS 使用的服务。
rest 多连接 短连接 HTTP 同步传输 表单序列化 同http,适用于更加符合rest规范的服务 同http

3.2 如何引用服务

目前引用服务有两个方案,分别是

  • 直接引用
  • 通过注册中心引用服务

3.2.1 直接引用服务

直接引用服务,顾名思义就是绕开注册中心获取我们所想要的服务提供者,由于绕开了注册中心,自然也无法做到服务发现,而且由于单点问题,无法做到负载均衡以及高可用,  所以生产环境不推荐使用此模式的  .

但是由于其开发上的便利性,在开发环境/测试环境仍可以尝试使用此模式.

Node 调用 dubbo 服务的探索及实践

由上图所示,开发同学联调过程中,需要在项目工程中对指定服务开发同学的机器进行直连,而其他没有指定的服务将会默认走注册中心.为了避免对工程代码的侵入性,我们会在工程中建立应对不同环境的dubbo.properies,而dubbo.properies不会加入到工程的版本控制当中,主要用于解决不同环境下的服务直连问题.其中服务的控制粒度可以精确到具体的服务.

Node 调用 dubbo 服务的探索及实践

3.2.2 通过注册中心引用服务

通过注册中心发现引用服务,Dubbo常用的引用服务方式,可以做到服务自动发现,负载均衡.正式环境调用基本基于此模式.其中注册中心实现有很多种,例如Zookeeper/Redis/Multicast.官方推荐Zookeeper.

Node 调用 dubbo 服务的探索及实践

3.3 服务请求结构的定义

服务请求体结构,是在对dubbo在注册中心上注册信息的抽象之后的一层封装,一方面可以提升开发人员的开发效率,另外降低开发人员自身手动拼接请求的错误率.

3.3.1 服务的构成

基于上述基于协议所分析,我们目前协议将只会锁定在dubbo/rest,那么我们先看来这两个协议在注册中心注册的信息是什么样子的.

dubbo://192.168.1.2:10880/com.service.ProductService?dubbo=2.8&methods=getById,getByName
rest://192.168.1.2:10081/service/com.service.ProductService?dubbo=2.8&methods=getById,getByName

我们对这两个协议公共部分进行提取一下

dubbo://
com.service.ProductService

3.3.2 请求体的定义

基于上述服务结构构成的分析,dubbo和rest服务请求结构构成大体类似,我们对不同的协议请求的可以做如下定义.

// 1. dubbo协议的请求体定义
services.ProductService = (dubbo) => dubbo.proxyService({
    dubboInterface: 'com.service.ProductService',
    methods: {
        getById(id) {
            return [java.Long(id)];
        },
        getByName(name) {
            return [java.String(name)];
        }
    },
});
复制代码
// rest 请求体定义
services.ProductService = (dubbo) => dubbo.proxyService({
    dubboInterface: 'com.service.ProductService',
    methods: {
        getById(id) {
            return {
                method: 'get',
                query: [parseInt(id)]
            };
        },
        getByName(name) {
            return [String(name)];
        }
    },
});
复制代码

两者大不同点在于参数定义上的不同,dubbo需要强制转换为强类型,而rest不需要.

3.4 服务定义的维护

我们在对服务定义完成之后,接下来就会面临一个使用上的问题,最直接的方法就是为每个工程每个服务新建一个服务文件,但是一用就会发现一个问题请求定义的文件分散在不同工程,无法进行统一维护升级,维护成本较高.

Node 调用 dubbo 服务的探索及实践

我们第一个反应是每个服务抽象出来,各自成为一个独立的NPM包,譬如MemberService我们可以抽象成为  @dubbo-service/member-service  ,这样就可以解决文件分散在不同工程导致的维护问题.

Node 调用 dubbo 服务的探索及实践


当前文章:Node调用dubbo服务的探索及实践-创新互联
网站路径:http://cqcxhl.com/article/dpeggc.html

其他资讯

在线咨询
服务热线
服务热线:028-86922220
TOP