使用RabbitMQ和NestJS如何实现Go消息传递及消费

对于一个Golang开发者来说，牢固扎实的基础是十分重要的，golang学习网就来带大家一点点的掌握基础知识点。今天本篇文章带大家了解《使用RabbitMQ和NestJS如何实现Go消息传递及消费》，主要介绍了，希望对大家的知识积累有所帮助，快点收藏起来吧，否则需要时就找不到了！

我有一个 go 服务，它向 rabbitmq 发布消息，负责该部分的代码如下：

package main

import (
    "log"

    "github.com/streadway/amqp"
)

func main() {
    conn, amqerror := amqp.dial("amqp://localhost:5672/")
    if amqerror != nil {
        panic(amqerror)
    }

    ch, err := conn.channel()
    failonerror(err, "failed to open a channel")
    q, err := ch.queuedeclare(
        "default", // name
        true,      // durable
        false,     // delete when unused
        false,     // exclusive
        false,     // no-wait
        nil,       // arguments
    )
    failonerror(err, "failed to declare a queue")

    body := "{ \"body\":\"hello...\", \"pattern\":\"test\",  \"age\":\"20\"}"

    err = ch.publish(
        "",     // exchange
        q.name, // routing key
        false,  // mandatory
        false,  // immediate
        amqp.publishing{
            contenttype: "text/plain",
            body:        []byte(body),
        },
    )
    failonerror(err, "failed to publish a message")

}

func failonerror(err error, msg string) {
    if err != nil {
        log.fatalf("%s: %s", msg, err)
    }
}

使用消息的 nestjs 部分如下：

import { Controller } from '@nestjs/common';
import { Ctx, EventPattern, Payload, RmqContext } from '@nestjs/microservices';

@Controller()
export class AppController {
  constructor() { }

  @EventPattern("test")
  getEventMessage(@Payload() data: any, @Ctx() context: RmqContext) {
    console.log("data is -> ", data) // always undefined
    console.log(
      "content of message is -> ",
      JSON.parse(
        context.getMessage().content.toString() // from buffer to string
      )
    )
  }
}

现在的问题是，我无法从数据中获取消息，而不是从 ctx 解析消息，而且我需要以 json 的形式在 go 中发送消息，而不跳过像这样的双引号 "\""

正确答案

针对您的问题，回复如下：

1. 在 nextjs 的示例中，他们没有提供如何使用有效负载数据，而是提供了 say：

访问原始 rabbitmq 消息（包含属性、字段、 和内容），使用 rmqcontext 的 getmessage() 方法

鉴于上述陈述，您正在正确解析队列中的消息。

1. 避免手动发送正文字符串，您应该使用名为 json marhsal 的结构的过程，例如：

• 您应该创建一个包含要发送到队列的信息的结构
• marshal 结构体并生成 []byte

type messagequeue struct {
    body    string `json:"body"`
    pattern string `json:"pattern"`
    age     string `json:"age"`
    data    string `json:"data"`
}

func newmessagequeue(body, pattern, age string, data) *messagequeue {
    return &messagequeue{
        body, pattern, age, data
    }
}

func (m *messagequeue) marshal() ([]byte, error) {
    bytes, err := json.marshal(m)

    if err != nil {
        return nil, err
    }
    return bytes, err
}

func main() {
    ...

    message := newmessagequeue("hello...", "test", "20", "data...")
    // todo: check the error
    body, _ := message.marshal()

    err = ch.publish(
        "",         // exchange
        q.name,     // routing key
        false,      // mandatory
        false,      // immediate
        amqp.publishing{
            contenttype: "text/plain",
            body:        body,
        },
    )

    ...
}

更新：

1. 控制器在 geteventmessage 方法上接收到的 data 参数，应将其从 golang 发送到正文，以由 nestjs 反序列化。这意味着结构应如下所示：

type MessageQueue struct {
    Body    string `json:"body"`
    Pattern string `json:"pattern"`
    Age     string `json:"age"`
    Data    string `json:"data"`
}

到这里，我们也就讲完了《使用RabbitMQ和NestJS如何实现Go消息传递及消费》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！