SpringCloud笔记三:服务消费者ribbon和feign和注册中心高可用
发布日期:2021-05-28 16:45:02 浏览次数:8 分类:技术文章

本文共 5570 字,大约阅读时间需要 18 分钟。

SpringCloud笔记三:服务消费者ribbon和feign和注册中心高可用

文章目录

常用的服务间调用方式

  1. RPC调用方式

远程过程调用,像调用本地服务一样调用服务器的服务。

支持同步,异步调用。

客户端和服务端之间建立TCP连接,可以一次建立一个,也可以多个调用复用一次连接。

​ 也就是说,建立连接后,每次调用就用这个连接,不需要再次连接了,因为每次建立连接都会消耗资源的。(三次握手)

适合千万级别的用户。

Rpc数据包小,使用谷歌开源protobuf

开发成本高,编码,序列化问题,丢包,分包。

  1. Rest(http)

http请求,支持各种协议和功能。

开发方便成本低。

http数据包大

微服务调用之ribbon实战,订单调用商品服务

  1. 开发步骤

1、创建order_service项目

2、开发伪下单接口

3、使用ribbon

​ 启动类增加注解,这个是ribbon的负载均衡策略

​ @Bean

​ @LoadBalanced

​ public RestTemplate restTemplate(){

​ return new RestTemplate();

​ }

4、根据名称进行调用商品,获取商品详情。

  1. ribbon介绍

类似于HttpClient,urlConnection

  1. 核心代码
@Servicepublic class PorductOrderServiceImpl implements ProductOrderService {
@Autowired private RestTemplate restTemplate; @Override public ProductOrder save(int userId, int productId) {
Object obj = restTemplate.getForObject("http://product-service/api/v1/product/find?id=" + productId, Object.class); System.out.println(obj); //获取商品详情 ProductOrder productOrder=new ProductOrder(); productOrder.setCreateTime(new Date()); productOrder.setUserId(userId); productOrder.setTradeNo(UUID.randomUUID().toString()); return productOrder; }}
  1. 核心配置
server:  port: 8781#服务的名称spring:  application:    name: order-service#指定注册中心地址eureka:  client:    serviceUrl:      defaultZone: http://localhost:8761/eureka/

Ribbon负载均衡源码分析

  1. 引入rbbion的负载均衡器的第二种方式

通过注入:LoadBalancerClient,和在启动类里面添加Bean一样。

@Servicepublic class PorductOrderServiceImpl implements ProductOrderService {
/*@Autowired private RestTemplate restTemplate;*/ @Autowired private LoadBalancerClient loadBalancerClient; @Override public ProductOrder save(int userId, int productId) {
//Map
productMap = restTemplate.getForObject("http://product-service/api/v1/product/find?id=" + productId, Map.class); //获取商品详情 ServiceInstance instance = loadBalancerClient.choose("product-service"); String url=String.format("http://%s:%s/api/v1/product/find?id="+productId,instance.getHost(),instance.getPort()); RestTemplate restTemplate=new RestTemplate(); Map
productMap1 =restTemplate.getForObject(url,Map.class); ProductOrder productOrder=new ProductOrder(); productOrder.setCreateTime(new Date()); productOrder.setUserId(userId); productOrder.setTradeNo(UUID.randomUUID().toString()); productOrder.setProductName(productMap.get("name").toString()); productOrder.setPrice(Integer.parseInt(productMap.get("price").toString())); return productOrder; }}
  1. 源码分析ribbon的负载均衡类

ctrl+shift+N搜索LoadBalancerClient,查看chose()方法,通过源码得知里面的负载均衡策略。

调用负载均衡步骤

1、首先从注册中心获取provider的列表

​ 2、通过一定的策略选择其中一个节点。

​ 3、再返回restTemplete调用。

调整ribbon的负载均衡策略

  1. 在yml文件里面进行配置

ribbon默认的负载均衡策略是:轮流进行,下面修改成随机的。

#要调用的服务名product-service:		ribbon:		    #找到IRule的实现类,并将该实现类的权限名copy过来。			NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule
  1. 策略配置

1、如果每个机器配置一样,则建议不修改策略。(推荐)

2、如果部分机器配置强,则可以改为 WeightedResponseTimeRule

微服务调用方式feign

  1. feign

Feign:伪RPC客户端(本质还是http)

  1. 使用步骤

1、加入依赖,注意新旧版本

org.springframework.cloud
spring-cloud-starter-openfeign

2、启动类添加@EnableFeignClients注解

3、增加接口并@FeignClient(name=“所调用服务的注册名字”)

@FeignClient(name = "product-service")public interface ProductClient {
@GetMapping("api/v1/product/find") String findById(@RequestParam(value = "id") int id);}

4、实现类调用,将响应的json转成JsonNode,然后从里面取值。

@Servicepublic class PorductOrderServiceImpl implements ProductOrderService {
/*@Autowired private RestTemplate restTemplate;*/ /* @Autowired private LoadBalancerClient loadBalancerClient;*/ @Autowired private ProductClient productClient; @Override public ProductOrder save(int userId, int productId) {
//Map
productMap = restTemplate.getForObject("http://product-service/api/v1/product/find?id=" + productId, Map.class); //获取商品详情 /* ServiceInstance instance = loadBalancerClient.choose("product-service"); String url=String.format("http://%s:%s/api/v1/product/find?id="+productId,instance.getHost(),instance.getPort()); RestTemplate restTemplate=new RestTemplate(); Map
productMap1 =restTemplate.getForObject(url,Map.class);*/ String response = productClient.findById(productId); JsonNode jsonNode = JsonUtils.str2JsonNode(response); ProductOrder productOrder=new ProductOrder(); productOrder.setCreateTime(new Date()); productOrder.setUserId(userId); productOrder.setTradeNo(UUID.randomUUID().toString()); /*productOrder.setProductName(productMap.get("name").toString()); productOrder.setPrice(Integer.parseInt(productMap.get("price").toString()));*/ productOrder.setProductName(jsonNode.get("name").toString()); productOrder.setPrice(Integer.parseInt(jsonNode.get("price").toString())); return productOrder; }}

5、json转JsonNode

public class JsonUtils {
private static final ObjectMapper objectMapper=new ObjectMapper(); public static JsonNode str2JsonNode(String str) {
try {
return objectMapper.readTree(str); } catch (JsonProcessingException e) {
return null; } }}

Feign源码解读以及Feign和Ribbon的选择

  1. 设置当前线程睡眠
TimeUnit.SECONDS.sleep(10);//该方法会让当前线程睡眠10s,睡眠会放弃cpu,但是不会放弃锁对象。wait()会让出cpu和锁对象。该API还可以设置分钟。
  1. 超时配置

默认options readtimeout是60,但是由于Hystrix默认是1s超时.下面是超时配置

#修改feign请求的超时时间feign:  client:    config:      default:        connectTimeout: 2000        readTimeout: 2000
  1. Feign内部的负载均衡策略其实使用的是ribbon
  2. 尽量使用Feign,因为Feign解耦性更强。

转载地址:https://blog.csdn.net/qq_33322074/article/details/106271851 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:SpringCloud笔记四:互联网架构服务降级熔断Hystrix
下一篇:SpringCloud笔记二:springCloud核心组件注册中心

发表评论

最新留言

表示我来过!
[***.240.166.169]2024年02月17日 10时52分45秒