Dubbo实战运用Demo、SpringBoot整合Dubbo、Dubbo中超时重试和负载均衡策略

分类：菜鸟笔记作者：qq_40585384

Dubbo与SpringBoot整合

项目结构：

在这里插入图片描述

工程依赖POM

<dependencyManagement>
    <dependencies>
        <!-- Spring Boot -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-dependencies</artifactId>
            <version>${spring-boot.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>

        <!-- Apache Dubbo  -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-bom</artifactId>
            <version>${dubbo-version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>${dubbo-version}</version>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>javax.servlet</groupId>
                    <artifactId>servlet-api</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>
</dependencyManagement>

<dependencies>
    <!-- Dubbo Spring Boot Starter -->
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-spring-boot-starter</artifactId>
        <version>${dubbo-version}</version>
    </dependency>
    <!-- Dubbo核心组件 -->
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo</artifactId>
    </dependency>
    <!--Spring Boot 依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>${spring-boot.version}</version>
    </dependency>
    <!-- Zookeeper客户端框架 -->
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>4.0.1</version>
    </dependency>
    <!-- Zookeeper dependencies -->
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-dependencies-zookeeper</artifactId>
        <version>${dubbo-version}</version>
        <type>pom</type>
        <exclusions>
            <exclusion>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
</dependencies>

接口服务

为便于客户端与服务端的RPC接口引用， 这里对RPC接口做统一封装。

在这里插入图片描述

提供的接口：

public interface OrderService {
	
	/**
	 * 获取订单详情
	 *
	 * @param orderId
	 * @return
	 */
	String getOrder(Long orderId);
}

服务端工程

在这里插入图片描述

pom文件依赖：

<dependencies>
    <dependency>
        <groupId>com.yida</groupId>
        <artifactId>dubbo-interface</artifactId>
        <version>${project.parent.version}</version>
    </dependency>

    <!-- Dubbo Spring Boot Starter -->
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-spring-boot-starter</artifactId>
        <version>${dubbo-version}</version>
    </dependency>
    <!-- Dubbo 核心依赖 -->
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo</artifactId>
    </dependency>

</dependencies>

RPC接口服务

@DubboService(version = "${dubbo.spring.provider.version}")
public class OrderServiceImpl implements OrderService {
	/**
	 * 服务端口
	 */
	@Value("${server.port}")
	private String serverPort;
	
	@Value("${dubbo.spring.provider.version}")
	private String serviceVersion;
	
	@Override
	public String getOrder(Long orderId) {
		// try {
		// 	Thread.sleep(1500);
		// } catch (InterruptedException e) {
		// 	e.printStackTrace();
		// }
		// System.out.println(1/0);
		String result = "get order detail ,orderId=" + orderId + ",serverPort=" + serverPort + ",serviceVersion=" + serviceVersion + "\t" + UUID.randomUUID();
		System.out.println(result);
		return result;
	}
}

通过DubboService注解， 声明为RPC服务，version可以标识具体的版本号， 消费端需匹配保持一致。

配置文件

server:
  port: 18081

spring:
  application:
    name: dubbo-springboot-demo-provider

dubbo:
  scan:
    base-packages: com.yida
  protocol:
    name: dubbo  # Dubbo 通讯协议
    port: -1  # Dubbo服务提供的端口， 配置为-1，代表为随机端口 默认20880
  registry:
    address: zookeeper://112.124.**.**:2181
    file: ${user.home}/dubbo-cache/${spring.application.name}/dubbo.cache
  metadata-report:
    timeout: 90000
  config-center:
    timeout: 90000
  spring:
    provider:
      version: 1.0.0

Spring Boot启动程序

@SpringBootApplication
public class DubboProviderApplication {
	public static void main(String[] args) {
		SpringApplication.run(DubboProviderApplication.class, args);
	}
}

消费端工程

在这里插入图片描述

pom文件依赖：

<dependencies>
    <dependency>
        <groupId>com.yida</groupId>
        <artifactId>dubbo-interface</artifactId>
        <version>${project.parent.version}</version>
    </dependency>

    <!-- dubbo -->
    <dependency>
        <groupId>org.apache.dubbo</groupId>
        <artifactId>dubbo-spring-boot-starter</artifactId>
        <version>${dubbo-version}</version>
    </dependency>

</dependencies>

消费端控制器

@Controller
@RequestMapping("/order")
public class OrderController {
	
	private final Logger logger = LoggerFactory.getLogger(getClass());
	
	
	/**
	 * 订单服务接口
	 */
	@DubboReference(version = "${dubbo.spring.provider.version}",timeout = 1000,retries = 3,loadbalance = "roundrobin")
	private OrderService orderService;
	
	/**
	 * 获取订单详情接口
	 *
	 * @param orderId
	 * @return
	 */
	@RequestMapping("/getOrder")
	@ResponseBody
	public String getOrder(Long orderId) {
		String result = null;
		try {
			result = orderService.getOrder(orderId);
		} catch (Exception e) {
			logger.error(e.getMessage(), e);
		}
		return result;
	}
	
}

配置文件

server:
  port: 18084

spring:
  application:
    name: dubbo-spring-consumer

dubbo:
  spring:
    provider:
      version: 1.0.0
  registry:
    address: zookeeper://112.124.**.**:2181
    file: ${user.home}/dubbo-cache/${spring.application.name}/dubbo.cache
  metadata-report:
    timeout: 90000
  config-center:

timeout: 90000

工程调用

  1. 启动ZK注册中心
  2. 启动服务端， 运行DubboSpringProviderApplication
  3. 启动消费端， 运行DubboSpringConsumerApplication
  4. 请求获取订单接口， 地址：http://localhost:18084/order/getOrder?orderId=1234

调用成功：

在这里插入图片描述

不同配置覆盖关系

关于配置参看官方文档：https://dubbo.apache.org/zh/docsv2.7/user/configuration/

演示：
1、通过ProviderConfig配置全局超时（可通过yml配置覆盖）
2、在@DubboService注解上配置接口超时
3、在@DubboService注解上配置接口方法超时
4、在消费方进行配置，查看覆盖情况

配置规则：

在这里插入图片描述

  • 方法级优先，接口级次之，全局配置再次之。
  • 如果级别一样，则消费方优先，提供方次之。

Dubbo消费超时在客户端设置：

增加配置类：

/**
 * 设置超时时间
 */
@Configuration
public class DubboCustomerConfig {
	
	@Bean
	public ProviderConfig registryConfig() {
		ProviderConfig providerConfig = new ProviderConfig();
		providerConfig.setTimeout(1000);
		
		return providerConfig;
	}
}

同时可以在接口、服务、方法中设置超时时间，优先级关系看上面配置规则

_/**

  • 订单服务接口
    */
    @DubboReference(version = “${dubbo.spring.provider.version}”,timeout = 1000,retries = 3,loadbalance = “roundrobin”)
    _private OrderService orderService;

重试与容错处理机制

容错机制：

  • Failfast Cluster快速失败，只发起一次调用，失败立即报错。通常用于非幂等性的写操作，比如新增记录。
  • Failsafe Cluster失败安全，出现异常时，直接忽略。通常用于写入审计日志等操作。
  • Failback Cluster失败自动恢复，后台记录失败请求，定时重发。通常用于消息通知操作。
  • Forking Cluster并行调用多个服务器，只要一个成功即返回。通常用于实时性要求较高的读操作，但需要浪费更多服务资源。可通过 forks=“2” 来设置最大并行数。
  • Broadcast Cluster广播调用所有提供者，逐个调用，任意一台报错则报错。通常用于通知所有提供者更新缓存或日志等本地资源信息。

:::warning
调整客户端重试次数：
/**
* 订单服务接口
*/
@DubboReference(version = “${dubbo.spring.provider.version}”,retries = 3)
private OrderService orderService;
:::

负载均衡机制

Dubbo默认采用的是随机负载策略。

  • Random LoadBalance：默认随机，按权重设置随机概率。在一个截面上碰撞的概率高，但调用量越大分布越均匀，而且按概率使用权重后也比较均匀，有利于动态调整提供者权重。
  • RoundRobin LoadBalance加权轮询负载均衡，按公约后的权重设置轮询比率。存在慢的提供者累积请求的问题，比如：第二台机器很慢，但没挂，当请求调到第二台时就卡在那，久而久之，所有请求都卡在调到第二台上。
  • LeastActive LoadBalance最少活跃调用数，相同活跃数的随机，活跃数指调用前后计数差。活跃数其实就是在当前这个服务调用者中当前这个时刻 某个invoker（某个服务提供者的某个接口）某个方法的调用并发数，在调用之前+1 调用之后-1的一个计数器，如果出现多个活跃数相等invoker的时候使用随机算法来选取一个
  • ConsistentHash LoadBalance一致性 Hash，相同参数的请求总是发到同一提供者。当某一台提供者挂时，原本发往该提供者的请求，基于虚拟节点，平摊到其它提供者，不会引起剧烈变动。
  • ShortestResponseLoadBalance 最短响应时间负载均衡。从多个服务提供者中选择出调用成功的且响应时间最短的服务提供者，由于满足这样条件的服务提供者有可能有多个。所以当选择出多个服务提供者后要根据他们的权重做分析，如果权重一样，则随机。

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

dubbo负载均衡

相关推荐

如何学习编程？新手菜鸟如何学编程？
学习编程是顺着互联网的发展潮流，是一件好事。新手如何学习编程？其实不难，不过在学习编程之前你得先了解你的目的是什么？这个很重要，因为目的决定你的发展方向、决定你的发展速度。
it行业都是什么工作？it行业主要做什么？
IT行业是什么工作做什么？IT行业的工作有：产品策划类、页面设计类、前端与移动、开发与测试、营销推广类、数据运营类、运营维护类、游戏相关类等，根据不同的分类下面有细分了不同的岗位。
女生学Java好就业吗？女生适合学Java编程吗？
女生学Java好就业吗？女生适合学Java编程吗？目前有不少女生学习Java开发，但要结合自身的情况，先了解自己适不适合去学习Java，不要盲目的选择不适合自己的Java培训班进行学习。只要肯下功夫钻研，多看、多想、多练
mysql-connect-confused
Can’t connect to local MySQL server through socket \'/var/lib/mysql/mysql.sock问题 1.进入mysql路径
oracle基本命令
oracle基本命令 一、登录操作 1.管理员登录 # 管理员登录 sqlplus / as sysdba 2.普通用户登录
shell判断服务是否启动
一、背景 因为项目中需要通北京网络，所以需要连vpn，但是服务器有时候会断掉，所以写个shell脚本每五分钟去判断是否连接，于是就有下面的shell脚本。
SQL BETWEEN 操作符
BETWEEN 操作符选取介于两个值之间的数据范围内的值。这些值可以是数值、文本或者日期。
​​windows上传ipa到开发者中心app store的方法
假如你已经使用过苹果开发者中心上架app，你肯定知道在苹果开发者中心的web界面，无法直接提交ipa文件，而是需要使用第三方工具，将ipa文件上传到构建版本，开...
SQL 入门篇之什么是别名？
下面的 SQL 语句指定了两个别名，一个是 name 列的别名，一个是 country 列的别名。**提示：**如果列名称包含空格，要求使用双引号或方括号：
windows上传ipa文件到app store的方法​
在使用H5混合开发的app打包后，需要将ipa文件上传到appstore进行发布，就需要去苹果开发者中心进行发布。​
SQL AND & OR 运算符
+----+--------------+---------------------------+-------+---------+
C++ 数组
数组的声明并不是声明一个个单独的变量，比如 number0、number1、...、number99，而是声明一个数组变量，比如 numbers，然后使用 nu...
最全iOS 应用上架流程提交到AppStore
第一步：到appuploader官网下载辅助工具和iCloud驱动，使用前面创建的AppID登录。
SQL ALTER TABLE 语句
如需删除表中的列，请使用下面的语法（请注意，某些数据库系统不允许这种在数据库表中删除列的方式）：
dism操作巨慢
前不久在制作win11pe，制作了一版，1.26GB，太大了，不满意，想再裁剪下，发现这次dism mount正常，commit或discard巨慢，以前都很快...
三种方法卸载Symantec Endpoint Protection 赛门铁克
赛门铁克各个版本概览：https://knowledge.broadcom.com/external/article?legacyId=tech163829
python3.6、python3.10用什么版本的pip
实测Python 3.6.6用pip 21.3.1，再高就报错了，Python 3.10.7用pip 22.3.1是可以的
博通和诺顿
Broadcom Corporation （博通公司，股票代号AVGO）是全球领先的有线和无线通信半导体公司。其产品实现向家庭、 办公室和移动环境以及在这些环境...
高版本c4d在低版本windows系统上打开后不显示窗格
发现个问题，server2016上安装了c4d这些版本，低版本的正常显示窗格，但红色圈出的高版本c4d打开后不显示窗格，
基础网络windows不要使用TAT、如何卸载TAT
TAT：https://cloud.tencent.com/document/product/1340
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot