内容简介:照例附上本项目实现的是将一个简单的天气预报系统一步一步改造成一个SpringCloud微服务系统的过程。本章主要讲解微服务的消费模式主要有:
照例附上 项目github链接
本项目实现的是将一个简单的天气预报系统一步一步改造成一个SpringCloud微服务系统的过程。本章主要讲解 微服务的消费 。
微服务的消费模式
微服务的消费模式主要有:
- 服务直连模式
- 客户端发现模式
- 服务端发现模式
下面我们主要讲解客户端发现模式,以及服务端发现模式。
客户端发现模式
客户端发现模式的具体流程如下:
1)服务实例启动后,将自己的位置信息提交到服务注册表中。
2)客户端从服务注册表进行查询,来获取可用的服务实例。
3)客户端自行使用负载均衡算法从多个服务实例中选择出一个。
服务端发现模式
服务端发现模式与客户端发现模式的区别在于:服务端发现模式的负载均衡由负载均衡器(独立的)来实现,客户端不需要关心具体调用的是哪一个服务。
微服务的消费者
下面我们价格介绍一些常见的微服务的消费者。
HttpClient
HttpClient是常见的微服务的消费者,它是Apache Jakarta Common 下的子项目,可以用来提供高效的、最新的、功能丰富的支持 HTTP 协议的客户端编程 工具 包,并且它支持 HTTP协议最新的版本和建议。
Ribbon
Ribbon是一个基于HTTP和TCP的客户端负载均衡工具,它基于Netflix Ribbon实现。通过Spring Cloud的封装,可以让我们轻松地将面向服务的REST模版请求自动转换成客户端负载均衡的服务调用。
Ribbon常与Eureka结合使用。在典型的分布式部署中,Eureka为所有的微服务提供服务注册,Ribbon提供服务消费的客户端,含有许多负载均衡的算法。
Feign
Feign是一个声明式的Web Service客户端,它的目的就是让Web Service调用更加简单。Feign提供了HTTP请求的模板,通过编写简单的接口和插入注解,就可以定义好HTTP请求的参数、格式、地址等信息。
而Feign则会完全代理HTTP请求,我们只需要像调用方法一样调用它就可以完成服务请求及相关处理。Feign整合了Ribbon和Hystrix(关于Hystrix我们后面再讲),可以让我们不再需要显式地使用这两个组件。
总起来说,Feign具有如下特性:
- 可插拔的注解支持,包括Feign注解和JAX-RS注解;
- 支持可插拔的HTTP编码器和解码器;
- 支持Hystrix和它的Fallback;
- 支持Ribbon的负载均衡;
- 支持HTTP请求和响应的压缩。
集成Feign
本节我们主要讲解如何集成Feign,实现微服务的消费功能。
添加配置
pom.xml配置文件,添加如下依赖。
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-feign</artifactId> </dependency>
application.yml文件,添加如下配置
服务的名称与工程的名称一致,并且设置请求一个服务的connect与read的超时时间。
spring: application: name: micro-weather-eureka-client-feign eureka: client: service-url: defaultZone: http://localhost:8761/eureka/ feign: client: config: feignName: connectTimeout: 5000 readTimeout: 5000
添加注解
添加@EnableFeignClients注解,启动Feign功能。
package com.demo; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.web.servlet.ServletComponentScan; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.netflix.feign.EnableFeignClients; import org.springframework.scheduling.annotation.EnableScheduling; //@ServletComponentScan(basePackages="com.demo.web.servlet") @SpringBootApplication @EnableDiscoveryClient @EnableScheduling @EnableFeignClients public class Sifoudemo02Application { public static void main(String[] args) { SpringApplication.run(Sifoudemo02Application.class, args); } }
创建Feign客户端
创建一个Feign客户端,通过其CityClient的接口,可以调用城市数据API微服务mas-weather-city-eureka中的cities接口,返回城市列表。
package com.demo.service; import java.util.List; import org.springframework.cloud.netflix.feign.FeignClient; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import com.demo.vo.City; //创建一个Feign客户端 获取城市数据微服务中的城市列表信息 @FeignClient("msa-weather-city-eureka") public interface CityClient { @RequestMapping(value="/cities",method=RequestMethod.GET) List<City> listCity()throws Exception; }
使用Feign客户端
@RestController public class CityController{ @Autowired private CityClient cityClient; @GetMapping("/cities") public List<City> listCity(){ List<City> cityList=cityClient.listCity(); ![在这里插入图片描述](https://img-blog.csdnimg.cn/20190311174443475.jpg?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwOTU1Mjg3,size_16,color_FFFFFF,t_70) return cityList; } }
测试
先启动Eureka服务端,然后启动被请求的微服务——城市数据API微服务,最后启动Feign客户端。
以上所述就是小编给大家介绍的《微服务的消费 | 从0开始构建SpringCloud微服务(11)》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!
猜你喜欢:本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
Java Concurrency in Practice
Brian Goetz、Tim Peierls、Joshua Bloch、Joseph Bowbeer、David Holmes、Doug Lea / Addison-Wesley Professional / 2006-5-19 / USD 59.99
This book covers: Basic concepts of concurrency and thread safety Techniques for building and composing thread-safe classes Using the concurrency building blocks in java.util.concurrent Pe......一起来看看 《Java Concurrency in Practice》 这本书的介绍吧!