springCloud Finchley 实战入门(基于springBoot 2.0.3)【四 Ribbon 服务容错保护】

本文涉及的产品
传统型负载均衡 CLB,每月750个小时 15LCU
应用型负载均衡 ALB,每月750个小时 15LCU
EMR Serverless StarRocks,5000CU*H 48000GB*H
简介: spring Cloud RibbonRibbon是一个基于HTTP和TCP协议的客户端负载均衡工具,他也是基于Netflix Ribbon实现。通过Spring Cloud的封装,可以让我们很容易的将面向服务的REST模板请求自动转换成客户端负载均衡的调用。

spring Cloud Ribbon

Ribbon是一个基于HTTP和TCP协议的客户端负载均衡工具,他也是基于Netflix Ribbon实现。通过Spring Cloud的封装,可以让我们很容易的将面向服务的REST模板请求自动转换成客户端负载均衡的调用。虽然Ribbon只是一个工具类框架,不像服务注册中心、配置中心、API网关那样需要独立部署,但是他几乎存在于每一个Srping Cloud构建的微服务和基础设施中。

客户端负载均衡

负载均衡在系统架构中是一个非常重要的,并且是不得不去实施的内容。因为负载均衡是对系统的高可用、网络压力的缓解和处理能力的扩容的一个重要的手段之一。我们通常说的负载均衡都是指服务端的负载均衡,其中服务端的负载均衡分为硬件负载均衡和软件负载均衡。硬件负载均衡主要通过服务器节点之间安装专门的负载均衡设备,而软件负载均衡则是通过在服务器安装一些具有负载均衡的软件来实现,比如:Nginx;
而客户端的负载均衡和服务端的负载均衡最大的不同点在于服务清单所存储的位置。在客户端负载均衡中,所有的客户端节点都维护着自己要访问的服务端清单。而这些服务清单均来自服务注册中心。

入门案例

我们接着上一篇的创建的service-user项目。我们在该项目中写一个业务接口实现。


img_be6bec5d8a4fd194e1f3a78c383780b6.png
15324818571.jpg

创建一个UserManagementController类。并且暴露一个get请求的服务接口;模拟返回用户数据。代码如下

@RestController
@Log
public class UserManagementController {

    @Value("${server.port}")
    String serverPort;
    
    @GetMapping("/listUsers")
    public String ListUsers() throws InterruptedException {
        /**
         * 模拟从数据库查询
         */
        List<Map<String, Object>> users = new ArrayList<Map<String, Object>>();
        for (int i = 1; i < 5; i++) {
            Map<String, Object> user = new HashMap<String, Object>();
            user.put("id", i);
            user.put("name", "小明" + i);
            users.add(user);
        }
        log.info("/listUsers, host:"+serverPort);
        return "服务器端口号:   " + serverPort + "   |   用户信息:   " + users.toString();
    }
}

这里说一个日志输出,我比较喜欢使用lombok,所以项目中的日志输出我都会使用这种方式来输出日志。
使用的方式很简单;
在pom.xml添加lombok的依赖

 <dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
 </dependency>

然后我们在类名添加@Log注解就可以了,关于其他更多的用户,大家可以网上了解一下。

重启项目,访问http://localhost:8802/listUsers,如果有数据返回,则说明服务接口正常了。

img_17fb0e42a4ee41cdc2f70862153f5b12.png
1532482987004.png

到这里service-user的服务接口已经写好了。接下来我们就创建一个新的springBoot 类型的module,命名为"eureka-bussniss-service-user-client-ribbon"做为服务消费者。
创建的过程中我们选中Eureka-server和Ribbon两个依赖即可:


img_975f36544e0b8fab9406f5f3425a4dcc.png
1532483177335.png

创建项目成功后,修改application.yml

spring:
  application:
    name: service-user-ribbon
server:
  port: 8901
eureka:
  client:
    serviceUrl:
      defaultZone: http://peer1:8762/eureka/,http://peer2:8763/eureka/

项目主类名添加@EnableEurekaClient注解,并且注入RestTemplate类。主类的代码如下:

@SpringBootApplication
@EnableEurekaClient
public class EurekaBussnissServiceUserClientRibbonApplication {

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

    @Bean
    @LoadBalanced //开启客户端负载均衡
    RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

上面的@LoadBalanced 注解表示开启客户端的负载均衡。
接下来,我们新建一个UserManagementRibbonClient请求类,实现负载均衡请求service-user服务,代码如下:

@RestController
@Log
public class UserManagementRibbonClient {

    @Value("${server.port}")
    private String port;

    @Autowired
    RestTemplate restTemplate;

    @GetMapping("/listUsersByRibbon")
    public String ListUsersByRibbon() {

        long start = System.currentTimeMillis();
        String result = this.restTemplate.getForObject("http://service-user/listUsers", String.class);
        long end = System.currentTimeMillis();
        log.info("Spend Time :"+(end-start));
        return result;
    }
}

说明:service-user 为服务名称, 一个服务名称对应多个主机IP和端口号,这样根据服务名调用就实现了负载均衡的功能。
这样服务消费者就已经创建好了,接下来我们来验证测试Ribbon负载均衡的请求。

我们先把服务提供者service-user开启两个分别对应端口8802和8803。启动的方式可以向之前服务注册中心的方式,也可以直接在Idea里面启动,这里我们选择在Idea启动。启动的方式:


img_dbf00934181faca12a19e95b4880c015.png
1532484083723.png

修改这里,把single instance only的勾去掉。


img_89854328ddae37d737f6e750b8bb4ad2.png
1532484159323.png

启动完8802端口后,我们修改一个application.yml的port为8803,即可启动8803对应的服务了。
接着把"eureka-bussniss-service-user-client-ribbon"服务也启动了。
这个时候我们访问注册中心的面板信息,可以看到相关的服务实例已经注册到了注册中心了。


img_97f083dd9aa083c82a3ca64acd0f09ed.png
1532484522884.png

这个时候我们访问service-user-ribbon的接口地址:http://localhost:8901/listUsersByRibbon
这里可以看到接口响应信息轮询的返回8802和8803的信息。

img_65f23350764fcdf53350200fc412d51a.png
1532484661718.png

img_236f8b69de178c1868ad4a018038f663.png
1532484671894.png

到这里说明Ribbon已经实现负载均衡请求了。
项目的源码

接口的负载均衡已经实现了,当时这里就会有一个问题了,如果服务提供者service-user其中一个服务挂了,ribbon还是会负载均衡到这个挂掉的服务的。例如:8把002端口停掉,然后继续访问http://localhost:8901/listUsersByRibbon。我们会看到当接口负载到8802的时候就报错了。

img_7ee439ea7c81a262fabc51445afc576d.png
1532485030017.png

只有负载到8803才正常,这里如果是生产环境是可能不能出现这张情况的。

如果我们使用过Nginx,就会知道Nginx有一种容灾的功能,就是如果nginx反向代理的其中一个服务节点挂了不能访问了,nginx会自动踢掉这个节点,不会代理到这个节点的。在spring cloud中的Hystrix组件的主要作用就是服务容错保护来实现这个功能的。

所以我们下一篇会使用Hystrix组件来实现客户端负载均衡的服务容错保护。

相关实践学习
SLB负载均衡实践
本场景通过使用阿里云负载均衡 SLB 以及对负载均衡 SLB 后端服务器 ECS 的权重进行修改,快速解决服务器响应速度慢的问题
负载均衡入门与产品使用指南
负载均衡(Server Load Balancer)是对多台云服务器进行流量分发的负载均衡服务,可以通过流量分发扩展应用系统对外的服务能力,通过消除单点故障提升应用系统的可用性。 本课程主要介绍负载均衡的相关技术以及阿里云负载均衡产品的使用方法。
目录
相关文章
|
28天前
|
JSON Java 网络架构
elasticsearch学习四:使用springboot整合 rest 进行搭建elasticsearch服务
这篇文章介绍了如何使用Spring Boot整合REST方式来搭建和操作Elasticsearch服务。
104 4
elasticsearch学习四:使用springboot整合 rest 进行搭建elasticsearch服务
|
2月前
|
设计模式 Java 关系型数据库
【Java笔记+踩坑汇总】Java基础+JavaWeb+SSM+SpringBoot+SpringCloud+瑞吉外卖/谷粒商城/学成在线+设计模式+面试题汇总+性能调优/架构设计+源码解析
本文是“Java学习路线”专栏的导航文章,目标是为Java初学者和初中高级工程师提供一套完整的Java学习路线。
374 37
|
28天前
|
监控 Dubbo Java
dubbo学习三:springboot整合dubbo+zookeeper,并使用dubbo管理界面监控服务是否注册到zookeeper上。
这篇文章详细介绍了如何将Spring Boot与Dubbo和Zookeeper整合,并通过Dubbo管理界面监控服务注册情况。
66 0
dubbo学习三:springboot整合dubbo+zookeeper,并使用dubbo管理界面监控服务是否注册到zookeeper上。
|
28天前
|
自然语言处理 Java Maven
elasticsearch学习二:使用springboot整合TransportClient 进行搭建elasticsearch服务
这篇博客介绍了如何使用Spring Boot整合TransportClient搭建Elasticsearch服务,包括项目创建、Maven依赖、业务代码和测试示例。
76 0
elasticsearch学习二:使用springboot整合TransportClient 进行搭建elasticsearch服务
|
2月前
|
缓存 前端开发 Java
springboot 的单体服务 字典参数转译
本文介绍了如何在Spring Boot项目中使用缓存来管理字典参数,并确保前后端数据一致性。首先,通过`@EnableCaching`启用缓存功能,接着创建一个自定义的字典缓存类`DicCache`。然后,通过配置类将`DicCache`添加到`cacheManager`中。此外,对字典服务进行改造,使用`@CachePut`和`@CacheEvict`注解保证数据一致性。最后,实现自定义注解`@DicSerializer`和序列化处理类`DictSerializerHandel`,用于在序列化过程中自动转换字典值。通过这种方式,可最小化代码改动并提高系统性能。
springboot 的单体服务 字典参数转译
|
1月前
|
负载均衡 网络协议 Java
浅谈Springboot与Springcloud的区别
浅谈Springboot与Springcloud的区别
35 1
|
3月前
|
小程序 JavaScript Java
微信小程序+SpringBoot接入后台服务,接口数据来自后端
这篇文章介绍了如何将微信小程序与SpringBoot后端服务进行数据交互,包括后端接口的编写、小程序获取接口数据的方法,以及数据在小程序中的展示。同时,还涉及到了使用Vue搭建后台管理系统,方便数据的查看和管理。
微信小程序+SpringBoot接入后台服务,接口数据来自后端
|
3月前
|
Java 微服务 Spring
SpringBoot+Vue+Spring Cloud Alibaba 实现大型电商系统【分布式微服务实现】
文章介绍了如何利用Spring Cloud Alibaba快速构建大型电商系统的分布式微服务,包括服务限流降级等主要功能的实现,并通过注解和配置简化了Spring Cloud应用的接入和搭建过程。
SpringBoot+Vue+Spring Cloud Alibaba 实现大型电商系统【分布式微服务实现】
|
3月前
|
Java Windows
SpringBoot Windows 自启动 - 通过 Windows Service 服务实现
SpringBoot Windows 自启动 - 通过 Windows Service 服务实现
104 2
|
3月前
|
Java 开发者 Spring
"揭秘SpringBoot魔法SPI机制:一键解锁服务扩展新姿势,让你的应用灵活飞天!"
【8月更文挑战第11天】SPI(Service Provider Interface)是Java的服务提供发现机制,用于运行时动态查找和加载服务实现。SpringBoot在其基础上进行了封装和优化,通过`spring.factories`文件提供更集中的配置方式,便于框架扩展和组件替换。本文通过定义接口`HelloService`及其实现类`HelloServiceImpl`,并在`spring.factories`中配置,结合`SpringFactoriesLoader`加载服务,展示了SpringBoot SPI机制的工作流程和优势。
56 5