Dubbo3应用开发—XML形式的Dubbo应用开发和SpringBoot整合Dubbo开发

news/2024/10/21 5:39:58/

Dubbo3程序的初步开发

Dubbo3升级的核心内容

  • 易⽤性

    开箱即⽤，易⽤性⾼，如 Java 版本的⾯向接⼝代理特性能实现本地透明调⽤功能丰富，基于原⽣库或轻量扩展即可实现绝⼤多数的 微服务治理能⼒。更加完善了多语言支持（GO PYTHON RUST)

  • 超⼤规模微服务实践

    • ⾼性能通信（Triple GRPC)
    • ⾼可扩展性 (SPI 多种序列化⽅式 多种协议)
    • 丰富的服务治理能⼒
    • 超⼤规模集群实例⽔平扩展

  • 云原生友好

    • 容器调度平台（Kubernetes）

      将服务的组织与注册交给底层容器平台，如 Kubernetes，这是更云原 ⽣的⽅式。

    • Service Mesh

      原有Mesh结构中通过Sidecar完成负载均衡、路由等操作，但是存在链路的性能损耗⼤，现有系统迁移繁琐等问题。 Dubbo3 引⼊Proxyless Mesh，直接和I控制⾯交互[istio]通信。集成 ServiceMesh更为⽅便，效率更高。

Dubbo3前言

代码结构及其术语解释

  1. provider 功能提供者
  2. consumer 功能调⽤者【功能消费者】
  3. commons-api 通⽤内容 entity service接口
  4. registry 注册中⼼
    1. 可选
    2. ⽤于管理provider集群

模块结构

开发步骤

  1. 开发commons-api 通⽤内容
  2. 开发provider 功能提供者
  3. 开发 consumer 功能调⽤者【功能消费者】
  4. 如需要注册中心，开发registry 注册中⼼

本专题所使用软件版本

JDK使用了两种JDK：JDK8和JDK17

Maven:3.8.7

Dubbo:3.2.0

JDK与Dubbo版本的关系

1. JDK8 与 Dubbo3.1.x以前的版本匹配，在使⽤Zookeeper注册作为注册中⼼时，消费者会出现节点已经存在的异常https://github.com/apache/dubbo/issues/11077
2. JDK17 与 Dubbo3.1.x之前的版本搭配使⽤会出现如下问题a. JDK9之后的深反射问题，需要通过JVM参数配置解决-Dio.netty.tryReflectionSetAccessible=true--add-opensjava.base/jdk.internal.misc=ALL-UNNAMED--add-opensjava.base/java.nio=ALL-UNNAMED--add-opensjava.base/java.lang=ALL-UNNAMEDb. Dubbo3.2.0.beat4以前的版本使⽤的是Spring5.2.x 不能⽀持 JDK17会产⽣如下异常Unsupported class file major version 61 【major 61 对应 17 】版本需要升级到Dubbo3.2.0.beat5以上版本

基于XML的Dubbo3程序开发

环境搭建

项目结构

父项目pom.xml的依赖

<dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.22</version>
</dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><version>1.7.32</version>
</dependency><dependency><groupId>ch.qos.logback</groupId><artifactId>logback-classic</artifactId><version>1.2.9</version>
</dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId><version>3.2.0</version>
</dependency>

首先开发公共模块-api模块

实体entity
@Data
@ToString
@NoArgsConstructor
@AllArgsConstructor
public class User implements Serializable {private String name;private String password;
}
接口service
public interface UserService {public boolean login(String name,String password);
}

类文件目录

开发provider模块

在provider模块添加依赖
<dependencies><dependency><groupId>com.sjdwz</groupId><artifactId>dubbo-01-api</artifactId><version>1.0-SNAPSHOT</version></dependency>
</dependencies>
实现接口
public class UserServiceImpl implements UserService{@Overridepublic boolean login(String name, String password) {System.out.println("UserServiceImpl.login name "+name + " password "+password);return false;}
}
创建Spring配置文件，配置Dubbo相关内容使得UserServiceImpl可以跨虚拟机来调用

配置文件结构

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"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"><!-- 为dubbo起个名字，要做到唯一，可以被注册中心所管理 --><dubbo:application name="dubbo-02-provider"/><!-- 设置rpc相关的协议 使得可以网络通信 --><dubbo:protocol name="dubbo" port="20880"/><!-- 创建对象 --><bean id="userService" class="com.sjdwz.service.UserServiceImpl"/><!-- 发布dubbo服务 --><dubbo:service interface="com.sjdwz.service.UserService" ref="userService"/></beans>
Spring工厂启动类

Spring工厂启动类

运行起来发现，会导出一个url

export url

dubbo://192.168.96.1:20880/com.sjdwz.service.UserService

开发consumer模块

引入api模块依赖
<dependencies><dependency><groupId>com.sjdwz</groupId><artifactId>dubbo-01-api</artifactId><version>1.0-SNAPSHOT</version></dependency>
</dependencies>
创建Spring配置文件

配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"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"><!-- 配置dubbo服务名称 --><dubbo:application name="dubbo-03-consuemer" /><!-- 获取远端服务url就是刚才导出的url--><dubbo:reference interface="com.sjdwz.service.UserService" id="userService"url="dubbo://192.168.96.1:20880/com.sjdwz.service.UserService"/></beans>
创建启动类

启动类

启动起来就可以看到消费端和生产端相应的输出。

注意

消费端会有一个异常

16:40:41.156 [main] ERROR org.apache.dubbo.qos.server.Server -  [DUBBO] qos-server can not bind localhost:22222, dubbo version: 3.2.0, current host: 192.168.96.1, error code: 7-4. This may be caused by , go to https://dubbo.apache.org/faq/7/4 to find instructions. 问题产生的原因：
Qos=Quality of Service，qos是Dubbo的在线运维命令，可以对服务进⾏动态的配置、控制及查询，Dubboo2.5.8新版本重构了telnet（telnet是从Dubbo2.0.5开始⽀持的）模块，提供了新的telnet命令支持，新版本的telnet端⼝与dubbo协议的端⼝是不同的端⼝，默认为22222。正是因为这个问题：如果在⼀台服务器里面，启动provider是22222端⼝，⽽consumer启动时就会报错了。

xml解决方案

<dubbo:parameter key="qos.enable" value="true"/> <!--
是否开启在线运维命令 -->
<dubbo:parameter key="qos.accept.foreign.ip" value="false"/> <!--
不允许其他机器的访问 -->
<dubbo:parameter key="qos.port" value="33333"/> <!--
修改port-->

boot解决方案

dubbo.application.qos.enable=true
dubbo.application.qos.port=33333
dubbo.application.qos.accept.foreign.ip=false

细节补充

  1. 协议、端口
provider基于dubbo协议 默认的端⼝是20880
<dubbo:protocol name="dubbo" port="20880"/>
但是随着应⽤数量过⼤如果显示指定协议端⼝，会容易造成端⼝冲突所以建议按照如下写法设置
端⼝
<dubbo:protocol name="dubbo" port="-1"/>

  1. 应用程序运行过程浅析

    • 为什么provider提供了UserService的实现，而在另一个JVM中的consumer中可以调用？Consumer中调用的到底是什么？

      实际上调用的是远端UserServiceImpl的代理对象 Proxy

    • 代理的核心工作是什么？

      被consumer实际调用，通过代理对consumer屏蔽网络通信的过程（通信方式、协议、序列化），数据传递。

基于SpringBoot的方式使用Dubbo

SpringBoot应用Dubbo开发应用的核心思路分析

深度封装，把公⽤的配置放置到application.yml中，把个性的配置应⽤注解进⾏设置。

provider的处理

provider的处理

consumer的处理

consumer的处理

编码开发

provider模块

创建新的module

provider模块

再引入api模块和dubbo-starter

<dependency><groupId>com.sjdwz</groupId><artifactId>dubbo-01-api</artifactId><version>1.0-SNAPSHOT</version>
</dependency>
<dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>3.2.0</version>
</dependency>

创建applicaion.yml；将公共的配置放到这里面：

applicaion.yml

个性化的配置使用注解来完成；

DubboService注解

启动类上加**@EnableDubbo**注解：

启动类

启动日志

consumer模块

consumer模块

再引入api模块和dubbo-starter

<dependency><groupId>com.sjdwz</groupId><artifactId>dubbo-01-api</artifactId><version>1.0-SNAPSHOT</version>
</dependency>
<dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>3.2.0</version>
</dependency>

创建applicaion.yml；将公共的配置放到这里面：

applicaion.yml

在启动类中加上注解

启动类

在测试类中进行测试：

@SpringBootTest
class Dubbo05BootConsumerApplicationTests {//url是刚才输出的url@DubboReference(url = "dubbo://192.168.96.1:20880/com.sjdwz.service.UserService")private UserService userService;@Testpublic void test1() {boolean ret = userService.login("sjdwz", "123456");System.out.println("ret = " + ret);}
}

输出

@EnableDubbo注解的作用

  1. @EnableDubbo ⽤于扫描@DubboService，并把对应的对象实例化、发布成RPC服务。扫描的路径：应⽤这个注解的类（启动类）所在的包及其子包。
  2. 如果@DubboService注解修饰的类没有放到@EnableDubbo注解修饰类当前包及其⼦包，还希望能够扫描到它该如何处理？
    可以通过@DubboComponentScan(basePackages ={“org.sjdwz.service”})，显示的指定扫描的路径
  3. yml进⾏配置扫描@DubboService 并把对应的对象实例化，发布成RPC服务。
    dubbo.scan.base-packages 等同于 @EnableDubbo

@DubboService注解的作用

  1. 应⽤@DubboService注解修饰类型，SpringBoot会创建这个类型的对象，并发布成Dubbo服务。
  2. @DubboService 等同于 @Component(@Service) @Bean注解的创建对象的作⽤。
    通过源码SingletonObjects可以验证
  3. @DubboService
    a. 创建对象 等同于 @Component(@Service) @Bean
    b. 发布成RPC服务
  4. 后续开发过程中如果考虑兼容性，建议实现类不仅仅要加⼊@DubboService注解，同时也要加⼊@Service注解

@DubboReference注解的作用

  1. 在Consumer端，通过@DubboReference，注⼊远端服务的代理对象。
  2. @DubboReference类似于原始Spring开发中@Autowired注解的作⽤。

http://www.ppmy.cn/news/1116520.html

相关文章

前端实现打字效果

前端实现打字效果

前端实现打字效果 不带光标 只一次播放 HTML <!-- 需要在初始化的时候不显示文字 --> <div id"typing"></div>CSS #typing {position: relative;font-size: 24px;font-family: Arial, sans-serif;padding: 10px; }JS const text "要显…
阅读更多...
LeetCode 78 子集

LeetCode 78 子集

1、在使用回溯算法时&#xff0c;循环中&#xff0c;对于数组和字符串的处理是不一样的 数组是在回溯时indexi1&#xff0c;而字符串是在循环时便加1&#xff0c;然后回溯使用的indexi。&#xff08;子集使用的是i1&#xff09; 2、似乎使用new ArrayList<>(LinkedList…
阅读更多...
大数据Hadoop高可用

大数据Hadoop高可用

HA高可靠集群 hdfs中的HA搭建&#xff1a; 三个namenode如何保证数据一致&#xff1f; fsimage: 更新频率低, 由一台进行修改&#xff0c;剩下的所有机器进行同步edits: 更新频率高&#xff0c;JN日志节点&#xff08;hadoop的专属zk&#xff0c;只做数据全局一致性保证&…
阅读更多...
MySQL 某个字段存储不了内容

MySQL 某个字段存储不了内容

1. 原因 某个字段存储的内容过大 2. 解决 修改max_allowed_packet参数 max_allowed_packet参数是指mysql服务器端在一次传送数据包的过程当中最大允许的数据包大小。如果超过了设置的最大长度&#xff0c;则会数据库保持数据失败。 2.1 查询参数 show variables like %max…
阅读更多...
数据库计算机三级等级考试--数据库技术相关知识点和笔记

数据库计算机三级等级考试--数据库技术相关知识点和笔记

数据库计算机三级等级考试–数据库技术 计算机三级等级考试笔记,是博主通过计算机三级数据库技术考试的相关笔记&#xff0c;此篇博客&#xff0c;不仅适合需要考计算机三级考试的各位考生&#xff0c;也适合在职场处理关于数据库的部分操作&#xff0c;个人认为算是一篇使用性…
阅读更多...
Angular变更检测机制

Angular变更检测机制

前段时间遇到这样一个 bug&#xff0c;通过一个 click 事件跳转到一个新页面&#xff0c;新页面迟迟不加载&#xff1b; 经过多次测试发现&#xff0c;将鼠标移入某个 tab &#xff0c;页面就加载出来了。 举个例子&#xff0c;页面内容无法加载&#xff0c;但是将鼠标移入下图…
阅读更多...
图解 LeetCode 算法汇总——二分查找

图解 LeetCode 算法汇总——二分查找

二分查找&#xff08;Binary Search&#xff09;是一种在有序数组中查找特定元素的高效算法。它的基本思想是将目标值与数组中间的元素进行比较&#xff0c;如果目标值小于中间元素&#xff0c;则在数组的左半部分继续查找&#xff0c;否则在右半部分查找&#xff0c;不断缩小搜…
阅读更多...
【Vue】入门及生命周期（前后端分离）

【Vue】入门及生命周期（前后端分离）

目录 一、Vue简介 1、Vue.js是什么 2、库和框架的区别 2.1 库(Library) 2.2 框架(Framework) 3、MVVM的介绍 二、Vue入门 1、Vue快速入门 2、Vue的优势 三、Vue事件 四、Vue生命周期 1、实例 一、Vue简介 1、Vue.js是什么 Vue是一款流行的构建用户界面(UI)的[渐进式…
阅读更多...
最新文章

Copyright @ 2022~2023