AWS 上的间歇性 NATS 连接失败并超时

发布于 2025-01-12 05:48:46 字数 1293 浏览 3 评论 0原文

我们有一个 clojure 应用程序，它使用 NATS 和 NATS Java 库来支持集群。这全部部署在AWS EC2实例上。

从昨晚开始，我们发现应用程序和 NATS 实例之间出现间歇性连接超时。我们没有更改任何代码，也不知道有任何网络或 AWS 配置更改。这些错误开始同时在所有环境中发生。

我们的连接代码：

defn connect
  "Create a Nats connect and return a Connection object.
     @urls -> Nats server urls (\"nats://127.0.0.1:4222\"), either a seq or comma separated string
     returns <- a Nats Connection object"
  ([]
   (connect ["nats://127.0.0.1:4222"]))
  ([urls]
   (->> (.. (Options$Builder.)
            (errorListener (make-error-handler))
            (connectionListener (make-connection-handler))
            (servers (into-array String urls))
            (executor pool)
            build)
        (Nats/connect))))

我们还修改了上面的连接代码，将超时更新为 10 秒，但仍然会看到超时并出现如下错误。

NATS Error Exception: java.net.SocketTimeoutException: connect timed out

java.io.IOException: Unable to connect to NATS servers: nats://my.nats.uri:4222.
    at io.nats.client.impl.NatsConnection.connect(NatsConnection.java:235)
    at io.nats.client.impl.NatsImpl.createConnection(NatsImpl.java:29)
    at io.nats.client.Nats.createConnection(Nats.java:247)
    at io.nats.client.Nats.connect(Nats.java:164)
...

如果不更改代码，什么会导致 NATS 连接开始以这种方式失败？

原文

We have a clojure application that users NATS and the NATS Java libraries to support clustering. This is all deployed on AWS EC2 instances.

Starting last night we are seeing intermittent connection timeouts between the application and the NATS instance. We didn't change any code and don't know of any network or AWS configuration changes. The errors started occurring in all environments at the same time.

Our connection code:

defn connect
  "Create a Nats connect and return a Connection object.
     @urls -> Nats server urls (\"nats://127.0.0.1:4222\"), either a seq or comma separated string
     returns <- a Nats Connection object"
  ([]
   (connect ["nats://127.0.0.1:4222"]))
  ([urls]
   (->> (.. (Options$Builder.)
            (errorListener (make-error-handler))
            (connectionListener (make-connection-handler))
            (servers (into-array String urls))
            (executor pool)
            build)
        (Nats/connect))))

We also modified the connection code above to update the timeout to be 10 seconds and still are seeing timeouts with an error like the one below.

NATS Error Exception: java.net.SocketTimeoutException: connect timed out

java.io.IOException: Unable to connect to NATS servers: nats://my.nats.uri:4222.
    at io.nats.client.impl.NatsConnection.connect(NatsConnection.java:235)
    at io.nats.client.impl.NatsImpl.createConnection(NatsImpl.java:29)
    at io.nats.client.Nats.createConnection(Nats.java:247)
    at io.nats.client.Nats.connect(Nats.java:164)
...

Without a code change what could cause NATS connections to start failing in that fashion?

分享到QQ

分享到微博