NATS请求-回复-它是如何工作的?

您添加了 nats-streaming-server 标记,所以我首先要澄清的是,在NATS流中没有请求/回复API,因为它实际上没有意义。

在NATS中,当发布应用程序想要知道订阅应用程序确实接收并处理了消息时,您将使用请求/回复。它是一种端到端的确认,确认已接收并处理发布的消息。

也可能是因为订阅应用程序处理作业并将该作业的结果发送回请求者。

一个简单的例子是:

// Request will create an internal subscription on
// a private inbox and set it to the message's Reply
// field.
msg, err := nc.Request("job", payload, time.Second)
if err != nil {
    ...
} else {
    // msg is the reply sent by the subscribing application.
}

另一方面,您将注册一个订阅来处理作业请求。

nc.Subscribe("job", func(req *nats.Msg) {
    // req is the request received by the publisher above.
    // Send back a reply to the request reply subject.
    nc.Publish(req.Reply, []byte(reply))
})

不知道你用什么语言,但这里有一个链接 Go client