io.Reader 可以接受文件描述符吗？ “JSON 输入意外结束”

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 的情况下执行此操作？

1. 已验证 json 完全有效。使用 jq 和 3 个在线 json 验证器进行验证。
2. 验证数据实际上已通过另一个实现 io.write 的函数成功写入文件。
3. 已验证 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 输入意外结束”》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！