请求 nats 团队招求_TOU_

亲爱的编程学习爱好者，如果你点开了这篇文章，说明你对《请求 nats 团队招求_TOU_》很感兴趣。本篇文章就来给大家详细解析一下，主要介绍一下，希望所有认真读完的童鞋们，都有实质性的提高。

这是我的 sub.go 示例：

package main

import (
    "fmt"
    nats "github.com/nats-io/nats.go"
)

type message struct {
    status string `json:"status"`
    msg    string `json:"msg"`
}

type response struct {
    status string `json:"status"`
    msg    string `json:"msg"`
}

var nc *nats.conn
var c *nats.encodedconn

func start(){
    nc, _ := nats.connect("127.0.0.1:4222")
    c, _ := nats.newencodedconn(nc, nats.json_encoder)
    c.queuesubscribe("subject_toto", "queue_titi", func(_, reply string, message  *message) {
        fmt.printf("%+v\n", message)
        var response response
        response.msg = "message received"
        response.status = "ok"
        c.publish("reply", response)
        c.flush()
    })
    c.flush()
}

func main() {
    fmt.println("begin")
    go start()
    defer c.close()
    fmt.scanln()
    nc.drain()
    // close connection
    nc.close()
    fmt.println("done")
}

它运行完美，所以现在我想向这个队列发布一条消息，这是我的 pub.go：

package main

import (
    "fmt"
    nats "github.com/nats-io/nats.go"
    "time"
)

type Message struct {
    Status string `json:"Status"`
    Msg    string `json:"Msg"`
}

type Response struct {
    Status string `json:"Status"`
    Msg    string `json:"Msg"`
}

var nc *nats.Conn
var c *nats.EncodedConn

func start(){
    var err error
    var message Message
    var response Response
    nc, _ := nats.Connect("127.0.0.1:4222")
    c, _ := nats.NewEncodedConn(nc, nats.JSON_ENCODER)
    message.Status = "Ok"
    message.Msg = "hello"
    err = c.Request("subject_toto", message, &response, 6*time.Second)
    if err != nil {
        fmt.Printf("%+v\n", err)
    }
    fmt.Printf("%+v\n","response")
    fmt.Printf("%+v\n", response)
    defer c.Close()
}

func main() {
    fmt.Println("begin")
    start()
    fmt.Println("done")
}

但是当我尝试发布到它时，我得到一个空响应：

响应{状态：消息：}

答案的开头之一似乎使用 publishrequest 但似乎我只能向服务器发送字符串而不是结构。

解决方案

问题出在这一行：

c.publish("reply", response)

当您发送请求并且您的订阅者要回复时，应该有一个称为收件箱的“回复主题”。该收件箱在处理函数的 reply arg 中设置。

因此，您必须将响应发布到 queuesubscribe() 中处理函数的 reply 参数返回的主题中，因此将该行更改为：

c.publish(reply, response)

回复参数的值对于通信很重要，如下所示：_inbox.bw5etjshbti9oqdvxfoblz.vxsgbcjh

这是 sub 的功能版本：

package main

import (
    "encoding/json"
    "fmt"
    nats "github.com/nats-io/nats.go"
)
type Message struct {
    Status string `json:"Status"`
    Msg    string `json:"Msg"`
}

type Response struct {
    Status string `json:"Status"`
    Msg    string `json:"Msg"`
}

var nc *nats.Conn
var c *nats.EncodedConn


func start(){

    nc, _ := nats.Connect("127.0.0.1:4222")
    c, _ := nats.NewEncodedConn(nc, nats.JSON_ENCODER)
    c.QueueSubscribe("subject_toto", "queue_titi",func(msg *nats.Msg) {
        var message Message
        err := json.Unmarshal([]byte(msg.Data), &message)
        if err != nil {
            fmt.Printf("%+v\n", err)
        }
        fmt.Printf("%+v\n", "message from pub")
        fmt.Printf("%+v\n", message)
        var response Response
        response.Msg = "message received"
        response.Status = "Ok"
        fmt.Printf("%+v\n", "response to  sub")
        fmt.Printf("%+v\n", response)
        byteConfApi, err2 := json.Marshal(response)
        if err2 != nil {
            fmt.Printf("%+v\n", err2)
        }
        msg.Respond(byteConfApi)
        c.Flush()
    })
}



func main(){
    fmt.Println("begin")
    go  start()
    defer c.Close()
    fmt.Scanln()
    nc.Drain()
    // Close connection
    nc.Close()
    fmt.Println("done")
}

终于介绍完啦！小伙伴们，这篇关于《请求 nats 团队招求_TOU_》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！