AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

探索分布式服务框架Dubbo4：Dubbo初体验

2018-06-21 1578
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
注册配置 MSE Nacos/ZooKeeper，118元/月
云原生网关 MSE Higress，422元/月
任务调度 XXL-JOB 版免费试用，400 元额度，开发版规格
简介： 阿里 RPC 框架 DUBBO 初体验 Jun 7, 2018 | haifeiWu | Java | 231 阅读 文章目录 1. 快速开始 2. 接口创建 3. 接口配置 4. 准备测试 5. 运行 6. 小结 7. 号外 最近研究了一下阿里开源的分布式RPC框架dubbo，楼主写了一个 demo，体验了一下dubbo的功能。

快速开始

实际上，dubbo的官方文档已经提供了如何使用这个RPC框架example代码，基于 Netty 的长连接。楼主看这个框架主要是为了在微服务，service mesh大火的今天做一些技术储备以及了解一下分布式 RPC 框架的设计。

当然即便是写一个dubbo的demo也不能随便写写就好了，要认真对待说不定哪一天可以派上用场呢，下面是楼主写的代码的目录结构：

下面我来一一说明一下每个model的作用，

  1. micro-service-dubbo-common是通用工具模块其他的model都需要依赖它 。
  2. micro-service-dubbo-dal是整个项目的dao模块，有关数据库操作的相关代码都放在这里。
  3. micro-service-dubbo-interface 是通用接口模块，专门用来声明接口，被consumer与provider同时依赖，这么做是为了项目的可拆分与分布式部署。
  4. micro-service-dubbo-model是公用的实体类模块，不限于数据库对应的model，也可以放DTO，VO等。
  5. micro-service-dubbo-provider项目的服务提供者。
  6. micro-service-dubbo-web 项目的消费者，也是直接跟前端交互的controller层。

另外需要在pom文件中添加相关依赖

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24


<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>dubbo</artifactId>
    <version>${dubbo.version}</version>
</dependency>

<dependency>
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>${zkclient_version}</version>
</dependency>

<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>${zookeeper_version}</version>
</dependency>

<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>${curator_version}</version>
</dependency>

接口创建

既然是 RPC 服务，那就需要一个接口，再有一个实现类。在这里的接口定义是在我们的micro-service-dubbo-interface，具体实现是在provider这里创建，在楼主的项目中就是在micro-service-dubbo-provider中创建DemoService 的实现。

1
2
3
4
5

public interface DemoService {
      
    String sayHello(String name);

    public List getUsers();
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

@Service("demoService")
public class DemoServiceImpl implements DemoService {
      

    @Override
    public String sayHello(String name) {
      
        System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] Hello " + name + ", request from consumer: " + RpcContext
                .getContext().getRemoteAddress());
        return "Hello " + name + ", response from provider: " + RpcContext.getContext().getLocalAddress();
    }

    @Override
    public List getUsers() {
      
        List list = new ArrayList();
        User u1 = new User();
        u1.setName("hejingyuan");
        u1.setAge(20);
        u1.setSex("f");

        User u2 = new User();
        u2.setName("xvshu");
        u2.setAge(21);
        u2.setSex("m");


        list.add(u1);
        list.add(u2);

        return list;
    }
}

然后consumer的 pom.xml 添加对这个接口的依赖，在这里的接口定义是在我们的consumer就是micro-service-dubbo-web。


  com.whforever
    micro-service-dubbo-provider
    1.0-SNAPSHOT


    com.whforever
    micro-service-dubbo-interface
    1.0-SNAPSHOT

有了接口，就需要配置一下。

接口配置

首先在提供方这里发布接口。创建一个 xml 文件，名为：dubbo-provider.xml。

文件内容：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23


<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    
    <dubbo:application name="demo-provider"/>

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

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

    
    <bean id="demoProviderService" class="com.whforever.service.impl.DemoServiceImpl"/>

    
    <dubbo:service interface="com.whforever.service.DemoService" ref="demoProviderService"/>

</beans>

很简单，发布了一个接口，类似 Spring 的一个 bean。

同样的，在consumer即micro-service-dubbo-web的 resource 文件下，也创建一个dubbo-consumer.xml文件。内容稍有不同。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20


<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    
    <dubbo:application name="demo-consumer"/>

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

    
    <dubbo:reference id="demoConsumerService" check="false" interface="com.whforever.service.DemoService"/>

</beans>

从上面可以看出这两个文件的注册发现协议是zookeeper，因此在服务启动之前需要启动zookeeper。

准备测试

测试之前还要做点点工作。

在启动provider事需要一部分引导程序，请看如下代码：

1
2
3
4
5
6
7
8
9

public class ProviderMain {
      
    public static void main(String[] args) throws IOException {
      
        System.setProperty("java.net.preferIPv4Stack", "true");
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-provider.xml");
        context.start();

        System.in.read(); // press any key to exit
    }
}

consumer代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15


@Controller
@RequestMapping("/")
public class IndexController {
      

    @Autowired
    DemoService demoService;

    @RequestMapping("/echo")
    @ResponseBody
    public String echo() {
      
        System.out.println(">>>>>>echo");
        return JSON.toJSONString(demoService.getUsers());
    }
}

运行

先运行provider：

1
2
3
4
5

[06/06/18 11:56:29:029 CST] main  INFO config.AbstractConfig:  [DUBBO] The service ready on spring started. service: com.whforever.service.DemoService, dubbo version: 2.6.1, current host: 192.168.1.120
[06/06/18 11:56:30:030 CST] main  INFO config.AbstractConfig:  [DUBBO] Export dubbo service com.whforever.service.DemoService to local registry, dubbo version: 2.6.1, current host: 192.168.1.120
[06/06/18 11:56:30:030 CST] main  INFO config.AbstractConfig:  [DUBBO] Export dubbo service com.whforever.service.DemoService to url dubbo://192.168.1.120:20880/com.whforever.service.DemoService?anyhost=true&application=demo-provider&bind.ip=192.168.1.120&bind.port=20880&dubbo=2.6.1&generic=false&interface=com.whforever.service.DemoService&methods=sayHello,getUsers&pid=13992&side=provider&timestamp=1528300589682, dubbo version: 2.6.1, current host: 192.168.1.120
[06/06/18 11:56:30:030 CST] main  INFO config.AbstractConfig:  [DUBBO] Register dubbo service com.whforever.service.DemoService url dubbo://192.168.1.120:20880/com.whforever.service.DemoService?anyhost=true&application=demo-provider&bind.ip=192.168.1.120&bind.port=20880&dubbo=2.6.1&generic=false&interface=com.whforever.service.DemoService&methods=sayHello,getUsers&pid=13992&side=provider&timestamp=1528300589682 to registry registry://127.0.0.1:2181/com.alibaba.dubbo.registry.RegistryService?application=demo-provider&dubbo=2.6.1&pid=13992&registry=zookeeper&timestamp=1528300589673, dubbo version: 2.6.1, current host: 192.168.1.120
[06/06/18 11:56:30:030 CST] main  INFO transport.AbstractServer:  [DUBBO] Start NettyServer bind /0.0.0.0:20880, export /192.168.1.120:20880, dubbo version: 2.6.1, current host: 192.168.1.120

小结

对于dubbo听其大名已久，直到最近才动手写了一些demo，总体来看上手还是比较简单，官方也提供了比较详细的文档，社区也比较活跃。

微信公众号【Java技术江湖】一位阿里 Java 工程师的技术小站。（关注公众号后回复”Java“即可领取 Java基础、进阶、项目和架构师等免费学习资料，更有数据库、分布式、微服务等热门技术学习视频，内容丰富，兼顾原理和实践，另外也将赠送作者原创的Java学习指南、Java程序员面试指南等干货资源）


​


文章标签：
微服务引擎
应用服务中间件
Dubbo
监控
数据格式
XML
关键词：
分布式服务
分布式初体验
分布式框架
Dubbo框架
框架Dubbo
相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作，您将了解并实现在线业务的微服务全链路灰度能力。
程序员黄小斜
目录
相关文章
我是快乐的嘟嘟
|
4月前
|
Java 数据库
在Java中使用Seata框架实现分布式事务的详细步骤
通过以上步骤，利用 Seata 框架可以实现较为简单的分布式事务处理。在实际应用中，还需要根据具体业务需求进行更详细的配置和处理。同时，要注意处理各种异常情况，以确保分布式事务的正确执行。
我是快乐的嘟嘟
330 64
codetrend
|
7天前
|
消息中间件 人工智能 监控
文生图架构设计原来如此简单之分布式服务
想象一下，当成千上万的用户同时要求AI画图，如何公平高效地处理这些请求？文生图/图生图大模型的架构设计看似复杂，实则遵循简单而有效的原则：合理排队、分工明确、防患未然。
codetrend
43 14
文生图架构设计原来如此简单之分布式服务
一只笨鼠
|
3月前
|
存储 监控 数据可视化
常见的分布式定时任务调度框架
分布式定时任务调度框架用于在分布式系统中管理和调度定时任务，确保任务按预定时间和频率执行。其核心概念包括Job（任务）、Trigger（触发器）、Executor（执行器）和Scheduler（调度器）。这类框架应具备任务管理、任务监控、良好的可扩展性和高可用性等功能。常用的Java生态中的分布式任务调度框架有Quartz Scheduler、ElasticJob和XXL-JOB。
一只笨鼠
1163 66
别惹CC
|
2月前
|
SQL Java 关系型数据库
【📕分布式锁通关指南 01】从解决库存超卖开始加锁的初体验
本文通过电商场景中的库存超卖问题，深入探讨了JVM锁、MySQL悲观锁和乐观锁的实现及其局限性。首先介绍了单次访问下库存扣减逻辑的正常运行，但在高并发场景下出现了超卖问题。接着分析了JVM锁在多例模式、事务模式和集群模式下的失效情况，并提出了使用数据库锁机制（如悲观锁和乐观锁）来解决并发问题。 悲观锁通过`update`语句或`select for update`实现，能有效防止超卖，但存在锁范围过大、性能差等问题。乐观锁则通过版本号或时间戳实现，适合读多写少的场景，但也面临高并发写操作性能低和ABA问题。 最终，文章强调没有完美的方案，只有根据具体业务场景选择合适的锁机制。
别惹CC
76 12
【📕分布式锁通关指南 01】从解决库存超卖开始加锁的初体验
喵手
|
2月前
|
数据采集 人工智能 分布式计算
MaxFrame：链接大数据与AI的高效分布式计算框架深度评测与实践！
阿里云推出的MaxFrame是链接大数据与AI的分布式Python计算框架，提供类似Pandas的操作接口和分布式处理能力。本文从部署、功能验证到实际场景全面评测MaxFrame，涵盖分布式Pandas操作、大语言模型数据预处理及企业级应用。结果显示，MaxFrame在处理大规模数据时性能显著提升，代码兼容性强，适合从数据清洗到训练数据生成的全链路场景...
喵手
120 5
MaxFrame：链接大数据与AI的高效分布式计算框架深度评测与实践！
dufadayang
|
4月前
|
数据库
如何在Seata框架中配置分布式事务的隔离级别？
总的来说，配置分布式事务的隔离级别是实现分布式事务管理的重要环节之一，需要认真对待和仔细调整，以满足业务的需求和性能要求。你还可以进一步深入研究和实践 Seata 框架的配置和使用，以更好地应对各种分布式事务场景的挑战。
dufadayang
177 63
warmhearted
|
2月前
|
人工智能 分布式计算 大数据
MaxFrame 产品评测：大数据与AI融合的Python分布式计算框架
MaxFrame是阿里云MaxCompute推出的自研Python分布式计算框架，支持大规模数据处理与AI应用。它提供类似Pandas的API，简化开发流程，并兼容多种机器学习库，加速模型训练前的数据准备。MaxFrame融合大数据和AI，提升效率、促进协作、增强创新能力。尽管初次配置稍显复杂，但其强大的功能集、性能优化及开放性使其成为现代企业与研究机构的理想选择。未来有望进一步简化使用门槛并加强社区建设。
warmhearted
191 7
dufadayang
|
4月前
|
存储 Java 关系型数据库
在Spring Boot中整合Seata框架实现分布式事务
可以在 Spring Boot 中成功整合 Seata 框架，实现分布式事务的管理和处理。在实际应用中，还需要根据具体的业务需求和技术架构进行进一步的优化和调整。同时，要注意处理各种可能出现的问题，以保障分布式事务的顺利执行。
dufadayang
258 53
卷福同学
|
3月前
|
消息中间件 存储 安全
分布式系统架构3：服务容错
分布式系统因其复杂性，故障几乎是必然的。那么如何让系统在不可避免的故障中依然保持稳定？本文详细介绍了分布式架构中7种核心的服务容错策略，包括故障转移、快速失败、安全失败等，以及它们在实际业务场景中的应用。无论是支付场景的快速失败，还是日志采集的安全失败，每种策略都有自己的适用领域和优缺点。此外，文章还为技术面试提供了解题思路，助你在关键时刻脱颖而出。掌握这些策略，不仅能提升系统健壮性，还能让你的技术栈更上一层楼！快来深入学习，走向架构师之路吧！
卷福同学
87 11
郑小健
|
3月前
|
分布式计算 大数据 数据处理
技术评测：MaxCompute MaxFrame——阿里云自研分布式计算框架的Python编程接口
随着大数据和人工智能技术的发展，数据处理的需求日益增长。阿里云推出的MaxCompute MaxFrame（简称“MaxFrame”）是一个专为Python开发者设计的分布式计算框架，它不仅支持Python编程接口，还能直接利用MaxCompute的云原生大数据计算资源和服务。本文将通过一系列最佳实践测评，探讨MaxFrame在分布式Pandas处理以及大语言模型数据处理场景中的表现，并分析其在实际工作中的应用潜力。
郑小健
138 2

热门文章

最新文章

  • 1
    【📕分布式锁通关指南 02】基于Redis实现的分布式锁
  • 2
    DeepSeek开源周第五弹之一！3FS：支撑V3/R1模型数据访问的高性能分布式文件系统
  • 3
    Springboot使用Redis实现分布式锁
  • 4
    新一代 Cron-Job 分布式任务调度平台 正式发布！
  • 5
    🗄️Spring Boot 3 整合 MinIO 实现分布式文件存储
  • 6
    新一代 Cron-Job分布式任务调度平台 部署指南
  • 7
    DeepSeek进阶开发与应用4：DeepSeek中的分布式训练技术
  • 8
    大道至简-基于ACK的Deepseek满血版分布式推理部署实战
  • 9
    云产品评测｜分布式Python计算服务MaxFrame获奖名单公布！
  • 10
    redisson分布式锁
  • 1
    如何将Dubbo应用接入服务网格
    129
  • 2
    Dubbo背景和简介
    83
  • 3
    理解java的springboot+mybatisplus+dubbo+nacos+kafka这一套技术栈
    152
  • 4
    Spring Boot 调用 Dubbo 接口与编写 Dubbo 接口实战
    877
  • 5
    分布式系统面试全集通第一篇（dubbo+redis+zookeeper----分布式+CAP+BASE+分布式事务+分布式锁）
    143
  • 6
    Dubbo怎么配置监控中心
    163
  • 7
    dubbo-admin安装(分离版本)
    78
  • 8
    DUBBO--基础篇（二）--监控中心
    87
  • 9
    DUBBO--基础篇（一）--简介（示意Demo）
    169
  • 10
    dubbo面试题收集
    89

    • 相关课程

    更多
  • Dubbo开源、自研、商业化三位一体战略解读
  • Spring Boot+Vue.js+FastDFS实现分布式图片服务器
  • 基于Zookeeper、Dubbo构建互联网分布式基础架构
  • 分布式文件存储系统技术及实现
  • 分布式协调系统 Zookeeper 快速入门
  • Dubbo分布式服务治理实战

    • 相关电子书

    更多
  • Dubbo开源现状与2.7规划
  • Dubbo分布式服务治理实战
  • 《Dubbo 3.0 前瞻》

    • 相关实验场景

    更多
  • 体验PolarDB-X透明分布式
  • 快速玩转Dubbo生态之一致性事务篇（Seata）
  • 快速玩转Dubbo生态之限流降级篇（Sentinel）
  • 快速上手使用Dubbo进行远程调用
  • Spring-cloud-bus-rocketmq入门与实践
  • Spring-cloud-stream-binder-rocketmq入门与实践
    • 下一篇
    阿里云百炼已上线超强推理开源模型QwQ-32B，尺寸更小，性能比肩DeepSeek满血版