开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 网络协议 -> dubbo入门 -> 正文阅读

[网络协议]dubbo入门

zookeeper安装与配置

下载地址：http://archive.apache.org/dist/zookeeper/zookeeper-3.4.14/

选择 zookeeper-3.4.14.tar.gz 即可

zookeeper配置

安装完成之后，进入conf文件，复制zoo_sample.cfg文件并命名为zoo.cfg

在这里插入图片描述

然后进入bin目录点击zkServer.cmd启动zookeeper服务

在这里插入图片描述

没有报错就算启动完成

接着可以启动zkCli.cmd启动客户端进行测试但是一般开发中我们的java程序就是客户端因此这里只是为了测试

在这里插入图片描述

连接成功以后使用ls /命令就可以看到zookeeper的当前节点数量

也可以使用create -e key value的方式进行节点的创建

windows环境下和Linux环境下的操作一样 linux环境下启动 .sh后缀的服务即可

Dubbo

在这里插入图片描述

async：异步调用 sync：同步调用 init：数据初始化

生产者向注册中心注册服务

消费者订阅注册中心，当有新的服务被注册，注册中心就会通知消费者

消费者就可以进行同步调用实现对生产者服务的调用

dubbo是一个rpc框架主要提供通讯和序列化，序列化是为了保证数据可以在网络中传输

rpc：远程调用通俗点说就是两个部署在不同服务器上的程序， A可以调用B 。区别与本地调用主要是部署在了不同的服务器上

DubboAdmin下载与安装

下载地址 https://github.com/apache/dubbo-admin.git 选择 master 0.2.0 分支

下载完成之后修改配置文件在dubbo-admin-master-0.2.0\dubbo-admin\src\main\resources\application.properties文件中修改zookeeper的地址即可

默认主页地址是localhost:7001

打包

在当前文件夹下以管理员身份打开cmd

然后执行打包命令mvn clean package -Dmaven.test.skip=true 打成jar包以后可以直接执行jar运行程序

也可以每次在Idea中打开该文件运行该程序效果都一样

运行

打包成功之后将zookeeper服务启动

在dubbo-admin-master-0.2.0\dubbo-admin\target文件夹下打开cmd窗口使用 java -jar dubbo-admin.jar命令运行程序

然后访问localhost:7001进入admin界面默认账号密码都是admin

在这里插入图片描述

DubboAdmin是一个监控管理后台可以查看我们注册了哪些服务哪些服务被消费了

dubbo是一个jar包需要在我们的java程序中引入

zookeeper负责服务注册与发现

整合springboot

准备工作

创建一个空的项目
添加model模块 xxxx.-provider、xxx-consumer、common-interface

xxxx-provider：生产者模块主要用于提供服务

xxxx-consumer：消费者模块主要用于服务调用

common-interface：用于存放生产者和消费者中用到的接口和实体类作为公共模块提高复用
创建之后的结构图

在这里插入图片描述

依赖导入

工共模块只存放实体类和接口因此只需要引入lombok即可

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.llf</groupId>
    <artifactId>common-interface</artifactId>
    <version>1.0-SNAPSHOT</version>
<dependencies>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <version>1.18.20</version>
    </dependency>
</dependencies>
    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

</project>

生产者和消费者都需要导入dubbo、zookeeper以及其他依赖包因此两个模块的依赖是一致的

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.5.3</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.llf</groupId>
    <artifactId>adress-service-provider</artifactId>
    <version>1.0</version>
    <name>adress-service-provider</name>
    <description>adress-service-provider</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!-- Dubbo-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.8</version>
        </dependency>

        <!-- dubbo其他依赖 -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.2.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.2.0</version>
        </dependency>
        <!--公共接口依赖-->
        <dependency>
            <groupId>org.llf</groupId>
            <artifactId>common-interface</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <!-- zookeeper Client -->
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <!--   zookeeper     -->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.14</version>
            <exclusions>
                <!--排除依赖冲突-->
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

这里需要注意的是需要将工共模块引入到消费者、生产者的依赖中以便于引用

环境配置

通过dubbo-admin的配置文件可以知道配置dubbo 只需要配置几个属性即可

---------------生产者配置-----------------
server.port=8081
#服务应用名字
dubbo.application.name=addressServiceProvider
#哪些服务需要注册  扫描的包
dubbo.scan.base-packages=com.llf.addressserviceprovider.service.*
#服务注册地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#端口配置 默认208800
dubbo.protocol.port=20880
#使用的协议名字
dubbo.protocol.name=dubbo

---------------------消费者配置-------------------
server.port=8082
#服务应用名字
dubbo.application.name=addressServiceProvider
#向哪一个服务注册中心进行远程调用
dubbo.registry.address=zookeeper://127.0.0.1:2181
#端口配置 默认208800
dubbo.protocol.port=20880
#使用的协议名字
dubbo.protocol.name=dubbo

代码编写

这里的service是从公共模块引入的而不是自己写的 import的地址是从所在路径的上一级开始

消费者

package com.llf.orderserviceconsummer.service;

import Pojo.Address;
import Pojo.Order;
import Service.OrderService;
import Service.AddressService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Iterator;

/**
 * @author llf
 * @date 2022/2/13 9:26
 */
@Service
public class OrderServiceImpl implements OrderService {

    @DubboReference //使用DubboReference注解引用服务 而不是autowired
    AddressService addressService;

    @Override
    public Order getOrderById(String userId) {
        Logger logger = LoggerFactory.getLogger(this.getClass());
        Order order = new Order();
        ArrayList<Address> list = addressService.findAddressById(userId);

        Iterator<Address> iterator = list.iterator();
        if (iterator.hasNext()) {
            Address address = iterator.next();
            order = new Order(userId, "小孩嗝屁丸", address.getUserName(), address.getAddress());
        } else {
            System.out.println("数据不匹配");
        }
        logger.info("远程调用成功！");
        return order;
    }
}

生产者

package com.llf.addressserviceprovider.service;


import Pojo.Address;
import Service.AddressService;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.stereotype.Service;

import java.util.ArrayList;

/**
 * @author llf
 * @date 2022/2/13 9:24
 */

@Service  // 注册到spring容器中
@DubboService  // 注册到dubbo中
public class AddressServiceImpl implements AddressService {

    @Override
    public ArrayList<Address> findAddressById(String userId) {
        ArrayList<Address> list = new ArrayList<>();
        list.add(new Address(userId,"张三","12345656565","北京市昌平区"));
        return list;
    }
}

工共接口

package Service;

import Pojo.Address;

import java.util.ArrayList;

/**
 * @author llf
 * @date 2022/2/13 9:35
 */
public interface AddressService {
    /**
     * 通过用户id查找地址
     * @param userId
     * @return
     */
    public ArrayList<Address> findAddressById(String userId);
}

------------------------------------------------------------------------------
package Service;

import Pojo.Order;

/**
 * @author llf
 * @date 2022/2/13 9:35
 */
public interface OrderService {
    /**
     *
     * @param userId
     * @return
     */
    public Order getOrderById(String userId);
}

启动测试

首先启动zookeeper
然后启动dubbo-admin 进行监控
启动消费者和生产者服务需要在启动类添加 @EnableDubbo注解
测试

    @Autowired
    OrderServiceImpl orderService;

    @Test
    void contextLoads() {
        Order order = orderService.getOrderById("111");
        System.out.println(order);
    }

结果

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-pymhVT6g-1644733439538)(E:/Typroa图片/image-20220213111410726.png)]

dubbo配置优先级

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-AnO2ULQo-1644733439539)(E:/Typroa图片/image-20220213125743899.png)]

如图所示，优先级的属性依次为虚拟机参数>xml配置>dubbo.properties,虚拟机参数即程序启动之前我们通过-D配置的dubbo属性,xml配置即我们项目中自己写的xml文件或者是springboot中的application.properties，当公共配置很简单，没有多注册中心，多协议等情况，或者想多个 Spring 容器想共享配置的情况下可以用dubbo.properties作为缺省配置；需要注意的是我这里的测试用例都是写在application.properties中,当然如果感觉不习惯,也可以跟普通maven项目一样新建xml文件,在xml中进行配置，只是不要忘了在springboot的启动类中添加@ImportResource(locations=“xml路径”)注解来引入就行,

虚拟机参数大于xml配置、properties配置大于默认配置
dubbo默认端口20880 默认协议dubbo 可以不进行配置

可以在resources根目录下创建dubbo.properties配置文件将application.properties中的dubbo配置文件剪贴到dubbo.properties中同样可以识别生效

#服务应用名字
dubbo.application.name=addressServiceProvider
#向哪一个服务注册中心进行远程调用
dubbo.registry.address=zookeeper://127.0.0.1:2181
#端口配置 默认208800
dubbo.protocol.port=20880
#使用的协议名字
dubbo.protocol.name=dubbo

dubbo超时设置与检查设置

超时设置分为三种方式：全局配置、service类配置、具体方法配置

优先级比较：同级别：消费者配置 > 生产者配置

? 不同级别：具体方法配置 > service类配置 > 全局配置

? 同一个模块：具体方法配置 > service类配置 > 全局配置

xml配置

这里需要注意的是生产者是 <dubbo: provider timeout=“2000”> < /dubbo:provider >

? 消费者是 <dubbo: consummer timeout=“2000”> < /dubbo:provider >

其他配置都相同

在这里插入图片描述

注解配置

生产者

全局配置
    dubbo.provider.imeout=2000
service类配置
    @DubboService(timeout = 2000)
具体方法配置
    @DubboService(methods = {
        @Method(name = "findAddressById",timeout = 1000，retries = 1)
							})
    	retries指的是超时重连次数 默认为2次  超时重连次数不包含第一次连接

消费者

全局配置
    dubbo.consummer.imeout=2000
service类配置
    @DubboReference(timeout = 2000)
具体方法配置
    @DubboReference(methods = {
        @Method(name = "findAddressById",timeout = 1000，retries = 1)
							})
    	retries指的是超时重连次数 默认为2次  超时重连次数不包含第一次连接