Dubbo分布式服务框架

本文涉及的产品
应用型负载均衡 ALB,每月750个小时 15LCU
注册配置 MSE Nacos/ZooKeeper,118元/月
传统型负载均衡 CLB,每月750个小时 15LCU
简介:


1. Dubbo是什么?

Dubbo是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案。简单的说,dubbo就是个服务框架,如果没有分布式的需求,其实是不需要用的,只有在分布式的时候,才有dubbo这样的分布式服务框架的需求,并且本质上是个服务调用的东东,说白了就是个远程服务调用的分布式框架(告别Web Service模式中的WSdl,以服务者与消费者的方式在dubbo上注册)
其核心部分包含:
1. 远程通讯: 提供对多种基于长连接的NIO框架抽象封装,包括多种线程模型,序列化,以及“请求-响应”模式的信息交换方式。
2. 集群容错: 提供基于接口方法的透明远程过程调用,包括多协议支持,以及软负载均衡,失败容错,地址路由,动态配置等集群支持。
3. 自动发现: 基于注册中心目录服务,使服务消费方能动态的查找服务提供方,使地址透明,使服务提供方可以平滑增加或减少机器。

2. Dubbo能做什么?

1.透明化的远程方法调用,就像调用本地方法一样调用远程方法,只需简单配置,没有任何API侵入。      
2.软负载均衡及容错机制,可在内网替代F5等硬件负载均衡器,降低成本,减少单点。
3. 服务自动注册与发现,不再需要写死服务提供方地址,注册中心基于接口名查询服务提供者的IP地址,并且能够平滑添加或删除服务提供者。

Dubbo采用全Spring配置方式,透明化接入应用,对应用没有任何API侵入,只需用Spring加载Dubbo的配置即可,Dubbo基于Spring的Schema扩展进行加载。

之前使用Web Service,我想测试接口可以通过模拟消息的方式通过soapui或LR进行功能测试或性能测试。但现在使用Dubbo,接口之间不能直接交互,我尝 试通过模拟消费者地址测试,结果不堪入目,再而使用jmeter通过junit进行测试,但还是需要往dubbo上去注册,如果再不给提供源代码的前提 下,这个测试用例不好写啊....

 

3. dubbo的架构

dubbo架构图如下所示:

 

 

 

节点角色说明:

       Provider: 暴露服务的服务提供方。

       Consumer: 调用远程服务的服务消费方。

       Registry: 服务注册与发现的注册中心。

       Monitor: 统计服务的调用次调和调用时间的监控中心。

       Container: 服务运行容器。

这点我觉得非常好,角色分明,可以根据每个节点角色的状态来确定该服务是否正常。

调用关系说明:

0 服务容器负责启动,加载,运行服务提供者。

1. 服务提供者在启动时,向注册中心注册自己提供的服务。

2. 服务消费者在启动时,向注册中心订阅自己所需的服务。

3. 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。

4. 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。

5. 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。

dubbo的容错性显而易见,性能方面还没有还得及测,我们系统某页面需要掉5次接口,本来想建议做个缓存,但业务关系不能采纳,还需要研究下dubbo的性能调优问题...

4. dubbo使用方法。

Dubbo采用全Spring配置方式,透明化接入应用,对应用没有任何API侵入,只需用Spring加载Dubbo的配置即可,Dubbo基于Spring的Schema扩展进行加载。如果不想使用Spring配置,而希望通过API的方式进行调用(不推荐)

下面我们就来看看spring配置方式的写法:

服务提供者:

1. 下载zookeeper注册中心,下载地址:http://www.apache.org/dyn/closer.cgi/zookeeper/  下载后解压即可,进入D:\apach-zookeeper-3.4.5\bin,

双击zkServer.cmd启动注册中心服务。

2. 定义服务接口: (该接口需单独打包,在服务提供方和消费方共享)

 

 下面这个例子不错,写的很详细可以做个model.

  1. package com.unj.dubbotest.provider;  

  2.   

  3. import java.util.List;  

  4.   

  5. public interface DemoService {  

  6.   

  7.     String sayHello(String name);  

  8.   

  9.     public List getUsers();  

  10.   

  11. }  


在服务提供方实现接口:(对服务消费方隐藏实现)

 

  1. package com.unj.dubbotest.provider;  

  2.   

  3. import java.util.ArrayList;  

  4. import java.util.LinkedList;  

  5. import java.util.List;  

  6.   

  7.   

  8. public class DemoServiceImpl implements DemoService{  

  9.       

  10.      public String sayHello(String name) {  

  11.             return "Hello " + name;  

  12.      }  

  13.      public List getUsers() {  

  14.          List list = new ArrayList();  

  15.          User u1 = new User();  

  16.          u1.setName("jack");  

  17.          u1.setAge(20);  

  18.          u1.setSex("男");  

  19.            

  20.          User u2 = new User();  

  21.          u2.setName("tom");  

  22.          u2.setAge(21);  

  23.          u2.setSex("女");  

  24.            

  25.          User u3 = new User();  

  26.          u3.setName("rose");  

  27.          u3.setAge(19);  

  28.          u3.setSex("女");  

  29.            

  30.          list.add(u1);  

  31.          list.add(u2);  

  32.          list.add(u3);  

  33.          return list;  

  34.      }  

  35. }  

 

用Spring配置声明暴露服务:

  1. <?xml version="1.0" encoding="UTF-8"?>  

  2. <beans xmlns="http://www.springframework.org/schema/beans"  

  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  

  4.     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  

  5.     xsi:schemaLocation="http://www.springframework.org/schema/beans  

  6.         http://www.springframework.org/schema/beans/spring-beans.xsd  

  7.         http://code.alibabatech.com/schema/dubbo  

  8.         http://code.alibabatech.com/schema/dubbo/dubbo.xsd  

  9.         ">  

  10.    

  11.     <!-- 具体的实现bean -->  

  12.     <bean id="demoService" class="com.unj.dubbotest.provider.DemoServiceImpl" />  

  13.       

  14.     <!-- 提供方应用信息,用于计算依赖关系 -->  

  15.     <dubbo:application name="xixi_provider"  />  

  16.    

  17.     <!-- 使用multicast广播注册中心暴露服务地址   

  18.     <dubbo:registry address="multicast://224.5.6.7:1234" />-->  

  19.     

  20.     <!-- 使用zookeeper注册中心暴露服务地址 -->  

  21.     <dubbo:registry address="zookeeper://127.0.0.1:2181" />   

  22.     

  23.     <!-- 用dubbo协议在20880端口暴露服务 -->  

  24.     <dubbo:protocol name="dubbo" port="20880" />  

  25.    

  26.     <!-- 声明需要暴露的服务接口 -->  

  27.     <dubbo:service interface="com.unj.dubbotest.provider.DemoService" ref="demoService" />  

  28.       

  29. </beans>  

加载Spring配置,启动服务:

  1. package com.unj.dubbotest.provider;  

  2.   

  3. import org.springframework.context.support.ClassPathXmlApplicationContext;  

  4.   

  5. public class Provider {  

  6.    

  7.     public static void main(String[] args) throws Exception {  

  8.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"applicationContext.xml"});  

  9.         context.start();  

  10.    

  11.         System.in.read(); // 为保证服务一直开着,利用输入流的阻塞来模拟  

  12.     }  

  13.    

  14. }  


服务消费者:

 applicationContext-dubbo.xml 中注册自己需要调用的接口,我刚开始测试的时候需要的接口很多,所以把这个文件写的满满的,后来熟悉了把接口按业务类型分开,写了N多个 applicationContext-dubbo-***.xml 简练多了 》。 

 

1.通过Spring配置引用远程服务:

  1. <?xml version="1.0" encoding="UTF-8"?>  

  2. <beans xmlns="http://www.springframework.org/schema/beans"  

  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"  

  4.     xsi:schemaLocation="http://www.springframework.org/schema/beans  

  5.         http://www.springframework.org/schema/beans/spring-beans.xsd  

  6.         http://code.alibabatech.com/schema/dubbo  

  7.         http://code.alibabatech.com/schema/dubbo/dubbo.xsd  

  8.         ">  

  9.   

  10.     <!-- 消费方应用名,用于计算依赖关系,不是匹配条件,不要与提供方一样 -->  

  11.     <dubbo:application name="hehe_consumer" />  

  12.   

  13.     <!-- 使用zookeeper注册中心暴露服务地址 -->  

  14.     <!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->  

  15.     <dubbo:registry address="zookeeper://127.0.0.1:2181" />  

  16.   

  17.     <!-- 生成远程服务代理,可以像使用本地bean一样使用demoService -->  

  18.     <dubbo:reference id="demoService"  

  19.         interface="com.unj.dubbotest.provider.DemoService" />  

  20.   

  21. </beans>  


2.加载Spring配置,并调用远程服务:

  1. package com.alibaba.dubbo.demo.pp;  

  2.   

  3. import java.util.List;  

  4.   

  5. import org.springframework.context.support.ClassPathXmlApplicationContext;  

  6.   

  7. import com.unj.dubbotest.provider.DemoService;  

  8.   

  9. public class Consumer {  

  10.   

  11.     public static void main(String[] args) throws Exception {  

  12.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(  

  13.                 new String[] { "applicationContext.xml" });  

  14.         context.start();  

  15.   

  16.         DemoService demoService = (DemoService) context.getBean("demoService"); //  

  17.         String hello = demoService.sayHello("tom"); //   

  18.         System.out.println(hello); //   

  19.   

  20.         //   

  21.         List list = demoService.getUsers();  

  22.         if (list != null && list.size() > 0) {  

  23.             for (int i = 0; i < list.size(); i++) {  

  24.                 System.out.println(list.get(i));  

  25.             }  

  26.         }  

  27.         // System.out.println(demoService.hehe());  

  28.         System.in.read();  

  29.     }  

  30.   

  31. }  

调用结果为:

 


dubbo管理页面:

这个管理页面还需要部署一个环境的,一开始我还以为是dubbo自带的,找了半天没有找到....

 


 

 

 

 

应用页面:

 

 

 

 

提供者页面:

 

 

 

 

消费者页面:

 

 

 

 

服务页面:

测试是否成功,我觉得只要看看状态是否正常,就ok了 ....

 

案例代码下载:http://download.csdn.net/detail/yiyu1/7116319

 

 

 

 

 

 

敏捷测试团队,不再仅仅是在coding之后。而是和研发人员贯穿在需求分析、规格说明、自动化单元测试、自动化验收测试、静态代码分析、技术债等环节中。所以敏捷项目必定在将来效率的趋势下成为主流。



本文转自 msj0905 51CTO博客,原文链接:http://blog.51cto.com/sky66/1694675

相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作,您将了解并实现在线业务的微服务全链路灰度能力。
相关文章
|
1月前
|
Java 数据库
在Java中使用Seata框架实现分布式事务的详细步骤
通过以上步骤,利用 Seata 框架可以实现较为简单的分布式事务处理。在实际应用中,还需要根据具体业务需求进行更详细的配置和处理。同时,要注意处理各种异常情况,以确保分布式事务的正确执行。
|
1月前
|
消息中间件 Java Kafka
在Java中实现分布式事务的常用框架和方法
总之,选择合适的分布式事务框架和方法需要综合考虑业务需求、性能、复杂度等因素。不同的框架和方法都有其特点和适用场景,需要根据具体情况进行评估和选择。同时,随着技术的不断发展,分布式事务的解决方案也在不断更新和完善,以更好地满足业务的需求。你还可以进一步深入研究和了解这些框架和方法,以便在实际应用中更好地实现分布式事务管理。
|
2月前
|
存储 缓存 算法
分布式锁服务深度解析:以Apache Flink的Checkpointing机制为例
【10月更文挑战第7天】在分布式系统中,多个进程或节点可能需要同时访问和操作共享资源。为了确保数据的一致性和系统的稳定性,我们需要一种机制来协调这些进程或节点的访问,避免并发冲突和竞态条件。分布式锁服务正是为此而生的一种解决方案。它通过在网络环境中实现锁机制,确保同一时间只有一个进程或节点能够访问和操作共享资源。
92 3
|
8天前
|
消息中间件 存储 安全
分布式系统架构3:服务容错
分布式系统因其复杂性,故障几乎是必然的。那么如何让系统在不可避免的故障中依然保持稳定?本文详细介绍了分布式架构中7种核心的服务容错策略,包括故障转移、快速失败、安全失败等,以及它们在实际业务场景中的应用。无论是支付场景的快速失败,还是日志采集的安全失败,每种策略都有自己的适用领域和优缺点。此外,文章还为技术面试提供了解题思路,助你在关键时刻脱颖而出。掌握这些策略,不仅能提升系统健壮性,还能让你的技术栈更上一层楼!快来深入学习,走向架构师之路吧!
43 11
|
7天前
|
分布式计算 大数据 数据处理
技术评测:MaxCompute MaxFrame——阿里云自研分布式计算框架的Python编程接口
随着大数据和人工智能技术的发展,数据处理的需求日益增长。阿里云推出的MaxCompute MaxFrame(简称“MaxFrame”)是一个专为Python开发者设计的分布式计算框架,它不仅支持Python编程接口,还能直接利用MaxCompute的云原生大数据计算资源和服务。本文将通过一系列最佳实践测评,探讨MaxFrame在分布式Pandas处理以及大语言模型数据处理场景中的表现,并分析其在实际工作中的应用潜力。
34 2
|
1月前
|
存储 Java 关系型数据库
在Spring Boot中整合Seata框架实现分布式事务
可以在 Spring Boot 中成功整合 Seata 框架,实现分布式事务的管理和处理。在实际应用中,还需要根据具体的业务需求和技术架构进行进一步的优化和调整。同时,要注意处理各种可能出现的问题,以保障分布式事务的顺利执行。
51 6
|
1月前
|
数据库
如何在Seata框架中配置分布式事务的隔离级别?
总的来说,配置分布式事务的隔离级别是实现分布式事务管理的重要环节之一,需要认真对待和仔细调整,以满足业务的需求和性能要求。你还可以进一步深入研究和实践 Seata 框架的配置和使用,以更好地应对各种分布式事务场景的挑战。
29 6
|
28天前
|
消息中间件 运维 数据库
Seata框架和其他分布式事务框架有什么区别
Seata框架和其他分布式事务框架有什么区别
25 1
|
1月前
|
机器学习/深度学习 自然语言处理 并行计算
DeepSpeed分布式训练框架深度学习指南
【11月更文挑战第6天】随着深度学习模型规模的日益增大,训练这些模型所需的计算资源和时间成本也随之增加。传统的单机训练方式已难以应对大规模模型的训练需求。
146 3
|
1月前
|
机器学习/深度学习 并行计算 Java
谈谈分布式训练框架DeepSpeed与Megatron
【11月更文挑战第3天】随着深度学习技术的不断发展,大规模模型的训练需求日益增长。为了应对这种需求,分布式训练框架应运而生,其中DeepSpeed和Megatron是两个备受瞩目的框架。本文将深入探讨这两个框架的背景、业务场景、优缺点、主要功能及底层实现逻辑,并提供一个基于Java语言的简单demo例子,帮助读者更好地理解这些技术。
101 2

热门文章

最新文章