接收消息
通常情况下,应用程序可以异步或同步地接收消息。使用 NATS 接收消息的方式可能取决于所使用的客户端库。
一些语言(如 Go 或 Java)同时提供同步和异步的 API,而其他语言可能仅支持其中一种订阅方式。
在所有情况下,订阅的过程都涉及让客户端库告知 NATS 系统某个应用程序对特定主题感兴趣。当应用程序不再需要订阅时,它会取消订阅,从而通知服务器停止发送消息。
客户端将为每个匹配的订阅收到一条消息,因此如果一个连接有多个使用相同或重叠主题(例如 foo 和 >)的订阅,那么相同的消息将会被发送给客户端多次。
注意:客户端 API(异步)的订阅调用可能会在 nats-server 上实际完成订阅之前返回。如果您需要确保与服务器端的订阅完全建立同步,可以在调用 subscribe 后立即对连接调用 Flush() 方法。
