微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

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

分类：常见问题作者：qq_40585384AI导航网

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负载均衡

相关推荐

使用Nvdia显卡驱动自带的录屏功能录制游戏
显卡天梯图2024最新版 显卡性能天梯图2024最新排行榜
显卡天梯图2024最新版，显卡是电脑进行图形处理的重要设备，显卡的性能高低决定了电脑的性能高低。显卡天梯图用数据直观地为我们展示了具体性能数据，让我们可以根据这些参数进行显卡性能的选择，让我们可以获得符合自己使用需求的显卡
初始化电脑时出现问题怎么办 初始化电脑时出现问题解决方法
初始化电脑时出现问题怎么办，可以使用win系统的安装介质，连接电脑后重启，选择从介质中引导，然后点击修复计算机-疑难解答-高级选项-自动修复，等待一段时间就可以了。有些小伙伴在初始化电脑是碰到了问题，下面小编给大家带来了初始化电脑时出现问题解决方法。
todesk远程开机怎么设置 todesk远程开机教程
todesk远程开机怎么设置，两台电脑要在同一局域网内，然后需要修改BIOS，还要修改电源选项。我们在使用todesk软件时，有些小伙伴想要进行远程开机，那应该怎么设置呢，下面小编就给大家带来了todesk远程开机教程，一起来看看吧。
油猴谷歌插件怎么安装 油猴谷歌插件安装教程
油猴谷歌插件怎么安装，可以通过谷歌应用商店进行安装，需要才能打开应用商店，或者是下载插件到本地，解压后把Tampermonkey.crx文件拖到谷歌浏览器的程序扩展页面进行安装。小伙伴想知道谷歌浏览器怎么安装油猴，下面小编给大家带来了油猴谷歌插件安装教程。
16g虚拟内存设置多少合适 16g虚拟内存最佳设置方法
虚拟内存这个名词想必很多人都听说过，我们在使用电脑的时候，特别是玩大型游戏时候，如果内存空间不足则会开启使用虚拟内存，这样就能够防止死机的情况。有不少的新用户在安装系统的时候，不知道16G的内存设置多大的虚拟内存，下面小编就详细给大家讲解下多少才
win11本地账户怎么改名 win11本地账户改名图文介绍
win11本地账户怎么改名?win11很多操作都变了样，用户如果想要修改用户名称可能找不到具体的位置在哪。win11系统本地账户的名称都是默认的，很多用户为了有特征性想要更改一些有趣的名称，这样看起来更有个性点。win11本地账户怎么改名，我们可以通过打开控制面板，然后
网速怎么看快慢k/s,b/s是什么意思 网速怎么看快慢k/s,b/s哪个快
网速怎么看快慢k s,b s是什么意思，k b就是网速1kb每秒，b s就是网速1b每秒,1kb=1024b。很多小伙伴在下载或上传文件时都会看着kb s，b s等等单位，这些单位是什么意思呢，哪个比较快呢，下面小编给大家带来了网速怎么看快慢k s,b s哪个快的相关资讯。
笔记本声卡驱动怎么更新 笔记本声卡驱动更新方法
我们在使用电脑的时候，经常需要对各种驱动进行更新，如果长期不更新会导致无法正常的使用。有不少的用户在问，该怎么更新声卡驱动？其实很简单，我们右键“我的电脑”打开“设备管理器”，找到“声音”选项并右键“realtek audio”更新驱动程序即可，具体如下。
应用程序无法正常启动0x0000142怎么办 0x0000142错误代码解决办法
应用程序无法正常启动0x0000142怎么办?我们的电脑在日经月累的使用下，难免会出现各种问题，最近有小伙伴反应自己的电脑出现应用程序无法正常启动0x0000142的错误代码，这要怎么解决呢?下面小编就告诉大家电脑遇到0x0000142错误代码的解决办法。
苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-bootreact-native