go 如何处理接收到json格式body

对于接收到的JSON格式的body，Go可以通过使用标准库中的encoding/json包来进行处理。你可以定义一个结构体来表示JSON中的数据格式，并使用json.Unmarshal函数将JSON数据解析到该结构体中。在解析完成后，就可以像处理普通的Go结构体一样来处理JSON数据了。当需要将Go数据转化为JSON字符串时，可以使用json.Marshal函数将Go结构体转化为相应的JSON格式字符串。

相关问题

Python发送rabbitmq json信息，golang接收rabbitmq json信息，收到的json会有意外换行，导致json格式错误，请问是怎么回事

这个问题可能与消息的编码方式有关。

在 Python 中，发送 RabbitMQ 消息时，可以使用 `pika` 库。当使用 `pika` 库发送 JSON 格式的消息时，可以使用 `json.dumps()` 方法将 Python 的字典对象转换成 JSON 字符串，然后使用 `channel.basic_publish()` 方法发布消息，如下所示：

import pika
import json

# 创建连接和 channel
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 发布 JSON 格式的消息
message = {'name': 'Alice', 'age': 25}
message_json = json.dumps(message)
channel.basic_publish(exchange='test_exchange', routing_key='test_queue', body=message_json)

# 关闭连接
connection.close()

在 Golang 中，接收 RabbitMQ 消息时，可以使用 `streadway/amqp` 库。当使用 `streadway/amqp` 库接收 JSON 格式的消息时，可以使用 `json.Unmarshal()` 方法将接收到的消息转换成 Golang 的结构体对象，如下所示：

package main

import (
    "encoding/json"
    "log"

    "github.com/streadway/amqp"
)

func main() {
    // 创建连接
    conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    if err != nil {
        log.Fatalf("Failed to connect to RabbitMQ: %v", err)
    }
    defer conn.Close()

    // 创建 channel
    ch, err := conn.Channel()
    if err != nil {
        log.Fatalf("Failed to open a channel: %v", err)
    }
    defer ch.Close()

    // 声明队列
    q, err := ch.QueueDeclare(
        "test_queue", // 队列名称
        false,        // 是否持久化
        false,        // 是否自动删除
        false,        // 是否具有排他性
        false,        // 是否阻塞等待
        nil,          // 额外参数
    )
    if err != nil {
        log.Fatalf("Failed to declare a queue: %v", err)
    }

    // 消费消息
    msgs, err := ch.Consume(
        q.Name, // 队列名称
        "",     // 消费者标识符
        true,   // 是否自动应答
        false,  // 是否具有排他性
        false,  // 是否阻塞等待
        nil,    // 额外参数
    )
    if err != nil {
        log.Fatalf("Failed to register a consumer: %v", err)
    }

    // 处理消息
    for msg := range msgs {
        var message struct {
            Name string `json:"name"`
            Age  int    `json:"age"`
        }
        if err := json.Unmarshal(msg.Body, &message); err != nil {
            log.Printf("Failed to parse message: %v", err)
            continue
        }
        log.Printf("Received message: %+v", message)
    }
}

如果您在接收到的 JSON 消息中发现了意外换行，可以尝试使用 `strings.TrimSpace()` 方法去除换行符，如下所示：

// 处理消息
for msg := range msgs {
    body := strings.TrimSpace(string(msg.Body)) // 去除换行符
    var message struct {
        Name string `json:"name"`
        Age  int    `json:"age"`
    }
    if err := json.Unmarshal([]byte(body), &message); err != nil {
        log.Printf("Failed to parse message: %v", err)
        continue
    }
    log.Printf("Received message: %+v", message)
}

此外，还可以检查消息的编码方式是否正确。在 Python 中，可以使用 `json.dumps()` 方法的 `ensure_ascii` 参数来控制是否将非 ASCII 字符转义成 Unicode 转义序列。在 Golang 中，可以使用 `json.Marshal()` 方法的 `ascii` 标签来控制是否将非 ASCII 字符转义成 Unicode 转义序列。如果消息的编码方式不一致，也可能会导致消息中出现意外的换行符。

func (ths *CenterServer) AddDevice(ctx *gin.Context) { defer ctx.Request.Body.Close() clog.Infof("start add device") devAddReq := &brmproto.DeviceInfo{} body, err := ioutil.ReadAll(ctx.Request.Body) if err != nil { clog.Errorf("read body failed, err[%v]", err) ctx.JSON(http.StatusOK, httpUtil.CreateResultByErr(httpUtil.ReadRequestBodyError())) return } clog.Debugf("add dev request[%s]", string(body)) err = json.Unmarshal(body, devAddReq) if err != nil { clog.Errorf("json unmarshal failed, err:%v", err) ctx.JSON(http.StatusOK, httpUtil.CreateResultByErr(httpUtil.UnmarshalError())) return } devDB := AddReqToDb(devAddReq) //向数据库添加 err = dataBaseModels.GetInstance().AddDevice(&devDB) if err != nil { clog.Errorf("add dev to database err[%v]", err) ctx.JSON(http.StatusOK, httpUtil.CreateResultByErr(httpUtil.DataBaseError())) return } //向ars添加 //todo ctx.JSON(http.StatusOK, httpUtil.CreateSuccessfulResult("")) clog.Debugf("add device success") }

这段代码是一个Go语言的函数，用于在中心服务器上添加设备信息。以下是代码的解释：

- `func (ths *CenterServer) AddDevice(ctx *gin.Context)`: 这是一个方法，属于`CenterServer`结构体的成员函数。它接收一个`gin.Context`类型的参数`ctx`，用于处理HTTP请求。

- `defer ctx.Request.Body.Close()`: 使用`defer`关键字来延迟关闭HTTP请求的Body，确保在函数执行完毕后关闭请求的Body，以免资源泄露。

- `clog.Infof("start add device")`: 使用`clog.Infof`函数输出日志信息，表示开始添加设备的操作。

- `devAddReq := &brmproto.DeviceInfo{}`: 创建一个`brmproto.DeviceInfo`类型的指针变量`devAddReq`，用于存储从HTTP请求中解析出的设备信息。

- `body, err := ioutil.ReadAll(ctx.Request.Body)`: 使用`ioutil.ReadAll`函数读取HTTP请求的Body内容，并将读取结果存储在变量`body`中。

- `err = json.Unmarshal(body, devAddReq)`: 使用`json.Unmarshal`函数将读取到的Body内容解析为JSON格式，并将解析结果存储在`devAddReq`变量中。

- `devDB := AddReqToDb(devAddReq)`: 调用`AddReqToDb`函数，将解析得到的设备信息结构体转换为数据库操作所需的设备信息结构体，并将结果赋值给`devDB`变量。

- `err = dataBaseModels.GetInstance().AddDevice(&devDB)`: 调用`dataBaseModels`包中的`AddDevice`方法，向数据库中添加设备信息。

- `ctx.JSON(http.StatusOK, httpUtil.CreateSuccessfulResult(""))`: 使用`ctx.JSON`函数将HTTP响应的状态码和结果数据返回给客户端，表示设备添加操作成功。

- `clog.Debugf("add device success")`: 使用`clog.Debugf`函数输出调试日志信息，表示设备添加操作成功。

这段代码的功能是解析HTTP请求中的设备信息，并将其添加到数据库中。最后，返回一个表示操作结果的JSON响应给客户端。