SpringCloud(三)-应用间通信(慕课网廖师兄SpringCloud微服务实战)

1. RestTemplate直连消费服务

  • 核心依赖
      <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

 <!--HttpClient-->
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>4.5.3</version>
        </dependency>
  • 相关bean准备
@Configuration
public class RestConfiguration {

   @Autowired
   private RestTemplateBuilder restTemplateBuilder;

   @Bean
   public RestTemplate restTemplate(){
       return restTemplateBuilder.build();
   }
}
  • 访问http服务
 /**
     * 将数据放在缓存中
     * @param uri
     */
    private String saveWeatherData(String uri){
        ResponseEntity<String> respString = restTemplate.getForEntity(uri,String.class);

        String strBody = null;

        if(HttpStatus.OK.equals(respString.getStatusCode())){
            strBody = respString.getBody();
        }

        //TODO 对返回值做校验

        stringRedisTemplate.opsForValue().set(uri,strBody,TIME_OUT, TimeUnit.SECONDS);
        return strBody;
    }
  • 微服务中使用RestTemplate访问其他服务的三种方式
@Component
public class RestTemplateConfig {

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


@RestController
@Slf4j
public class ClientController {

//    @Autowired
//    private LoadBalancerClient loadBalancerClient;

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/getProductMsg")
    public String getProductMsg() {
        //1.第一种方式(直接使用restTemplate, url写死)
//        RestTemplate restTemplate = new RestTemplate();
//        String response = restTemplate.getForObject("http://localhost:8080/msg", String.class);

        //2. 第二种方式(利用loadBalancerClient通过应用名获取url, 然后再使用restTemplate)
//        RestTemplate restTemplate = new RestTemplate();
//        ServiceInstance serviceInstance = loadBalancerClient.choose("PRODUCT");
//        String url = String.format("http://%s:%s", serviceInstance.getHost(), serviceInstance.getPort()) + "/msg";
//        String response = restTemplate.getForObject(url, String.class);

        //3. 第三种方式(利用@LoadBalanced, 可在restTemplate里使用应用名字)
        String response = restTemplate.getForObject("http://PRODUCT/msg", String.class);

        log.info("response={}", response);
        return response;
    }
}

客户端负载均衡服务器:Ribbon

使用了Ribbon的通信器

  • RestTemplate (@LoadBalanced 使用了Ribbon)
  • Feign
  • Zuul

Ribbon实现客户端软负载均衡核心

  • 服务发现 (依据服务的名字,把该副本下所有的实例都找出来)
  • 服务选择规则 (依据规则测量,从多个服务中选择一个有效的服务)
  • 服务监听 (服务监听,检测失效的服务做到高效剔除)

主要组件

  • ServerList (首先通过ServerList 获取所有的可用服务列表)
  • ServerListFilter (然后通过ServerListFilter 过滤掉一部分地址)
  • IRule (最后剩下的地址中通过IRule选择一个实例作为最终目标结构)

追踪源码自定义负载均衡策略

通过上文第二种方式追踪

1.使用

2.loadBalancerClient.choose

2.loadBalancerClient.choose

3.getServer()

3.getServer(

4.ILoadBalancer

1.通过ServerList 获取所有的可用服务列表

5.getAllServers

2.负载均衡策略

6.chooseServer

使用默认策略

默认策略

使用其他策略的方式,规则为IRule的实现类

image.png

使用

IDEA观察类之间关系的方法

IDEA观察类之间关系

3.feign消费服务

  • 声明式REST客户端(RPC)
  • 采用了基于借口的注解
  • 核心依赖
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-feign</artifactId>
        </dependency>
  • 相关实现代码

在启动类加入````@EnableFeignClients``注解

/**
 * 启动类
 * @author gaowenfeng
 */
@SpringBootApplication
@EnableScheduling
@EnableDiscoveryClient
@EnableFeignClients
public class MsaWeatherCollectionWeatherApplication {

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

服务消费bean

import com.gwf.weather.vo.City;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;

import java.util.List;

/**
 * @author gaowenfeng
 * @package com.gwf.weather.service
 * @describe Feign访问城市数据API服务接口
 * @date 2018/2/21
 */
@FeignClient("msa-weather-city-server") // 要访问的微服务名称
public interface CityClient {

    /**
    * GetMapping 的参数是要访问的服务方法名(基于http协议接口)
    * @return 返回值可以自己定义,会自动讲返回字符串做转型,转型失败会抛异常
    */
    @GetMapping("cities")
    List<City> listCitys() throws Exception;
}

使用

...
@Autowired
    private CityClient cityClient;
...
cityList = cityClient.listCitys();
  • 相关配置
feign:
  client:
    config:
      feignName:
        # 连接超时时间,单位为ms
        connectTimeout: 50000
       # 读取超时时间,单位为ms
        readTimeout: 50000

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Java成神之路

Spring_总结_04_高级配置(三)之处理歧义

本文承接上一节:Spring_总结_04_高级配置(二)之条件注解@Conditional

884
来自专栏技术墨客

Spring核心——官配后置处理器 原

RequiredAnnotationBeanPostProcessor它用于处理@Required注解。当我们一个Setter方法加入@Required后,表示...

592
来自专栏javathings

Spring Boot 中的自动配置

SpringBoot 启动的时候,会有大量的自动配置的类加载到容器中。正是因为 SpringBoot 的这些自动配置,使得我们在编程的时候,不像 Spring ...

1542
来自专栏开发与安全

muduo网络库学习之Logger类、LogStream类、LogFile类封装中的知识点

一、Logger类、LogStream类 1、日志作用 开发过程中: 调试错误 更好的理解程序 运行过程中: 诊断系统故障并处理 记录系统运行状态 ...

26310
来自专栏JavaWeb

项目中Spring 声明式事务使用的一些坑点分析01

7048
来自专栏Netkiller

使用 Jersey 调用 Restful 服务

第 20 章 Jersey - RESTful Web Services in Java. 目录 20.1. Client 20.1.1. Maven 版本 ...

3564
来自专栏用户2442861的专栏

ubuntu16安装nginx

https://www.digitalocean.com/community/tutorials/how-to-install-nginx-on-ubuntu-...

1332
来自专栏Android中高级开发

Android开发之漫漫长途 Ⅷ——Android Binder(也许是最容易理解的)

该文章是一个系列文章,是本人在Android开发的漫漫长途上的一点感想和记录,我会尽量按照先易后难的顺序进行编写该系列。该系列引用了《Android开发艺术探索...

1131
来自专栏java、Spring、技术分享

Ribbon与Spring cloud整合源码分析

Ribbon是一种客户端的负载均衡器。提供了多种负载均衡的算法,支持多种协议(HTTP,TCP,UDP),并提供了故障容错的能力。官方网址为:https://g...

1413
来自专栏个人分享

RestTemplate

RestTemplate是Spring提供的用于访问Rest服务的客户端,RestTemplate提供了多种便捷访问远程Http服务的方法,能够大大提高客户端的...

1342

扫码关注云+社区