Hystrix: Apache запросов HTTP-клиент не прерываются

Question

Я клиент Apache HTTP определяется следующим образом:

private static HttpClient httpClient = null; 
HttpParams httpParams = new BasicHttpParams(); 
httpParams.setParameter(CoreProtocolPNames.USE_EXPECT_CONTINUE, Boolean.TRUE); 
httpParams.setParameter(CoreProtocolPNames.USER_AGENT, "ABC"); 

HttpConnectionParams.setStaleCheckingEnabled(httpParams, Boolean.TRUE); 

SSLSocketFactory sf = SSLSocketFactory.getSocketFactory(); 

SchemeRegistry schemeRegistry = new SchemeRegistry(); 
schemeRegistry.register(new Scheme("http", 80, PlainSocketFactory.getSocketFactory())); 
schemeRegistry.register(new Scheme("https", 443, sf)); 

//Initialize the http connection pooling 
PoolingClientConnectionManager connectionManager = new PoolingClientConnectionManager(schemeRegistry); 

// Initialize the connection parameters for performance tuning 
connectionManager.setMaxTotal(12); 
connectionManager.setDefaultMaxPerRoute(10); 

httpClient = new DefaultHttpClient(connectionManager, httpParams); 

У меня есть команда Hystrix play и имеют следующие свойства позволили:

hystrix.command.play.execution.isolation.thread.timeoutInMilliseconds=1 
hystrix.command.play.execution.isolation.thread.interruptOnTimeout=true 

сама команда определяется следующим образом:

@HystrixCommand(groupKey="play_group",commandKey="play") 
    public String process(String request) throws UnsupportedOperationException, IOException, InterruptedException { 
     System.out.println("Before - process method : " + request); 
     callHttpClient(request); 
     System.out.println("After - process method" + request); 
     return ""; 
    } 

    private void callHttpClient(String request) throws ClientProtocolException, IOException, InterruptedException { 
     HttpGet get = new HttpGet("http://www.google.co.in"); 
     HttpResponse response = httpClient.execute(get); 
     System.out.println("Response:" + response); 
    } 

Теперь я попробую выполнить команду 5 раз в цикле:

public static void main(String[] args) throws UnsupportedOperationException, IOException, InterruptedException { 
     ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContextTest.xml"); 
     HystrixPlayground obj = ctx.getBean(HystrixPlayground.class); 

     long t1 = System.currentTimeMillis(); 
     for (int i = 0; i < 5; i++) { 
      try{ 
       System.out.println(obj.process("test" + i)); 
      } catch(Exception ex) { 
       System.out.println(ex); 
      } 
      long t2 = System.currentTimeMillis(); 
      System.out.println("Time(ms) : ---->" + (t2 - t1)); 

Тайм-аут установлен в 1 милли секунду, поэтому метод процесс бросает HystrixRunTimeException. Тем не менее, HTTP-запрос продолжает выполнять и печатает строку «After-process method».

Я видел это поведение последовательно только для запросов клиента http. Если HTTP-запрос заменяется чем-то другим, подобным потоку нити или очень большим циклом, поток hystrix прерывается, как ожидалось.

Кто-нибудь знает, почему это может произойти?

Answer 1

Причина в том, что прерывание потока в Java не «принудительно останавливает» его. Вместо этого вызов Thread.interrupt() просто устанавливает флаг, который может, но не должен быть интерпретирован текущим потоком. Подробнее см. Здесь: What does java.lang.Thread.interrupt() do?

Apache HTTP-клиент не интерпретирует этот флаг. Таким образом, HTTP-запрос не отменяется и просто завершается.