彗星和超時

Question

你好，因爲很長一段時間使用彗星Tomcat的聊天應用程序。問題是，我已經在雲中部署了應用程序，在30秒內有一個打開連接的上限。 因此，每次服務器需要超過30秒的響應時間（例如，當沒有聊天消息要推送時）客戶端收到504異常。

那麼這是否意味着彗星技術在我們有時間上限的情況下不起作用？

附加的代碼片段

package com.cumulations.clique.ChatHandler; 
public class AsynchronousGetChatHandler extends HttpServlet implements 
    CometProcessor { 

public static HashMap consumerConnectionQueue = new HashMap(); 
public static HashMap consumerPoolingQueue = new HashMap<String, String>(); 
public static HashMap consumerSessionQueue = new HashMap<String, Date>(); 

public static ConnectionFactory factory; 
public static Connection connection; 

public void event(CometEvent event) throws IOException, ServletException { 

    HttpServletRequest request = event.getHttpServletRequest(); 
    HttpServletResponse response = event.getHttpServletResponse(); 

    String userName = request.getParameter("userName"); 
    String sessionId = request.getParameter("accesskey"); 

    AsynchronousGetChatHandler.consumerPoolingQueue.put(userName, "ON"); 

    try { 

     if (event.getEventType() == CometEvent.EventType.BEGIN) { 

      String str = fromRabitQ(userName); 

      if (str != null) { 


        System.out.println("delivering a message: " + str); 

        PrintWriter writer = response.getWriter(); 
        writer.println(str); 
        writer.flush(); 
        writer.close(); 
       } 

      else { 
       PrintWriter writer = response.getWriter(); 
       writer.println(""); 
       writer.flush(); 
       writer.close(); 
      } 
     } 
    } 

    catch (Exception e) { 
     throw new ServletException("Recieving exception"); 

     // TODO: handle exception 
    } 

} 

public static String fromRabitQ(String userName) throws Exception { 
    try { 

     Channel channel; 
     QueueingConsumer consumer; 

     String QUEUE_NAME = userName; 
     String message = ""; 

     connection = RabbitMqConnection.getConnection(); 

     channel = connection.createChannel(); 

     channel.queueDeclare(QUEUE_NAME, true, false, false, null); 
     consumer = new QueueingConsumer(channel); 
     channel.basicConsume(QUEUE_NAME, true, consumer); 

     QueueingConsumer.Delivery delivery; 

     delivery = consumer.nextDelivery(27000); 

     if (delivery != null) { 
      message = new String(delivery.getBody()); 

     } else { 
      message = null; 
     } 

     channel.basicCancel(consumer.getConsumerTag()); 
     channel.close(); 

     return message; 
    } 

    catch (Exception e) { 
     System.out.println("Exception occured while receiveing " + e); 
     throw e; 
    } 

} 

}

Answer 1

我說那就去修改

delivery = consumer.nextDelivery(27000); 

到：

delivery = consumer.nextDelivery(20000); 

此外，如果您也可以提供你的執行認爲RabbitMqConnection會很棒。