如何在 golang 中回复 nats.Subscribe 中已接受的连接

Golang不知道大家是否熟悉？今天我将给大家介绍《如何在 golang 中回复 nats.Subscribe 中已接受的连接》，这篇文章主要会讲到等等知识点，如果你在看完本篇文章后，有更好的建议或者发现哪里有问题，希望大家都能积极评论指出，谢谢！希望我们能一起加油进步！

我正在尝试在 golang 中创建一个 tcp 服务器，它接受连接，读取数据，然后通过 nats.Publish 发布它。但我也想回复并关闭订阅者内部的连接，而不是在主服务器脚本中 我看到两种可能的方法：发布连接或在订阅者中建立新连接，但我无法意识到 预先感谢您

UPD 关于 I. Kozlovic 回答的评论： 不完全是我想要的，但可能会有所帮助:) 我正在写关于关闭 tcp 连接 - 不是一个 nats 连接，并在另一个 go 进程中关闭 - 不是在它被接受的连接中。但由于我没有成功，我可以根据您的回答执行以下操作：我可以通过 nats 发布我需要的信息，处理它，然后回复“确定。关闭连接”并关闭发布者中的 TCP 连接，这是一个 TCP服务器。然而，如果我不是从这个流程而是从另一个流程进行回复，那就太好了。我理解这很棘手，但我想做与上一条消息中写的相同的操作，但进行一些修改。我有 TCP 服务器，它接受连接，然后连接 nats 并发布消息，订阅此消息的另一个 go 进程处理输入，然后将其输出发布到第三个 go 进程，该进程处理其输入，然后回复“确定。完成。关闭 TCP 连接” “到第一个 go 进程......:)

解决方案

根据您更新的问题，这是一种可能的方法。 请注意，这里的两个额外进程由 go 例程表示，但在实际情况中您将让它们成为单独的进程。 我还省略了错误检查。

// This represent what would be the last process in your
// example.
go func() {
    nc, _ := nats.Connect(nats.DefaultURL)
    nc.Subscribe("bar", func(m *nats.Msg) {
        fmt.Printf("Received request: %s, final stop, sending back to %v\n", m.Data, m.Reply)
        nc.Publish(m.Reply, []byte("I'm here to help!"))
    })
    nc.Flush()
    runtime.Goexit()
}()

// This would be the in-between process that receives
// the message triggered by the TCP accept
go func() {
    nc, _ := nats.Connect(nats.DefaultURL)
    nc.Subscribe("foo", func(m *nats.Msg) {
        fmt.Printf("Received request: %s, forward to bar\n", m.Data)
        nc.PublishRequest("bar", m.Reply, []byte(fmt.Sprintf("got %s", m.Data)))
    })
    nc.Flush()
    runtime.Goexit()
}()

// This would be your TCP server
l, _ := net.Listen("tcp", "127.0.0.1:1234")
for {
    c, _ := l.Accept()
    go func(c net.Conn) {
        // Close socket when done
        defer c.Close()
        // Connect to NATS
        nc, _ := nats.Connect(nats.DefaultURL)
        // Close NATS connection when done
        defer nc.Close()
        // Sends the request to first process. Note that this
        // has a timeout and so if no response is received, the
        // go-routine will exit, closing the TCP connection.
        reply, err := nc.Request("foo", []byte("help"), 10*time.Second)
        if err != nil {
            fmt.Printf("Got error: %v\n", err)
        } else {
            fmt.Printf("Got reply: %s\n", reply.Data)
        }
    }(c)
}

请注意，通常不建议创建生命周期非常短的 nats 连接。如果 nats 连接适合您的模型，您可能希望重用该连接。

理论要掌握，实操不能落！以上关于《如何在 golang 中回复 nats.Subscribe 中已接受的连接》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！