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

Question

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

这是我在我的 k8s 文件夹中用于 NATS 流服务器的部署 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 等内容提供完整且正确的清单......所以，在安装 Helm Kubernetes 包管理器，您可以通过运行像“helm install my-nats nats/nats”这样简单的命令在 Kubernetes 集群中安装 NATS，然后在 Kubernetes 中启动并运行 NATS。

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

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

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