Spring Cloud微服务实战：手把手带你整合eureka&zuul&feign&hystrix

布满荆棘的人生 2022-01-06 14:57 143阅读 0赞

转载自:[https://www.jianshu.com/p/cab8f83b0f0e][https_www.jianshu.com_p_cab8f83b0f0e]

代码实现:[https://gitee.com/ccsoftlucifer/springCloud\_Eureka\_zuul][https_gitee.com_ccsoftlucifer_springCloud_Eureka_zuul]

首先建立一个空的maven工程,作为项目的主工程.

在主工程的基础上,建立modul从工程.

目录的结构是这样的的:

![759102-20190417141356286-391814436.png][]

**一 .注册中心**

首先微服务是一个分布式服务,那么多服务需要协调统一维护肯定需要一个注册中心来维护.所以首先建立一个注册中心模块.

在创建的时候,选择spring Initializr , GroupID对应你的com.xxxx

Artifact对应着项目名.

选择 Cloude Discovery -> Eureka Server

启动类上加上@EnableEurekaServer注解

application.properties中添加注册中心端口号,注册中心名字

#端口号.
    server.port=8070
    #关闭自我保护.
    eureka.server.enable-self-preservation=false
    #清理服务器时间间隔[5s]
    eureka.server.eviction-interval-timer-in-ms=5000
    
    #主机名.
    eureka.instance.hostname=localhost
    #是否将自己作为客户端注册到Eureka Server[当前模块只是作为Eureka Server服务端所以设为false]
    eureka.client.register-with-eureka=false
    #是否从Eureka Server获取注册信息[当前是单点的Eureka Server所以不需要同步其它节点的数据]
    eureka.client.fetch-registry=false
    
    #Eureka Server[查询注册服务]地址.
    eureka.client.serviceUrl.defaultZone=http://${eureka.instance.hostname}:${server.port}/eureka

直接访问 Locatlhost:8070就可以打开Eureka 的主界面,查看注册中心状态.当前是没有任何一个连接注册的,所以什么都没有显示.

**二.服务提供者**

服务的提供者也在主maven工程上创建一个modul,选择spring Initializr .

cloud Discovery -> Eureka Discovery

启动类上添加@EnableDiscoverClient注解.

application.properties中添加如下配置:

#应用名称.
    spring.application.name=cloud-provider
    #应用端口号.
    server.port=8080
    #Eureka Server服务器地址.
    eureka.client.serviceUrl.defaultZone=http://localhost:8070/eureka/

定义一个controller向外暴露API

@RestController
    public class MyController {
    
        @RequestMapping(value = "/info", method = RequestMethod.GET)
        public String info() {
            try {
                //休眠2秒，测试超时服务熔断[直接关闭服务提供者亦可]
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Hello, cloud-provider";
        }
    }

**三.服务消费者**

服务的提供者也在主maven工程上创建一个modul,选择spring Initializr .

cloud Discovery -> Eureka Discovery

在启动类上添加@EnableFeignClients和@EnableEurekaClient注解\\

添加application.properties

#应用名称.
    spring.application.name=cloud-consumer
    #端口号.
    server.port=8081
    #Eureka Server服务器地址.
    eureka.client.serviceUrl.defaultZone=http://localhost:8070/eureka/
    
    #高版本spring-cloud-openfeign请求分为两层，先ribbon控制，后hystrix控制.
    #ribbon请求处理的超时时间.
    ribbon.ReadTimeout=5000
    #ribbon请求连接的超时时间
    ribbon.ConnectionTimeout=5000
    
    ##设置服务熔断超时时间[默认1s]
    hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=10000
    
    #开启Hystrix以支持服务熔断[高版本默认false关闭]，如果置为false，则请求超时交给ribbon控制.
    #feign.hystrix.enabled=true

用Feign调用远程服务.

定义服务接口类:

//1.name为被调用的服务应用名称.
    //2.InfoFallBack作为熔断实现，当请求cloud-provider失败时调用其中的方法.
    //3.feign配置.
    @FeignClient(name = "cloud-provider", fallback = InfoFallBack.class, configuration = MyFeignConfig.class)
    public interface InfoClient {
    
        //被请求微服务的地址
        @RequestMapping("/info")
        String info();
    }

定义熔断类,当远程调用失败的时候调用熔断类方法.

@Component
    public class InfoFallBack implements InfoClient {
        @Override
        public String info() {
            return "fallback info";
        }
    }

定义个性化feign

@Configuration
    public class MyFeignConfig {
    
        /**
         * feign打印日志等级
         * @return
         */
        @Bean
        Logger.Level feignLoggerLeval(){
            return Logger.Level.FULL;
        }
    }

定义服务调用类ConsumerController,通过本地方法入口调用远程服务：

@RestController
    @Configuration
    public class ConsumerController {
    
        @Autowired
        InfoClient infoClient;
    
        @RequestMapping(value = "/consumerInfo", method = RequestMethod.GET)
        public String consumerInfo(){
            return infoClient.info();
        }
    }

访问[http://127.0.0.1:8081/consumerInfo][http_127.0.0.1_8081_consumerInfo]  就会找到远程微服务提供 的info

**四 .路由Zuul**

服务的提供者也在主maven工程上创建一个modul,选择spring Initializr .

cloud Discovery -> Eureka Discovery

启动类上添加@EnableZuulProxy和@EnableEurekaClient

添加application.properties配置

#应用名称.
    spring.application.name=cloud-zuul
    #应用端口号.
    server.port=8071
    #Eureka Server服务器地址.
    eureka.client.serviceUrl.defaultZone=http://localhost:8070/eureka/
    
    #通过指定URL配置了Zuul路由，则配置以下两个超时时间.
    #zuul.host.connect-timeout-millis=5000
    #zuul.host.socket-timeout-millis=5000
    
    #zuul使用服务发现的方式[通过serviceId路由服务]，得配置ribbon的超时时间.
    #官网文档已说明：http://cloud.spring.io/spring-cloud-netflix/single/spring-cloud-netflix.html#_zuul_timeouts
    #ribbon请求处理的超时时间.
    ribbon.ReadTimeout=5000
    #ribbon请求连接的超时时间.
    ribbon.ConnectionTimeout=5000
    
    ##设置服务熔断超时时间[默认1s]
    hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=10000
    
    #只要访问以/api/开头的多层目录都可以路由到服务名为cloud-provider的服务上.
    zuul.routes.cloud-provider=/api/**

定义网关过滤器用来过滤请求信息.

/**
     * 服务网关过滤器
     */
    @Component
    public class AccessFilter extends ZuulFilter {
    
        /**
         * 返回一个字符串代表过滤器的类型，在zuul中定义了四种不同生命周期的过滤器类型：
         *  pre：可以在请求被路由之前调用
         *  route：在路由请求时候被调用
         *  post：在route和error过滤器之后被调用
         *  error：处理请求时发生错误时被调用
         * @return
         */
        @Override
        public String filterType() {
            return "pre"; //前置过滤器
        }
    
        @Override
        public int filterOrder() {
            return 0; //过滤器的执行顺序，数字越大优先级越低
        }
    
        @Override
        public boolean shouldFilter() {
            return true;//是否执行该过滤器，此处为true，说明需要过滤
        }
    
        /**
         * 过滤器具体逻辑
         * @return
         * @throws ZuulException
         */
        @Override
        public Object run() throws ZuulException {
            RequestContext ctx = RequestContext.getCurrentContext();
            HttpServletRequest request = ctx.getRequest();
            System.out.println(String.format("%s demoFilter request to %s", request.getMethod(), request.getRequestURL().toString()));
            String username = request.getParameter("username");// 获取请求的参数
            if(!StringUtils.isEmpty(username)&&username.equals("bright")){
        //当请求参数username为“bright”时通过
                ctx.setSendZuulResponse(true);// 对该请求进行路由
                ctx.setResponseStatusCode(200);
                ctx.set("isSuccess", true);// 设值，让下一个Filter看到上一个Filter的状态
                return null;
            }else{
                ctx.setSendZuulResponse(false);// 过滤该请求，不对其进行路由
                ctx.setResponseStatusCode(401);// 返回错误码
                ctx.setResponseBody("{\"result\":\"username is not correct!\"}");// 返回错误内容
                ctx.set("isSuccess", false);
                return null;
            }
        }
    }

访问[http://127.0.0.1:8071/api/info][http_127.0.0.1_8071_api_info]  就会被拦截下来,过滤该请求.

访问[http://127.0.0.1:8071/api/info?username=bright][http_127.0.0.1_8071_api_info_username_bright]  就会被路由.调用远程微服务的接口.

转载于:https://www.cnblogs.com/battlecry/p/10722573.html

[https_www.jianshu.com_p_cab8f83b0f0e]: https://www.jianshu.com/p/cab8f83b0f0e
[https_gitee.com_ccsoftlucifer_springCloud_Eureka_zuul]: https://gitee.com/ccsoftlucifer/springCloud_Eureka_zuul
[759102-20190417141356286-391814436.png]: /images/20211227/e1591c32153a4945923299d7b78b83ef.png
[http_127.0.0.1_8081_consumerInfo]: http://127.0.0.1:8081/consumerInfo
[http_127.0.0.1_8071_api_info]: http://127.0.0.1:8071/api/info
[http_127.0.0.1_8071_api_info_username_bright]: http://127.0.0.1:8071/api/info?username=bright