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

转载作者：我是一只小鸟更新时间：2023-09-19 23:01:58

29

4

Dubbo3程序的初步开发

Dubbo3升级的核心内容

易⽤性。

开箱即⽤，易⽤性⾼，如 Java 版本的⾯向接⼝代理特性能实现本地透明调⽤功能丰富，基于原⽣库或轻量扩展即可实现绝⼤多数的微服务治理能⼒。更加完善了多语言支持（GO PYTHON RUST) 。
超⼤规模微服务实践。
- ⾼性能通信（Triple GRPC)
- ⾼可扩展性 (SPI 多种序列化⽅式多种协议)
- 丰富的服务治理能⼒
- 超⼤规模集群实例⽔平扩展
云原生友好。
- 容器调度平台（Kubernetes）。
  
  将服务的组织与注册交给底层容器平台，如 Kubernetes，这是更云原⽣的⽅式.
- Service Mesh 。
  
  原有Mesh结构中通过Sidecar完成负载均衡、路由等操作，但是存在链路的性能损耗⼤，现有系统迁移繁琐等问题。 Dubbo3 引⼊Proxyless Mesh，直接和I控制⾯交互[istio]通信。集成 ServiceMesh更为⽅便，效率更高.

Dubbo3前言

代码结构及其术语解释

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

模块结构

开发步骤

开发commons-api 通⽤内容
开发provider 功能提供者
开发 consumer 功能调⽤者【功能消费者】
如需要注册中心，开发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-opens
        java.base/jdk.internal.misc=ALL-UNNAMED
        --add-opens
        java.base/java.nio=ALL-UNNAMED
        --add-opens
        java.base/java.lang=ALL-UNNAMED
	b. 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{
    @Override
    public 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工厂启动类

运行起来发现，会导出一个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

细节补充

协议、端口

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

应用程序运行过程浅析。
- 为什么provider提供了UserService的实现，而在另一个JVM中的consumer中可以调用？Consumer中调用的到底是什么?
  
  实际上调用的是远端UserServiceImpl的代理对象 Proxy 。
- 代理的核心工作是什么?
  
  被consumer实际调用，通过代理对consumer屏蔽网络通信的过程（通信方式、协议、序列化），数据传递.

基于SpringBoot的方式使用Dubbo

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

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

provider的处理

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模块

再引入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;

    @Test
    public void test1() {
        boolean ret = userService.login("sjdwz", "123456");
        System.out.println("ret = " + ret);
    }
}

@EnableDubbo注解的作用

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

@DubboService注解的作用

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

@DubboReference注解的作用

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

最后此篇关于Dubbo3应用开发—XML形式的Dubbo应用开发和SpringBoot整合Dubbo开发的文章就讲到这里了,如果你想了解更多关于Dubbo3应用开发—XML形式的Dubbo应用开发和SpringBoot整合Dubbo开发的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！。

29

4

0

文章推荐：【python技巧】文本处理-re库字符匹配

文章推荐： 5.2磁盘CRC32完整性检测

【Springboot】SpringBoot-Admin服务监控+告警通知
SpringBoot-Admin 服务监控简单介绍 Spring Boot Actuator 是 Spring Boot 自带的一个功能模块，提供了一组已经开箱即用的生产环境下常用
java - Springboot : How to execute custom mongodb query by springboot?
我想查找通过关键字匹配字段 nameEnglish 或 nameChinese 的模型列表。我花了一个多小时谷歌搜索但我做不到。请帮忙。 Springboot Mongo 入门示例 https://s
java - 为什么我的实体不能与 SpringBoot 一起工作，尽管它可以在没有 SpringBoot 的情况下工作
(请注意:在调查 this issue 时，我更好地发现了我在此处介绍的问题根源) 我对 Hibernate 和 SpringBoot 非常陌生。我的项目涉及一个搜索引擎，其中索引(javafx 客户
java - Springboot -> Springboot 2 : 2 Spring WebApplicationInitializers detected on classpath
我最近有一个 Web 应用程序从 springboot 升级到 springboot 2。当我将其部署到 Tomcat 8 时，它似乎启动了，但没有完全启动。在 localhost.2019-09-
java - com.springboot.todoController.TodoController 中的字段 todoService 需要类型为 'com.springboot.todo.TodoService' 的 bean，但无法找到
我是 Spring boot 的新手...我在运行 Controller 时遇到问题， Description: Field todoService in com.springboot.todoCon
SpringBoot, Hibernate and AWS RDS (Aurora) with new CA rds-ca-ecc384-g1(SpringBoot、休眠和AWS RDS(Aurora)以及新的CA rds-ca-ecc384-G1)
我有一个SpringBoot应用程序，它使用以下配置与PostgreSQL通信，通过AWS Beanstrik部署：。在我将AWS Aurora证书更新为rds-ca-ecc384-g1之前，一切都很
Springboot---使用国内的AI大模型对话
实在是不知道标题写什么了可以在评论区给个建议哈哈哈哈先用这个作为标题吧尝试使用国内给出的 AI 大模型做出一个可以和 AI 对话的网站出来使用智普AI 只能在控制
SpringBoot+ShardingSphere轻松实现数据库字段加解密
一、介绍在实际的软件系统开发过程中，由于业务的需求，在代码层面实现数据的脱敏还是远远不够的，往往还需要在数据库层面针对某些关键性的敏感信息，例如：身份证号、银行卡号、手机号、工资等信息进行加密存储
SpringBoot+Selenium模拟用户操作浏览器
Selenium Selenium是一个用于Web应用程序自动化测试的开源工具套件。它主要用于以下目的：浏览器自动化：Selenium能够模拟真实用户在不同浏览器（如Chrome、Fire
SpringBoot+mail轻松实现各类邮件自动推送
一、简介在实际的项目开发过程中，经常需要用到邮件通知功能。例如，通过邮箱注册，邮箱找回密码，邮箱推送报表等等，实际的应用场景非常的多。早期的时候，为了能实现邮件的自动发送功能，通常会使用 Ja
SpringBoot：基于redis自定义注解实现后端接口防重复提交校验
SpringBoot：基于redis自定义注解实现后端接口防重复提交校验一、添加依赖 org.springframework.boot spring
SpringBoot：使用Jackson完成全局序列化配置
SpringBoot：使用Jackson完成全局序列化配置一、测试准备 com.fasterxml.jackson.core jackson-cor
springboot：整合rocketmq
springboot：整合rocketmq 一、简易消息操作生产者整合mq 导入依赖 org.springframework.boot
springboot：常用注解
springboot：常用注解一、spring常用注解包扫描+组件标注注解 @Component：泛指各种组件 @Controller、@Service、@Repository都可以称为@Comp
SpringBoot——实现WebService接口服务端以及客户端开发
我们经常需要在两个系统之间进行一些数据的交互，这时候我们就需要开发数据交互接口。一般来说，遇到比较多的接口有HTTP接口、WebService接口、FTP文件传输。今天我要来学习一下在SpringB
SpringBoot-Web应用安全策略实现
背景近期项目上线，甲方要求通过安全检测才能进行验收，故针对扫描结果对系统进行了一系列的安全加固，本文对一些常见的安全问题及防护策略进行介绍，提供对应的解决方案跨站脚本攻击 XSS常发生于论坛评论等
springBoot 通过使用log4j2
1.排除 Spring-boot-starter 默认的日志配置将原本的 spring-boot-starter 改为 org.springframework.boot
springboot：解决跨域问题
springboot：解决跨域问题一、跨域简介 URL的组成: // 协议 + 域名（子域名 + 主域名） + 端口号 + 资源地址 http://www.baidu.com:8080/ 只要协
SpringBoot—自定义Starter篇
一、自定义Starter 的思路：创建一个Maven工程，创建三个模块一个模块为demo-app，一个模块为demo-module，一个模块为demo-module-springboot-star
SpringBoot + WebSocket实现点对点在线单聊案例
1.pom.xml 4.0.0 org.springframework.boot spring-boot-starter-parent

首页

博学

6Ren·AI

商城

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

Dubbo3程序的初步开发

Dubbo3升级的核心内容

Dubbo3前言

代码结构及其术语解释

开发步骤

本专题所使用软件版本

JDK与Dubbo版本的关系

基于XML的Dubbo3程序开发

环境搭建

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

实体entity

接口service

开发provider模块

在provider模块添加依赖

实现接口

创建Spring配置文件，配置Dubbo相关内容使得UserServiceImpl可以跨虚拟机来调用

Spring工厂启动类

开发consumer模块

引入api模块依赖

创建Spring配置文件

创建启动类

注意

细节补充

基于SpringBoot的方式使用Dubbo

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

provider的处理

consumer的处理

编码开发

provider模块

consumer模块

@EnableDubbo注解的作用

@DubboService注解的作用

@DubboReference注解的作用