相关疑难解决方法(0)

我需要一个监视器类来定期检查给定的HTTP URL是否可用.我可以使用Spring TaskExecutor抽象来处理"常规"部分,因此这不是主题.问题是:在java中ping URL的首选方法是什么？

这是我当前的代码作为起点:

try {
    final URLConnection connection = new URL(url).openConnection();
    connection.connect();
    LOG.info("Service " + url + " available, yeah!");
    available = true;
} catch (final MalformedURLException e) {
    throw new IllegalStateException("Bad URL: " + url, e);
} catch (final IOException e) {
    LOG.info("Service " + url + " unavailable, oh no!", e);
    available = false;
}

1. 这有什么好处(它会做我想要的)吗？
2. 我必须以某种方式关闭连接吗？
3. 我想这是一个GET请求.有没有办法发送HEAD？

我需要在Java中编写一个冒烟测试,验证系统是否连接到kafka,

有谁有想法吗？我发现这篇文章:

如何检查Kafka Server是否正在运行？

但是从Java代码中做起来太复杂了,我不认为这是我应该使用的方向.

提前致谢.

我正在使用 kafka-net 客户端向 kafka 发送消息。我只是想知道是否有任何方法可以检查 kafka 服务器是否已启动并可以接收消息。我关闭了 kafka，但是已经成功创建了生产者并且 SendMessageAsync 只是冻结了很长时间。我试图通过超时，但它没有改变任何东西。我使用 kafka-net 0.9 当 kafka 服务器启动并运行时它工作得很好