Chrome 当 JSON 大小超过 65500 个字符时,golang 中的本地消息传递主机失败
Chrome native messaging host in golang fails when JSON size is more than 65500 characters
我正在尝试用 golang 为 chrome 编写一个本地消息传递主机。为此,我尝试使用 chrome-go as well as 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://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
的区别只有几百个字符。
这里有什么问题?
管道缓冲区的限制因系统而异。 Mac OS 以X为例,默认使用16384字节的容量
您可以使用这个 bash 脚本来检查您的缓冲区容量:
M=0; while printf A; do >&2 printf "\r$((++M)) B"; done | sleep 999
所以它与 go 无关,因为我试图将您的代码更改为从文件读取和解组并且它起作用了:
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)
}
这是因为您的 OS 的管道缓冲区被限制为 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(...)
returned nil, nil
.
要解决此问题,您的函数 Receive(...)
不应 return nil, nil
。
我正在尝试用 golang 为 chrome 编写一个本地消息传递主机。为此,我尝试使用 chrome-go as well as 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://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
的区别只有几百个字符。
这里有什么问题?
管道缓冲区的限制因系统而异。 Mac OS 以X为例,默认使用16384字节的容量
您可以使用这个 bash 脚本来检查您的缓冲区容量:
M=0; while printf A; do >&2 printf "\r$((++M)) B"; done | sleep 999
所以它与 go 无关,因为我试图将您的代码更改为从文件读取和解组并且它起作用了:
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)
}
这是因为您的 OS 的管道缓冲区被限制为 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(...)
returned nil, nil
.
要解决此问题,您的函数 Receive(...)
不应 return nil, nil
。