首頁手記 Dubbo入門教程：輕松搭建微服務框架

Dubbo入門教程：輕松搭建微服務框架

標簽：

Java 中間件微服務

概述

Dubbo是一个高性能、轻量级的Java RPC框架，广泛应用于构建微服务架构。它提供了服务发布与发现、负载均衡、服务路由等功能，使得服务治理变得更为便捷。Dubbo支持多种配置方式和注册中心，如Zookeeper和Nacos，并且通过丰富的配置选项和注解驱动开发方式，使得使用Dubbo变得简单易用。

Dubbo简介

Dubbo是什么

Dubbo 是一个高性能、轻量级的 Java RPC 框架，主要由阿里巴巴开源并广泛使用。它允许开发者通过简单易用的 API 和配置来开发分布式服务，使得构建微服务架构变得更为便捷。Dubbo 提供了丰富的功能，涵盖了服务发布与发现、负载均衡、服务路由、服务降级、熔断等众多功能，是构建微服务架构的重要工具之一。

Dubbo的核心概念

在 Dubbo 中，主要有以下几个核心概念：

服务提供者（Service Provider）：提供服务的一方，使用 Dubbo API 将接口和实现进行定义，并将服务注册到注册中心。
服务消费者（Service Consumer）：调用服务的一方，通过 Dubbo API 发起调用，从注册中心获取服务地址并进行调用。
注册中心（Registry Center）：服务注册与发现的中心，Dubbo 支持多种注册中心，如 Zookeeper、Nacos 等。
服务调用模型：Dubbo 采用基于代理的调用模型，通过动态代理生成调用代码，实现服务的远程调用。
配置中心：用于集中管理 Dubbo 服务的配置，支持 XML、Properties 等多种配置方式。
监控中心：监控 Dubbo 服务的调用情况，如调用次数、耗时等，支持多种监控接口，如 Dubbo 自带的监控中心、Prometheus 等。

配置中心示例

配置中心用于集中管理 Dubbo 服务的配置。例如，通过一个配置文件集中管理服务提供者和消费者的相关配置。

<dubbo:application name="demo-provider"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:protocol name="dubbo" port="20880"/>
<dubbo:service interface="com.example.demo.service.HelloService" ref="helloService"/>

监控中心示例

监控中心可以监控 Dubbo 服务的调用情况。通过 Dubbo 提供的监控中心可以查看服务的调用次数、耗时等信息。

<dubbo:application name="demo-provider"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:protocol name="dubbo" port="20880"/>
<dubbo:service interface="com.example.demo.service.HelloService" ref="helloService"/>
<dubbo:monitor/>

Dubbo的优势和应用场景

优势

高性能：Dubbo 使用高效的序列化协议，如 Hessian、FST 与 Protobuf，并支持 Netty 作为网络传输框架，提供高效的网络通信能力。
灵活性：支持多种服务注册与发现机制，如 Zookeeper、Nacos、Consul 等，灵活适应不同的服务治理需求。
功能丰富：集成了负载均衡、服务路由、服务降级、熔断、服务鉴权等多种功能，满足微服务架构的多样化需求。
易用性：提供了丰富的配置选项和注解驱动开发方式，使得使用 Dubbo 开发和服务治理变得简单易用。
社区活跃：作为阿里巴巴开源的项目，Dubbo 社区活跃，版本更新频繁，解决了大量实际生产中的问题。

应用场景

微服务架构：Dubbo 是构建微服务架构的核心组件之一，被广泛应用于大型分布式系统中。
服务治理：Dubbo 提供了服务注册与发现、负载均衡、服务降级等功能，非常适合用于服务治理。
性能优化：通过 Dubbo 的高性能序列化协议与网络通信框架，可以显著提高系统的性能。
分布式系统：可用于构建分布式系统，提供高性能的服务调用和数据传输能力。
云原生应用：在云原生环境下，Dubbo 可以与云服务无缝集成，支持容器化部署，提升系统的弹性和可扩展性。

快速入门

搭建开发环境

安装Java

安装 JDK，建议使用 Java 8 及以上版本。
配置环境变量，确保 JAVA_HOME、PATH 等变量正确设置。

安装IDE

下载并安装 IntelliJ IDEA 或 Eclipse。

安装Maven

下载并安装 Maven。
配置环境变量，确保 MAVEN_HOME、PATH 等变量正确设置。
在命令行中运行 mvn -v，确保 Maven 已经安装成功。

安装Dubbo

在本地项目中添加 Dubbo 依赖。
配置 Dubbo 的相关依赖，例如在 Maven 的 pom.xml 中进行配置：

<dependencies>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.7.8</version>
    </dependency>
    <!-- 其他依赖，例如日志框架，序列化框架等 -->
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <version>3.4.14</version>
    </dependency>
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>5.1.0</version>
    </dependency>
</dependencies>

安装Zookeeper

下载并安装 Zookeeper。
配置 Zookeeper 集群，启动 Zookeeper 服务器。

创建首个Dubbo服务

创建服务接口

创建一个简单的服务接口 HelloService。

package com.example.demo.service;

public interface HelloService {
    String sayHello(String name);
}

实现服务接口

实现 HelloService 接口，给出具体的实现逻辑。

package com.example.demo.service.impl;

import com.example.demo.service.HelloService;

public class HelloServiceImpl implements HelloService {
    @Override
    public String sayHello(String name) {
        return "Hello, " + name;
    }
}

配置服务提供者

在服务提供者的配置文件 provider.xml 中配置服务提供者的相关信息。

<dubbo:application name="demo-provider"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:protocol name="dubbo" port="20880"/>
<dubbo:service interface="com.example.demo.service.HelloService" ref="helloService"/>

启动服务提供者

启动服务提供者，将服务发布到 Zookeeper 注册中心。

import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.alibaba.dubbo.config.ServiceConfig;
import com.example.demo.service.HelloService;
import com.example.demo.service.impl.HelloServiceImpl;

public class Provider {
    public static void main(String[] args) throws Exception {
        // 创建服务提供者配置
        ServiceConfig<HelloService> serviceConfig = new ServiceConfig<>();
        serviceConfig.setApplication(new ApplicationConfig("demo-provider"));
        serviceConfig.setRegistry(new RegistryConfig("zookeeper://127.0.0.1:2181"));
        serviceConfig.setProtocol("dubbo");
        serviceConfig.setInterface(HelloService.class);
        serviceConfig.setRef(new HelloServiceImpl());

        // 发布服务
        serviceConfig.export();
    }
}

创建服务消费者

创建服务消费者的接口引用和配置。

import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.ReferenceConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.example.demo.service.HelloService;

public class Consumer {
    public static void main(String[] args) throws Exception {
        // 创建服务引用配置
        ReferenceConfig<HelloService> referenceConfig = new ReferenceConfig<>();
        referenceConfig.setApplication(new ApplicationConfig("demo-consumer"));
        referenceConfig.setRegistry(new RegistryConfig("zookeeper://127.0.0.1:2181"));
        referenceConfig.setInterface(HelloService.class);

        // 获取服务引用对象
        HelloService helloService = referenceConfig.get();

        // 调用服务
        String result = helloService.sayHello("world");
        System.out.println(result);
    }
}

启动服务消费者

启动服务消费者，从 Zookeeper 注册中心获取服务地址并发起调用。

配置服务提供者与服务消费者

服务提供者配置

<dubbo:application name="demo-provider"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:protocol name="dubbo" port="20880"/>
<dubbo:service interface="com.example.demo.service.HelloService" ref="helloService"/>

服务消费者配置

<dubbo:application name="demo-consumer"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:reference id="helloService" interface="com.example.demo.service.HelloService"/>

启动服务提供者和消费者

在服务提供者和消费者中分别通过 XML 配置文件或 Java 配置进行启动。

import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.ReferenceConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.example.demo.service.HelloService;

public class Consumer {
    public static void main(String[] args) throws Exception {
        // 创建服务引用配置
        ReferenceConfig<HelloService> referenceConfig = new ReferenceConfig<>();
        referenceConfig.setApplication(new ApplicationConfig("demo-consumer"));
        referenceConfig.setRegistry(new RegistryConfig("zookeeper://127.0.0.1:2181"));
        referenceConfig.setInterface(HelloService.class);

        // 获取服务引用对象
        HelloService helloService = referenceConfig.get();

        // 调用服务
        String result = helloService.sayHello("world");
        System.out.println(result);
    }
}

Dubbo服务模型

服务提供者配置详解

服务提供者配置文件

服务提供者需要在配置文件中指定应用名称、注册中心地址和协议相关信息。

<dubbo:application name="demo-provider"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:protocol name="dubbo" port="20880"/>
<dubbo:service interface="com.example.demo.service.HelloService" ref="helloService"/>

配置详解

<dubbo:application>：配置应用相关信息。
<dubbo:registry>：配置注册中心地址。
<dubbo:protocol>：配置服务协议和端口。
<dubbo:service>：配置服务接口和服务实现。

服务消费者配置详解

服务消费者配置文件

服务消费者需要在配置文件中指定应用名称、注册中心地址和服务接口相关信息。

<dubbo:application name="demo-consumer"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:reference id="helloService" interface="com.example.demo.service.HelloService"/>

配置详解

<dubbo:application>：配置应用相关信息。
<dubbo:registry>：配置注册中心地址。
<dubbo:reference>：配置服务引用接口。

注解驱动开发示例

使用注解开发服务提供者

import com.alibaba.dubbo.config.EnableDubbo;
import com.alibaba.dubbo.config.annotation.DubboService;
import com.example.demo.service.HelloService;

@DubboService
public class HelloServiceImpl implements HelloService {
    @Override
    public String sayHello(String name) {
        return "Hello, " + name;
    }
}

使用注解开发服务消费者

import com.alibaba.dubbo.config.EnableDubbo;
import com.alibaba.dubbo.config.annotation.DubboReference;
import com.example.demo.service.HelloService;

@EnableDubbo
public class Consumer {
    @DubboReference
    private HelloService helloService;

    public static void main(String[] args) throws Exception {
        new Consumer().callService();
    }

    private void callService() {
        String result = helloService.sayHello("world");
        System.out.println(result);
    }
}

Dubbo配置管理

XML配置文件详解

配置文件示例

<dubbo:application name="demo-provider"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:protocol name="dubbo" port="20880"/>
<dubbo:service interface="com.example.demo.service.HelloService" ref="helloService"/>

配置详解

<dubbo:application>：配置应用相关信息。
<dubbo:registry>：配置注册中心地址。
<dubbo:protocol>：配置服务协议和端口。
<dubbo:service>：配置服务接口和服务实现。

使用Spring进行配置管理

配置文件示例

<bean id="helloService" class="com.example.demo.service.impl.HelloServiceImpl"/>
<bean id="registry" class="com.alibaba.dubbo.registry.zookeeper.ZookeeperRegistryFactory">
    <property name="address" value="zookeeper://127.0.0.1:2181"/>
</bean>
<bean id="protocol" class="com.alibaba.dubbo.protocol.dubbo.DubboProtocol">
    <property name="port" value="20880"/>
</bean>
<bean id="serviceConfig" class="com.alibaba.dubbo.config.spring.ServiceConfig">
    <property name="interface" value="com.example.demo.service.HelloService"/>
    <property name="ref" ref="helloService"/>
</bean>

配置详解

helloService：配置服务提供者的实现。
registry：配置注册中心。
protocol：配置服务协议和端口。
serviceConfig：配置服务接口和服务实现。

动态配置与热更新

动态配置

通过编程方式动态修改 Dubbo 配置。

import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.alibaba.dubbo.config.ServiceConfig;

public class DynamicConfig {
    public static void main(String[] args) {
        ApplicationConfig applicationConfig = new ApplicationConfig();
        applicationConfig.setName("demo-provider");

        RegistryConfig registryConfig = new RegistryConfig();
        registryConfig.setAddress("zookeeper://127.0.0.1:2181");

        ServiceConfig serviceConfig = new ServiceConfig();
        serviceConfig.setApplication(applicationConfig);
        serviceConfig.setRegistry(registryConfig);
        serviceConfig.setProtocol("dubbo");
        serviceConfig.setInterface(HelloService.class);
        serviceConfig.setRef(new HelloServiceImpl());

        serviceConfig.export();
    }
}

热更新

通过配置中心进行配置热更新。

<dubbo:config-center>
    <dubbo:property name="address" value="zookeeper://127.0.0.1:2181"/>
</dubbo:config-center>

Dubbo集群管理

集群模式介绍

集群模式

广播模式（Broadcast）：所有服务提供者都会为每个请求提供服务。
静态模式（Static）：服务提供者列表固定，由开发者手动配置。
动态模式（Dynamic）：服务提供者列表由注册中心动态更新。
失效转移（Failover）：出现异常时，自动切换到其他服务提供者。

配置示例

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

负载均衡策略配置

负载均衡策略

随机策略（Random）：随机选择服务提供者。
轮询策略（RoundRobin）：轮询选择服务提供者。
最少活跃调用策略（LeastActive）：选择调用次数最少的服务提供者。
一致性哈希策略（ConsistentHash）：根据一致性哈希算法选择服务提供者。

配置示例

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

故障转移与服务降级

故障转移

通过配置集群模式为 failover，实现服务提供者的故障转移。

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

服务降级

通过配置服务降级策略，当服务提供者不可用时，返回默认值。

import com.alibaba.dubbo.config.ServiceConfig;
import com.alibaba.dubbo.config.spring.ServiceConfigBean;

public class ServiceConfigExample {
    public static void main(String[] args) {
        ServiceConfig serviceConfig = new ServiceConfig();
        serviceConfig.setInterface(HelloService.class);
        serviceConfig.setRef(new HelloServiceImpl());
        serviceConfig.setRetries(2); // 设置重试次数
        serviceConfig.setTimeout(3000); // 设置超时时间
        serviceConfig.setVersion("1.0.0");
        serviceConfig.setGroup("group1");
        serviceConfig.setGeneric(true); // 设置泛化调用
        serviceConfig.setStub(true); // 设置 Stub 接口
        serviceConfig.setUrlParam("param1", "value1"); // 设置 URL 参数
        serviceConfig.setConfigBean(new ServiceConfigBean()); // 设置配置 Bean
        serviceConfig.export();
    }
}

Dubbo常用插件和扩展点

常用插件介绍

Dubbo Filter 插件

Dubbo Filter 插件可以用于在服务调用前后执行一些逻辑，如日志记录、认证授权等。

import com.alibaba.dubbo.rpc.Filter;
import com.alibaba.dubbo.rpc.Invocation;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.Result;
import com.alibaba.dubbo.rpc.RpcContext;

public class LogFilter implements Filter {
    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        System.out.println("Request: " + RpcContext.getContext().getMethodName() + "()");
        Result result = invoker.invoke(invocation);
        System.out.println("Response: " + result.getValue());
        return result;
    }
}

Dubbo Decorator 插件

Dubbo Decorator 插件可以在调用服务之前或之后包装原始的 Invoker，从而拦截并修改调用过程中的行为。

import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.RpcContext;

public class DecoratorFilter {
    public static Invoker decorate(Invoker<?> invoker) {
        return new Invoker() {
            @Override
            public Result invoke(Invocation invocation) throws RpcException {
                System.out.println("Decorator: " + RpcContext.getContext().getMethodName());
                Result result = invoker.invoke(invocation);
                System.out.println("Decorator: " + result.getValue());
                return result;
            }
        };
    }
}

Dubbo Listener 插件

Dubbo Listener 插件可以在调用完成之后执行一些逻辑，如日志记录、统计分析等。

import com.alibaba.dubbo.rpc.Filter;
import com.alibaba.dubbo.rpc.Invocation;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.Result;

public class ListenerFilter implements Filter {
    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        Result result = invoker.invoke(invocation);
        System.out.println("Listener: " + RpcContext.getContext().getMethodName());
        return result;
    }
}

扩展点开发示例

Dubbo Filter 扩展点开发

import com.alibaba.dubbo.config.spring.ConfigBean;
import com.alibaba.dubbo.config.spring.ServiceConfigBean;
import com.alibaba.dubbo.rpc.Filter;
import com.alibaba.dubbo.rpc.Invocation;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.Result;

public class LogFilter implements Filter {
    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        System.out.println("Request: " + invocation.getMethodName());
        Result result = invoker.invoke(invocation);
        System.out.println("Response: " + result.getValue());
        return result;
    }
}

Dubbo Decorator 扩展点开发

import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.RpcContext;

public class DecoratorFilter {
    public static Invoker decorate(Invoker<?> invoker) {
        return new Invoker() {
            @Override
            public Result invoke(Invocation invocation) throws RpcException {
                System.out.println("Decorator: " + RpcContext.getContext().getMethodName());
                Result result = invoker.invoke(invocation);
                System.out.println("Decorator: " + result.getValue());
                return result;
            }
        };
    }
}

Dubbo Listener 扩展点开发

import com.alibaba.dubbo.config.spring.ConfigBean;
import com.alibaba.dubbo.config.spring.ServiceConfigBean;
import com.alibaba.dubbo.rpc.Filter;
import com.alibaba.dubbo.rpc.Invocation;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.Result;

public class ListenerFilter implements Filter {
    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        Result result = invoker.invoke(invocation);
        System.out.println("Listener: " + RpcContext.getContext().getMethodName());
        return result;
    }
}

插件使用场景分析

日志记录

通过自定义的 Dubbo Filter 插件记录服务调用的日志信息，便于调试和追踪。

认证授权

通过 Dubbo Filter 描件在调用前后执行认证授权逻辑，确保调用的安全性。

统计分析

通过 Dubbo Listener 揔件在调用完成后执行统计分析逻辑，收集服务调用的各类信息。

高可用

通过 Dubbo Decorator 揔件在调用前包装 Invoker，实现服务的高可用和负载均衡。

数据校验

通过 Dubbo Filter 揔件在调用前执行数据校验逻辑，确保数据的合法性和有效性。

服务降级

通过 Dubbo Filter 揔件在调用前执行服务降级逻辑，当服务提供者不可用时返回默认值。

點擊查看更多內容

為 TA 點贊

若覺得本文不錯，就分享一下吧！

評論

評論

共同學習，寫下你的評論

評論加載中...

展開查看更多評論

作者其他優質文章

正在加載中

慕神8447489

手記
篇

粉絲

174

獲贊與收藏

959

關注作者，訂閱最新文章

閱讀免費教程

Java并發工具

23個小節 19844 321

Java 并發原理入門教程

26個小節 40021 580

Java 入門教程

50個小節 351802 3256

推薦

評論

收藏

共同學習，寫下你的評論



感謝您的支持，我會繼續努力的～

掃碼打賞，你說多少就多少

贊賞金額會直接到老師賬戶

支付方式

打開微信掃一掃，即可進行掃碼打賞哦

今天注冊有機會得

100積分直接送

付費專欄免費學

大額優惠券免費領

立即參與放棄機會

點擊
抽獎

慕課手記新用戶專享福利

恭喜你，你的運氣太好了，居然抽中了 100個積分！

恭喜你，抽中了價值元的專欄！

太棒了，直接落到你賬戶里！

積分商城里的羅技鼠標、機械鍵盤、
Kindle 閱讀器、小米平衡車
Apple iPad （10.2英寸）、大額優惠券
在等著你去兌換了噢

作者：

免費贈送

兌換碼：1111222211 復制

優惠券可用于購買實戰課、體系課
無門檻使用

先去看看，有什么好東西馬上兌換我愛學習，選課去


亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

熱搜

最近搜索清空

Dubbo入門教程：輕松搭建微服務框架

优势

应用场景

安装Java

安装IDE

安装Maven

安装Dubbo

安装Zookeeper

创建服务接口

实现服务接口

配置服务提供者

启动服务提供者

创建服务消费者

启动服务消费者

服务提供者配置

服务消费者配置

启动服务提供者和消费者

服务提供者配置文件

配置详解

服务消费者配置文件

配置详解

使用注解开发服务提供者

使用注解开发服务消费者

配置文件示例

配置详解

配置文件示例

配置详解

动态配置

热更新

集群模式

配置示例

负载均衡策略

配置示例

故障转移

服务降级

Dubbo Filter 插件

Dubbo Decorator 插件

Dubbo Listener 插件

Dubbo Filter 扩展点开发

Dubbo Decorator 扩展点开发

Dubbo Listener 扩展点开发

日志记录

认证授权

统计分析

高可用

数据校验

服务降级

閱讀免費教程