分布式--Dubbo 分布式服务

本文涉及的产品
云原生网关 MSE Higress,422元/月
注册配置 MSE Nacos/ZooKeeper,118元/月
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: 1. Dubbo官网Dubbo下载地址1). 发展历史随着互联网的不断发展,网站的应用规模越来越大,常规的垂直架构已经无法应对,尤其是类似电商的项目,所以分布式架构和流动计算架构已经势在必行。

1. Dubbo官网

Dubbo下载地址

1). 发展历史

随着互联网的不断发展,网站的应用规模越来越大,常规的垂直架构已经无法应对,尤其是类似电商的项目,所以分布式架构和流动计算架构已经势在必行。Dubbo就是资源调度和服务治理中心的管理工具。
① 单一应用架构(ORM)
当网站流量很小时,只需一个应用,将所有功能如下单支付等都部署在一起,以减少部署节点和成本。 缺点:单一的系统架构,使得在开发过程中,占用的资源越来越多,而且随着流量的增加越来越难以维护


img_77bc51ee102a87ac1fa63800b74c200e.png
图1.png

② 垂直应用架构(MVC)
垂直应用架构解决了单一应用架构所面临的扩容问题,流量能够分散到各个子系统当中,且系统的体积可控,一定程度上降低了开发人员之间协同以及维护的成本,提升了开发效率。 缺点:但是在垂直架构中相同逻辑代码需要不断的复制,不能复用。


img_b26336eb43b88206f6e275938bc5ce2e.png
图2.png

③ 分布式服务架构(RPC)
当垂直应用越来越多,有很多相同的业务逻辑,这样应用直接的交互不可避免,此时将核心业务抽取出来,作为独立的服务,逐 渐形成稳定的服务中心,以应对快速变化的外部市场环境。


img_8ed50e3888183019517a445fe32aec9d.png
图3.png

④ 流动计算架构(SOA)
当服务越来越多,容量的评估,小服务资源浪费等问题逐渐暴露,此时需要一个服务治理工具来管理集群容量,提高利用率。


img_1d74547bdc4682e4fa6fecf7a4be0cab.png
图4.png
2). 为什么使用dubbo?

1.webservice:效率不高基于soap协议,项目中不建议使用,但它的优点在于跨语言通信,适用于不同公司相互调用接口。
2.使用restful形式服务:http+json。很多项目中的应用,如果服务太多,系统之间调用关系混乱,需要治疗服务。
3.使用dubbo。使用rpc协议进行远程调用,之间使用socket通信,传输效率高,并且可以统计出系统之间的调用关系、调用次数。
说白了dubbo就是一个服务治理工具,是一个服务的中间件,由于dubbo是通过java编写的,dubbo最大的缺点就出现了,它只适用于java系统间的通信。

3). Dubbo架构

角色说明:

  • Provider:暴露服务的服务提供方
  • Container:服务运行容器
  • Consumer:调用服务的消费方
  • Registry:注册服务与发现服务中心
  • Monitor:统计服务调用的监控中心(可有可无)


    img_95345b2981ac8d51e5322c8713891cfb.png
    图5.png

调用关系说明:
0:服务运行容器启动,加载服务提供者
1:在启动时告诉注册中心服务方有什么服务
2:消费者调用服务时,先到注册中心订阅所需要服务
3:注册中心返回结果即该服务的地址
4:消费者通过地址调用服务(此时注册中心没用了)
5:服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次到监控中心

4). RPC(Remote Procedure Call Protocol)

远程过程调用: 两台服务器A、B,分别部署不同的应用a,b。当A服务器想要调用B服务器上应用b提供的函数或方法的时候,由于不在一个内存空间,不能直接调用,需要通过网络来表达调用的语义传达调用的数据。


img_debc93292f7c2564b80f4b1e6d1aa0cb.png
图6.png

RPC是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在,如TCP或UDP,为通信程序之间携带信息数据。在OSI网络通信模型中,RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。 RPC采用客户机/服务器模式。请求程序就是一个客户机,而服务提供程序就是一个服务器。首先,客户机调用进程发送一个有进程参数的调用信息到服务进程,然后等待应答信息。在服务器端,进程保持睡眠状态直到调用信息到达为止。当一个调用信息到达,服务器获得进程参数,计算结果,发送答复信息,然后等待下一个调用信息,最后,客户端调用进程接收答复信息,获得进程结果,然后调用执行继续进行。

5). Dubbo的注册中心
  • Multicast注册中心
  • Zookeeper注册中心
  • Redis注册中心
  • Simple注册中心
6). Dubbo优缺点
  • 优点:
  1. 透明化的远程方法调用:像调用本地方法一样调用远程方法;只需简单配置,没有任何API侵入。
  2. 软负载均衡及容错机制:可在内网替代nginx lvs等硬件负载均衡器。
  3. 服务注册中心自动注册 & 配置管理:不需要写死服务提供者地址,注册中心基于接口名自动查询提供者ip。使用类似zookeeper等分布式协调服务作为服务注册中心,可以将绝大部分项目配置移入zookeeper集群。
  4. 服务接口监控与治理 :Dubbo-admin与Dubbo-monitor提供了完善的服务接口管理与监控功能,针对不同应用的不同接口,可以进行 多版本,多协议,多注册中心管理。
  • 缺点:只支持JAVA语言

2. Spring+Dubbo+ZooKeeper实例

1). 准备jar包(共16个)
2). 创建Dubbo-api Java项目

I. 引入jar包
右键项目 -> Build Path -> Configure Build Path... -> Libraries -> Add External JARs... 找到自己刚刚存放jar包的文件夹,我的是在E:\eclipse\libs\文件夹中,全选(Ctrl+A)jar包,点击打开—> OK. 导包成功.

img_0ed82937daaf01843d86a9e8aa435315.png
图8.png

II. 将解压ZooKeeper后的文件夹中/conf/文件夹下的log4j.properties拷贝到工程的src目录下


img_fba547f7ec3cb0c7f98feae4b5a28b95.png
图9.png

III. 在src下创建ItemService接口

public interface ItemService {
    List<String> getList(Long id);
}

IV. Dubbo-api 工程目录结构


img_b9b877d03ea80d566574cf982aecf2a5.png
图10.png
3). 创建Dubbo-provider Java工程

I. 导包--方法同上
II. 依赖上一步完成的Dubbo-api Java工程
工程上右键 -> Build Path -> Configure Build Path... -> Project -> Add... ->选择Dubbo-api 点击OK -> OK
III. 创建ItemService的实现类ItemServiceImpl

public class ItemServiceImpl implements ItemService{

    @Override
    public List<String> getList(Long id) {
        List<String> list = new ArrayList<>();
        for (int i = 0; i < 20; i++) {
            list.add("item" + i);
        }
        return list;
    }

}

IV. 在src目录下创建provider.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<beans 
    xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://code.alibabatech.com/schema/dubbo 
       http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
    <!-- 定义了提供方应用信息,用于计算依赖关系,在 dubbo-admin 或 dubbo-monitor 会显示这个名字,方便辨识 -->
    <dubbo:application name="Dubbo-provider" owner="programmer" organization="mazaiting"/>
    <!-- 使用ZooKeeper 注册中心暴露服务,注意要先开启ZooKeeper -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    <!-- 使用Dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880"/>
    <!-- 使用dubbo 协议实现定义好的服务接口 -->
    <dubbo:service protocol="dubbo" ref="itemService" interface="com.mazaiting.service.ItemService"/>
    <!-- 具体实现该接口的bean -->
    <bean id="itemService" class="com.mazaiting.service.impl.ItemServiceImpl"/>
    
</beans>

如果遇到无法快捷提示dubbo标签的情况, 请参考此文--Dubbo 无法加载dubbo.xsd
V. 创建Provider类,此类中启动此工程

public class Provider {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context = 
                new ClassPathXmlApplicationContext("provider.xml");
        System.out.println(context.getDisplayName() + " : here");
        context.start();
        System.out.println("服务已经启动...");
        System.in.read();
    }
}

VI. Dubbo-provider 工程目录结构


img_66371999f10d5ade167512b8df827847.png
图11.png
4). 创建Dubbo-consumer Java工程

I. 导包 -- 方法同上
II. 在src下创建consumer.xml配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans 
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://code.alibabatech.com/schema/dubbo 
       http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
        <!-- 定义了提供方应用信息,用于计算依赖关系,在 dubbo-admin 或 dubbo-monitor 会显示这个名字,方便辨识 -->
        <dubbo:application name="Dubbo-consumer" owner="programmer" organization="mazaiting"/>
        <!-- 向ZooKeeper 订阅provider的地址, 由ZooKeeper定时推送 -->
        <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
        <!-- 使用协议调用定义好的接口 -->
        <dubbo:reference id="itemService" interface="com.mazaiting.service.ItemService"/>
</beans>

III. 创建Consumer类来启动当前工程

public class Consumer {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = 
                new ClassPathXmlApplicationContext("consumer.xml");
        context.start();
        System.out.println("consumer start");
        ItemService demoService = context.getBean(ItemService.class);
        System.out.println("consumer");
        List<String> list = demoService.getList(1L);
        for (String string : list) {
            System.out.println(string); 
        }
    }
}

IV. Dubbo-consumer 工程目录结构


img_a1bc69872ddd5691106b61d18c475a67.png
图12.png
5). 测试

I. 开启ZooKeeper -- ZooKeeper安装及使用
II. 执行Dubbo-provider工程中的Provider类

img_86abdb806d758b071c4e7488e6bf9df9.png
图13.png

III. 再启动Dubbo-consumer工程中的Consumer类
img_c1c1a4aedb0b5330d34c3ad98b17086e.png
图15.png

3. Dubbo 控制台安装

1). Dubbo-admin下载
2). 编译项目

编译项目需要使用到Maven命令, Linux 安装MavenWindows 安装Maven
下载之后解压,并进入incubator-dubbo-ops-master文件夹,在命令提示符窗口中输入

mvn clean package

编译成功如下图:


img_79bb17c68d97ffa1e9fd62e9b46691e6.png
图16.png
3). 安装Tomcat容器

img_fefa48a33f5d119d2d1da3cdb268edcb.png
图17.png

这里我下载的是zip包,下载后并解压
img_809a93ece71a0c920ab307311156cc2c.png
图18.png

4). 复制文件

将incubator-dubbo-ops-master\dubbo-admin\target\下的dubbo-admin-2.0.0.war复制到apache-tomcat-8.5.31\webapps\目录下


img_b76a15608ff22f3a1c5ee070fc9f734d.png
图19.png
5). 解压

将dubbo-admin-2.0.0.war解压

img_7428b6f166f2a8359f5c98248e6c6c90.png
图20.png

在WEB-INF/dubbo.properties文件中可以配置ZooKeeper地址,管理员密码

4. 使用Dubbo-admin

1). 开启ZooKeeper
img_61e319ebeea484e8a730a1b5aba7109a.png
图21.png
2). 开启Tomcat
  • 双击startup.bat批处理开发


    img_451b8653bf8453941fa3a6213e1aa964.png
    图22.png
  • 浏览器打开http://localhost:8080/dubbo-admin-2.0.0页面
    img_426a32704f581a794e6ea8236aa2ee8b.png
    图23.png

    用户名和密码默认的均为root,此时登录后数据为空。
    img_54754cb6be96e0b31f3870bb2078c94b.png
    图24.png
3). 在Eclipse中运行Dubbo-provider项目

程序启动后刷新http://localhost:8080/dubbo-admin-2.0.0/governance/providers

img_1ef61d72f846f0b12c8151194d937413.png
图25.png

此时提供者已有数据,再进入消费者页面
img_66f758cc27f22e0b6674a1b547c4becf.png
图26.png

4). 在Eclipse中运行Dubbo-consumer项目

程序启动后,Eclipse控制台打印出数据,刷新http://localhost:8080/dubbo-admin-2.0.0/governance/consumers页面

img_f48d327521fbbb4cb8e81727da3fb31c.png
图27.png

此时消费者页面也有数据了。

代码下载

相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作,您将了解并实现在线业务的微服务全链路灰度能力。
目录
相关文章
|
26天前
|
存储 缓存 算法
分布式锁服务深度解析:以Apache Flink的Checkpointing机制为例
【10月更文挑战第7天】在分布式系统中,多个进程或节点可能需要同时访问和操作共享资源。为了确保数据的一致性和系统的稳定性,我们需要一种机制来协调这些进程或节点的访问,避免并发冲突和竞态条件。分布式锁服务正是为此而生的一种解决方案。它通过在网络环境中实现锁机制,确保同一时间只有一个进程或节点能够访问和操作共享资源。
59 3
|
2月前
|
安全 应用服务中间件 API
微服务分布式系统架构之zookeeper与dubbo-2
微服务分布式系统架构之zookeeper与dubbo-2
|
28天前
|
监控 Dubbo Java
dubbo学习三:springboot整合dubbo+zookeeper,并使用dubbo管理界面监控服务是否注册到zookeeper上。
这篇文章详细介绍了如何将Spring Boot与Dubbo和Zookeeper整合,并通过Dubbo管理界面监控服务注册情况。
66 0
dubbo学习三:springboot整合dubbo+zookeeper,并使用dubbo管理界面监控服务是否注册到zookeeper上。
|
2月前
|
数据采集 分布式计算 MaxCompute
MaxCompute 分布式计算框架 MaxFrame 服务正式商业化公告
MaxCompute 分布式计算框架 MaxFrame 服务于北京时间2024年09月27日正式商业化!
75 3
|
2月前
|
负载均衡 监控 Dubbo
分布式框架-dubbo
分布式框架-dubbo
|
2月前
|
Dubbo Java 应用服务中间件
分布式-dubbo的入门
分布式-dubbo的入门
|
2月前
|
存储 Dubbo 应用服务中间件
分布式-Dubbo-Dubbo的由来
分布式-Dubbo-Dubbo的由来
|
2月前
|
XML 负载均衡 监控
分布式-dubbo-简易版的RPC框架
分布式-dubbo-简易版的RPC框架
|
2月前
|
负载均衡 监控 Dubbo
分布式-Dubbo-dubbo能解决什么问题
分布式-Dubbo-dubbo能解决什么问题
|
3月前
|
JSON Dubbo Java
【Dubbo协议指南】揭秘高性能服务通信,选择最佳协议的终极攻略!
【8月更文挑战第24天】在分布式服务架构中,Apache Dubbo作为一款高性能的Java RPC框架,支持多种通信协议,包括Dubbo协议、HTTP协议及Hessian协议等。Dubbo协议是默认选择,采用NIO异步通讯,适用于高要求的内部服务通信。HTTP协议通用性强,利于跨语言调用;Hessian协议则在数据传输效率上有优势。选择合适协议需综合考虑性能需求、序列化方式、网络环境及安全性等因素。通过合理配置,可实现服务性能最优化及系统可靠性提升。
53 3