SpringCloud集成Eureka并实现负载均衡

亦凉 2024-02-18 10:17 76阅读 0赞

#### 文章目录 ####

*   *  前言
     *  1.Eureka
     *  2.整合Eureka作为注册中心
     *   *  2.1创建maven工程
         *  2.2依赖配置(Eureka-Server)
         *  2.3业务配置(Eureka-Client)
         *  2.4服务调用流程
     *  3.集成负载均衡

### 前言 ###

辗转两家公司也算工作了大半年，有幸见识过很多微服务架构，比如Dubbo+Redis的组合；Dubbo+Zookepper的组合；SpringCloud+Eureka的组合；SpringCloud+Nacos的组合…  
每一种组合都有属于自己的故事。  
**笔者认为：流行的不一定是最好的，如果只学习最流行的技术，这对以后的发展是很受限的。作为后端我们还是需要追求一定的广度。在以后的职业生涯中遇到一些特殊业务场景，才能够有更多的方案去灵活应对!当领导让你做技术选型，你直接好几套方案往他面前一摆，这真的很酷炫。**  
我想从当下最流行的SpringCloud体系谈起，从demo到底层循序渐进地整理出每一套组合，也非常希望能够对你起到一些绵薄的帮助~

故事从Eureka（译文：发现你了）说起…

### 1.Eureka ###

你问我Eureka是什么，其实就是一个基于SpringBoot的Java程序。解压Eureka-server的jar包之后，可以清楚看到一个标准的Java目录结构（还有一些存放前端页面的static文件）：  
![在这里插入图片描述][ec266564630a415a90927a3e449204f5.png]  
和nacos非常相似，只不过Eureka作为注册中心默认是将实例信息存放在eureka-server内存中，这比较适用于开发环境与测试环境，生产环境中还是建议配置相应的数据库表，做好数据持久化。在启动方式上，二者大体相似，shell脚本，maven模块启动，docker镜像…都可以实现。

### 2.整合Eureka作为注册中心 ###

给大家提供一个我已经整合好的demo(用户-支付的场景)，实现了服务间的注册与发现，并且有数据库表的支持，可以进行简单的调用：`https://gitee.com/lazy-sheep-java/cloud-eureka.git`  
下面采用将Eureka-server作为独立maven模块的方式启动来作为注册中心，其实本质也就是扫描运行Eureka-server的jar包而已，并在此过程中做一些人为配置：

#### 2.1创建maven工程 ####

创建一个父-子结构的maven工程,这个很简单点点点就好  
![在这里插入图片描述][5190c34d404c41f5af66b337b2284d65.png]

#### 2.2依赖配置(Eureka-Server) ####

作为独立的maven模块启动Eureka服务，只需要引入核心依赖，配置一个启动类，并配置相应路径端口即可提供服务：

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            </dependency>

![在这里插入图片描述][078c47ed74004ddb92afab7084e63861.png]

server:
      port: 10086 # 服务端口
    spring:
      application:
        name: eureka-server # eureka的服务名称
    eureka:
      client:
        service-url:  # eureka的地址信息
          defaultZone: http://127.0.0.1:10086/eureka

#### 2.3业务配置(Eureka-Client) ####

在业务模块中，都属于Eureka的客户端，其核心依赖为：

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>

并在相应的模块中配置服务端的地址  
![在这里插入图片描述][7419be13f5f64c15884d39fd3e6106ef.png]  
直到这里，当启动eureka-server、user-service模块之后，登录`http://127.0.0.1:10086`就会发现，Eureka-server作为注册中心已经成功注册了user-service服务，就像这样：  
![在这里插入图片描述][f0f4f1bc18324dfbba0eafa5858effb8.png]

#### 2.4服务调用流程 ####

在一个订单服务（A）调用用户服务（B）的模型中，A服务从Eureka-server获取B服务的地址。在A服务中使用RestTemplate通过getForObject()方法发送HTTP请求到B服务的地址，并处理返回的响应将其封装为指定的对象。  
![在这里插入图片描述][70083719c1384319aeb967f2174f5fef.png]  
这是一个最简单的调用链路。用非官方语言描述该过程，即A拿着B的使用说明书向B发消息并得到了回应，而Eureka正是那本说明书  
当然，在生产环境中一个微服务不太可能只会有单实例，更多的是一服务多实例的形式，当被调用方接收到调用请求，会去做负载均衡的处理，从而将请求落到合适实例上。以此来实现高可用、高扩展、高伸缩…

### 3.集成负载均衡 ###

首先给一个服务多部署几个实例：  
![在这里插入图片描述][eb8b0755208849e2955962bd42bf8a35.png]  
效果就像这样：  
![在这里插入图片描述][6ce10d1cd3f84e1c92eee09ff276f5d8.png]  
以前我们拉取的是某个服务的那个实例，现在则是拉取某个服务的实例列表。并在此基础上通过负载均衡将发来的请求指定到其中的某一实例上。  
**那要怎么实现呢？**  
只需要在**服务调用方**添加一个注解即可，最简单的方式就是这样：

@Bean
        @LoadBalanced //负载均衡
        public RestTemplate restTemplate() {
        
            return new RestTemplate();
        }

其实，在RestTemplate内部继承了一个拦截器（实现请求的转发，也就是负载均衡），而@LoadBalance注解则是帮助开启了该功能  
![在这里插入图片描述][da8486c477d54e4a964bd8e23d24db60.png]  
注解本身是没有实现相关功能的（后面分析实现原理）：  
![在这里插入图片描述][2d13d4fc6eb14814b00b866c3d8f8e2e.png]  
**言归正传**  
现在我们的user服务已经有三个实例，并且已经进入到了负载均衡的列表  
![在这里插入图片描述][ec5c21a485a449948dd042c0643a060e.png]  
我们用aop做一个切面，来把负载均衡分发到服务实例上的信息以日志的形式打印到控制台，以便更直观地看到均衡的效果：

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-aop</artifactId>
            </dependency>

注入Eureka客户端，通过提供的api来查询服务的客户端分发到的实例信息：

@Aspect
    @Component
    @Slf4j
    public class RequestAspect {
        
        @Resource
        EurekaClient eurekaClient;
    
        @Before(value = "execution(* com.yu7.user.web.*.*(..))")
        public void logBefore(JoinPoint joinPoint) {
        
            String methodName = joinPoint.getSignature().getName();
            String className = joinPoint.getTarget().getClass().getName();
            log.debug("调用方法:{} ", className + "." + methodName);
            InstanceInfo instanceInfo = eurekaClient.getApplicationInfoManager().getInfo();
            log.debug("负载均衡到的实例信息为：{}",instanceInfo.getInstanceId());
        }
    }

当调用方再次发起请求，观察控制台的信息，可以直接看到请求被分发到了端口为8084的实例上：  
![在这里插入图片描述][26248fd33a0e4601b77b7a0cfdca9d0f.png]  
负载均衡成功实现

[ec266564630a415a90927a3e449204f5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/4c9aeb4bb8654ab583712ff2b141ab3a.png
[5190c34d404c41f5af66b337b2284d65.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/7dc065372ebe44d89ab4f513e57f01f5.png
[078c47ed74004ddb92afab7084e63861.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/1e763599ba184127a55d8c7ecbc52cf4.png
[7419be13f5f64c15884d39fd3e6106ef.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/3b3a88fb90204b62af610a7e3e77e0f2.png
[f0f4f1bc18324dfbba0eafa5858effb8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/b990689729874337905ecc1d94e7d182.png
[70083719c1384319aeb967f2174f5fef.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/b0f87520931b48b9aef35ca87de3ae4f.png
[eb8b0755208849e2955962bd42bf8a35.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/a696542f7ee84f3dac516492ca43fc8c.png
[6ce10d1cd3f84e1c92eee09ff276f5d8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/944ba9b779854455b470bce2a4e07bf0.png
[da8486c477d54e4a964bd8e23d24db60.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/e01783ab07a6411f8845f403ffcd5410.png
[2d13d4fc6eb14814b00b866c3d8f8e2e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/a236dab0721d416db0ce5809895bcd9f.png
[ec5c21a485a449948dd042c0643a060e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/137c8d95b66343ee83b12949f083c294.png
[26248fd33a0e4601b77b7a0cfdca9d0f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/18/a4070be0695347bc8c584a0a25026a98.png