背景：

有一次在生產(chǎn)環(huán)境，突然出現(xiàn)了很多筆還款單被掛起，后來(lái)排查原因，發(fā)現(xiàn)是內(nèi)部系統(tǒng)調(diào)用時(shí)出現(xiàn)了Hystrix調(diào)用異常。在開發(fā)過(guò)程中，因?yàn)楹诵木€程數(shù)設(shè)置的比較大，沒(méi)有出現(xiàn)這種異常。放到了測(cè)試環(huán)境，偶爾有出現(xiàn)這種情況，后來(lái)在網(wǎng)上查找解決方案，網(wǎng)上的方案是調(diào)整maxQueueSize屬性就好了，當(dāng)時(shí)調(diào)整了一下，確實(shí)有所改善?？蓻](méi)想到在生產(chǎn)環(huán)境跑了一段時(shí)間后卻又出現(xiàn)這種了情況，此時(shí)我第一想法就是去查看maxQueueSize屬性，可是maxQueueSize屬性是設(shè)置值了。當(dāng)時(shí)就比較納悶了，為什么maxQueueSize屬性不起作用，后來(lái)通過(guò)查看官方文檔發(fā)現(xiàn)Hystrix還有一個(gè)queueSizeRejectionThreshold屬性，這個(gè)屬性是控制隊(duì)列最大閾值的，而Hystrix默認(rèn)只配置了5個(gè)，因此就算我們把maxQueueSize的值設(shè)置再大，也是不起作用的。兩個(gè)屬性必須同時(shí)配置

先看一下正確的Hystrix配置姿勢(shì)。

application.yml：

hystrix:
 threadpool:
  default:
   coreSize: 200 #并發(fā)執(zhí)行的最大線程數(shù)，默認(rèn)10
   maxQueueSize: 1000 #BlockingQueue的最大隊(duì)列數(shù)，默認(rèn)值-1
   queueSizeRejectionThreshold: 800 #即使maxQueueSize沒(méi)有達(dá)到，達(dá)到queueSizeRejectionThreshold該值后，請(qǐng)求也會(huì)被拒絕，默認(rèn)值5

接下來(lái)編寫一個(gè)測(cè)試類，來(lái)驗(yàn)證幾種錯(cuò)誤配置，看看會(huì)出現(xiàn)什么情況。

測(cè)試類代碼（A調(diào)用方）：

/**
 * @Author: XiongFeng
 * @Description:
 * @Date: Created in 11:12 2018/6/11
 */
public class RepaymentHelperTest extends FundApplicationTests {

  @Autowired
  RepaymentHelper repaymentHelper;
  @Autowired
  private RouterFeign routerFeign;

  @Test
  public void hystrixTest() throws InterruptedException {

    for (int i = 0; i < 135; i++) {
      new Thread(new Runnable() {
        @Override
        public void run() {
          job();
        }
      }).start();
    }

    Thread.currentThread().join();
  }

  public void job() {
    String repaymentNo = "xf1002";
    String transNo = "T4324324234";
    String reqNo = "xf1002";
    String begintime = "20180831130030";
    String endtime = "20180831130050";

    TransRecQueryReqDto transRecQueryReqDto = new TransRecQueryReqDto();
    transRecQueryReqDto.setTransNo(transNo);
    transRecQueryReqDto.setBeginTime(begintime);
    transRecQueryReqDto.setEndTime(endtime);
    transRecQueryReqDto.setReqNo(reqNo);

    Resp<List<TransRecDto>> queryTransRecListResp = routerFeign.queryTransRec(new Req<>(repaymentNo, "2018080200000002", null, null, transRecQueryReqDto));

    System.out.println(String.format("獲取結(jié)果為：【%s】", JsonUtil.toJson(queryTransRecListResp)));
  }
}

這個(gè)測(cè)試類的作用就是創(chuàng)建135個(gè)線程，通過(guò)RouterFeign類并發(fā)請(qǐng)求B服務(wù)方，看看請(qǐng)求結(jié)果是否出現(xiàn)異常。

Feign調(diào)用代碼：

@FeignClient(value = "${core.name}", fallbackFactory = RouterFeignBackFactory.class, path = "/router")
public interface RouterFeign {

  /**
   * 代扣結(jié)果查詢
   * @param transRecQueryReqDtoReq
   * @return
   */
  @PostMapping("/queryTransRec")
  Resp<List<TransRecDto>> queryTransRec(@RequestBody Req<TransRecQueryReqDto> transRecQueryReqDtoReq);

}

這個(gè)類，就是通過(guò)Feign方式去調(diào)用B服務(wù)方的客戶端

服務(wù)提供方代碼（B服務(wù)方）：

/**
 * @Author: XiongFeng
 * @Description:
 * @Date: Created in 16:04 2018/5/24
 */
@Api("還款服務(wù)")
@RefreshScope
@RestController
@RequestMapping("/router")
public class TestController {

  private static Logger logger = LoggerFactory.getLogger(TestController.class);

  // 計(jì)數(shù)器
  private static AtomicInteger count = new AtomicInteger(1);

  @ApiOperation(value = "代扣結(jié)果查詢")
  @PostMapping("/queryTransRec")
  Resp<List<TransRecDto>> queryTransRec(@RequestBody Req<TransRecQueryReqDto> transRecQueryReqDtoReq) throws InterruptedException {
    System.out.println(String.format("查詢支付結(jié)果......計(jì)數(shù)： %s", count.getAndAdd(1)));
    Thread.sleep(500);
    return Resp.success(RespStatus.SUCCESS.getDesc(), null);
  }
  

這個(gè)類的作用，就是一個(gè)服務(wù)提供方，計(jì)數(shù)并返回結(jié)果。

下面我們看一下幾種錯(cuò)誤的配置。

案例一（將核心線程數(shù)調(diào)低，最大隊(duì)列數(shù)調(diào)大一點(diǎn)，但是隊(duì)列拒絕閾值設(shè)置小一點(diǎn)）：

hystrix:
 threadpool:
  default:
   coreSize: 10
   maxQueueSize: 1000
   queueSizeRejectionThreshold: 20

此時(shí)的結(jié)果：

左窗口是B服務(wù)方，右窗口是A調(diào)用方。從結(jié)果可以看出，調(diào)用135次，成功32次左右，其余線程全部拋異常。

案例二（將核心線程數(shù)調(diào)低，最大隊(duì)列數(shù)調(diào)小一點(diǎn)，但是隊(duì)列拒絕閾值設(shè)置大一點(diǎn)）：

hystrix:
 threadpool:
  default:
   coreSize: 10
   maxQueueSize: 15
   queueSizeRejectionThreshold: 2000

此時(shí)的結(jié)果：

java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@7d6d472b rejected from java.util.concurrent.ThreadPoolExecutor@17f8bcb7[Running, pool size = 3, active threads = 3, queued tasks = 15, completed tasks = 0]

左窗口是B服務(wù)方，右窗口是A調(diào)用方。從結(jié)果可以看出，調(diào)用135次，成功25次左右，其余線程全部拋異常。。

案例三（將核心線程數(shù)調(diào)低，最大隊(duì)列數(shù)調(diào)大一點(diǎn)，但是隊(duì)列拒絕閾值不設(shè)置值）：

hystrix:
 threadpool:
  default:
   coreSize: 10
   maxQueueSize: 1500

此時(shí)的結(jié)果：

java.util.concurrent.RejectedExecutionException: Rejected command because thread-pool queueSize is at rejection threshold.

左窗口是B服務(wù)方，右窗口是A調(diào)用方。此時(shí)的結(jié)果和案例一的情況一樣，調(diào)用135次，成功47次左右，其余線程全部拋異常。報(bào)錯(cuò)跟案例一一樣

案例四（將核心線程數(shù)調(diào)低，最大隊(duì)列數(shù)不設(shè)值，但是隊(duì)列拒絕閾值設(shè)置的比較大）：

hystrix:
 threadpool:
  default:
   coreSize: 10
   queueSizeRejectionThreshold: 1000

此時(shí)的結(jié)果：

java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@23d268ea rejected from java.util.concurrent.ThreadPoolExecutor@66d0e2f4[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379)
at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:112)

左窗口是B服務(wù)方，右窗口是A調(diào)用方。此時(shí)的結(jié)果和案例二的情況一樣，調(diào)用135次，成功10次左右，其余線程全部拋異常。報(bào)錯(cuò)跟案例二一樣

下面來(lái)看一看正確的配置案例

案例一：將核心線程數(shù)調(diào)低，最大隊(duì)列數(shù)和隊(duì)列拒絕閾值的值都設(shè)置大一點(diǎn)）：

hystrix:
 threadpool:
  default:
   coreSize: 10
   maxQueueSize: 1500
   queueSizeRejectionThreshold: 1000

此時(shí)的結(jié)果：

左窗口是B服務(wù)方，右窗口是A調(diào)用方。此時(shí)的結(jié)果就完全正常了，并發(fā)請(qǐng)求了135次，全部成功！

結(jié)論：官方默認(rèn)隊(duì)列閾值只有5個(gè)， 如果要調(diào)整隊(duì)列，必須同時(shí)修改maxQueueSize和queueSizeRejectionThreshold屬性的值，否則都會(huì)出現(xiàn)異常！參考文檔：

Spring Hystrix 官方文檔

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論