Dubbo 分布式框架

一、Dubbo 簡(jiǎn)介

  • Dubbo是一款高性能、輕量級(jí)的開(kāi)源Java RPC框架，它提供了三大核心能力：面向接口的遠(yuǎn)程方法調(diào)用，智能容錯(cuò)和負(fù)載均衡，以及服務(wù)自動(dòng)注冊(cè)和發(fā)現(xiàn)。
  • Remoting: 網(wǎng)絡(luò)通信框架，實(shí)現(xiàn)了 sync-over-async 和 request-response 消息機(jī)制。
  • RPC: 一個(gè)遠(yuǎn)程過(guò)程調(diào)用的抽象，支持負(fù)載均衡、容災(zāi)和集群功能。
  • Registry: 服務(wù)目錄框架用于服務(wù)的注冊(cè)和服務(wù)事件發(fā)布和訂閱。

二、Zookeeper 簡(jiǎn)介

  • 功能描述：Zookeeper是一個(gè)分布式的，開(kāi)放源碼的分布式應(yīng)用程序協(xié)調(diào)服務(wù)，是Google的Chubby一個(gè)開(kāi)源的實(shí)現(xiàn)，是Hadoop和Hbase的重要組件。它是一個(gè)為分布式應(yīng)用提供一致性服務(wù)的軟件，提供的功能包括：配置維護(hù)、域名服務(wù)、分布式同步、組服務(wù)等。
  • 官網(wǎng)下載：https://zookeeper.apache.org/releases.html，選擇Zookeeper版本和HTTP下載方式。
    zookeeper
    下載完成后，進(jìn)入conf目錄下修改配置文件的名稱(chēng)，并進(jìn)入該文件修改dataDir的屬性為D:\Program Files\Java\apache-zookeeper-3.7.0\data。
    zookeeper
    最后進(jìn)入bin目錄，windows的啟用方式是雙擊zkServer.cmd文件，如能正常打開(kāi)窗口則證明啟動(dòng)成功！
    zookeeper

三、SpringBoot整合Dubbo和ZooKeeper框架

  • 創(chuàng)建SpringBoot項(xiàng)目作為父工程，利用其多模塊特性構(gòu)建出common、provider、consumer三個(gè)子工程，其中common包存放接口和實(shí)體，provider作為提供者角色，consumer作為消費(fèi)者角色，創(chuàng)建步驟如下：1、選中父工程并鼠標(biāo)右擊出現(xiàn)菜單 -> New -> Module；2、構(gòu)建方式同樣選擇SpringBoot項(xiàng)目；3、父工程作為子工程的關(guān)聯(lián)，具體實(shí)現(xiàn)在子工程，因此無(wú)需進(jìn)行額外配置，項(xiàng)目結(jié)構(gòu)如下：
    project
  • 為避免SpringBoot工程啟用時(shí)端口沖突，特定給每個(gè)項(xiàng)目配置一個(gè)唯一的端口。
server.port=8088 -> application.properties
  • common工程：創(chuàng)建service包用于存放Java接口，創(chuàng)建domain包，用于存放Java實(shí)體類(lèi)，實(shí)體類(lèi)需要實(shí)現(xiàn)序列化，避免遠(yuǎn)程服務(wù)調(diào)用時(shí)不能被解析，因?yàn)橹皇谴娣沤涌?，所以也無(wú)需進(jìn)行額外配置。

UserService 接口

public interface UserService {
    User getUser();
}

User 實(shí)體類(lèi)

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依賴(lài)、ZooKeeper依賴(lài)，創(chuàng)建impl包用于存放Java接口實(shí)現(xiàn)類(lèi)，創(chuàng)建Dubbo的配置文件實(shí)現(xiàn)遠(yuǎn)程服務(wù)調(diào)用。

pom.xml 在dependencies節(jié)點(diǎn)里加入以下代碼：

<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 創(chuàng)建方式：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"/> -> 注冊(cè)到服務(wù)中心

    <dubbo:annotation package="com.provider.impl"/> -> 掃描注解包路徑，多個(gè)包用逗號(hào)分隔

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

    <bean id="userService" class="com.provider.impl.UserServiceImpl"/> -> 接口實(shí)現(xiàn)

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

UserServiceImpl 接口實(shí)現(xiàn)類(lèi)

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 啟動(dòng)類(lèi)

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依賴(lài)、ZooKeeper依賴(lài)，創(chuàng)建controller包用于存放Java外部調(diào)用的API，創(chuàng)建Dubbo的配置文件實(shí)現(xiàn)遠(yuǎn)程服務(wù)訪問(wèn)。

pom.xml 在dependencies節(jié)點(diǎn)里加入以下代碼：

<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 創(chuàng)建方式：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"/> -> 消費(fèi)者

    <dubbo:registry address="zookeeper://127.0.0.1:2181"/> -> 注冊(cè)到服務(wù)中心

    <dubbo:annotation package="com.consumer.controller"/> -> 掃描注解包路徑，多個(gè)包用逗號(hào)分隔

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

    <dubbo:reference id="userService" check="false" interface="com.common.service.UserService"/> -> 遠(yuǎn)程訪問(wèn)
</beans>

UserController 接口實(shí)現(xiàn)類(lèi)

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 啟動(dòng)類(lèi)

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);
    }
}

  • 搭建過(guò)程已全部完成，接下來(lái)是啟動(dòng)過(guò)程，步驟為：1、啟動(dòng)ZooKeeper；2、啟動(dòng)Provider項(xiàng)目；3、啟動(dòng)Consumer項(xiàng)目；4、訪問(wèn)Controller的接口，得到如下結(jié)果則證明運(yùn)行成功：
    project

四、Dubbo-Admin 監(jiān)控臺(tái)

  • 功能描述：提供可視化界面工具，可以直觀查看ZooKeeper上有哪些服務(wù)，方便管理。
  • 克隆項(xiàng)目：IDEA克隆步驟：1、根部導(dǎo)航欄File -> New -> Project From Version Control；2、輸入git的倉(cāng)庫(kù)地址 https://github.com/apache/incubator-dubbo-ops；3、設(shè)置本地磁盤(pán)存放位置并點(diǎn)擊確定即可從遠(yuǎn)端拉取項(xiàng)目；
    project
  • 運(yùn)行項(xiàng)目：IDEA運(yùn)行步驟：1、啟動(dòng)本地的ZooKeeper服務(wù)注冊(cè)中心；2、修改dubbo-admin-server模塊下的端口為8081，避免默認(rèn)8080端口沖突；3、運(yùn)行該模塊并訪問(wèn) http://localhost:8081；4、控制臺(tái)的初始化賬號(hào)和密碼都是root，出現(xiàn)以下界面證明運(yùn)行成功：
    project
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書(shū)系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容