springcloud之ribbon小栗子

Love The Way You Lie 2022-12-17 10:53 128阅读 0赞

## 写在前面 ##

本文在[这篇博文][Link 1]基础上继续进行分析。这里我们需要增加一个新的maven模块`my-service-ribbon`，从`my-enreka-server`拉取服务注册信息，然后以负载均衡的方式调用`myeureka-client`的接口。源码在[这里][Link 2]。

## 1：创建`my-service-ribbon` ##

### 1.1：创建项目 ###

`new`\->`module`,选择`Spring Inilializr`以及java8，然后next，录入gav等信息，创建完成后如下图：  
![在这里插入图片描述][20201023141019379.jpg_pic_center]

### 1.2：设置parent ###

<parent>
      <groupId>dongshi.daddy</groupId>
      <artifactId>my-eureka</artifactId>
      <version>1.0-SNAPSHOT</version>
      <relativePath/> 
    </parent>

### 1.3：引入依赖 ###

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

### 1.4：完整pom ###

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
    
      <groupId>dongshi.daddy</groupId>
      <artifactId>my-service-ribbon</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <packaging>jar</packaging>
    
      <name>my-service-ribbon</name>
      <description>Demo project for Spring Boot</description>
    
      <parent>
        <groupId>dongshi.daddy</groupId>
        <artifactId>my-eureka</artifactId>
        <version>1.0-SNAPSHOT</version>
        <relativePath/> 
      </parent>
    
      <properties>
        <java.version>1.8</java.version>
      </properties>
    
      <dependencies>
        <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
          <groupId>org.springframework.cloud</groupId>
          <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
      </dependencies>
    
      <build>
        <plugins>
          <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
          </plugin>
        </plugins>
      </build>
    
    </project>

### 1.5：配置文件 ###

server:
      port: 8764
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://localhost:8761/eureka/
    
    spring:
      application:
        name: dongshidaddy-first-ribbon

除了端口号外，使用`eureka.client.serviceUrl.defaultZone`设置eureka服务端的地址，从而将自己注册上去，使用`spring.application.name`设置自己的名称，该名称会显示在eureka的注册信息中。

### 1.6：启用相关注解 ###

@EnableEurekaClient
    @EnableDiscoveryClient

注解`@EnableEurekaClient`启用自己作为eureka的客户端，并向eureka的服务端注册。注解`@EnableDiscoveryClient`启用发现者客户端，从eureka服务端读取所有eureka客户端的注册信息。然后注册`RestTemplate`的bean到IOC容器中，并通过`@LoadBanlanced`注解赋予其使用ribbon进行负载均衡的能力，源码如下：

@Bean
    @LoadBalanced
    RestTemplate restTemplate() { 
        return new RestTemplate();
    }

完整代码如下：

@SpringBootApplication
    @EnableEurekaClient
    @EnableDiscoveryClient
    public class MyServiceRibbonApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(MyServiceRibbonApplication.class, args);
        }
    
        @Bean
        @LoadBalanced
        RestTemplate restTemplate() { 
            return new RestTemplate();
        }
    
    }

### 1.7：配置service ###

@Service
    public class HelloService { 
    
        @Autowired
        RestTemplate restTemplate;
    
        public String hiService(String name) { 
            return restTemplate.getForObject("http://DONGSHIDADDY-FIRST-EUREKA-CLIENT/hi?name="+name,String.class);
        }
    }

需要注意`DONGSHIDADDY-FIRST-EUREKA-CLIENT`是我的`myeureka-client`模块的服务名，要换成你自己的！！！。

### 1.8：配置controller ###

@RestController
    public class HelloControler { 
    
        @Autowired
        HelloService helloService;
    
        @GetMapping(value = "/hi")
        public String hi(@RequestParam String name) { 
            return helloService.hiService( name );
        }
    }

## 2：测试 ##

### 2.1：启动`my-enreka-server` ###

该服务是eureka的服务端，作为服务的注册中心使用，端口号是`8761`。

### 2.2：启动`myeureka-client`第1个实例 ###

修改配置文件设置端口号为`8762`，然后启动。

### 2.3：启动`myeureka-client`第2个实例 ###

修改端口号为`8763`。注意不能直接启动，需要在`Edit Configurations`下添加一个springboot的程序，然后设置名称和主函数，如下图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmcwOTA3_size_16_color_FFFFFF_t_70_pic_center]  
启动成功后，查看`http://localhost:8761/`可以看到`myeureka-client`的实例注册了两个，端口号分别为`8762`,`8763`。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmcwOTA3_size_16_color_FFFFFF_t_70_pic_center 1]

### 2.4：启动`my-service-ribbon` ###

启动后可以在eureka服务端看到注册的信息，如下图：  
![在这里插入图片描述][20201023144959510.jpg_pic_center]

### 2.5：访问接口 ###

如下重复访问，可以在`myeureka-client`的两个实例中进行负载调用：

C:\Users\cj>curl http://localhost:8764/hi?name=dongshidaddy
    hi dongshidaddy ,i am from port:8763
    C:\Users\cj>curl http://localhost:8764/hi?name=dongshidaddy
    hi dongshidaddy ,i am from port:8762
    C:\Users\cj>curl http://localhost:8764/hi?name=dongshidaddy
    hi dongshidaddy ,i am from port:8763
    C:\Users\cj>curl http://localhost:8764/hi?name=dongshidaddy
    hi dongshidaddy ,i am from port:8762

## 3：项目架构 ##

此时系统中有`1`个eureka的服务端，端口号为`8761`,`2`个eureka客户端，分别是`myeureka-client`,`my-service-ribbon`，其中myeureka-client启动`2个实例`，端口号分别是`8762`和`8763`，my-service-ribbon调用myeureka-client提供的服务，最终结构如下图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmcwOTA3_size_16_color_FFFFFF_t_70_pic_center 2]  
注意图中的菱形组件ribbon，因为内部负载实际使用的就是ribbon，所以这里换成ribbon来表示，另外其应该是在`my-service-riibon`内部的，这里为了强调单摘出来说明。

## 最后：都让开，我要喝瑞幸 ##

![在这里插入图片描述][20200828090303329.png_pic_center]

[Link 1]: https://blog.csdn.net/wang0907/article/details/109228723
[Link 2]: https://download.csdn.net/download/wang0907/13025665
[20201023141019379.jpg_pic_center]: /images/20221122/0fc37d27e3f342c099cab85e2e41726d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmcwOTA3_size_16_color_FFFFFF_t_70_pic_center]: /images/20221122/162b2fd989aa4817b8e7bedacf90debf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmcwOTA3_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221122/fb822a6fb24745a687fc9379618430e3.png
[20201023144959510.jpg_pic_center]: /images/20221122/3fab983f18c146f0a437497157d3a6d7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dhbmcwOTA3_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221122/bd30728bf9554d2a97d1e9ea856e675f.png
[20200828090303329.png_pic_center]: /images/20221122/80f9c4deeaf7489fa95985351bdd3ac2.png