Spring Boot Dubbo 构建分布式服务

时间  2019-12-10
标签 spring boot dubbo 构建 分布式 服务 栏目 Spring 繁體版
原文   原文链接

概述：

dubbo.png

节点角色说明html

节点 角色说明
Provider 暴露服务的服务提供方
Consumer 调用远程服务的服务消费方
Registry 服务注册与发现的注册中心
Monitor 统计服务的调用次数和调用时间的监控中心
Container 服务运行的容器

调用关系说明前端

  1. 服务容器 Container 负责启动，加载，运行服务提供者。
  2. 服务提供者 Provider 启动的时候，向注册中心 Registry 注册本身提供的服务。
  3. 服务消费者 Consumer 在启动的时候，向注册中心 Registry 订阅本身所须要的服务。
  4. 注册中心 Registry 返回服务提供者的地址列表给消费者，若是有变动注册中心将基于长链接推送变动数据给消费者。
  5. 服务消费者从提供者地址列表中，基于软负载均衡算法，选择一台提供者进行进行调用，若是调用失败再选择另一台。
  6. 服务消费者与提供者在内存中统计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心 Monitor 。

项目构建

开发环境主要涉及如下方面：java

  • Spring Boot
  • JDK 8
  • Dubbo 2.7.1
  • Zookeeper

具体代码能够查看 github 的 dubbo 模块：github.com/UniqueDong/…git

Dubbo API

定义服务接口，打成 jar 包让消费者依赖，服务者实现接口。该工程只有接口定义以及 model 对象。@Data 属于lombok 开源库提供的特性，方便开发。github

  • model 对象定义：
@Data
public class User implements Serializable {
    private Long id;
    private String username;
}
复制代码
  • provider 接口定义：
public interface UserProvider {
    List<User> listUser();
}
复制代码

Provider 服务提供者

  • pom依赖：

引入spring-boot-starter，dubbo-api 接口就是咱们上面提到的 接口定义 jar ，dubbo-spring-boot-starter ，dubbo-dependencies-zookeeper。web

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
            <exclusions>
                <exclusion>
                    <artifactId>spring-boot-starter-logging</artifactId>
                    <groupId>org.springframework.boot</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>zero.springboot.study</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>1.0.0-SNAPSHOT</version>
        </dependency>
        <!--dubbo start-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.1</version>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.7.1</version>
        </dependency>

        <!-- Zookeeper dependencies -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>2.7.1</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <artifactId>log4j</artifactId>
                    <groupId>log4j</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>slf4j-log4j12</artifactId>
                    <groupId>org.slf4j</groupId>
                </exclusion>
            </exclusions>
        </dependency>

        <!--dubbo end-->
       
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.57</version>
        </dependency>
    </dependencies>
复制代码
  • 配置文件 yaml 定义：
spring:
 application:
 name: dubbo-provider
#自定义配置
embedded:
 zookeeper:
    # zookeeper 服务链接端口
 port: 2181

# dubbo 配置
dubbo:
  # 注册中心配置 
 registry:
 id: dubbo-provider
 address: zookeeper://127.0.0.1:${embedded.zookeeper.port}
 group: local
 application:
 name: dubbo-provider
 id: dubbo-provider
 logger: slf4j
 qosEnable: true
 qosPort: 22224
 qosAcceptForeignIp: false
  # dubbo 协议配置
 protocol:
    # -1 表示使用随机未被占用的端口
 port: -1
 name: dubbo
 scan:
    # dubbo 服务提供者实现类所在包
 base-packages: com.zero.provider.impl
复制代码

  • 实现 api 定义的接口算法

    注意 @Service 是 Dubbo 的，不要导入了 Spring 的。spring

import com.google.common.collect.Lists;
import com.zero.api.model.User;
import com.zero.api.provider.UserProvider;
import org.apache.dubbo.config.annotation.Service;

import java.util.List;

@Service(interfaceClass = UserProvider.class)
public class UserProviderImpl implements UserProvider {
    @Override
    public List<User> listUser() {
        User user = new User();
        user.setId(1L);
        user.setUsername("青龙");
        return Lists.newArrayList(user);
    }
}
复制代码

Consumer

  • Pom 定义：

咱们要依赖 spring-boot-starter-web 提供http rest接口给前端调用。同时内部经过 Dubbo 实现 RPC调用服务提供者。apache

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-logging</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>zero.springboot.study</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>1.0.0-SNAPSHOT</version>
        </dependency>
        <!--dubbo start-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.1</version>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.7.1</version>
        </dependency>

        <!-- Zookeeper dependencies -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>2.7.1</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <artifactId>log4j</artifactId>
                    <groupId>log4j</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>slf4j-log4j12</artifactId>
                    <groupId>org.slf4j</groupId>
                </exclusion>
            </exclusions>
        </dependency>

        <!--dubbo end-->

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

    </dependencies>
复制代码
  • yaml 定义：
server:
  # web 日更年期端口
 port: 9005
spring:
 application:
 name: dubbo-comsumer
#自定义配置
embedded:
 zookeeper:
 port: 2181
# dubbo 配置
dubbo:
 registry:
 id: dubbo-comsumer
 address: zookeeper://127.0.0.1:${embedded.zookeeper.port}
 group: local
 application:
 name: dubbo-comsumer
 id: dubbo-comsumer
 logger: slf4j
 qosEnable: false
 qosPort: 22223
 qosAcceptForeignIp: false
 protocol:
 port: -1
 name: dubbo
  # 是否检查服务提供者有效 
 consumer:
 check: false
复制代码
  • 服务消费者调用服务生产者
import com.zero.api.model.User;
import com.zero.api.provider.UserProvider;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class UserService {

    @Reference
    private UserProvider userProvider;

    public List<User> listUser() {
        return userProvider.listUser();
    }
}
复制代码
  • 咱们经过一个RESTfull接口，提供给前端调用。
@RestController
@RequestMapping("/users")
public class UserController {
    @Autowired
    private UserService userService;

    @GetMapping
    public Object listUser() {
        List<User> list = userService.listUser();
        return list;
    }
}

复制代码

总结

各类具体协议、注册中心、多注册中心、超时等配置能够查看官方文档dubbo.apache.org/zh-cn/docs/…json

欢迎你们讨论纠正，邮箱：zero_develop@163.com 。点赞与关注微信公众号是咱们前进的动力。

扫码_搜索联合传播样式-微信标准绿版.png
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程