美文网首页
Dubbo 分布式框架

Dubbo 分布式框架

作者: 潜心之力 | 来源:发表于2021-06-10 16:41 被阅读0次

一、Dubbo 简介

  • Dubbo是一款高性能、轻量级的开源Java RPC框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。
  • Remoting: 网络通信框架,实现了 sync-over-async 和 request-response 消息机制。
  • RPC: 一个远程过程调用的抽象,支持负载均衡、容灾和集群功能。
  • Registry: 服务目录框架用于服务的注册和服务事件发布和订阅。

二、Zookeeper 简介

  • 功能描述:Zookeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。
  • 官网下载:https://zookeeper.apache.org/releases.html,选择Zookeeper版本和HTTP下载方式。 zookeeper 下载完成后,进入conf目录下修改配置文件的名称,并进入该文件修改dataDir的属性为D:\Program Files\Java\apache-zookeeper-3.7.0\data。
    zookeeper 最后进入bin目录,windows的启用方式是双击zkServer.cmd文件,如能正常打开窗口则证明启动成功! zookeeper

三、SpringBoot整合Dubbo和ZooKeeper框架

  • 创建SpringBoot项目作为父工程,利用其多模块特性构建出common、provider、consumer三个子工程,其中common包存放接口和实体,provider作为提供者角色,consumer作为消费者角色,创建步骤如下:1、选中父工程并鼠标右击出现菜单 -> New -> Module;2、构建方式同样选择SpringBoot项目;3、父工程作为子工程的关联,具体实现在子工程,因此无需进行额外配置,项目结构如下: project
  • 为避免SpringBoot工程启用时端口冲突,特定给每个项目配置一个唯一的端口。
server.port=8088 -> application.properties
  • common工程:创建service包用于存放Java接口,创建domain包,用于存放Java实体类,实体类需要实现序列化,避免远程服务调用时不能被解析,因为只是存放接口,所以也无需进行额外配置。

UserService 接口

public interface UserService {
    User getUser();
}

User 实体类

public class User implements Serializable {
    private String name = "wjx";

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}
  • provider工程:POM文件引入common工程、Dubbo依赖、ZooKeeper依赖,创建impl包用于存放Java接口实现类,创建Dubbo的配置文件实现远程服务调用。

pom.xml 在dependencies节点里加入以下代码:

<dependency> -> dubbo
    <groupId>com.alibaba</groupId>
    <artifactId>dubbo</artifactId>
    <version>2.5.5</version>
    <exclusions>
        <exclusion>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
        </exclusion>
    </exclusions>
</dependency>

<dependency> -> zookeeper
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.10</version>
</dependency>

<dependency> -> common模块
    <groupId>com.common</groupId>
    <artifactId>common</artifactId>
    <version>0.0.1-SNAPSHOT</version>
</dependency>

dubbo.xml 创建方式:New -> XML Configuration File -> Spring Config

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       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"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo">

    <dubbo:application name="provider"/> -> 提供者

    <dubbo:registry address="zookeeper://127.0.0.1:2181"/> -> 注册到服务中心

    <dubbo:annotation package="com.provider.impl"/> -> 扫描注解包路径,多个包用逗号分隔

    <dubbo:protocol name="dubbo" port="20880"/> -> dubbo端口

    <bean id="userService" class="com.provider.impl.UserServiceImpl"/> -> 接口实现

    <dubbo:service interface="com.common.service.UserService" ref="userService"/> -> 接口
</beans>

UserServiceImpl 接口实现类

import com.alibaba.dubbo.config.annotation.Service;

@Service(version = "1.0.0")
public class UserServiceImpl implements UserService {
    @Override
    public User getUser() {
        return new User();
    }
}

ProviderApplication 启动类

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ImportResource;

@SpringBootApplication
@ImportResource({"classpath:dubbo.xml"})
public class ProviderApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }
}
  • consumer工程:POM文件引入common工程、Dubbo依赖、ZooKeeper依赖,创建controller包用于存放Java外部调用的API,创建Dubbo的配置文件实现远程服务访问。

pom.xml 在dependencies节点里加入以下代码:

<dependency> -> dubbo
    <groupId>com.alibaba</groupId>
    <artifactId>dubbo</artifactId>
    <version>2.5.5</version>
    <exclusions>
        <exclusion>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
        </exclusion>
    </exclusions>
</dependency>

<dependency> -> zookeeper
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.10</version>
</dependency>

<dependency> -> common模块
    <groupId>com.common</groupId>
    <artifactId>common</artifactId>
    <version>0.0.1-SNAPSHOT</version>
</dependency>

dubbo.xml 创建方式:New -> XML Configuration File -> Spring Config

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       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"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo">

    <dubbo:application name="consumer"/> -> 消费者

    <dubbo:registry address="zookeeper://127.0.0.1:2181"/> -> 注册到服务中心

    <dubbo:annotation package="com.consumer.controller"/> -> 扫描注解包路径,多个包用逗号分隔

    <dubbo:protocol name="dubbo" port="20880"/> -> dubbo端口

    <dubbo:reference id="userService" check="false" interface="com.common.service.UserService"/> -> 远程访问
</beans>

UserController 接口实现类

import com.alibaba.dubbo.config.annotation.Reference;
import javax.annotation.Resource;

@RestController
public class UserController {
    @Resource
    @Reference(version = "1.0.0")
    private UserService userService;

    @RequestMapping("user")
    public User user() {
        return userService.getUser();
    }
}

ConsumerApplication 启动类

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ImportResource;

@SpringBootApplication
@ImportResource({"classpath:dubbo.xml"})
public class ConsumerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}
  • 搭建过程已全部完成,接下来是启动过程,步骤为:1、启动ZooKeeper;2、启动Provider项目;3、启动Consumer项目;4、访问Controller的接口,得到如下结果则证明运行成功: project

四、Dubbo-Admin 监控台

  • 功能描述:提供可视化界面工具,可以直观查看ZooKeeper上有哪些服务,方便管理。
  • 克隆项目:IDEA克隆步骤:1、根部导航栏File -> New -> Project From Version Control;2、输入git的仓库地址 https://github.com/apache/incubator-dubbo-ops;3、设置本地磁盘存放位置并点击确定即可从远端拉取项目; project
  • 运行项目:IDEA运行步骤:1、启动本地的ZooKeeper服务注册中心;2、修改dubbo-admin-server模块下的端口为8081,避免默认8080端口冲突;3、运行该模块并访问 http://localhost:8081;4、控制台的初始化账号和密码都是root,出现以下界面证明运行成功: project

相关文章

网友评论

      本文标题:Dubbo 分布式框架

      本文链接:https://www.haomeiwen.com/subject/uigueltx.html