SpringCloud - （二）服务消费者（ribbon+restTemplate）

矫情吗；* 2022-05-26 06:13 202阅读 0赞

在微服务架构中，业务都会被拆分成一个独立的服务，服务与服务的通讯是基于http restful的。

Spring cloud有两种服务调用方式：

*  一种是ribbon+restTemplate
 *  一种是feign

这里先学习ribbon+restTemplate

## Ribbon ##

ribbon是一个负载均衡客户端，可以很好的控制htt和tcp的一些行为。  
***Feign默认集成了ribbon。***

## 准备工作 ##

**创建一个AHUT-EUREKA-CLIENT服务的集群**

创建一个Ahut-Eureka-Client-Two项目，创建过程和代码都和上一篇的Ahut-Eureka-Client-One一样，仅仅是配置文件的服务器端口号不一样，application.properties

# 配置服务器端口
    server.port=8920
    # 配置spring应用名称
    spring.application.name=AHUT-EUREKA-CLIENT
    # 注册服务
    eureka.client.service-url.defaultZone=http://localhost:8900/eureka/

启动项目

*  Ahut-Eureka-Server（注册中心）
 *  Ahut-Eureka-Client-One（AHUT-EUREKA-CLIENT服务一）
 *  Ahut-Eureka-Client-Two（AHUT-EUREKA-CLIENT服务二）

浏览器访问Eureka  
![这里写图片描述][Image 1]

## 此时的项目架构 ##

![这里写图片描述][70]

## 创建服务消费者 ##

新创建一个项目Ahut-Service-Ribbon，和Ahut-Eureka-Client-One类似

右键，New>>Module>>Spring Init>>填写项目maven信息>>选择依赖>>填写项目名称

![这里写图片描述][70 1]

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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.ahut</groupId>
        <artifactId>service-ribbon</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <packaging>jar</packaging>
    
        <name>service-ribbon</name>
        <description>service ribbon</description>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.5.12.RELEASE</version>
            <relativePath/> 
        </parent>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
            <spring-cloud.version>Edgware.SR3</spring-cloud.version>
        </properties>
    
        <dependencies>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-ribbon</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring-cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    
    </project>

项目启动类  
通过@EnableDiscoveryClient向服务中心注册  
并且向程序的ioc注入一个bean: restTemplate;并通过@LoadBalanced注解表明这个restRemplate开启负载均衡的功能

package com.ahut;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    /** * @author cheng * @className: ServiceRibbonApplication * @description: service ribbon * @dateTime 2018/4/26 14:23 */
    @SpringBootApplication
    @EnableDiscoveryClient
    public class ServiceRibbonApplication { 
    
        public static void main(String[] args) {
            SpringApplication.run(ServiceRibbonApplication.class, args);
        }
    
        /** * @description: 注入restTemplate, 并且开启负载均衡 * @author cheng * @dateTime 2018/4/26 14:25 */
        @Bean
        @LoadBalanced
        public RestTemplate createRestTemplate() {
            return new RestTemplate();
        }
    
    }

项目配置文件application.properties

# 配置服务器端口
    server.port=8940
    # 配置spring 程序名称
    spring.application.name=AHUT-SERVICE-RIBBON
    # 配置注册中心地址
    eureka.client.service-url.defaultZone=http://localhost:8900/eureka/

声明一个接口HelloService

package com.ahut.service;
    
    /** * @author cheng * @interfaceName: HelloService * @description: * @dateTime 2018/4/26 14:34 */
    public interface HelloService { 
    
        /** * @description: 展示服务器端口 * @author cheng * @dateTime 2018/4/26 14:35 */
        String showPort();
    
    }

接口实现HelloServiceImpl

package com.ahut.serviceImpl;
    
    import com.ahut.service.HelloService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.web.client.RestTemplate;
    
    /** * @author cheng * @className: HelloServiceImpl * @description: * @dateTime 2018/4/26 14:35 */
    @Service
    public class HelloServiceImpl implements HelloService { 
    
        @Autowired
        private RestTemplate restTemplate;
    
        /** * @description: 展示服务器端口 * @author cheng * @dateTime 2018/4/26 14:35 */
        @Override
        public String showPort() {
            return restTemplate.getForObject("http://AHUT-EUREKA-CLIENT/v1/showPort", String.class);
        }
    }

控制层HelloAction

package com.ahut.action;
    
    import com.ahut.service.HelloService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    /** * @author cheng * @className: HelloAction * @description: * @dateTime 2018/4/26 14:40 */
    @RestController
    @RequestMapping(value = "/v1")
    public class HelloAction { 
    
        @Autowired
        private HelloService helloService;
    
        /** * @description: 模拟调用 * @author cheng * @dateTime 2018/4/26 14:42 */
        @RequestMapping(value = "/hello")
        public String hello() {
            return helloService.showPort();
        }
    
    }

启动项目

*  Ahut-Eureka-Server（注册中心）
 *  Ahut-Eureka-Client-One（AHUT-EUREKA-CLIENT服务一）
 *  Ahut-Eureka-Client-Two（AHUT-EUREKA-CLIENT服务二）
 *  Ahut-Service-Ribbon（AHUT-SERVICE-RIBBON服务消费者）

浏览器访问Eureka  
![这里写图片描述][70 2]

浏览器访问Ahut-Service-Ribbon项目,[http://localhost:8940/v1/hello][http_localhost_8940_v1_hello]  
因为实现了负载均衡,浏览器交替显示  
![这里写图片描述][70 3]

![这里写图片描述][70 4]

这说明当我们通过调用**restTemplate.getForObject(“[http://AHUT-EUREKA-CLIENT/v1/showPort][http_AHUT-EUREKA-CLIENT_v1_showPort]“, String.class);**方法时，已经做了负载均衡，访问了不同的端口的服务实例。

## 此时的项目架构 ##

![这里写图片描述][70 5]

*  一个服务注册中心，Eureka Server,端口为8900
 *  AHUT-EUREKA-CLIENT工程跑了两个实例，端口分别为8910,8920，分别向服务注册中心注册
 *  AHUT-SERVICE-RIBBON端口为8940,向服务注册中心注册
 *  当AHUT-SERVICE-RIBBON通过RestTemplate调用AHUT-EUREKA-CLIENT的/v1/showPort接口时，因为用ribbon进行了负载均衡，会轮流的调用AHUT-EUREKA-CLIENT：8910和8920 两个端口的接口；

[Image 1]: 
[70]: /images/20220526/78096230945d4f25b47faf50be0159e4.png
[70 1]: /images/20220526/127e11f8ea37476497d618fb99f69acf.png
[70 2]: /images/20220526/2e11ec4409be4ac08c428eb44c4148b8.png
[http_localhost_8940_v1_hello]: http://localhost:8940/v1/hello
[70 3]: /images/20220526/a823113198e5408cb96174cf64a154dd.png
[70 4]: /images/20220526/48663e74c6d54f248349e9acd8aa6ed7.png
[http_AHUT-EUREKA-CLIENT_v1_showPort]: http://AHUT-EUREKA-CLIENT/v1/showPort
[70 5]: /images/20220526/f77b8ad358bf4bd290a095296994067e.png