SpringCloud内部服务调用Ribbon组件

一时失言乱红尘 2022-03-12 01:42 258阅读 0赞

## 微服务：独立的工程之间通过框架形成的一个集群的服务调用；这个集群称之为微服务集群； ##

微：集群中的工程（服务器），都是独立运行的项目；功能非常单一微小,例如后台的增删改查可以切分成4个独立运行的微服务工程.

## springCloud的微服务框架具有很多的功能组件： ##

1 服务治理 eureka 所有工程都可以在eureak中注册自己的服务名称，如果名称一致，将会被eureka作为同一个服务来使用；

###### 2 负载均衡调用组件：ribbon, 前端的客户端的组件 ######

3 接口客户端组件： feign 底层依赖ribbon+template实现的调用。看不到实际调用的方法，利用接口，注解  
4 熔断器：Hystrix, 当服务调用出现任何异常或者问题时，可以利用熔断的逻辑完成错误的解决；类似代码中的try catch  
5 分布式配置：config，分布式配置组件；  
6 网关组件：zuul，实现网关路由，监听，对当前的需要的服务进行网关治理；

### Ribbon组件+restTemplate ###

实现通过springcloud内部服务调用，完成负载均衡的访问，从服务提供者调用工程代码/数据,就是为了解决微服务集群中某个独立的服务无法单独完成一个任务,需要别的服务帮助的情况;

#### 1 quickstart 的骨架 ####

可以再 [start.spring.io][] 生成一个springboot工程

#### 2 pom依赖 ####

<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.arno</groupId>
      <artifactId>ribbon-client</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <packaging>jar</packaging>
    
      <name>ribbon-client</name>
      <url>http://maven.apache.org</url>
    <parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>1.5.9.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>
    	</properties>
      <dependencies>
        <dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</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>
      </dependencies>
      <dependencyManagement>
    		<dependencies>
    			<dependency>
    				<groupId>org.springframework.cloud</groupId>
    				<artifactId>spring-cloud-dependencies</artifactId>
    				
    				<version>Dalston.SR4</version>
    				<type>pom</type>
    				<scope>import</scope>
    			</dependency>
    
    
    		</dependencies>
    	</dependencyManagement>
    </project>

#### 3 application.properties ####

server.port=8094
    //在eureka中心注册一个service-hi的服务,名字自定义，服务中心根据服务名称判断是否是处理同一种逻辑的服务，
    //例如用户登录服务，统一一个名字，可以启动多个项目，到注册中心
    spring.application.name=service-ribbon
    //指向注册中心，与eureka center一致，服务启动后悔自动到下面的地址注册名称为service-ribbon的服务
    eureka.client.serviceUrl.defaultZone=http://localhost:8090/eureka/

#### 4 启动类 ####

@EnableEurekaClient 添加客户端注解会去注册中心注册服务  
@Bean 交给Spring 来管理对象  
@LoadBalanced 当一个被@LoadBalanced注解修饰的RestTemplate对象向外发起HTTP请求时，会被LoadBalancerInterceptor类的intercept方法拦截，在这个方法中直接通过getHost方法就可以获取到服务名（因为我们在使用RestTemplate调用服务的时候，使用的是服务名而不是域名，所以这里可以通过getHost直接拿到服务名然后去调用execute方法发起请求）。

package com.arno;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    @SpringBootApplication
    @EnableEurekaClient
    public class StarterRibbon { 
    	
    	public static void main(String[] args) { 
    		SpringApplication.run(StarterRibbon.class, args);
    	}
    	@Bean
    	@LoadBalanced
    	public RestTemplate getRes(){ 
    		return new RestTemplate();
    	}
    }

#### 5 完成负载均衡的访问 ####

Controller 实现服务的调用，调用client01,client02工程的数据，需要实现调用的对象注入，RestTemplate  
1 创建这个RestTemplate,指明它的负载逻辑（Balanced）  
2 注入使用

package com.arno.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.http.ResponseEntity;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    public class HiController { 
    	//注入restTemplate完成服务的调用
    	@Autowired
    	private RestTemplate template;
    	@RequestMapping("hi")
    	public String sayHi(String name){ 
    		//ribbon返回 hello name 不具备说hello的能力
    		//请求传递到服务之后,要求service-hi的服务提供者帮助
    		//ribbon完成sayHi的方法
    		//想办法,调用servie-hi完成本次客户端响应
    		//利用template对象访问ekurea注册中心的service-hi服务
    		String result=template.getForObject("http://service-hi/hi?name="+name, String.class);
    		//url:访问服务的地址
    		//resposeType:封装返回数据类型 
    		//result hello name i am 8091/8092
    		/*ResponseEntity<String> response = template.getForEntity("http://service-hi/hi?name="+name, String.class); response.getBody();*/
    		
    		return "RIBBON:"+result;
    		
    	}
    }

#### 然后在之前文章中创建的客户端中添加Controller来处理调用 ####

以下代码需要创建到客户端中，并且启动多个客户端服务（注意修改客户端的端口）

package com.arno.controller;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class HiController { 
    	
    	//测试 访问hi请求地址,返回当前工程的端口
    	@Value("${server.port}")
    	private String port;
    	
    	@RequestMapping("hi")
    	@ResponseBody
    	public String sayHi(String name){ 
    		return "hello "+name+",I am "+port;
    	}
    }

请求 [http://localhost:8094/hi?name=1111][http_localhost_8094_hi_name_1111] 返回8091处理的端口调用。通过多次刷新，观察端口，可以发现是通过负载均衡调用不同的服务来完成请求  
![在这里插入图片描述][20190304201344891.png]

#### 6 启动额外的服务提供者，直接注册service-Hi测试访问 ####

在新创建一个客户端，启动后直接加入集群，访问的负载均衡可以直接访问；动态添加，其他的结构任何位置都没有发生任何变动；

[start.spring.io]: http://start.spring.io
[http_localhost_8094_hi_name_1111]: http://localhost:8094/hi?name=1111
[20190304201344891.png]: /images/20220312/bc61158ebd7d4e538d22846bbb6adbf9.png