Storm中的连接被拒绝错误答案

【问题标题】：Connection refused error in StormStorm中的连接被拒绝错误
【发布时间】：2015-09-27 20:01:39
【问题描述】：

我是 Storm 的新手。我遇到以下错误

java.net.ConnectException: Connection refused
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1119)
1178482 [Thread-11-SendThread(localhost:2000)] WARN  org.apache.zookeeper.ClientCnxn  - Session 0x1417cd58578000b for server null, unexpected error, closing socket connection and attempting reconnect

有时我的拓扑工作正常，但当我再次尝试时，我得到了上述错误。在谷歌中搜索了很多但找不到任何线索。我在本地集群中运行我的拓扑..请提出一些解决方案

请在下面找到更多日志：-

2595 [Thread-11-EventThread] INFO  com.netflix.curator.framework.state.ConnectionStateManager  - State change: SUSPENDED
2596 [Thread-11-EventThread] WARN  backtype.storm.cluster  - Received event :disconnected::none: with disconnected Zookeeper.
2596 [ConnectionStateManager-0] WARN  com.netflix.curator.framework.state.ConnectionStateManager  - There are no ConnectionStateListeners registered.
3592 [Thread-11-SendThread(localhost:2000)] WARN  org.apache.zookeeper.ClientCnxn  - Session 0x1417e6596c7000b for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1119)
3895 [Thread-11-SendThread(localhost:2000)] WARN  org.apache.zookeeper.ClientCnxn  - Session 0x1417e6596c7000b for server null, unexpected error, closing socket connection and attempting reconnect
org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss
    at org.apache.zookeeper.KeeperException.create(KeeperException.java:90)
    at com.netflix.curator.framework.imps.CuratorFrameworkImpl.processBackgroundOperation(CuratorFrameworkImpl.java:380)
    at com.netflix.curator.framework.imps.BackgroundSyncImpl$1.processResult(BackgroundSyncImpl.java:49)
    at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:617)
    at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:506)

请查找更多日志：-

java.net.ConnectException: Connection refused
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599)
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1119)
50454 [Thread-15] ERROR com.netflix.curator.ConnectionState  - Connection timed out
org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss
    at com.netflix.curator.ConnectionState.getZooKeeper(ConnectionState.java:72)
    at com.netflix.curator.CuratorZookeeperClient.getZooKeeper(CuratorZookeeperClient.java:74)
    at com.netflix.curator.framework.imps.CuratorFrameworkImpl.getZooKeeper(CuratorFrameworkImpl.java:353)
    at com.netflix.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:149)
    at com.netflix.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:138)
    at com.netflix.curator.RetryLoop.callWithRetry(RetryLoop.java:85)
    at com.netflix.curator.framework.imps.ExistsBuilderImpl.pathInForeground(ExistsBuilderImpl.java:134)
    at com.netflix.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:125)
    at com.netflix.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:34)
    at backtype.storm.zookeeper$exists_node_QMARK_.invoke(zookeeper.clj:78)
    at backtype.storm.zookeeper$exists.invoke(zookeeper.clj:117)
    at backtype.storm.cluster$mk_distributed_cluster_state$reify__1996.set_data(cluster.clj:70)
    at backtype.storm.cluster$mk_storm_cluster_state$reify__2415.worker_heartbeat_BANG_(cluster.clj:276)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    at java.lang.reflect.Method.invoke(Method.java:597)
    at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
    at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
    at backtype.storm.daemon.worker$do_executor_heartbeats.doInvoke(worker.clj:35)
    at clojure.lang.RestFn.invoke(RestFn.java:439)
    at backtype.storm.daemon.worker$fn__4348$exec_fn__1228__auto____4349$fn__4352.invoke(worker.clj:346)
    at backtype.storm.timer$schedule_recurring$this__1776.invoke(timer.clj:69)
    at backtype.storm.timer$mk_timer$fn__1759$fn__1760.invoke(timer.clj:33)
    at backtype.storm.timer$mk_timer$fn__1759.invoke(timer.clj:26)
    at clojure.lang.AFn.run(AFn.java:24)
    at java.lang.Thread.run(Thread.java:680)

【问题讨论】：

您能否分享您用于运行拓扑的代码。 when I tried again 是什么意思？您是否随机收到此错误？
TopologyBuilder tBuilder=new TopologyBuilder(); tBuilder.setSpout("oracle-reader", new OracleDBSourceSpout()); tBuilder.setBolt("writer", new WriteToFileBolt()).shuffleGrouping("oracle-reader");配置 conf=新配置（）； conf.setDebug(false); conf.put(Config.TOPOLOGY_MAX_SPOUT_PENDING, 1); LocalCluster 集群=新 LocalCluster(); cluster.submitTopology("Getting-Started-Topologie",conf,tBuilder.createTopology());以上是我的拓扑代码....是的，我随机收到此错误...
您使用的是哪个storm版本，看起来像是zookeeper关闭不当的情况，您是否在运行拓扑时遇到异常后遇到此错误？您还可以发布更多错误日志
我使用的是 0.8.2 版本。我在运行拓扑时遇到此错误。在此之前也不例外。
我的意思是，如果您在运行拓扑时遇到异常（然后尝试再次运行），如果发生这种情况，因为您提到它是随机且不一致的......您可以看看 @987654321 @ 有类似的问题，似乎是因为 Zookeeper 关闭不当造成的。如果可能的话，你能发布更多的日志吗

标签： apache-storm

【解决方案1】：

我也遇到过这个问题。我的问题是运行时间设置的太短。zookeeper没有足够的时间正常关闭。看下面的代码：

    builder.createTopology());

    try {
        Thread.sleep(20000);
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    cluster.shutdown();
}

您应该在调用 cluster.shutdown() 之前设置足够的时间。一开始我设置了Thread.sleep(1000)，然后出现了和你一样的问题。改了时间之后，这个问题就再也没有出现过。

【讨论】：