问题标签 [nats-streaming-server]

我正在使用两个 .NET Core Web API；一个用于发布内容，另一个用于使用 NATS 流服务器订阅该内容。

在出版商方面

在订阅方

但是当我运行项目时，我无法转到订阅者的回调方法。

我正在试验 Nats 流服务器，到目前为止它看起来很有希望。但是，似乎只有在为其创建了持久订阅后，队列才能持久。这当然是有道理的，但是它在微服务架构中是如何工作的呢？

例如，假设您正在发布服务，而 Service1 正在将消息发送到尚未持久且没有侦听器的队列中。一段时间后，相应的服务启动并使该队列持久。你只是处理这个有希望的短暂损失还是确保先启动后面的服务？

我想使用 NATs 流服务器来流式传输数据并使用 Flink 来处理数据。

如何使用 apache flink 通过 NATS 流服务器处理实时流数据？

我是 kubernetes 的新手，正在尝试设置 nats 流集群。我正在使用以下清单文件。但是我对如何在我的应用程序中访问 nats 流服务器感到困惑。我正在使用 azure kubernetes 服务。

我尝试使用nats://nats-streaming:4222，但它给出了以下错误。

stan: connect request timeout (possibly wrong cluster ID?)

我指的是https://docs.nats.io/nats-on-kubernetes/minimal-setup

如何启用打字稿中默认禁用的--rs，我需要将此命令放在启动脚本中

我们正在建立一个 NATS 和 STAN 集群。显然，STAN 集群需要连接到我们的 NATS 集群。但是现在在将 STAN 集群连接到 NATS 集群时，我无法进行身份验证。

我们使用 NKeys 进行身份验证（https://docs.nats.io/developing-with-nats/security/nkey）。当我尝试使用 python 客户端（nats.py）连接 STAN 凭据时，我完全没有问题。

STAN 要求提供凭据文件以进行身份​​验证。我尝试提供一个只包含种子、种子和用户 pubkey 的文件......我应该怎么做？

我在这里先向您的帮助表示感谢！

我正在尝试使用 nodejs + express + nats 为我的前端应用程序构建一个 REST API。我的终端中运行着一个 nats-server。

这是我的测试代码：

运行测试代码后，无法访问 localhost:3000。

我在 github 上找到了一个类似的项目：https ://github.com/georgehaidar/poc-express-nats/blob/master/api.js 。

我似乎找不到我的错误。

谁能帮我弄清楚我做错了什么？

先感谢您。

我正在寻找具有消息持久性保证的流服务器，即在服务器确认向生产者发布之前，可以保证生产者发布的消息被持久存储。

我的用例要求我们减少丢失任何生成的消息的可能性。如果需要，生产者可以重播消息，但他们需要确保 ACKed 消息持久保存，并将由流服务器传递给消费者。

NATS 流服务器似乎在做一些事情，但是集群和容错的文档并没有很清楚地说明在每种情况下都提供了哪些持久性保证。关于生产者集成的文档确认服务器将主动 ACK 已发布的消息，无论是同步还是通过回调，但它没有明确 ACK 是否意味着该消息在此时已持久存储。

关于存储配置的文档，特别是SQL 选项简要提到了来自服务器的 ACK 意味着持久存储保证，但目前尚不清楚在集群和容错以及不同的持久性后端（文件或 SQL）的情况下究竟如何应用。

我正在寻找流媒体服务器，而 NATS Streaming 上的文档并没有明确说明在我的情况下可以使用哪种扩展策略。

我假设我们将使用FT 模式，因为我们需要确保最佳的消息持久性，但这意味着整个通道集一次只能由一个服务器处理。

也可以对通道进行分区，从而允许多个服务器 FT 组在单个网格中共存，并在不同服务器之间拆分通道集。

然而，尚不清楚的是以下内容。

如果我选择每个实体接收一个专用唯一通道的应用程序模型，并且我可以拥有数百万个共存实体（例如活跃客户） - NATS 是否能够在 FT+Partitioning 模式下一次处理数百万个通道？

在这种情况下，每个频道可能只有一个发布者和消费者。

我在 Kubernetes 集群上创建了一个 NATS 流服务器。

并且“ Kubectl get services ”输出如下：

在我的 nats-publisher.js 文件上是这样的：

我得到：

NatsError：无法连接到服务器：错误：连接 ECONNREFUSED 10.105.230.126:4222

但在另一项服务上，我使用相同的连接代码进行 nats 连接。并且该服务可以成功连接nats服务器。

为什么我收到此错误？相同的代码在另一个服务上运行正确，但是这个代码如何从这个服务崩溃？