当 JSON 大小超过 65500 个字符时，golang 中的 Chrome 原生消息传递主机失败答案

【问题标题】：Chrome native messaging host in golang fails when JSON size is more than 65500 characters当 JSON 大小超过 65500 个字符时，golang 中的 Chrome 原生消息传递主机失败
【发布时间】：2018-11-30 15:41:04
【问题描述】：

我正在尝试在 golang 中为 chrome 编写本机消息传递主机。为此，我尝试使用chrome-go 和chrome-native-messaging 包。两者都出现了相同的问题，如下所述。

这里是代码。我已经将chrome-go包中的相关部分添加到主文件中，而不是导入它以便于理解。

当我像 {content:"Apple Mango"} 向它发送 json 消息时，以下代码实际上可以工作。但是，一旦 json 的长度超过大约 65500 个字符，它就会停止工作，给或取 100 个字符。也没有错误输出。

package main

import (
  "encoding/binary"
  "encoding/json"
  "fmt"
  "io"
  "os"
)

var byteOrder binary.ByteOrder = binary.LittleEndian

func Receive(reader io.Reader) ([]byte, error) {
   // Read message length in native byte order
   var length uint32
   if err := binary.Read(reader, byteOrder, &length); err != nil {
       return nil, err
   }

// Return if no message
if length == 0 {
    return nil, nil
}

// Read message body
received := make([]byte, length)
if n, err := reader.Read(received); err != nil || n != len(received) {
    return nil, err
}
return received, nil
}

type response struct {
    Content string `json:"content"`
}

func main() {

  msg, err := Receive(os.Stdin)
  if err != nil {
    panic(err)
  }
  var res response
  err = json.Unmarshal([]byte(msg), &res)
  if err != nil {
     panic(err)
  }
  fmt.Println(res.Content)
 }

对于那些对测试感兴趣的人，我已经建立了一个包含说明的存储库。运行以下

  git clone --depth=1  https://tesseract-index@bitbucket.org/tesseract-index/chrome-native-messaging-test-riz.git && cd chrome-native-messaging-test-riz
 ./json2msg.js < test-working.json | go run main.go
 ./json2msg.js < test-not-working.json | go run main.go

您会看到test-not-working.json 没有输出，尽管它与test-working.json 的区别只有几百个字符。

这里有什么问题？

【问题讨论】：

根据Alex的回复，或许可以压缩json流。

标签： json go chrome-native-messaging

【解决方案1】：

管道缓冲区存在一个限制，该限制因系统而异。例如，Mac OS X 默认使用 16384 字节的容量。

您可以使用此 bash 脚本来检查您的缓冲区容量：

M=0; while printf A; do >&2 printf "\r$((++M)) B"; done | sleep 999

所以它与 go 无关，因为我尝试将您的代码更改为从文件读取和 Unmarshal 并且它有效：

func main() {
    reader, err := os.Open("test-not-working.json")
    if err != nil {
        panic(err)
    }

    var res response
    decoder := json.NewDecoder(reader)
    err = decoder.Decode(&res)
    if err != nil {
        panic(err)
    }

    fmt.Println(res.Content)
}

【讨论】：

听起来不错。我系统中的管道缓冲区限制为 65536。我已将您的答案标记为已接受。但是，如果您可以使用有关如何克服此问题的信息对其进行修改，那就太棒了。 PS：还值得一提的是native host written in python在某种程度上没有相同的限制。

【解决方案2】：

这是因为您的操作系统的管道缓冲区限制为 65536 字节。因此，os.Stdin.Read(...) 函数一次可以读取 65536 个字节。

您可以通过这个简单的替换来修复您的代码：

n, err := io.ReadFull(reader, received)

还有你的错误：

msg, err := Receive(os.Stdin)
if err != nil {
    panic(err)
}

您已将err 与nil 进行比较，但您尚未将msg 与nil 进行比较。但是由于您已经读取了 65532 (65536 - 4) 字节，func Receive(...) 返回了nil, nil。

要解决此问题，您的函数 Receive(...) 不应返回 nil, nil。

【讨论】：