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

通俗易懂的Dubbo学习（一） dubbo服务者和消费者的简单案例

2022-05-17 258
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
服务治理 MSE Sentinel/OpenSergo，Agent数量 不受限
云原生网关 MSE Higress，422元/月
注册配置 MSE Nacos/ZooKeeper，118元/月
简介： 通俗易懂的Dubbo学习（一） dubbo服务者和消费者的简单案例

随着互联网的不断发展，系统应用的规模也在不断扩大，常规的垂直类型应用架构已经无法较好的应对，所以分布式服务架构以及流动计算机架构的趋势越来越明显。在这种大规模类型的服务化架构到来之前，可能只是通过rmi,hessian等工具来进行简单的服务引用的处理，但是当规模量逐渐提升之后，过多的服务也带来了一定的繁琐问题，例如说对于服务url的管理。


当不同服务的调用量逐渐提升之后，服务的容量问题也越来越不明确。


对于错综复杂的服务调度关系，越来越繁琐，不利于统筹管理。


基于上述的一些情况，dubbo服务架构开始横空出世，其基本架构如下所示：


网络异常，图片无法展示
|


说了这么多的背景介绍，我们还是直接用个案例来进行介绍会比较好：


首先需要在ide里面搭建好相应的maven结构：


网络异常，图片无法展示
|


然后导入相应的pom依赖：


dubbo-root：


<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.sise</groupId>
    <artifactId>dubbo-root</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>dubbo-provide</module>
        <module>dubbo-api</module>
        <module>dubbo-consumer</module>
    </modules>
    <properties>
        <motan.version>0.3.0</motan.version>
        <!-- 在阿里巴巴内部广泛使用的GA版本为：2.4.9，强烈推荐此版本 -->
        <dubbo.version>2.5.3</dubbo.version>
        <dubbox.version>2.8.4</dubbox.version>
        <spring.version>4.3.6.RELEASE</spring.version>
        <java.version>1.7</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>
    <dependencies>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.5.3</version>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <!-- spring相关 -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-beans</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-web</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aop</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-orm</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjrt</artifactId>
            <version>1.6.11</version>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.6.11</version>
        </dependency>
    </dependencies>
</project>
复制代码


provider:


<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>dubbo-root</artifactId>
        <groupId>com.sise</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>dubbo-provide</artifactId>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <artifactId>dubbo-api</artifactId>
            <groupId>com.sise</groupId>
            <version>1.0-SNAPSHOT</version>
            <!--<scope>provided</scope>-->
        </dependency>
    </dependencies>
</project>
复制代码


consumer:


<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>dubbo-root</artifactId>
        <groupId>com.sise</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <java.version>1.8</java.version>
    </properties>
    <artifactId>dubbo-consumer</artifactId>
    <dependencies>
        <dependency>
            <artifactId>dubbo-api</artifactId>
            <groupId>com.sise</groupId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>
复制代码


api:


<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>dubbo-root</artifactId>
        <groupId>com.sise</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>dubbo-api</artifactId>
</project>
复制代码


这个案例的思路是，我们在api模块中编写rpc服务接口，在provider里面对服务进行实现，最后在consumer里面调用服务进行测试。


api里面的接口如下：


package com.sise.service;
/**
 * 作者：idea
 * 日期：2018/8/11
 * 描述：
 */
public interface UserRpcService {
    /**
     * 获取用户username的rpc服务
     * @param username
     * @return
     */
    String getUserName(String username) throws InterruptedException;
}
复制代码


关于provider部分的接口实现内容如下所示：


package com.lh.pro.rpc;
import com.sise.service.UserRpcService;
import org.springframework.stereotype.Service;
/**
 * 作者：idea
 * 日期：2018/8/11
 * 描述：用户service服务调度
 */
@Service("userService")
public class UserService implements UserRpcService{
    /**
     * 返回用户名的服务
     * @param username
     * @return
     */
    public String    getUserName(String username) throws InterruptedException {
        return username+" hello ! this is app222";
    }
}
复制代码


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:application name="dubbo_provider"  />
    <!-- 使用zookeeper注册中心暴露服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
    <dubbo:provider proxy="jdk" ></dubbo:provider>
    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />
    <!--rpc服务，提供给外界调用-->
    <dubbo:service interface="com.sise.service.UserRpcService" ref="userService" >
        <!--设置超时时限500ms,当链接失败后只会再次访问2回-->
        <dubbo:method name="getUserName" timeout="500" retries="2"></dubbo:method>
    </dubbo:service>
    <!--<bean id="userService" class="com.lh.pro.rpc.UserService"></bean>-->
</beans>
复制代码


spring配置：


<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:util="http://www.springframework.org/schema/util" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.0.xsd
        http://www.springframework.org/schema/util
        http://www.springframework.org/schema/util/spring-util-4.0.xsd"
       default-autowire="byName">
    <aop:aspectj-autoproxy />
    <context:component-scan base-package="com.lh.pro" />
    <import resource="classpath:dubbo-provider.xml" />
</beans>
复制代码


服务开关：


package com.lh.pro.server;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.io.IOException;
/**
 * 作者：idea
 * 日期：2018/8/11
 * 描述：provider开关
 */
public class Application {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext(new String[]{"application-context.xml"});
        context.start();
        System.out.println("dubbo的服务生产者1开启了");
        //长期开启应用
        System.in.read();
    }
}
复制代码


记得，开启dubbo之前需要开启zookeeper服务注册点，注册站点开启之后，所有在dubbo里面出现的服务都会被注册到这个位置上边。


开启服务提供者以后，窗口内容大致如下：


网络异常，图片无法展示
|


我们开启了dubbo里面的服务之后自然就可以开始对于服务的调度方consumer开始编写了。


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:application name="dubbo_consumer" />
    <!--关闭所有的服务时进行检查，当没有服务提供者的时候会报错-->
    <dubbo:consumer check="false"></dubbo:consumer>
    <!-- 使用multicast广播注册中心暴露发现服务地址 -->
    <dubbo:registry  protocol="zookeeper" address="zookeeper://127.0.0.1:2181" />
    <!-- 生成远程服务代理，可以和本地bean一样使用UserRpcService 其中的init配置是立即加载的含义，有点类似于饿汉式-->
    <dubbo:reference id="userService" interface="com.sise.service.UserRpcService" cluster="failsafe"   check="false" loadbalance="roundrobin">
    </dubbo:reference>
</beans>
复制代码


spring容器配置：


<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:util="http://www.springframework.org/schema/util" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.0.xsd
        http://www.springframework.org/schema/util
        http://www.springframework.org/schema/util/spring-util-4.0.xsd"
       default-autowire="byName">
    <aop:aspectj-autoproxy />
    <context:component-scan base-package="com.lh.consume" />
    <import resource="classpath:/dubbo-consume.xml" />
</beans>
复制代码


consumer模块部分的代码如下所示：


package com.lh.consume;
import com.sise.service.UserRpcService;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.io.IOException;
/**
 * 作者：idea
 * 日期：2018/7/29
 * 描述：
 */
public class ConsumerTest {
    public static void main(String[] args) throws InterruptedException {
        ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext(new String[]{"classpath:application-consumer.xml"});
        context.start();
        UserRpcService userService= (UserRpcService)context.getBean("userService");
        System.out.println(userService.getUserName("getUserName test"));
        try {
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
复制代码


在这里面，服务的调用者会先去zookeeper里面查找是否有相应的userService这一项服务内容，如果有则会生成一个远程代理对象，在本地进行引用相应服务。


这个时候我们开启消费者进行调用：


网络异常，图片无法展示
|


好了，一个简单易懂的dubbo入门案例就这样完成了。


下面一章节，我们来讲解如何搭建dubbo的admin管理平台

文章标签：
微服务引擎
Java
容器
应用服务中间件
Dubbo
Spring
Maven
API
数据格式
调度
XML
关键词：
Dubbo学习
Dubbo学习服务
Dubbo服务
Dubbo服务消费者
Dubbo消费者
相关实践学习
基于MSE实现微服务的全链路灰度
通过本场景的实验操作，您将了解并实现在线业务的微服务全链路灰度能力。
danny_idea
目录
相关文章
java冯坚持
|
1月前
|
存储 负载均衡 监控
dubbo学习一：zookeeper与dubbo的关系，下载安装启动zookeeper（解决启动中报错）
这篇文章是关于Apache Dubbo框架与Zookeeper的关系，以及如何下载、安装和启动Zookeeper的教程，包括解决启动过程中可能遇到的报错问题。
java冯坚持
51 3
dubbo学习一：zookeeper与dubbo的关系，下载安装启动zookeeper（解决启动中报错）
技术自由圈/原疯狂创客圈
|
1月前
|
Dubbo Java 应用服务中间件
Dubbo学习圣经：从入门到精通 Dubbo3.0 + SpringCloud Alibaba 微服务基础框架
尼恩团队的15大技术圣经，旨在帮助开发者系统化、体系化地掌握核心技术，提升技术实力，从而在面试和工作中脱颖而出。本文介绍了如何使用Dubbo3.0与Spring Cloud Gateway进行整合，解决传统Dubbo架构缺乏HTTP入口的问题，实现高性能的微服务网关。
技术自由圈/原疯狂创客圈
163 5
java冯坚持
|
1月前
|
监控 Dubbo Java
dubbo学习三：springboot整合dubbo+zookeeper，并使用dubbo管理界面监控服务是否注册到zookeeper上。
这篇文章详细介绍了如何将Spring Boot与Dubbo和Zookeeper整合，并通过Dubbo管理界面监控服务注册情况。
java冯坚持
80 0
dubbo学习三：springboot整合dubbo+zookeeper，并使用dubbo管理界面监控服务是否注册到zookeeper上。
java冯坚持
|
1月前
|
Dubbo IDE Java
dubbo学习二：下载Dubbo-Admin管理控制台，并分析在2.6.1及2.6.1以后版本的变化
这篇文章是关于如何下载和部署Dubbo管理控制台（dubbo-admin）的教程，并分析了2.6.1版本及以后版本的变化。
java冯坚持
41 0
dubbo学习二：下载Dubbo-Admin管理控制台，并分析在2.6.1及2.6.1以后版本的变化
土木林森
|
3月前
|
JSON Dubbo Java
【Dubbo协议指南】揭秘高性能服务通信，选择最佳协议的终极攻略！
【8月更文挑战第24天】在分布式服务架构中，Apache Dubbo作为一款高性能的Java RPC框架，支持多种通信协议，包括Dubbo协议、HTTP协议及Hessian协议等。Dubbo协议是默认选择，采用NIO异步通讯，适用于高要求的内部服务通信。HTTP协议通用性强，利于跨语言调用；Hessian协议则在数据传输效率上有优势。选择合适协议需综合考虑性能需求、序列化方式、网络环境及安全性等因素。通过合理配置，可实现服务性能最优化及系统可靠性提升。
土木林森
57 3
服务端技术栈
|
3月前
|
缓存 Dubbo Java
Dubbo服务消费者启动与订阅原理
该文章主要介绍了Dubbo服务消费者启动与订阅的原理，包括服务消费者的启动时机、启动过程以及订阅和感知最新提供者信息的方式。
服务端技术栈
59 0
Dubbo服务消费者启动与订阅原理
土木林森
|
3月前
|
C# 开发者 Windows
勇敢迈出第一步：手把手教你如何在WPF开源项目中贡献你的第一行代码，从选择项目到提交PR的全过程解析与实战技巧分享
【8月更文挑战第31天】本文指导您如何在Windows Presentation Foundation（WPF）相关的开源项目中贡献代码。无论您是初学者还是有经验的开发者，参与这类项目都能加深对WPF框架的理解并拓展职业履历。文章推荐了一些适合入门的项目如MvvmLight和MahApps.Metro，并详细介绍了从选择项目、设置开发环境到提交代码的全过程。通过具体示例，如添加按钮点击事件处理程序，帮助您迈出第一步。此外，还强调了提交Pull Request时保持专业沟通的重要性。参与开源不仅能提升技能，还能促进社区交流。
土木林森
44 0
服务端技术栈
|
3月前
|
缓存 负载均衡 Dubbo
Dubbo服务集群容错原理（重要）
该文章主要介绍了Dubbo服务集群容错的原理，包括集群容错技术的概念、Dubbo中使用的集群容错技术种类及其原理。
服务端技术栈
53 0
牵着猫散步的鼠鼠
|
6月前
|
Dubbo Java 应用服务中间件
微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用
微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用
牵着猫散步的鼠鼠
896 2
东方睿赢
|
28天前
|
Dubbo Java 应用服务中间件
Spring Cloud Dubbo：微服务通信的高效解决方案
【10月更文挑战第15天】随着信息技术的发展，微服务架构成为企业应用开发的主流。Spring Cloud Dubbo结合了Dubbo的高性能RPC和Spring Cloud的生态系统，提供高效、稳定的微服务通信解决方案。它支持多种通信协议，具备服务注册与发现、负载均衡及容错机制，简化了服务调用的复杂性，使开发者能更专注于业务逻辑的实现。
东方睿赢
52 2

热门文章

最新文章

  • 1
    SpringBoot开发案例之整合Dubbo提供者(一)
  • 2
    Spring-boot+Dubbo应用启停源码分析
  • 3
    Dubbo的Zookeeper单机配置和Zookeeper集群配置
  • 4
    Dubbo入门
  • 5
    高并发架构系列：如何从0到1设计一个类Dubbo的RPC框架
  • 6
    SpringBoot开发案例之整合Dubbo消费者
  • 7
    Dubbo架构介绍
  • 8
    学习dubbo（四）： 启动时检查
  • 9
    Dubbo之——改造Dubbo，使其能够兼容Spring 4注解配置
  • 10
    Apache Dubbo 被曝出“高危”远程代码执行漏洞
  • 1
    Dubbo背景和简介
    49
  • 2
    理解java的springboot+mybatisplus+dubbo+nacos+kafka这一套技术栈
    88
  • 3
    Spring Boot 调用 Dubbo 接口与编写 Dubbo 接口实战
    625
  • 4
    分布式系统面试全集通第一篇（dubbo+redis+zookeeper----分布式+CAP+BASE+分布式事务+分布式锁）
    105
  • 5
    Dubbo怎么配置监控中心
    80
  • 6
    dubbo-admin安装(分离版本)
    30
  • 7
    DUBBO--基础篇（二）--监控中心
    52
  • 8
    DUBBO--基础篇（一）--简介（示意Demo）
    65
  • 9
    dubbo面试题收集
    56
  • 10
    dubbo面试题库
    44

    • 相关课程

    更多
  • Dubbo + ZooKeeper 的服务发现最佳实践
  • Dubbo 3.0 服务治理最佳实践
  • Dubbo开源、自研、商业化三位一体战略解读
  • 基于Zookeeper、Dubbo构建互联网分布式基础架构
  • Dubbo分布式服务治理实战
  • 微服务实战-RocketMQ Binder

    • 相关电子书

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

    • 相关实验场景

    更多
  • 快速玩转Dubbo生态之一致性事务篇（Seata）
  • 快速玩转Dubbo生态之限流降级篇（Sentinel）
  • 快速上手使用Dubbo进行远程调用
  • Spring-cloud-bus-rocketmq入门与实践
  • Spring-cloud-stream-binder-rocketmq入门与实践
  • Rocketmq-spring入门与实践
    • 下一篇
    阿里云OSS设置跨域访问