SpringCloud之熔斷器Hystrix(二)

# 開啟斷路器

崇明網(wǎng)站建設(shè)公司成都創(chuàng)新互聯(lián)公司,崇明網(wǎng)站設(shè)計制作,有大型網(wǎng)站制作公司豐富經(jīng)驗。已為崇明近千家提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\成都外貿(mào)網(wǎng)站建設(shè)要多少錢,請找那個售后服務(wù)好的崇明做網(wǎng)站的公司定做!

enabled: true

斷路器要主動開啟,服務(wù)調(diào)用失敗時才會熔斷

此處有一個坑,把此配置寫到 application.yml 中熔斷不會生效

application.properties 和 bootstrap.yml 二選一就行

服務(wù)工程 A - controller 前端控制器(提供服務(wù))

package com.zwc.a.controller;

import org.springframework.beans.factory.annotation.Value;

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

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

/*

* @ClassName ASayHelloController

* @Desc TODO Say Hello

* @Date 2019/5/20 23:24

* @Version 1.0

*/

@RestController

public class ASayHelloController {

/*

* @ClassName ASayHelloController

* @Desc TODO 讀取配置文件中的端口

* @Date 2019/5/20 23:24

* @Version 1.0

*/

@Value("${server.port}")

private String port;

/*

* @ClassName ASayHelloController

* @Desc TODO Say Hello

* @Date 2019/5/20 23:24

* @Version 1.0

*/

@RequestMapping("/a")

public String a(){

return "Hello!I'm a. port:" + port;

}

}

提供一個服務(wù):輸出 Hello 和端口

服務(wù)工程 A - 服務(wù)調(diào)用

package com.zwc.a.api.feign;

import com.zwc.a.api.impl.FeignApiFallBack;

import org.springframework.cloud.openfeign.FeignClient;

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

/*

* @ClassName FeignApi

* @Desc TODO 使用 Feign 調(diào)用 b - 接口

* @Date 2019/5/20 23:21

* @Version 1.0

*/

@FeignClient(value = "hystrix-b" , fallback = FeignApiFallBack.class)

public interface FeignApi {

/*

* @ClassName FeignApi

* @Desc TODO 通過 hystrix-b 服務(wù)名調(diào)用 b() 方法

* @Date 2019/5/20 23:21

* @Version 1.0

*/

@RequestMapping("/b")

String b();

}

通過 @FeignClient 注解中 value = "hystrix-b" 來指定調(diào)用哪個服務(wù)

hystrix-b 就是提供者的 spring.application.name:應(yīng)用名稱

通過 @FeignClient 注解中 fallback = FeignApiFallBack.class 來指定熔斷時調(diào)用的方法

FeignApiFallBack 就是此類(FeignApi)的實現(xiàn)類,對應(yīng)的實現(xiàn)方法就是此類的熔斷時調(diào)用的方法

b():此方法是 B 工程中提供的服務(wù),在這里定義成接口

注意要與提供者具有相同返回值,相同方法名以及相同參數(shù)

服務(wù)工程 A - Fallback(FeignApiFallBack)

package com.zwc.a.api.impl;

import com.zwc.a.api.feign.FeignApi;

import org.springframework.stereotype.Component;

/*

* @ClassName FeignApi

* @Desc TODO fallback

* @Date 2019/5/20 23:21

* @Version 1.0

*/

@Component

public class FeignApiFallBack implements FeignApi {

/*

* @ClassName FeignApiFallBack

* @Desc TODO 調(diào)用 hystrix-b 服務(wù)中的 b() 方法失敗時執(zhí)行

* @Date 2019/5/20 23:31

* @Version 1.0

*/

@Override

public String b() {

return "Hello!aUseB fail";

}

}

使用 @Component 注解把此類交給 Spring 管理

實現(xiàn)了 FeignApi 接口,提供熔斷時對應(yīng)的方法

服務(wù)工程 A - controller 前端控制器(消費服務(wù))

package com.zwc.a.controller;

import com.zwc.a.api.feign.FeignApi;

import org.springframework.beans.factory.annotation.Autowired;

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

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

/*

* @ClassName AUseBFeignController

* @Desc TODO 使用 Feign 調(diào)用 b - 前端控制器

* @Date 2019/5/20 23:23

* @Version 1.0

*/

@RestController

public class AUseBFeignController {

@Autowired(required = false)

private FeignApi feignApi;

/*

* @ClassName FeignController

* @Desc TODO 通過 hystrix-b 服務(wù)名調(diào)用 b() 方法

* @Date 2019/5/20 23:13

* @Version 1.0

*/

@RequestMapping("/aUseB")

public String aUseB(){

return feignApi.b();

}

}

使用 @Autowired 注解裝配 Bean,通過此 Bean 中的方法調(diào)用服務(wù)

此類對外暴露接口,調(diào)用的實則是提供者的服務(wù)

服務(wù)工程 A - 啟動類

package com.zwc;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication

@EnableEurekaClient

@EnableFeignClients

public class SpringcloudHystrixAServiceCoreApplication {

public static void main(String[] args) {

SpringApplication.run(SpringcloudHystrixAServiceCoreApplication.class, args);

}

}無錫婦科醫(yī)院 http://www.bhnnk120.com/

添加 @EnableEurekaClient 注解表示此工程可以向注冊中心提供服務(wù)

添加 @EnableFeignClients 注解表示開啟 Feign 功能進(jìn)行遠(yuǎn)程調(diào)用

服務(wù)工程 A - 啟動項目

1. 項目啟動成功后訪問:http://localhost:8090/a (調(diào)用自己的服務(wù))

2. 輸出內(nèi)容:'Hello!I'm a. port:8090'

3. 刷新 http://localhost:8761/(注冊中心)可以看到服務(wù)已經(jīng)被注冊進(jìn)來了

4. 訪問地址:http://localhost:8090/aUseB (調(diào)用 B 工程的服務(wù))

5. 輸出內(nèi)容:'Hello!aUseB fail' (此時因為 B 工程還未啟動,所以調(diào)用了 fallback 中的方法)

6. 啟動服務(wù)工程 B,項目啟動成功后再次訪問:http://localhost:8090/aUseB (調(diào)用 B 工程的服務(wù))

7. 輸出內(nèi)容:'Hello!I'm b. port:8091' (如果還未調(diào)用成功,等待一會再刷新試試)

8. 此時就證明熔斷成功

9. 訪問地址:http://localhost:8091/b (調(diào)用自己的服務(wù))

10. 輸出內(nèi)容:'Hello!I'm b. port:8091'

11. 再次刷新 http://localhost:8761/(注冊中心),發(fā)現(xiàn) B 工程服務(wù)也注冊進(jìn)來了

service 工程 - 項目結(jié)構(gòu)

把多工程項目使用 IntelliJ IDEA 打開

把項目從 GitHub 中下載到你的本地

打開 IntelliJ IDEA

點擊 File -> Open

打開你下載到本地的項目目錄

springcloud-hystrix -> springcloud-hystrix-service(選擇打開此工程)

打開 service 工程后

再次點擊 File -> Project Structrue

選擇 Modules,點擊 '+' 符號

點擊 Import Module

還是打開你下載到本地的項目目錄

springcloud-hystrix -> springcloud-hystrix-commons -> pom.xml

點擊 OK

點擊 Next,F(xiàn)inish

點擊 Apply,OK

當(dāng)前標(biāo)題:SpringCloud之熔斷器Hystrix(二)
本文地址:http://muchs.cn/article20/pidhjo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供自適應(yīng)網(wǎng)站、網(wǎng)站收錄、品牌網(wǎng)站設(shè)計外貿(mào)網(wǎng)站建設(shè)、營銷型網(wǎng)站建設(shè)

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

網(wǎng)站托管運營