집 >Java >java지도 시간 >Dubbo 소스 코드 분석: 초보자 가이드

Dubbo 소스 코드 분석: 초보자 가이드

Java后端技术全栈앞으로: 2023-08-23 14:44:32677검색

이미 왼쪽: 2px; background-color: rgba(27, 31, 35, 0.05); ; word-break: break-all; color: rgb(239, 112, 96);">DubboDubbo熟练使用了，那这篇文章不太适合你，但如果想了解Dubbo，想学习Dubbo，那就非常适合你。

什么是Dubbo？

Dubbo一开始是由阿里巴巴开发，后面贡献给了Apache，所以后面我们称之为Apache Dubbo或者直接叫Dubbo。

Dubbo 당신이 그것을 능숙하게 사용한다면 이 글은 당신에게 적합하지 않을 것입니다. 자세히 알아보기

Dubbo ><blockquote data-tool="mdnice编辑器" style="border-top: none;border-right: none;border-bottom: none;font-size: 0.9em;overflow: auto;color: rgb(106, 115, 125);padding: 10px 10px 10px 20px;margin-bottom: 20px;margin-top: 20px;border-left-color: rgb(239, 112, 96);background: rgb(255, 249, 249);">, 배우고 싶어요<p style="font-size: 16px;padding-top: 8px;padding-bottom: 8px;color: black;line-height: 26px;"><code style="letter-spacing: 0px;font-size: 14px ; padding: 2px 4px; border-radius: 4px; margin-right: 2px; margin-left: 2px; background-color : rgba(27, 31, 35, 0.05); 글꼴 계열: " operator mono consolas monaco menlo monospace word-break: break-all>

, 당신에게 딱이네요. 🎜🎜

Dubbo 소스 코드 분석: 초보자 가이드 🎜

Dubbo란 무엇인가요? 🎜 🎜

🎜Dubbo는 처음에는 Alibaba에서 개발했으며 나중에 Apache이므로 Apache Dubbo또는 그냥 Dubbo. 🎜🎜Dubbo는 고성능, 경량 오픈 소스 서비스 프레임워크. 🎜🎜🎜먼저 발음을 교정하세요: 🎜

잘못된 발음: diubo, dubo

정확한 발음: |ˈdʌbəʊ|

Dubbo의 6가지 핵심 기능

인터페이스 에이전트를 위한 고성능RPC 호출

RPC

智能容错和负载均衡

服务自动注册和发现

高度可扩展能力

运行期流量调度

可视化的服务治理与运维。

开发中，我们都喜欢把Dubbo简称为RPC开源框架。

什么是RPC？

RPC是Remote Procedure Call的简称，翻译过来就是：远程过程调用

지능형 내결함성 및 로드 밸런싱 li>

서비스 자동 등록 및 검색

확장성이 뛰어난 기능

런타임 트래픽 스케줄링🎜🎜시각화된 서비스 거버넌스 및 운영. 🎜개발 중에 우리 모두는 Dubbo는 RPC오픈 소스 프레임워크입니다. 🎜

RPC란 무엇입니까?

🎜RPC는 Remote Procedure Call의 약어, 다음과 같이 번역됨: 원격 프로시저 호출. 🎜🎜🎜간단히 이해하자면 한 노드가 다른 노드에서 제공하는 서비스를 요청한다는 것입니다. 🎜🎜🎜일반인의 용어로:🎜

두 개의 서버 A와 B가 서버 A에 애플리케이션 serverA，在服务器B上部署一个应用程序serverB。此时，serverA想调用serverB을 배포합니다. 특정 메서드는 동일한 서버에 있지 않기 때문에 직접 호출할 수 없습니다. 호출의 의미와 호출의 데이터는 네트워크를 통해 전송되어야 합니다.

로컬 메서드를 호출하는 것처럼 원격 메서드도 호출하세요.

개발 과정에서 두 서비스(서로 다른 서버의 서비스) 간의 호출은 일반적으로 HTTP REST를 사용합니다.

RPC 프레임워크

사실 시중에는 수많은 RPC 프레임워크가 있으며, Dubbo는 그 중 하나일 뿐입니다. 예:

gRPC는 Google에서 개발한 고성능 범용 오픈 소스 RPC 프레임워크입니다. gRPC는 ProtoBuf를 사용하여 서비스를 정의합니다. ProtoBuf는 Google에서 개발한 데이터 직렬화 프로토콜로 상대적으로 높은 성능과 높은 압축률 및 전송 효율성을 자랑합니다. 간단한 구문. 또한 gRPC는 다국어를 지원하며 언어 기반으로 클라이언트 및 서버 기능 라이브러리를 자동으로 생성할 수 있습니다.
Thrift는 Facebook에서 시작되었으며 Dubbo와 마찬가지로 나중에 Thrift를 오픈 소스 프로젝트로 만들기 위해 Apache Foundation에 제출되었습니다. Facebook은 Facebook 시스템 간의 대량 데이터 전송 및 통신 문제와 크로스 플랫폼 문제가 필요한 시스템 간의 서로 다른 언어 환경 문제를 해결하기 위해 Thrift를 만들었습니다.
Motan은 Sina Weibo가 오픈 소스로 제공하는 Java RPC 프레임워크입니다. 공식 문서에 따르면 Weibo 플랫폼에서 널리 사용되어 매일 수백 개의 서비스에 대해 거의 1000억 건의 호출을 완료했습니다.
...

Dubbo 핵심 캐릭터

한 번 살펴보겠습니다Dubbo의 핵심 역할 아키텍처: Dubbo架构中的核心角色：

该图来自于官网，下面我们对图做一个简单介绍：

Registry

注册中心。负责服务地址的注册与查找，服务的 Provider 和 Consumer 只在启动时与注册中心交互。注册中心通过长连接感知 Provider 的存在，在 Provider 出现宕机的时候，注册中心会立即推送相关事件通知 Consumer

🎜이 사진은 공식 홈페이지에서 가져온 것입니다. 아래 사진에 대한 간략한 소개를 해보겠습니다:🎜

레지스트리

🎜등록 센터. 서비스 주소 등록 및 검색을 담당하는 서비스

공급자 및 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px; background-color: rgba(27, 31, 35, 0.05 );font-family: " operator mono consolas monaco menlo monospace break-all rgb>소비자

는 등록에서만 작동합니다. 센터 상호 작용. 등록 센터는 긴 연결을 감지합니다공급자 존재 , 공급자 다운타임이 있는 경우, 등록 센터는 관련 이벤트 알림을 즉시 푸시합니다소비자 . 🎜

Provider

서비스 제공자. 시작되면 레지스트리에 등록하고 서비스 주소와 관련 구성 정보를 URL로 캡슐화하여 ZooKeeper에 추가합니다.

Consumer

소비자에게 서비스를 제공하세요. 시작되면 레지스트리를 구독하게 됩니다. 구독 작업은 ZooKeeper 中获取 Provider 注册的 URL，并在 ZooKeeper 中添加相应的监听器。获取到 Provider URL 之后，Consumer 会根据负载均衡算法从多个 Provider 中选择一个 Provider 并与其建立连接，最后发起对 Provider 的 RPC 调用。如果 Provider URL 发生变更，Consumer 将会通过之前订阅过程中在注册中心添加的监听器，获取到最新的 Provider URL 信息，进行相应的调整，比如断开与宕机 Provider 的连接，并与新的 Provider에서 연결을 설정합니다.Consumer 및 Provider 建立的是长连接，且 Consumer 会缓存 Provider 信息，所以一旦连接建立，即使注册中心宕机，也不会影响已运行的 Provider 和 Consumer。

Monitor

监控中心。用于统计服务的调用次数和调用时间。Provider 和 Consumer 在运行过程中，会在内存中统计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。监控中心在上面的架构图中并不是必要角色，监控中心宕机不会影响 Provider、Consumer 以及 Registry 기능은 모니터링 데이터만 손실됩니다.

음란하게 전개되어 후기에 폭발합니다(초기에는 크게 신경쓰지 않으셔도 되지만 후기에 특히 향이 강합니다)

컨테이너:

컨테이너를 실행하는 서비스입니다. 서비스는 일반적으로 필요하지 않기 때문에 별도의 컨테이너입니다(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb (239, 112, 96);">Tomcat、JBoss 및 기타 웹 컨테이너 기능을 사용하면 서비스를 로드하기 위해 웹 컨테이너를 사용할 필요가 없습니다. 서비스 컨테이너는 단순한 기본 메소드일 뿐이며 간단한 Spring 컨테이너를 로드하여 서비스를 노출합니다. Tomcat、JBoss等Web容器的特性，没必要用Web容器去加载服务。服务容器只是一个简单的main方法，并加载一个简单的Spring容器，用于暴露服务。

流程说明

在上面这张图中，有几个角色，并且还画了很多线条，下面我们对此做一个简单说明。

服务容器负责启动，加载，运行服务提供者。
服务提供者在启动时，向注册中心注册自己提供的服务。
服务消费者在启动时，向注册中心订阅自己所需的服务。
注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

Dubbo官网

Dubbo的官网：https://dubbo.apache.org/

由于Dubbo

프로세스 설명

위 내용 그림에는 여러 문자가 있고 많은 선이 그려져 있습니다. 이에 대해 간단히 설명하겠습니다. 🎜

서비스 컨테이너는 서비스 공급자의 시작, 로드 및 실행을 담당합니다.
서비스 제공업체 시작하려면 등록 센터에 제공하는 서비스를 등록하세요.
서비스 소비자 스타트업, 필요한 서비스를 위해 등록 센터에 가입하세요.
등록 센터 반환 서비스 제공업체 주소 목록이 소비자에게 제공됩니다. 변경 사항이 있는 경우 등록 센터는 오랜 연결을 기반으로 변경 데이터를 소비자에게 푸시합니다.
서비스 소비자 , 소프트 로드 밸런싱 알고리즘을 기반으로 공급자 주소 목록에서 호출할 공급자를 선택합니다. 호출이 실패하면 호출할 다른 공급자를 선택합니다.
서비스 소비자 및 통화횟수와 통화시간을 메모리에 축적하고, 1분마다 정기적으로 모니터링 센터에 통계자료를 전송합니다.

Dubbo 공식 웹사이트

🎜Dubbo 공식 웹사이트: https://dubbo.apache.org/🎜

🎜Dubbo는 Alibaba 기술팀에서 개발했기 때문에 문서화가 매우 중요합니다. 중국에 있는 우리에게 인간적인 관점에서 보면 한 마디로 매우 친절합니다. 🎜

또한 Dubbo에는 많은 내용이 있습니다. 여기서는 하나씩 소개하지 않겠습니다. Dubbo官网上很多东西，我们就不在这里一一介绍了。

建议大家都去官网逛逛。

话不多说，咱们先来嗨一把！

demo案例1

我们先来搞一个没有注册中心的案例。

我们搭建一个项目，并创建三个module：

dubbo-demo
dubbo-demo-api
dubbo-demo-provider
dubbo-demo-consumer
모두가 공식 웹 사이트를 방문하는 것이 좋습니다.

즐거운 시간을 보내세요!

데모 사례 1

등록 센터가 없는 경우부터 시작해 보겠습니다.

dubbo-demo- 제공자 code>🎜<li><section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(1, 1, 1);"><code style="font- 크기: 14px; 패딩: 2px 4px; 테두리 반경: 4px; 여백 오른쪽: 2px; 여백 왼쪽: 2px; 배경색: rgba(27, 31, 35, 0.05); 글꼴 계열: " consolas monaco menlo monospace break-all rgb>dubbo-demo-consumer

🎜🎜🎜🎜프로젝트의 전체 구조는 다음과 같습니다. 🎜🎜🎜🎜🎜🎜🎜이제 코드에 대해 간략하게 설명하겠습니다. 🎜

첫 번째는 pom종속성: pom依赖：

<!--dubbo的依赖-->
<dependency>
     <groupId>org.apache.dubbo</groupId>
     <artifactId>dubbo</artifactId>
     <version>3.0.4</version>
</dependency>
<!-- provider和consumer共用类-->
<dependency>
     <groupId>com.tian.dubbo</groupId>
     <artifactId>dubbo-demo-api</artifactId>
     <version>1.0-SNAPSHOT</version>
</dependency>

consumer和provider项目都需要添加这两个依赖。

api

api主要是定义服务接口以及一些工具类，主要是供consumer和provider共用。

在api中我们只定义了一个服务接口：DemoService

package com.tian.dubbo.service;

public interface DemoService {
    String sayHello(String msg);
}

然后打成jar，在consumer和provider项目中添加到pom.xml依赖里，最后两遍都可以使用了。

provider

在resources目录下创建一个目录META-INF.spring，然后在目录下创建一个application.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服务名称--> 
    <dubbo:application name="dubbo-provider"/>
    <!--不需要注册到服务注册中心--> 
    <dubbo:registry address="N/A"/>
    <!--端口和协议--> 
    <dubbo:protocol name="dubbo" port="20880"/>
    <!--我们的服务--> 
    <dubbo:service interface="com.tian.dubbo.service.DemoService" ref="demoService"/>
    <bean id="demoService" class="com.tian.dubbo.service.DemoServiceImpl"/>
</beans>

再在resources目录下创建一个日志打印的配置文件：log4j.properties

###set log levels###
log4j.rootLogger=debug, stdout
###output to the console###
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target=System.out
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=[%d{dd/MM/yy HH:mm:ss:SSS z}] %t %5p %c{2}: %m%n

在定义一个业务实现类：DemoServiceImpl

package com.tian.dubbo.service;

public class DemoServiceImpl implements DemoService {
    public String sayHello(String msg) {
        System.out.println("msg= " + msg);
        return "SUCCESS";
    }
}

再就是定义一个provider的启动类：ProviderMain

package com.tian.dubbo;

import org.apache.dubbo.container.Main;

public class ProviderMain {
    public static void main(String[] args) {
        Main.main(args);
    }
}

소비자 프로젝트와 공급자 프로젝트 모두 이 두 가지 종속성을 추가해야 합니다.

api

🎜 API는 주로 소비자와 공급자가 공유하는 서비스 인터페이스와 일부 도구 클래스를 정의합니다. 🎜🎜API에서는 하나의 서비스 인터페이스만 정의합니다: DemoService 🎜

<?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"/>
    <!--不需要注册到服务注册中心--> 
    <!-- 通过url直接调用-->
    <dubbo:reference id="demoService"
                     interface="com.tian.dubbo.service.DemoService"
     url="dubbo://127.0.0.1:20880/com.tian.dubbo.service.DemoService"/>
</beans>

🎜 그런 다음 항아리에 넣고 소비자의 pom.xml 종속성, 마지막 두 번을 사용할 수 있습니다. 🎜

provider

🎜리소스 디렉토리 META-INF.spring , 그런 다음 application.xml, 내용은 다음과 같습니다. 🎜

package com.tian.dubbo;

import com.tian.dubbo.service.DemoService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class ConsumerMain {
    public static void main(String[] args) {
        DemoService demoService = null;
        ApplicationContext context = new ClassPathXmlApplicationContext
                ("classpath:META-INF/spring/application.xml");
        demoService = context.getBean(DemoService.class);
        //调用服务
        System.out.println(demoService.sayHello("tian"));
    }
}

🎜리소스 디렉터리에 로그 인쇄 구성 파일을 생성합니다: log4j.properties🎜

<dependency>
     <groupId>org.apache.dubbo</groupId>
     <artifactId>dubbo-dependencies-zookeeper</artifactId>
     <version>3.0.4</version>
     <type>pom</type>
</dependency>

🎜는 비즈니스 구현 클래스를 정의합니다: DemoServiceImpl🎜

<dubbo:registry address="N/A"/>

🎜그런 다음 공급자 시작 클래스를 정의합니다: ProviderMain🎜

package com.tian.dubbo;

import org.apache.dubbo.container.Main;

public class ProviderMain {
    public static void main(String[] args) {
        Main.main(args);
    }
}

注意：这里的Main类是Dubbo

最后，我们启动ProviderMain类，日志输出：

好了，已经启动成功了。

我们继续来看看consumer项目，在项目中，也就是调用我们服务的项目。

consumer

在consumer项目中application.xml配置文件和provider有所区别。

<?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"/>
    <!--不需要注册到服务注册中心--> 
    <!-- 通过url直接调用-->
    <dubbo:reference id="demoService"
                     interface="com.tian.dubbo.service.DemoService"
     url="dubbo://127.0.0.1:20880/com.tian.dubbo.service.DemoService"/>
</beans>

这个url地址，我们在provider启动的时候，可以从日志中找到。

日志文件和provider一样，然后就是ConsumerMain启动类了。

package com.tian.dubbo;

import com.tian.dubbo.service.DemoService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class ConsumerMain {
    public static void main(String[] args) {
        DemoService demoService = null;
        ApplicationContext context = new ClassPathXmlApplicationContext
                ("classpath:META-INF/spring/application.xml");
        demoService = context.getBean(DemoService.class);
        //调用服务
        System.out.println(demoService.sayHello("tian"));
    }
}

前面，我们已经把provider成功启动了，下面我们就来启动ConsumerMain。

从日志可以看出我们已经成功调用了provider，我们再来看看provider的日志输出：

也成功的输出了我们想要的。

到此，一个简单的入门无注册中心（通过url直接调用）的方式就完成了。

url은 등록 센터에 대한 의존성을 없애기 때문에 공동 디버깅을 개발할 때 여전히 매우 유용합니다.

데모 사례 2

이전에 등록 센터 없이 시연했지만 이제는 등록 센터를 사용하여 시연하겠습니다.

Dubbo

는 현재 거의 모든 것을 지원합니다. 시장 모든 등록 센터: Dubbo目前差不多能支持市面上所有的注册中心：

consul
zookeeper
eureka
redis
etcd
nacos
....

我们在实际开发中，Dubbo注册中心大部分都是使用Zookeeper和Nacos。

下面们基于Zookeeper

consul

사육사

유레카

redis

etcd

nacos

....

실제 개발에서는 Dubbo 대부분의 등록 센터에서는 Zookeeper 및 Nacos.

다음은 Zookeeper 시연합니다(Nacos도 유사하며 아래에서 언급됩니다).

코드레벨🎜🎜이전 사례를 토대로 수정했습니다. 변환은 두 곳만 조정하면 됩니다: 🎜

consumer和provider中添加pom依赖
application.xml中添加注册中心

`pom`依赖

我们需要在前面demo中consumer和provider的pom.xml中添加Zookeeper的依赖：

<dependency>
     <groupId>org.apache.dubbo</groupId>
     <artifactId>dubbo-dependencies-zookeeper</artifactId>
     <version>3.0.4</version>
     <type>pom</type>
</dependency>

provider端

在provider项目中我们需要调整：

<dubbo:registry address="N/A"/>

改成：

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

这个timeout建议配上，我这里其实没必要配，因为dubbo服务和Zookeeper都在我本地。

然后我们启动provider项目：

看到我们的项目已经启动成功，并且已经注册到Zookeeper上了。

我们可以使用Zookeeper的可视化工具，看看注册上去的信息。

我们再看看consumer端的调整。

consumer端

我们需要在application.xml中添加

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

同时，去掉reference中的url：

<dubbo:reference id="demoService"
                     interface="com.tian.dubbo.service.DemoService"
     url="dubbo://127.0.0.1:20880/com.tian.dubbo.service.DemoService"/>

因为是通过Zookeeper注册中心拿到地址，所以这里的url就可以去掉了。

最后，启动ConsumerMain类：

可以看到我们也成功调用服务，另外也有大量的Zookeeper日志。

到此，说明，我们的Zookeeper为注册中心的demo案例也成功了。

注意：provider和consumer项目都需要依赖相关jar包（api、zookeeper、dubbo）

其他

关于Nacos，我们这里就不演示了，因为太简单了，如果你把Nacos搭建好了后，直接配置就好了。

<dubbo:registry address="nacos://127.0.0.1:8848" timeout="10000"/>

就是把address地址改一下就可以了。

Nacos 的演示，我们下一篇文章中见。

总结

本文分享了Dubbo入门案例的两个版本：无注册中心和Zookeeper注册中心。

위 내용은 Dubbo 소스 코드 분석: 초보자 가이드의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

Java tomcat spring 架构 log4j dubbo 封装 xml 接口事件算法 zookeeper apache http https rpc 负载均衡

성명：

이 기사는 Java后端技术全栈에서 복제됩니다. 침해가 있는 경우 admin@php.cn으로 문의하시기 바랍니다. 삭제

이전 기사：Java 코드를 사용하여 여자친구의 생일을 추측해 보세요. 매우 흥미롭습니다!다음 기사：Java 코드를 사용하여 여자친구의 생일을 추측해 보세요. 매우 흥미롭습니다!

Dubbo 소스 코드 분석: 초보자 가이드

什么是Dubbo？

Dubbo란 무엇인가요? 🎜 🎜

Dubbo의 6가지 핵심 기능

什么是RPC？

RPC란 무엇입니까?

RPC 프레임워크

Dubbo 핵심 캐릭터

Registry

레지스트리

Provider

Consumer

Monitor

컨테이너:

流程说明

Dubbo官网

프로세스 설명

Dubbo 공식 웹사이트

demo案例1

데모 사례 1

api

provider

api

provider

consumer

데모 사례 2

pom依赖

provider端

consumer端

其他

总结

관련 기사

`pom`依赖