微服务框架入门(二)

标签: SpringCloud

搭建简单Cloud架构(Two)

上节我们介绍了Eureka的搭建及服务之间的注册、Ribbon的使用及规则的定义,这节我们了解一下Feign的使用和Hystrix

一、Feign的简单使用

首先引入Feign的坐标

<dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-openfeign</artifactId>
   <version>2.0.1.RELEASE</version>
</dependency>

启动类增加@EnableFeignClients注解(调用者)
 

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients(value = "com.yst.ysttestfeign.feign")
public class YstTestFeignApplication {
	public static void main(String[] args) {
		SpringApplication.run(YstTestFeignApplication.class, args);
	}
}

创建interface (调用者)

这里是需要调用的微服务名及接口

package com.yst.ysttestfeign.feign;


import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

@FeignClient("yst-ribbon-one") // 这里是要调用的application.name
public interface FeignClient {
    // 这里是yst-ribbon-one里的接口
    @RequestMapping(value = "/ribbon/demo",method = RequestMethod.GET)
    public String getName();
}

附上yst-ribbon-one里的Controller(被调用者)

package com.yst.ystribbonone.rest;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @program: yst-parent
 * @description: mmh
 * @author: Mr.Miao
 * @create: 2018-08-28 17:21
 **/
@RestController
@RequestMapping("/ribbon")
public class OneController {
    @GetMapping("/demo")
    public String getName(){
        System.out.println("XXX");
        return "XXX";
    }
}

OK我们可以调用interface实现远程调用啦。

那么如何覆写Feign的默认配置呢?

方案一:

同Ribbon一样,我们可以写一个Config类,通过@FeignClient注解引入的方式进行覆写

首先创建config类,注意跟Ribbon一样,放到启动类扫描不到的地方,因为被启动类的ComponentScan扫描到,则会应用于整个Feign。

package com.yst.config;

import feign.Contract;
import feign.auth.BasicAuthRequestInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @program: yst-parent
 * @description: mmh
 * @author: Mr.Miao
 * @create: 2018-08-31 15:06
 **/
@Configuration
public class FooConfiguration {
    @Bean
    public Contract feignContract() {
        return new feign.Contract.Default();
    }

//    @Bean
//    public BasicAuthRequestInterceptor basicAuthRequestInterceptor() {
//        return new BasicAuthRequestInterceptor("user", "password");
//    }
}

interface要注意了使用@RequestLine注解

package com.yst.ysttestfeign.feign;

import com.yst.config.FooConfiguration;
import feign.RequestLine;
// 这里解释一下fallback 它是调用失败的处理类
@FeignClient(name = "yst-ribbon-one",configuration = FooConfiguration.class , fallback = ExampleRemoteHystrix.class)
public interface FeignClient {
//    @RequestMapping(value = "/ribbon/demo",method = RequestMethod.GET)
    @RequestLine("GET /ribbon/demo")
    public String getName();
}

附 ExampleRemoteHystrix的代码:

import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestParam;
 
@Component
public class ExampleRemoteHystrix implements FeignClient {
    @Override
    public String echo(String str) {
        return " 调用失败,请重试";
    }
}

注意默认Feign和Hystrix是在一起用的,如果想禁用可以在config类加上

@Configuration
public class FooConfiguration {
    @Bean
	@Scope("prototype")
	public Feign.Builder feignBuilder() {
		return Feign.builder();
	}
}

表示只是用FeignBuild。 

还有一种禁用方式

feign.hystrix.enabled=false 

这里是全局的,所有的feign都禁用hystrix

Feign的日志:

很简单,再config类里加上下面一段bean

    // 开启Feign日志
    @Bean
    Logger.Level feignLoggerLevel(){
        return Logger.Level.FULL;
    }

还没完打开application.yml 添加

logging:
  level:
    com.yst.ysttestfeign.feign.FeignClient: DEBUG # 这个路径是interface的地址

启动即可

如果遇到第一次访问超时的问题:

方案一:可以通过设置Hystrix  在application.yml里配置

hystrix: 
  command: 
    default: 
      execution: 
        isolation: 
          threa: 
            timeoutInMilliseconds: 5000 # 默认为1秒

方案二:直接禁用Feign的Hystrix

hystrix: 
  command: 
    default: 
      execution: 
        timeout: 
          enable: false # 禁用timeout
feign: 
  hystrix: 
    enable: false  # 禁用Feign的Hystrix

两种 方式 任选 没有遇到超时的话请忽略。

二、Hystrix熔断:

Hystrix 和 Feign是结合使用的,出现雪崩效应如何解决

进入今天的Demo:

使用hystrix,首先引入坐标依赖:

<dependency>
	<groupId>org.springframework.cloud</groupId>
	<artifactId>spring-cloud-starter-hystrix</artifactId>
	<version>1.2.4.RELEASE</version>
</dependency>

然后启动类加上注解:

@EnableCircuitBreaker

然后是接口代码:

@RestController
@RequestMapping("/hystrix")
public class HystrixController {
    @Autowired
    private RestTemplate restTemplate;
    @RequestMapping("/test")
    @HystrixCommand(fallbackMethod = "getNameFallBack")
    public String getName (){
        return restTemplate.getForObject("http://YST-RIBBON-ONE/ribbon/demo",String.class);
    }
    public String getNameFallBack() {
        return "回调";
    }
}

方法上增加了@HystrixCommand注解表示开启断路器,fallbackMethod 的值为回调的方法名。如果调不通,则会调用该方法直接返回

@HystrixCommand的 commandProperties属性:

@HystrixCommand(fallbackMethod="getNameFallBack",[email protected](name="execution.isolation.strategy", value="SEMAPHORE"))

这里直接大白话说,加与不加的区别就是加上commandProperties 则注解@HystrixCommand与下边的方法共用一个线程,不加则各自有各自的线程。

后续会进行补充。

 

版权声明:本文为mmh_csdn原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/mmh_csdn/article/details/82253644

智能推荐

循环

与任何程序设计语言一样Java利用条件语句与循环结构确定流程控制,一下总结一下Java中的循环语句: while do while for switch 对于golang来说: switch非常灵活。从第一个expr为true的case开始执行,如果case带有fallthrough,程序会继续执行下一条case,不会再判断下一条case的expr,如果之后的case都有fallthrough,d...

1638 统计只差一个字符的子串数目(动态规划)

1. 问题描述: 给你两个字符串 s 和 t ,请你找出 s 中的非空子串的数目,这些子串满足替换一个不同字符以后,是 t 串的子串。换言之,请你找到 s 和 t 串中恰好只有一个字符不同的子字符串对的数目。比方说, "computer" 和 "computation"...

websocket基本原理

HTTP中一个request只能有一个response。而且这个response也是被动的,不能主动发起 因此过去的服务端推送信息是通过客户端不停的轮询实现的 websocket是双向通信协议,提供了服务端主动推送信息的能力 需要客户端(浏览器)和服务端同时支持 如果经过代理的话,还需要代理支持,否则有些代理在长时间无通信时会自动切断连接 因此WS为了保证连接不被断掉,会发心跳 WebSocket...

mybatis+ehcache二级缓存

导入jar包 mapper.xml文件开启二级缓存 pojo类实现序列化接口 配置ehcache.xml 测试...

python+opencv实现图像拼接

任务 拍摄两张图片去除相同部分,拼接在一起 原图 结果 步骤 读取两张图片 使用sift检测关键点及描述因子 匹配关键点 处理并保存关键点 得到变换矩阵 图像变换并拼接 代码实现 扩展 这里对右边图像进行变换,右边变得模糊,可以修改代码对左边图像变换 这里只有两张图片拼接,可以封装实现多张图片拼接 可以修改代码实现上下图片的拼接...

猜你喜欢

python_sklearn机器学习算法系列之AdaBoost------人脸识别(PCA,决策树)

          注:在读本文之前建议读一下之前的一片文章python_sklearn机器学习算法系列之PCA(主成分分析)------人脸识别(k-NearestNeighbor,KNN)         本文主要目的是通过一个简单的小...

memmove函数与memcpy函数的模拟实现

memmove函数和memcpy函数都是在内存复制任意类型的,但是它俩也有区别。当源区域和目标区域有重复的,memmove函数会复制缓冲区重叠的部分,而memcpy相反,会报出未知错误。 下面给出两个函数的实现 首先,memmove函数。 实现的基本原理如下图。 具体代码如下: memcpy函数的实现很简单,就直接给出源代码了...

SpringFramework核心 - IOC容器的实现 - 总结

1. 概述 把Spring技术内幕第一章和第二章过了一遍,也做了一些笔记, 对IOC容器的实现有了一定皮毛理解,现在跟着源码再过一遍总结一下IOC容器的初始化,Bean的初始化的过程,做一下总结 ① IOC容器和简单工厂模式 在开始之前,先想想我们平时是怎么使用IOC容器为我们管理Bean的,假设我们要把下面的User类交给IOC容器管理 我们不想关心如何创建一个User对象实例的,仅仅在需要他的...

Python和Django的安装

个人博客导航页(点击右侧链接即可打开个人博客):大牛带你入门技术栈  一、下载并安装Python Python 官方下载地址:http://www.python.org/ftp/python/ 我们这里选择的是 Python 2.7.2 。虽然目前最新版是Python 3.2.2, 但是Django目前还不支持 Python 3.2.2。 安装步骤很简单,双击安装包开...