当前位置： > > > > io.Reader 可以接受文件描述符吗？ “JSON 输入意外结束”
io.Reader 可以接受文件描述符吗？ “JSON 输入意外结束”
来源：stackoverflow
2024-04-19 20:36:34
0浏览
收藏
Golang不知道大家是否熟悉？今天我将给大家介绍《io.Reader 可以接受文件描述符吗？ “JSON 输入意外结束”》，这篇文章主要会讲到等等知识点，如果你在看完本篇文章后，有更好的建议或者发现哪里有问题，希望大家都能积极评论指出，谢谢！希望我们能一起加油进步！
问题内容
在将打开文件描述符从 os.create() 传递到接受类型 io.reader 的函数并运行 io.copy(b.bytes(), reader) 后，有效 json 的 json.unmarshal 失败
以下代码块中的 read() 方法是否正确实现？ io.reader 包装了 read 方法，但将向其传递一个打开的文件描述符读取文件为字节，允许 io.copy(b.bytes(), reader) 将数据复制到 var乙？
是否有更好的方法在不使用 ioutil.readall 的情况下执行此操作？
- 已验证 json 完全有效。使用 jq 和 3 个在线 json 验证器进行验证。
- 验证数据实际上已通过另一个实现 io.write 的函数成功写入文件。
- 已验证
ioutil.readall可以将 json 读取为字节，因此我认为所使用的方法实施不正确。
** 这不是我的代码，我正在对其他人编写的代码进行故障排除，但该人无法回答任何问题 **
我有一个 json 文件 collected_data.json。
该文件是使用 os.create 创建的
file, err := os.create("/var/log/collected_data.json")
配置了一个结构体，它将 file 设置为 datastore：
profiler := &collectors.systemprofiler{
datastore: file,
networkinterfaces: interfaces,
apiurl: *apiurl,
runonce: *runonce,
systag: *systag,
}
然后我们运行 gather() 方法。
err = profiler.send(output)
if err != nil {
log.error(err)
}
send() 方法实现 systemprofiler 结构：
func (s *systemprofiler) send(profile *systemprofile) error {...}
到目前为止，一切正常，直到我们尝试从 /var/log/collected_data.json 读取和解组数据的代码部分为止。
在这个 send() 方法中，我们尝试在两种情况下读取文件 /var/log/collected_data.json。
第一，如果文件不为空，我们读取该文件，并用它做一些事情（此处未显示）。
data, err := store.read(s.datastore)
if err != nil {
log.print("i couldn't read the datastore")
return err
}
第二，如果文件不是为空，我们将数据写入文件，然后立即将其读回并解组以满足稍后在比较的数据之间执行 reflect.deepequal 的函数以及写入文件的数据。
在这两种情况下，read() 方法都会返回“json 输入意外结束”，文件 /var/log/collected_data.json 中包含有效的 json。用于写入数据的方法工作得很好。
{"level":"info","msg":"i couldn't read the datastore","time":"2019-08-02t02:26:42-04:00"}
{"level":"error","msg":"unexpected end of json input","time":"2019-08-02t02:26:42-04:00"}
read() 方法如下所示：
// read reads json data from an io.reader
func read(reader io.reader) (interface{}, error) {
var data interface{}
var b bytes.buffer
io.copy(&b, reader)
err := json.unmarshal(b.bytes(), &data)
if err != nil {
return nil, err
}
return data, nil
}
预期结果：
有效的 json 从 io.reader 类型的 reader 复制到 bytes.buffer 类型的 b，成功解组并返回。
实际结果： {“level”:”error”,”msg”:”json 输入意外结束”,”time”:”2019-08-02t02:26:42-04:00″}
为了回答评论中提出的问题，以下是 send() 函数内的代码块：
var storedProfile SystemProfile
check := store.IsEmpty(s.DataStore)
if check == false {
log.Print("Data Store Exists")
// If there is data stored, read it
data, err := store.Read(s.DataStore)
if err != nil {
return err
}
//var tmp SystemProfile
err = mapstructure.Decode(data, &storedProfile)
if err != nil {
return err
}
} else {
log.Print("Data Store Doesn't Exist")
// If the data store is empty, write to it
err := store.Write(s.DataStore, profile)
if err != nil {
return err
}
data, err := store.Read(s.DataStore)
if err != nil {
log.Print("I couldn't read the datastore")
return err
}
err = mapstructure.Decode(data, &storedProfile)
if err != nil {
log.Print("I couldn't decode the json to a map")
return err
}
body, err := json.Marshal(profile)
if err != nil {
return err
}
_, err = client.Post(s.ApiURL, "application/json", bytes.NewBuffer(body)) // TODO: Handle response from API here
log.Print(client.LogString())
}
if !reflect.DeepEqual(storedProfile, profile ) {
// If what's in the data store and what has been collected are different,
// write the recently collected data to the data store and send it out to the API
store.Write(s.DataStore, profile)
body, err := json.Marshal(profile)
if err != nil {
return err
}
_, err = client.Post(s.ApiURL, "application/json", bytes.NewBuffer(body)) // TODO: Handle response from API here
if err != nil {
return err
}
log.Print(client.LogString())
}
解决方案
这个问题的答案是肯定的。 *os.file 可以用作 io.reader。
问题在于应用程序将数据写入文件，然后尝试从文件中读取相同的数据，而不查找数据写入的位置。
通过在调用 store.write 之后、调用 store.read 之前添加以下代码来修复该问题。
if _, err := s.DataStore.Seek(io.SeekStart, 0); err != nil {
return err
}
今天关于《io.Reader 可以接受文件描述符吗？ “JSON 输入意外结束”》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注米云公众号！
