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

Question

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

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

当我向它发送一个 json 消息时，下面的代码实际上有效，比如 {content:"Apple Mango"}。但是，一旦 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://[e-mail]/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只有几百个字符。

这里的问题是什么？

Answer 1

管道缓冲区的限制因系统而异。例如，Mac OS X 默认使用 16384 字节的容量。您可以使用此 bash 脚本来检查您的缓冲区容量：M=0; while printf A; do >&2 printf "\r$((++M)) B"; done | sleep 999所以它与 go 无关，因为我试图将您的代码更改为从文件和 Unmarshal 中读取并且它有效：func main() {&nbsp; &nbsp; reader, err := os.Open("test-not-working.json")&nbsp; &nbsp; if err != nil {&nbsp; &nbsp; &nbsp; &nbsp; panic(err)&nbsp; &nbsp; }&nbsp; &nbsp; var res response&nbsp; &nbsp; decoder := json.NewDecoder(reader)&nbsp; &nbsp; err = decoder.Decode(&res)&nbsp; &nbsp; if err != nil {&nbsp; &nbsp; &nbsp; &nbsp; panic(err)&nbsp; &nbsp; }&nbsp; &nbsp; fmt.Println(res.Content)}

Answer 2

这是因为您的操作系统的管道缓冲区限制为 65536 字节。因此，该os.Stdin.Read(...)函数一次可以读取 65536 个字节。您可以使用这个简单的替换来修复您的代码：n, err := io.ReadFull(reader, received)还有你的错误：msg, err := Receive(os.Stdin)if err != nil {&nbsp; &nbsp; panic(err)}你比较过err，nil但你没有比较msg过nil。但是由于您已经读取了 65532 ( 65536 - 4) 个字节，因此func Receive(...)返回的nil, nil.要解决此问题，您的函数Receive(...)不应返回nil, nil。