php小编香蕉在这里与大家分享一个有趣的技巧——“暂停一秒后继续读取数据”。在编程中，有时候我们需要等待一段时间后再继续执行后续的操作，而这个技巧可以帮助我们实现这个目标。无论是用于网络请求的延时操作，还是为了避免某些耗时的操作影响程序的执行效率，这个技巧都能发挥重要的作用。下面，我们将详细介绍如何在php中实现这个功能。
问题内容
我正在使用curl从端点获取数据并将其传输到程序中。程序的main函数读取数据是这样的
reader := bufio.NewReader(os.Stdin)var buf bytes.Bufferline, err := reader.ReadString(``)for { if err != nil{ buf.WriteString(line) break } buf.WriteString(line)}var data Memstatserr = json.Unmarshal(buf.Bytes(), &data)
登录后复制
到这里为止一切正常。然而，我的最终目标是像这样重复卷曲端点一段时间，以便程序读取以 N 时间间隔到达的 N 个 JSON blob。
for i in {1..10}; do curl localhost:6000/debug/vars | ./myprogram; sleep 1; done
登录后复制
每次卷曲到端点后都会到达相同结构的数据。因此，我必须将数据读取代码移至函数 readStdIn 中，我将重复调用该函数，直到curl 停止发送数据，并且每次我的程序接收到 json 数据时，我都会将其解组到结构中并将其添加到切片中。为了重复调用 readStdIn，我使用了 for 循环，为了读取 readStdIn 中的数据，我也使用了 for 循环。 readStdIn 函数永远无法完成。为什么不呢？
主要功能
for{ reader := bufio.NewReader(os.Stdin) h.readStdIn(reader) time.Sleep(1 * time.Second) var err error //check to see if curl sent more data, if not I break out of main function and continue on with program and hopefully an array full of Memstats newbytes, err := reader.ReadByte() if err != nil{ break }}
登录后复制
readStdIn函数
func (rt *Graph)readStdIn(reader *bufio.Reader){ var buf bytes.Buffer line, err := reader.ReadString('') for { if err != nil{ if err == io.EOF{ buf.WriteString(line) break }else{ fmt.Println(err.Error()) os.Exit(1) } } } buf.WriteString(line)}var data Memstatserr = json.Marshal(buf.Bytes(), &data)rt.Memstats = append(rt.Memstats, &record)}
登录后复制
解决方法
用于解析 JSON
您还可以通过自定义函数或更改 bash 脚本来使用扫描仪。但我相信两者都比下面的代码更复杂。
package mainimport ( "encoding/json" "errors" "fmt" "io" "os")func main() { fmt.Println("Start") decoder := json.NewDecoder(os.Stdin) for { var u User err := decoder.Decode(&u) if errors.Is(err, io.EOF) { fmt.Println("End") break } if err != nil { fmt.Println("Can not decode into json", err) continue } fmt.Println(u) }}type User struct { UserId int `json:"userId"` Id int `json:"id"` Title string `json:"title"`}
登录后复制
function repeatedCurl() { for i in $(seq 1 3); do # sleep 1 # optional you can emit curl -s "https://jsonplaceholder.typicode.com/posts/$i" done}repeatedCurl | ./foo
登录后复制
对于换行分隔数据
package mainimport ( "bufio" "fmt" "os")func main() { fmt.Println("Start") scanner := bufio.NewScanner(bufio.NewReader(os.Stdin)) for scanner.Scan() { fmt.Println(scanner.Text()) } fmt.Println("End")}
登录后复制
它适用于创建新的程序实例（如您的示例）和正常的管道使用。
使用相同的管道
function repeatedDateEcho() { while sleep 1; do echo "$(date)" done}repeatedDateEcho | ./myprogram
登录后复制
输出：
StartThu Jan 18 22:59:31 +03 2024Thu Jan 18 22:59:32 +03 2024Thu Jan 18 22:59:33 +03 2024Thu Jan 18 22:59:34 +03 2024
登录后复制
使用不同的管道（每次都是新实例）
while 睡眠 1;做 echo “$(date)” | ./我的程序；完成输出：
StartThu Jan 18 22:58:46 +03 2024EndStartThu Jan 18 22:58:47 +03 2024End
登录后复制
以上就是暂停一秒后继续读取数据的详细内容，更多请关注【创想鸟】其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至253000106@qq.com举报，一经查实，本站将立刻删除。
发布者：PHP中文网，转转请注明出处：https://www.chuangxiangniao.com/p/2483889.html
