问题标签 [nats-streaming-server]

我是微服务的新手，我有一个设置多个微服务的项目，该项目是这样设置的。每个 Nest js 应用程序都有

• 暴露给端口的 API 应用程序
• 数据库
• docker-compose 文件负责为每个微服务创建容器。

现在我正在做的是拥有

Nest JS 微服务 APP 1

NEST JS 应用微服务 2

问题是我想在第二个微服务和所有新创建的微服务上使用相同的 NATS 消息代理。我的 NEST JS APP 1 的 docker-compose 文件如下。

第二个NEST JS微服务docker-compose如下

现在我想使用 NATS 在两个应用程序之间进行通信。因此，如果我从微服务 1 发布消息并将该消息订阅到微服务 2，依此类推。

我已经看过很多关于如何在 heroku 上设置 HTTPS 和 Websockets 的文档和教程，但是可以设置另一个协议，比如 TLS 或 NATS？

如果可能的话，我该怎么做？

我想使用带有nats-streaming作为事件总线的nestjs构建一个异步微服务架构。

我使用下面的 dockerfile

现在，我想将运行在nestjs 上的多个heroku 应用程序连接到它，以便它们可以发布和订阅事件。

我正在使用这个库来实现连接到事件总线。

我面临两个挑战 -

1. 我想让容器在heroku提供的端口上运行（而不是上面Dockerfile中提到的4222 （-p 4222） ）
2. 在尝试连接到运行 nats-streaming-server 的 url 时，我收到错误“无效端口”。为什么应用程序知道运行 nats-streaming 的端口很重要？

我在这里为这个问题创建了一个最小的例子。

1. 要在开发模式下运行，请使用 docker-compose up
2. 在生产中，我想在不同的 Heroku 应用程序中使用 nats-streaming 和服务器。
3. 现在，转到 localhost:3000/publish 会发布一个事件，并且同一个应用程序已经订阅了该事件并将其记录到控制台。

我被困在这个问题上几天了，任何帮助将不胜感激。或者请告诉我，使用heroku 无法实现这一点。

我想在 Kubernetes 上测试一个非常基本的 NATS-streaming 应用程序。为此，我遵循了官方 NATS-docs 中的命令。

它基本上归结为跑步

在可以访问集群的终端中（在我的情况下，它是一个kind -cluster）。

我用作stan.goNATS-streaming-client。这是我尝试连接到 NATS-streaming-server 的代码：

这是我得到的错误：

所以我认为集群使用了另一个名称或其他名称。如果我使用上面 docs.nats-link 提供的示例nats-box，它也不起作用！我在这里哪里做错了？

如果需要，我很乐意提供更多信息。

当我想在 nats-server -js 中使用 golang 发布味精时， nats-server -js 出现错误，我有这样的错误：nats: no response from stream i want to publish video to nats-server -js 这是我的 pub 文件：

我该如何解决这个问题？提前感谢您的回复。

我有两个服务名称产品和订单。OrderDb 中的订单表有 price 和 productId 列，用于存储订购的产品价格和产品 ID。订单服务有 3 个副本。

现在，假设订购了一个产品，它的 id 为 80，并且从产品服务触发了一系列顺序更新事件，以针对该特定产品订购服务：

所以该产品的最终价格应该是 100，但有时这些事件是按随机顺序处理的，例如

由于最后处理事件 3，价格变为 400。

我在我的 Nodejs 应用程序中使用 Nats 流、node-nats-streaming。
我在 kubernetes 集群上运行了两个服务，使用 Nats 相互通信。
问题是当我的侦听器内部发生错误时，nats 客户端会断开连接，并且再也不会出现在 Nats 服务器的客户端列表中。
客户端在 kubernetes 集群内运行，连接到它的数据库，但它失去了与 Nats 流的连接并且永远不会重新连接。

我的问题是，它是 node-nats-streaming 客户端的默认行为吗？我该如何解决这个问题。
提前致谢。

我正在尝试将通过我的网络摄像头生成的帧提供给使用 NATS pub-sub 的网络应用程序。我能够检索可以在回调函数中放置打印“数据”时确认的帧（yield 语句已注释）。

但是，当我使用 yield 语句再次运行它时，它不会显示任何帧产量，并且 Web 应用程序页面是空白的。

你能帮我么？我对所有这些事情都很陌生。

下午好！

我是 nats/spark 的新手，我已经被困了几天。任何小费都会很棒。我正在使用https://github.com/Logimethods/nats-connector-spark-scala连接器从 nats 服务器读取消息。我正在使用带有 SBT 的 Intellij 来运行它并且它可以工作。相反，当我尝试构建 de jar 文件失败时：

我检查了 jar 文件是否有 MANIFEST.MF：

我在想我可能遗漏了一些依赖性或不兼容问题，所以我将附上我的 buildd.sbt 文件：

使用 JDK 1.8，SBT 根据 build.properties 1.5.4。

提前致谢！

我有一个应用程序，我使用此扩展方法创建 Stan 连接并将其添加到ServiceProvider.

当它失去与 nats 流服务器的连接 15 秒时，它处于重新连接模式，如果连接再次正常工作，我的应用程序可以毫无问题地发布消息。

但是 15 秒后，我会收到连接关闭错误，并且重新连接到服务器无法解决任何问题，并且我会收到连接关闭错误，直到我重新启动我的应用程序。

nats连接将再次连接但Stan连接无法更新其连接状态可以使事情更加清楚。

我的 stan 客户端版本是 0.3.0。

如何更新此连接或将其配置为在找到服务时重新连接？