Code

  1. /**
  2.  * @author luobo.cs@raycloud.com
  3.  * @since 2020/8/2 3:49 下午
  4.  */
  5. public class TimeOutCommand extends HystrixCommand<Boolean> {
  7.     final Logger log = LoggerFactory.getLogger(this.getClass());
  9.     private final DbConfig dbConfig;
  11.     public TimeOutCommand(DbConfig dbConfig) {
  12.         super(Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("fast-timeout"))
  13.                 .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey(dbConfig.getName()))
  14.                 .andCommandPropertiesDefaults(HystrixCommandProperties.Setter().withExecutionTimeoutInMilliseconds(10000).withExecutionTimeoutEnabled(true))
  15.                 .andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter().withMaxQueueSize(300).withCoreSize(10)));
  16.         this.dbConfig = dbConfig;
  17.     }
  19.     @Override
  20.     protected Boolean run() {
  21.         try {
  22.             DBUtils.testConn(dbConfig);
  23.             return Boolean.TRUE;
  24.         } catch (Exception e) {
  25.             log.error("[TimeOutCommand][error:{}]", e.getMessage(), e);
  26.             return Boolean.FALSE;
  27.         }
  28.     }
  30.     @Override
  31.     protected Boolean getFallback() {
  32.         log.error("出现降级 GG:{}", JSONObject.toJSONString(dbConfig));
  33.         return Boolean.FALSE;
  34.     }
  35. }

使用

  1.     TimeOutCommand timeOutCommand = new TimeOutCommand(config);
  2.     //这里的使用根据实际情况使用，例如有的场景需要同步，有的场景需要异步
  3.     //同步execute 异步 observe
  4.     final Boolean execute = timeOutCommand.execute();
  6.     //异步
  7.     Observable<Response<String>> observe = timeOutCommand.observe();
  8.                 observe.subscribe(new Observer<Response<String>>() {
  9.                     @Override
  10.                     public void onCompleted() {
  11.                         //没有什么东西
  12.                     }
  14.                     @Override
  15.                     public void onError(Throwable e) {
  16.                         //这里可无视
  17.                     }
  19.                     @Override
  20.                     public void onNext(Response<String> response) {
  21.                         //降级或者不降级都会走这里
  22.                         if (response.getSuccess()) {
  23.                             try {
  24.                                 TOMCAT_STATUS.put(tomcat.getTomcatId(), response.getBody().split("\\t")[2]);
  25.                             } catch (Exception e) {
  26.                                 TOMCAT_STATUS.put(tomcat.getTomcatId(), e.getMessage());
  27.                             }
  28.                         } else {
  29.                             TOMCAT_STATUS.put(tomcat.getTomcatId(), response.getErrorMsg());
  30.                         }
  31.                     }
  32.                 });

——————————
2021-01-06

对于豪猪的不了解，导致设置的有问题

  1. .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey(dbConfig.getName()))

这里会为每一个 dbConfig.getName 都生成一个线程池，所以随着name的增加，线程开始💥 爆炸。 这里需要明确是否要隔离. 例如我只想要的功能只要一个线程池就够了