node.js - 用于连接到 NATS 事件总线的 Kubernetes 部署配置

Question

我之前将 Nats Streaming 用于基于 Docker、Kubernetes 和 node.js 的微服务，但由于 Nats Streaming 目前已被弃用，我想迁移到 NATS 和 NATS JetStream。

这是我在我的 k8s 文件夹中用于 NATS Streaming 服务器的部署 yaml 配置文件，skaffold 使用它来应用它并且工作正常:

apiVersion: apps/v1
kind: Deployment
metadata:
  name: nats-depl
spec:
  replicas: 1
  selector:
    matchLabels:
      app: nats
  template:
    metadata:
      labels:
        app: nats
    spec:
      containers:
        - name: nats
          image: nats-streaming:0.23.2
          args:
            [
              '-p',
              '4222',
              '-m',
              '8222',
              '-hbi',
              '5s',
              '-hbt',
              '5s',
              '-hbf',
              '2',
              '-SD',
              '-cid',
              'adrian',
            ]
---
apiVersion: v1
kind: Service
metadata:
  name: nats-srv
spec:
  selector:
    app: nats
  ports:
    - name: client
      protocol: TCP
      port: 4222
      targetPort: 4222
    - name: monitoring
      protocol: TCP
      port: 8222
      targetPort: 8222

名为 adrian 的集群，我可以在我的 node.js 应用程序中作为客户端连接到 NATS Streaming 服务器:

import nats from 'node-nats-streaming';

const stan = nats.connect( 'adrian', 'abc', {
  url: "http://localhost:4222"
} );

现在我想迁移到 NATS 和 NATS JetStream。因此，我将我的 Kubernetes 部署配置更改为:

apiVersion: apps/v1
kind: Deployment
metadata:
  name: nats-depl
spec:
  replicas: 1
  selector:
    matchLabels:
      app: nats
  template:
    metadata:
      labels:
        app: nats
    spec:
      containers:
        - name: nats
          image: nats
          args:
            [
              '-p',
              '4222',
              '-m',
              '8222',
              '-D',
              '-js',
              '--cluster_name',
              'adrian',
            ]
---
apiVersion: v1
kind: Service
metadata:
  name: nats-srv
spec:
  selector:
    app: nats
  ports:
    - name: client
      protocol: TCP
      port: 4222
      targetPort: 4222
    - name: monitoring
      protocol: TCP
      port: 8222
      targetPort: 8222

当我尝试使用新的 NATS 客户端连接方法连接到 NATS 服务器时，如下所示:

import { connect } from 'nats';

const natsPublisher = async () => {
  try {
    const nc = await connect( { servers: "http://localhost:4222" } );
    console.log(`connected to ${nc.getServer()}`);
  } catch ( error ) {
    console.log( '--- NATS ERROR: ', error )
  }
}

natsPublisher();

我在终端中收到此错误:

--- NATS ERROR:  NatsError: CONNECTION_REFUSED
    at Function.errorForCode (E:\Projects\express-projects\adrian-microservices\nats-test\node_modules\nats\nats-base-client\error.ts:119:12)
    at NodeTransport.<anonymous> (E:\Projects\express-projects\adrian-microservices\nats-test\node_modules\nats\src\node_transport.ts:92:21)
    at Generator.throw (<anonymous>)
    at rejected (E:\Projects\express-projects\adrian-microservices\nats-test\node_modules\nats\lib\src\node_transport.js:6:65)
    at processTicksAndRejections (node:internal/process/task_queues:96:5) {
  code: 'CONNECTION_REFUSED',
  chainedError: Error: connect ECONNREFUSED 127.0.0.1:4222
      at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1161:16) {
    errno: -4078,
    code: 'ECONNREFUSED',
    syscall: 'connect',
    address: '127.0.0.1',
    port: 4222
  }
}

那么我怎样才能解决问题并毫无问题地连接到 NATS？

如有任何帮助，我们将不胜感激。

Answer 1

经过一些试验和错误以及一些研究，我意识到使用 Helm(Kubernetes 包管理器)实际上更好，可以为 NATS 或 Kafka 或 ElasticSearch 等提供完整和正确的 list ......所以，在安装 Helm Kubernetes 包管理器，您可以通过运行像“helm install my-nats nats/nats”这样简单的命令在您的 Kubernetes 集群中安装 NATS，然后您在 Kubernetes 中启动并运行 NATS。

但在这种情况下，我为 NATS 提出的 list 与以前不同，使用 localhost 从 node.js 客户端连接到 NATS 服务器很常见，并且可以进行外部访问，您可以连接通过使用像这样的服务名称从 node.js 客户端到 NATS 服务器，这可能更合适:

import { connect } from 'nats';

const natsPublisher = async () => {
  try {
    const nc = await connect( { servers: "http://nats-srv:4222" } );
    console.log( `connected to ${ nc.getServer() }` );
  } catch ( error ) {
    console.log( 'NATS ERROR: ', error )
  }
}

这是我连接到 NATS 后的终端日志:

[taxonomy] Listening on port 3000!
[taxonomy] connected to nats-srv:4222

希望这对其他人有所帮助。