如何進(jìn)行SpringCloud-Hystrix緩存與合并請(qǐng)求，相信很多沒(méi)有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策，為此本文總結(jié)了問(wèn)題出現(xiàn)的原因和解決方法，通過(guò)這篇文章希望你能解決這個(gè)問(wèn)題。

為市中等地區(qū)用戶提供了全套網(wǎng)頁(yè)設(shè)計(jì)制作服務(wù)，及市中網(wǎng)站建設(shè)行業(yè)解決方案。主營(yíng)業(yè)務(wù)為成都網(wǎng)站設(shè)計(jì)、網(wǎng)站建設(shè)、市中網(wǎng)站設(shè)計(jì)，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠(chéng)的服務(wù)。我們深信只要達(dá)到每一位用戶的要求，就會(huì)得到認(rèn)可，從而選擇與我們長(zhǎng)期合作。這樣，我們也可以走得更遠(yuǎn)！

緩存在開(kāi)發(fā)中經(jīng)常用到，我們常用 redis 這種第三方的緩存數(shù)據(jù)庫(kù)對(duì)數(shù)據(jù)進(jìn)行緩存處理。

結(jié)果緩存

在 Hystrix 中也為我們提供了方法級(jí)別的緩存。通過(guò)重寫 getCacheKey 來(lái)判斷是否返回緩存的數(shù)據(jù)，getCacheKey 可以根據(jù)參數(shù)來(lái)生成。這樣，同樣的參數(shù)就可以都用到緩存了。

改造之前的 MyHystrixCommand，在其中增加 getCacheKey 的重寫實(shí)現(xiàn)，代碼如下所示。

@Overrideprotected String getCacheKey() {return String.valueOf(this.name);
}

在上面的代碼中，我們把創(chuàng)建對(duì)象時(shí)傳進(jìn)來(lái)的 name 參數(shù)作為緩存的 key。

為了證明能夠用到緩存，在 run 方法中加一行輸出，在調(diào)用多次的情況下，如果控制臺(tái)只輸出了一次，那么可以知道后面的都是走的緩存邏輯，代碼如下所示。

@Overrideprotected String run() {System.err.println("get data");return this.name + ":" + Thread.currentThread().getName();
}

執(zhí)行 main 方法，發(fā)現(xiàn)程序報(bào)錯(cuò)了，如圖 1 所示：

完整錯(cuò)誤信息如下：

Caused by: java.lang.IllegalStateException: Request caching is not available. Maybe you need to initialize the HystrixRequestContext?

根據(jù)錯(cuò)誤提示可以知道，緩存的處理取決于請(qǐng)求的上下文，我們必須初始化 Hystrix-RequestContext。

改造 main 方法中的調(diào)用代碼，初始化 HystrixRequestContext，代碼如下所示。

public static void main(String[] args) throws InterruptedException, ExecutionException {
    HystrixRequestContext context = HystrixRequestContext.initializeContext();
    String result = new MyHystrixCommand("zhangsan").execute();
    System.out.println(result);
    Future<String> future = new MyHystrixCommand("zhangsan").queue();
    System.out.println(future.get());
    context.shutdown();
}

改造完之后重寫執(zhí)行 main 方法，就可以做正常運(yùn)行了，輸出結(jié)果如圖 2 所示：

我們可以看到只輸出了一次 get data，緩存生效。

緩存清除

剛剛我們學(xué)習(xí)了如何使用 Hystrix 來(lái)實(shí)現(xiàn)數(shù)據(jù)緩存功能。有緩存必然就有清除緩存的動(dòng)作。

當(dāng)數(shù)據(jù)發(fā)生變動(dòng)時(shí)，必須將緩存中的數(shù)據(jù)也更新掉，不然就會(huì)出現(xiàn)臟數(shù)據(jù)的問(wèn)題。同樣地，Hystrix 也有清除緩存的功能。

增加一個(gè)支持緩存清除的類，代碼如下所示。

public class ClearCacheHystrixCommand extends HystrixCommand<String> {private final String name;private static final HystrixCommandKey GETTER_KEY = HystrixCommandKey.Factory.asKey("MyKey");public ClearCacheHystrixCommand(String name) {super(HystrixCommand.Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("MyGroup"))
                .andCommandKey(GETTER_KEY));this.name = name;
    }public static void flushCache(String name) {
        HystrixRequestCache.getInstance(GETTER_KEY,HystrixConcurrencyStrategyDefault.getInstance()).clear(name);
    }@Overrideprotected String getCacheKey() {return String.valueOf(this.name);
    }@Overrideprotected String run() {
        System.err.println("get data");return this.name + ":" + Thread.currentThread().getName();
    }@Overrideprotected String getFallback() {return "失敗了 ";
    }
}

flushCache 方法就是清除緩存的方法，通過(guò) HystrixRequestCache 來(lái)執(zhí)行清除操作，根據(jù) getCacheKey 返回的 key 來(lái)清除。

修改調(diào)用代碼來(lái)驗(yàn)證清除是否有效果，代碼如下所示。

public static void main(String[] args) throws InterruptedException, ExecutionException {
    HystrixRequestContext context = HystrixRequestContext.initializeContext();
    String result = new ClearCacheHystrixCommand("zhangsan").execute();
    System.out.println(result);
    ClearCacheHystrixCommand.flushCache("zhangsan");
    Future<String> future = new ClearCacheHystrixCommand("zhangsan").queue();
    System.out.println(future.get());
}

執(zhí)行兩次相同的 key，在第二次執(zhí)行之前調(diào)用緩存清除的方法，也就是說(shuō)第二次用不到緩存，輸出結(jié)果如圖 3 所示：

由此可以看出，輸出兩次 get data，這證明緩存確實(shí)被清除了?？梢园?ClearCache-HystrixCommand.flushCache 這行代碼注釋掉再執(zhí)行一次，就會(huì)發(fā)現(xiàn)只輸出了一次 get data，緩存是有效的，輸入結(jié)果如圖 2 所示。

合并請(qǐng)求

Hystrix 支持將多個(gè)請(qǐng)求自動(dòng)合并為一個(gè)請(qǐng)求（代碼如下所示），利用這個(gè)功能可以節(jié)省網(wǎng)絡(luò)開(kāi)銷，比如每個(gè)請(qǐng)求都要通過(guò)網(wǎng)絡(luò)訪問(wèn)遠(yuǎn)程資源。如果把多個(gè)請(qǐng)求合并為一個(gè)一起執(zhí)行，將多次網(wǎng)絡(luò)交互變成一次，則會(huì)極大地節(jié)省開(kāi)銷。

public class MyHystrixCollapser extends HystrixCollapser<List<String>, String, String> {private final String name;public MyHystrixCollapser(String name) {this.name = name;
    }@Overridepublic String getRequestArgument() {return name;
    }@Overrideprotected HystrixCommand<List<String>> createCommand(final Collection<CollapsedRequest<String, String>> requests) {return new BatchCommand(requests);
    }@Overrideprotected void mapResponseToRequests(List<String> batchResponse,
            Collection<CollapsedRequest<String, String>> requests) {
        int count = 0;for (CollapsedRequest<String, String> request : requests) {
            request.setResponse(batchResponse.get(count++));
        }
    }private static final class BatchCommand extends HystrixCommand<List<String>> {private final Collection<CollapsedRequest<String, String>> requests;private BatchCommand(Collection<CollapsedRequest<String, String>> requests) {super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"))
                    .andCommandKey(HystrixCommandKey.Factory.asKey("GetValueForKey")));this.requests = requests;
        }@Overrideprotected List<String> run() {
            System.out.println(" 真正執(zhí)行請(qǐng)求......");
            ArrayList<String> response = new ArrayList<String>();for (CollapsedRequest<String, String> request : requests) {
                response.add(" 返回結(jié)果 : " + request.getArgument());
            }return response;
        }
    }
}

接下來(lái)編寫測(cè)試代碼，代碼如下所示。

public static void main(String[] args) throws InterruptedException, ExecutionException {
    HystrixRequestContext context = HystrixRequestContext.initializeContext();
    Future<String> f1 = new MyHystrixCollapser("zhangsan").queue();
    Future<String> f2 = new MyHystrixCollapser("zhangsan333").queue();
    System.out.println(f1.get() + "=" + f2.get());
    context.shutdown();
}

通過(guò) MyHystrixCollapser 創(chuàng)建兩個(gè)執(zhí)行任務(wù)，按照正常的邏輯肯定是分別執(zhí)行這兩個(gè)任務(wù)，通過(guò) HystrixCollapser 可以將多個(gè)任務(wù)合并到一起執(zhí)行。從輸出結(jié)果就可以看出，任務(wù)的執(zhí)行是在 run 方法中去做的，輸出結(jié)果如圖 4 所示： 

看完上述內(nèi)容，你們掌握如何進(jìn)行SpringCloud-Hystrix緩存與合并請(qǐng)求的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝各位的閱讀！

網(wǎng)站題目：如何進(jìn)行SpringCloud-Hystrix緩存與合并請(qǐng)求
本文地址：http://aaarwkj.com/article46/gpgeeg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供小程序開(kāi)發(fā)、網(wǎng)站導(dǎo)航、網(wǎng)站排名、、App開(kāi)發(fā)、用戶體驗(yàn)

廣告

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