【Dubbo】快速入门案例以及配置详情

￡神魔★判官ぃ 2024-04-07 13:39 45阅读 0赞

## 文章目录 ##

1、Dubbo的前世今生

2、Dubbo的快速入门

2.1、Dubbo的基本架构

2.2、Nacos

2.3、管理后台

2.4、入门案例

2.5、代码优化

### 1、Dubbo的前世今生 ###

2011年10月27日，阿里巴巴开源了自己的SOA服务化治理方案的核心框架Dubbo，服务治理和SOA的设计理念开始逐渐在国内软件行业中落地，并被广泛应用。

*  早期版本的dubbo遵循SOA的思想，是面向服务架构的重要组件。
 *  如今版本的Dubbo作为Spring Cloud的二进制通信方案来发挥Dubbo的性能优势

### 2、Dubbo的快速入门 ###

#### 2.1、Dubbo的基本架构![0e5ff9d1474049b9bb7ce63b8cbc742d.png][] ####

节点角色说明：

<table> 
 <thead> 
  <tr> 
   <th>节点</th> 
   <th>角色说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>Provider</td> 
   <td>暴露服务的服务提供方。</td> 
  </tr> 
  <tr> 
   <td>Consumer</td> 
   <td>调用远程服务的服务消费方。</td> 
  </tr> 
  <tr> 
   <td>Registry</td> 
   <td>服务注册与发现的注册中心。</td> 
  </tr> 
  <tr> 
   <td>Monitor</td> 
   <td>统计服务的调用次数和调用时间的监控中心。</td> 
  </tr> 
 </tbody> 
</table>

调用关系说明：

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

#### 2.2、Nacos ####

[Nacos][]是阿里巴巴的产品，是一个集服务发现，配置管理的平台，在国内受欢迎程度较高。

![cb9ab49141e04c55a7511f11fd2952a3.png][]

1、找到今日资料中的nacos安装包![a57990f66d064b119d247a65416527a0.png][]

2、解压到没有中文和特殊字符的目录

3、进入bin目录，执行启动命令

#进入bin目录
    cd bin
    #启动
    startup.cmd -m standalone

4、浏览器查看：[http://127.0.0.1:8848/nacos][http_127.0.0.1_8848_nacos]

#### 2.3、管理后台 ####

[DubboAdmin][]是阿里巴巴管理提供的管理控制台，可以实现服务查询，详情展示,服务测试等功能。借由DubboAdmin可以更好的帮助开发人员对服务进行管理和监控

#1、下载代码: 
    git clone https://github.com/apache/dubbo-admin.git
    #2、在 dubbo-admin-server/src/main/resources/application.properties中指定注册中心地址
    #3、构建
    mvn clean package -D maven.test.skip=true
    #4、启动
    mvn --projects dubbo-admin-server spring-boot:run
    #或者
    cd dubbo-admin-distribution/target; java -jar dubbo-admin-0.1.jar
    #5、访问 http://localhost:8080

#### 2.4、入门案例 ####

需求：使用Dubbo构建分布式架构，完成根据用户id查询用户

![bfcdef692d034f4fbaa63e6ddc06c102.png][]

2.4.1、服务提供者

搭建环境

（1）创建user-provider模块导入依赖

<dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
        </dependency>
    
        
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.8</version>
        </dependency>
    
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-nacos</artifactId>
            <version>2.7.8</version>
        </dependency>
    </dependencies>

（2）编写引导类

package cn.itcast.user;
    
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    @MapperScan("cn.itcast.user.mapper")
    @SpringBootApplication
    public class UserProviderApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(UserProviderApplication.class, args);
        }
    
    }

代码实现

（1）UserServiceImpl

package cn.itcast.user.service;
    
    
    import cn.itcast.user.api.UserService;
    import cn.itcast.user.domain.User;
    import cn.itcast.user.mapper.UserMapper;
    import org.apache.dubbo.config.annotation.DubboService;
    import org.springframework.beans.factory.annotation.Autowired;
    
    @DubboService
    public class UserServiceImpl implements UserService {
    
        @Autowired
        private UserMapper userMapper;
    
        //根据id查询用户名称
        public String queryUsername(Long id) {
            return userMapper.findById(id).getUsername();
        }
    }

配置文件

server:
      port: 18081
    spring:
      datasource:
        url: jdbc:mysql://localhost:3306/dubbo-demo?useSSL=false
        username: root
        password: root
        driver-class-name: com.mysql.jdbc.Driver
      application:
        name: user-provider
    logging:
      level:
        cn.itcast: debug
      pattern:
        dateformat: HH:mm:ss:SSS
    dubbo:
      protocol:
        name: dubbo
        port: 20881
      registry:
        address: nacos://127.0.0.1:8848
      scan:
        base-packages: cn.itcast.user.service

2.4.2、服务消费者

搭建环境

（1）创建user-consumer模块导入依赖

<dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    
    
        
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.8</version>
        </dependency>
    
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-registry-nacos</artifactId>
            <version>2.7.8</version>
        </dependency>
    </dependencies>

（2）配置引导类

package cn.itcast.user;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    
    @SpringBootApplication
    public class UserConsumerApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(UserConsumerApplication.class, args);
        }
    }

代码实现

package cn.itcast.user.controller;
    
    
    import cn.itcast.user.api.UserService;
    import cn.itcast.user.domain.User;
    import lombok.extern.slf4j.Slf4j;
    import org.apache.dubbo.config.annotation.DubboReference;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @Slf4j
    @RestController
    @RequestMapping("/user")
    public class UserController {
    
        //引用远程服务
        @DubboReference
        private UserService userService;
    
        @GetMapping("/username/1")
        public String findUserName(@PathVariable("id") Long id) {
            return userService.queryUsername(id);
        }
    }

配置文件

server:
      port: 18080
    spring:
      application:
        name: user-consumer
    logging:
      level:
        cn.itcast: debug
      pattern:
        dateformat: HH:mm:ss:SSS
    dubbo:
      registry:
        address: nacos://127.0.0.1:8848

#### 2.5、代码优化 ####

将接口抽取为独立模块，并且把接口有关的domain都放到这个模块中

（1）创建user-api模块引入依赖

（2）将UserService接口和User对象导入user-api模块下

（3）User对象实现序列化接口

package cn.itcast.user.domain;
    
    import lombok.Data;
    
    import java.io.Serializable;
    
    @Data
    public class User implements Serializable {
        private Long id;
        private String username;
        private String address;
    }

[0e5ff9d1474049b9bb7ce63b8cbc742d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/bcf8ab1e83f04fe29df2d061a2875d54.png
[Nacos]: https://nacos.io/
[cb9ab49141e04c55a7511f11fd2952a3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/83b5fc65c9054d4781a22ee8b4d22a47.png
[a57990f66d064b119d247a65416527a0.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/1cc0af5cc8a44def972683ef0d80aa7c.png
[http_127.0.0.1_8848_nacos]: http://127.0.0.1:8848/nacos
[DubboAdmin]: https://github.com/apache/dubbo-admin
[bfcdef692d034f4fbaa63e6ddc06c102.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/f00ce19fd9b04baa926f464a877ddc3f.png