java - 管理从 Java EE 应用程序到 Twitter 流 API 的长期连接

Question

我需要创建一个从 Java EE6 应用程序到 Twitter streaming API 的长时间运行的连接并且还能够在失败时监视和重新建立连接。

我已经使用 Jersey JAX-RS 和 OAuth 运行了一个测试，如下所示，它可以按照我的意愿处理流数据。

WebResource resource = client.resource(STATUS_URI);
resource.addFilter(oauthFilter);
ClientResponse clientResponse = resource.get(ClientResponse.class);
InputStream is = clientResponse.getEntityInputStream();
BufferedReader r = new BufferedReader(new InputStreamReader(is, "UTF8"));
boolean more = true;
while (more) {
    String jsonTweet = r.readLine();
    //send tweet to JMS queue
    ..... 
}

我已经尝试在单例“@PostConstruct”方法中运行上述代码，但它会阻塞并且应用程序无法正确加载。

我的问题是在应用程序启动时从 Java EE 环境中初始化连接然后在不直接创建新线程的情况下监视 + 重新连接错误的推荐方法是什么？

Answer 1

recommended way to initialise the connection from within a Java EE environment on application startup

• 您可以使用@Service 来创建Singleton MBean(JBoss 特定实现)，但我仍然更喜欢@Startup 和@Singleton 来获得在应用程序部署时为服务器的可移植性所做的事情。

monitor + re-connect on errors without directly creating new threads?

• ThreadPoolExecutor:一个 ExecutorService，它使用可能的多个池线程之一执行每个提交的任务，通常使用 Executors 工厂方法配置。

在异常情况下，任务可以重新提交给执行者服务，任务可能包括监控、重连等。