程序员经验分享-hwhale

Dubbo基础学习

2023-11-13

友情提醒

先看文章目录，大致了解文章知识点结构，点击文章目录可直接跳转到文章指定位置。

第一章、概念介绍

1.1）什么是RPC框架

RPC 【Remote Procedure Call】是指远程过程调用，是一种进程间通信方式，是一种技术思想，而不是规范。它允许程序调用另一个地址空间（网络的另一台机器上）的过程或函数，而不用开发人员显式编码这个调用的细节。调用本地方法和调用远程方法一样。

1.2）什么是分布式系统

分布式系统是若干独立计算机（服务器）的集合，这些计算机对于用户来说就像单个相关系统，分布式系统（distributed system）是建立在网络之上的服务器端一种结构。
部署在独立服务器上的各个子系统（项目），相互之间可以调用，形成一个大型分布式系统
独立部署的服务器没有额外要求，只需要满足子系统需求即可。
分布式系统中的计算机可以使用不同的操作系统，可以运行不同应用程序提供服务，将服务分散部署到多个计算机服务器上。

1.3）Dubbo概述

Dubbo官网网址：官网链接
①Apache Dubbo 是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。可以和Spring框架无缝集成。

②Dubbo是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案、服务治理方案。

③面向接口代理：调用接口的方法，在A服务器调用B服务器的方法，由dubbo实现对B的调用，无需关心实现的细节，就像MyBatis访问Dao的接口，可以操作数据库一样。不用关心Dao接口方法的实现。这样开发是方便，舒服的。

④支持多种协议：dubbo , hessian , rmi , http, webservice , thrift , memcached , redis。dubbo官方推荐使用dubbo协议。dubbo协议默认端口20880

1.3）Dubbo基本架构

①服务提供者（Provider）：暴露服务的服务提供方，服务提供者在启动时向注册中心注册自己提供的服务。服务容器spring负责启动，加载，运行服务提供者。

②服务消费者（Consumer）: 调用远程服务的服务消费方，服务消费者在启动时，向注册中心订阅自己所需的服务，服务消费者从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

③注册中心（Registry）：注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者 –如果信息有变，注册中心提供新的信息给消费者

④监控中心（Monitor）：服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心 –监控服务提供者、消费者状态，与开发没有直接关系
在这里插入图片描述

第二章、服务提供者(直连)

2.1）目录结构和依赖

在这里插入图片描述
pom文件

<?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>com.bjpowernode.dubbo</groupId>
    <artifactId>001-link-orderservice-provider</artifactId>
    <version>1.0.0</version>
    <dependencies>
        <!--Spring -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>4.3.16.RELEASE</version>
        </dependency>


        <!--Dubbo依赖-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.2</version>
        </dependency>

    </dependencies>


    <build>
        <plugins>

            <!--JDK1.8编译插件-->
            <plugin>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.1</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>

        </plugins>

    </build>


</project>

2.2）model层

order

package com.bjpowernode.dubbo.model;


import java.io.Serializable;

public class Order implements Serializable {
    private String id;
    private String goodsName;
    private Double price;
    private Integer amount;

    public Order() {
    }

    public Order(String id, String goodsName, Double price, Integer amount) {
        this.id = id;
        this.goodsName = goodsName;
        this.price = price;
        this.amount = amount;
    }

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getGoodsName() {
        return goodsName;
    }

    public void setGoodsName(String goodsName) {
        this.goodsName = goodsName;
    }

    public Double getPrice() {
        return price;
    }

    public void setPrice(Double price) {
        this.price = price;
    }

    public Integer getAmount() {
        return amount;
    }

    public void setAmount(Integer amount) {
        this.amount = amount;
    }

    @Override
    public String toString() {
        return "Order{" +
                "id='" + id + '\'' +
                ", goodsName='" + goodsName + '\'' +
                ", price=" + price +
                ", amount=" + amount +
                '}';
    }
}

2.3）service层

OrderService

package com.bjpowernode.dubbo.service;

import com.bjpowernode.dubbo.model.Order;

public interface OrderService {
    public Order addOrder(Integer userId,String goodsName, Double price,Integer amount);
}

OrderServiceImpl

package com.bjpowernode.dubbo.service;

import com.bjpowernode.dubbo.model.Order;

public class OrderServiceImpl implements OrderService{
    public Order addOrder(Integer userId, String goodsName, Double price, Integer amount) {
        return new Order("110",goodsName,price,amount);
    }
}

OrderApplication

package com.bjpowernode.dubbo;

import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;

import java.io.IOException;

public class OrderApplication {
    public static void main(String[] args) throws IOException {
        /**
         * 启动spring容器：阅读配置文件
         *   1、 new ClassPathXmlApplicationContext("orderservce-provider.xml");
         *   2、 new FileSystemXmlApplicationContext("D:/orderservce-provider.xml");
         *   3、tomcat启动
         */

        new ClassPathXmlApplicationContext("orderservce-provider.xml");

        //标准键盘输入：线程会阻塞
        System.in.read();
    }
}

2.4）resources配置文件

orderservce-provider.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <!--服务项目名称：唯一 ，它的名称是dubbo内部使用的唯一标识    饭店名称-->
    <dubbo:application name="001-link-order-service-provider"></dubbo:application>

    <!--定义协议：告诉消费者如何访问  怎么访问-->
    <dubbo:protocol name="dubbo" port="20880"></dubbo:protocol>

    <!--
      dubbo:service:提供（暴露）服务     菜单
        interface:区分不同的服务
        ref：关联真正提供服务的bean对象
         registry="N/A"：直连
    -->
    <dubbo:service
            interface="com.bjpowernode.dubbo.service.OrderService"
            ref="orderServiceImpl" registry="N/A"
    />

    <!--真正提供服务的bean对象    厨师-->
    <bean id="orderServiceImpl" class="com.bjpowernode.dubbo.service.OrderServiceImpl"></bean>
</beans>

第三章、服务消费者(直连)

3.1）目录结构和依赖

在这里插入图片描述
pom文件

<?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>com.bjpowernode.dubbo</groupId>
    <artifactId>002-link-main-web</artifactId>
    <version>1.0.0</version>

    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>4.3.16.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.2</version>
        </dependency>

        <dependency>
            <groupId>com.bjpowernode.dubbo</groupId>
            <artifactId>001-link-orderservice-provider</artifactId>
            <version>1.0.0</version>
        </dependency>


    </dependencies>


</project>

3.2）service层

ShopService

package com.bjpowernode.dubbo.service;


import com.bjpowernode.dubbo.model.Order;

public interface ShopService {

    public Order buyGoods(Integer userId, String goodsName, Double price, Integer amount);

}

ShopServiceImpl

package com.bjpowernode.dubbo.service;

import com.bjpowernode.dubbo.model.Order;

public class ShopServiceImpl implements ShopService {
    OrderService orderService;

    public void setOrderService(OrderService orderService) {
        this.orderService = orderService;
    }

    public Order buyGoods(Integer userId, String goodsName, Double price, Integer amount) {
       // new OrderServiceImpl().addOrder()
        return orderService.addOrder(userId, goodsName, price, amount);
    }
}

ShopApplication

package com.bjpowernode.dubbo;

import com.bjpowernode.dubbo.model.Order;
import com.bjpowernode.dubbo.service.ShopService;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class ShopApplication {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("shop-consume.xml");
        ShopService shopServiceImpl = (ShopService)context.getBean("shopServiceImpl");
        Order order = shopServiceImpl.buyGoods(1111, "apple", 10d, 2);
        System.out.println(order);
    }
}

3.3）resources配置文件

shop-consume.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <!--服务项目名称：唯一-->
    <dubbo:application name="002-link-main-web"></dubbo:application>

    <!--
        dubbo:reference:生成一个 代表远程服务的 bean对象
         id="remoteOrderService"：bean对象名称

        url:dubbo服务地址
        interface：区分不同的服务
        registry="N/A":直连
    -->
    <dubbo:reference
            id="remoteOrderService"
            url="dubbo://localhost:20880"
            interface="com.bjpowernode.dubbo.service.OrderService"
            registry="N/A"
            />

    <bean id="shopServiceImpl" class="com.bjpowernode.dubbo.service.ShopServiceImpl">
        <property name="orderService" ref="remoteOrderService"></property>
    </bean>

</beans>

第四章、注册中心Zookeeper

4.1）注册中心概述

通过将服务统一管理起来，可以有效地优化内部应用对服务发布/使用的流程和管理。服务注册中心可以通过特定协议来完成服务对外的统一。Dubbo 提供的注册中心有如下几种类型可供选：

1、Multicast注册中心：组播方式
2、Redis注册中心：使用Redis作为注册中心
3、Simple注册中心：就是一个dubbo服务。作为注册中心。提供查找服务的功能。
4、Zookeeper注册中心：使用Zookeeper作为注册中心

注册中心工作方式
在这里插入图片描述

4.2）下载Zookeeper注册中心

①Zookeeper是一个高性能的，分布式的，开放源码的分布式应用程序协调服务。Zookeeper运行需要java环境。

官网下载地址: http://zookeeper.apache.org/

②点击download下载
在这里插入图片描述
③找到历史版本in the archive
在这里插入图片描述
④下载3.5.6版本
在这里插入图片描述
在这里插入图片描述

4.3）Windows安装Zookeeper

①下载的文件zookeeper-3.5.4-beta.tar.gz. 解压后到目录就可以了，例如d:/servers/ zookeeper-3.5.4
修改zookeeper-3.5.4/conf/ 目录下配置文件
在这里插入图片描述
②复制zoo-sample.cfg改名为zoo.cfg，然后打开文件，查看文件内容
在这里插入图片描述
查看zoo.cfg文件内容
在这里插入图片描述
文件内容介绍
tickTime: 心跳的时间默认2000毫秒. Zookeeper服务器之间或客户端与服务器之间每2秒就会发送一个心跳。表明存活状态。

dataDir: 数据目录，可以是任意目录。存储zookeeper的快照文件、pid文件，默认为/tmp/zookeeper

clientPort: 客户端连接zookeeper的端口，即zookeeper对外的服务端口，默认为2181
④在文件配置最下面加入需要使用的端口号

admin.serverPort=8888

在这里插入图片描述

⑤bin目录下双击cmd文件，启动zookeeper
在这里插入图片描述
windows启动zookeeper成功
在这里插入图片描述

4.3）Linux安装Zookeeper

①VMware虚拟机下载安装，虚拟机中安装Linux系统CentOS7（图文详解）
Linux安装教程链接

②Zookeeper的运行需要Linux系统先安装好jdk.
安装jdk教程链接

③使用xftp工具将刚刚下载好的zookeeper-3.5.6-beta.tar.gz 文件传输到Linux系统下的/usr/local/目录
xftp工具的使用教程链接

④解压压缩文件到/usr/local/目录

tar -zxvf zookeeper-3.5.6-beta.tar.gz -C /usr/local/

⑤进入解压后的conf目录

cd apache-zookeeper-3.8.1-bin/conf

⑥拷贝文件 zoo-sample.cfg 为 zoo.cfg

zoo_sample.cfg

⑦使用vim命令修改zoo.cfg文件内容

vim zoo.cfg

增加如下内容后保存退出

admin.serverPort=9999

在这里插入图片描述

⑦切换到bin目录下，启动zookeeper，关闭zookeeper

切换bin目录

cd ..
cd bin

启动zookeeper

./zkServer.sh start

关闭zookeeper

./zkServer.sh stop

在这里插入图片描述

第五章、dubbo使用注册中心

5.1）项目加入zookeeper客户端依赖

每个模块均要加入如下代码

<!-- zookeeper客户端依赖 -->
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>4.1.0</version>
</dependency>

5.2）配置文件修改

服务提供者和消费者均要加入注册中心

 <dubbo:registry address="zookeeper://192.168.52.128:2181" check="false"></dubbo:registry>

直连的服务配置修改为注册中心方式

    <!--暴露服务-->
    <dubbo:service interface="com.bjpowernode.dubbo.service.UserInfoService"
                   ref="userInfoServiceImpl"  retries="2"  timeout="20000"
                   version="1.36"

    ></dubbo:service>

5.3）dubbo其他配置

①关闭检查

 <dubbo:registry address="zookeeper://192.168.52.128:2181" check="false"></dubbo:registry>

②重试次数

<dubbo:service retries="2" />
或
<dubbo:reference retries="2" />

③超时时间
由于网络或服务端不可靠。为了避免超时导致客户端资源（线程）挂起耗尽，必须设置超时时间。

dubbo消费端
指定接口超时配置
<dubbo:reference interface="com.foo.BarService" timeout="2000" />

dubbo服务端
指定接口超时配置
<dubbo:server interface="com.foo.BarService" timeout="2000" />

④版本号
服务提供者增加版本号

    <!--暴露服务-->
    <dubbo:service interface="com.bjpowernode.dubbo.service.UserInfoService"
                   ref="userInfoServiceImpl"  retries="2"  timeout="20000"
                   version="2.0.0"

    ></dubbo:service>

服务消费者增加版本号

  <dubbo:reference
            id="remoteUserInfoService2"
            interface="com.bjpowernode.dubbo.service.UserInfoService"
            version="2.0.0"
    />
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

后端框架知识汇总

dubbo

学习

笔记

Dubbo基础学习 的相关文章

  • Filter实现权限过滤

    有这么一个简单的要求 用户只有登录才能进入主页 一旦退出就无法进入主页 看似好像生来就该如此但代码层次却不简单 首先要判断用户登录状态 然后拦截判断 后面还会学习拦截器 web文件夹下新建一个文件夹名为sys 该文件夹新建jsp页面名为su

  • Linux 查看磁盘空间

    1 查看当前目录的总大小 du sh ps du disk usage 2 查看某个目录的总大小 du sh 目录名 du后面可以跟的参数含义 a 列出所有的文件与目录容量 因为默认仅统计目录底下的文件量而已 h 以人们较易读的容量格式 G

  • Deep Learning 大体概念和事情

    0 深度学习为什么可能 因为一个事物的发生 其背后总有一个理型 或者叫做规律性 这个规律性就体现在原因与结果的作用关系里 把大多数原因和结果进行量化之后 结果与原因间存在一个数量关系方程 使得 结果 f 众原因 找出来这个大致的方程 f 便

  • 前端 Websocket + Stomp.js 的使用

    什么是Stomp STOMP即Simple or Streaming Text Orientated Messaging Protocol 简单 流 文本定向消息协议 它提供了一个可互操作的连接格式 允许STOMP客户端与任意STOMP消息

随机推荐

  • 【蓝桥OJ——C语言】顺子日期、特殊时间、乘积尾零

    文章目录 顺子日期 特殊时间 乘积尾零 总结 顺子日期 小明特别喜欢顺子 顺子指的就是连续的三个数字 123 456 等 顺子日期指的就是在日期的 yyyymmdd 表示法中 存在任意连续的三位数是一个顺子的日期 例如 20220123 就

  • 【Vue学习笔记】- 模板语法

    Vue模板语法分为两大类 插值语法 指令语法 插值语法 功能 作用于标签体内 目的是解析内容 写法 xxx xxx 是js表达式或data中的数据 指令语法 功能 作用于标签自身 可解析 标签属性 标签体内容 绑定事件 举例 v bind

  • java调第三方接口

    目录 背景 Spring的RestTemplate 1 引入依赖 2 RestTemplate配置类 3 RestTemplate实现类 背景 java调第三方接口我百度的有三种方法 第一种 通过JDK网络类Java net HttpURL

  • SpringBoot jar包的部署方式

    centos版本 CentOS Linux release 7 6 1810 Core JDK1 8 一 SpringBoot jar包的部署方式 nohup 后台进程形式 Linux脚本 启动形式 systemd 优雅系统服务形式 sys

  • Tomcat的日志切分和定时删除

    在我负责的一个小系统中 Linux环境下 由于默认日志都是写入在 cattalina out中 我查看日志catalina out 竟然已经到了 40G了 我想做一下 文件内容检索来追踪问题都无法进行 于是我决定删除以前的无用日志 以每日作

  • Qt 与外部exe进程间通信-基于操作系统的消息传递

    步骤 进程A 通过WindowAPI找到需要传递信息的窗口 然后通过windowAPI发送自定义的消息 其实本质上还是window操作系统定义的消息结构 只不过其中有个字段的值被设置成了自己特有的值 const ULONG PTR CUST

  • Java分割字符串（spilt()）

    String 类的 split 方法可以按指定的分割符对目标字符串进行分割 分割后的内容存放在字符串数组中 该方法主要有如下两种重载形式 str split String sign str split String sign int lim

  • 学好了Python可以干什么？

    随着我国对编程的重视程度上升 Python编程的学习趋势逐渐低龄化 在全国掀起Python编程热的同时 还是有许多人对于学习Python抱有怀疑 那么我们就来看看学好了Python究竟可以干什么 根据目前就业市场的反馈 我们可以看到Pyth

  • Cscope的使用

    转载自 http blog csdn net dengxiayehu article details 6330200 首先在目录下建立cscope索引文件 find name c gt cscope file cscope Rbkq 这个命

  • ST芯片使用串口 + DMA接收 + 空闲中断处理，有USART1和LPUART

    普通串口 USART1 首先是DMA初始化 DMA初始化 void MX DMA Init void Init with LL driver DMA controller clock enable LL AHB EnableClock LL

  • 最新淘宝主图下载方法-最新淘宝主图下载工具-马赛克视频助手

    做电商的朋友经常需要去下载淘宝上的别人的主图视频 那么淘宝主图视频怎么下载呢 工具 材料 马赛克视频助手 免费工具 www mask4 com 大家自行下载 操作方法 1 先打开马赛克视频助手 2 随便打开一个淘宝主图地址 如果是手机端的朋

  • ORA-00937: not a single-group group function说明及解决方法

    A SELECT list cannot include both a group function such as AVG COUNT MAX MIN SUM STDDEV or VARIANCE and an individual co

  • uni-app调用手机摄像头进行扫码

  • 放弃node-sass，启用sass

    在下载一个新项目时运行 npm run install 发现报错 npm uninstall 异常 Error Could not find any Visual Studio installation to use 或是 You need

  • 滑动平均滤波

    滑动平均滤波是一种常用的数字信号处理技术 它可以有效地去除信号中的噪声 提高信号的质量 滑动平均滤波的原理是对信号的每一个采样点 取其周围的若干个点的平均值作为滤波后的值 这样 信号中的随机噪声会被平均掉 而信号中的有用信息会被保留 用C语

  • 人民日报：密码，让百姓生活更安全

    密码技术是保障网络与信息安全的核心技术和基础支撑 通过加密保护和安全认证两大核心功能 可以完整实现防假冒 防泄密 防篡改 抗抵赖等安全需求 在网络空间中扮演着 信使 卫士 和 基因 的重要角色 信息化 网络化 数字化高度发达的今天 密码技术

  • 【突发】解决remote: Support for password authentication was removed on August 13, 2021. Please use a perso

    今天 github突然宣布 无法通过用户名加密码进行上传代码和访问 git push remote Support for password authentication was removed on August 13 2021 Plea

  • 策略模式+注解，代替if-else

    策略模式 经常在网上看到一些名为 别再if else走天下了 教你干掉if else 等之类的文章 大部分都会讲到用策略模式去代替if else 策略模式实现的方式也大同小异 主要是定义统一行为 接口或抽象类 并实现不同策略下的处理逻辑 对

  • 判断exe是64位还是32位

    右击exe属性 查看兼容模式 如果有windwos vista之前的版本则为32位的 如下图 如果没有windwos vista之前的版本则为64位的 如下图 转载于 https www cnblogs com tiandsp p 9603

  • Dubbo基础学习

    目录 第一章 概念介绍 1 1 什么是RPC框架 1 2 什么是分布式系统 1 3 Dubbo概述 1 3 Dubbo基本架构 第二章 服务提供者 直连 2 1 目录结构和依赖 2 2 model层 2 3 service层 2 4 res

热门标签