php小编香蕉在这里与大家分享一个有趣的技巧——“暂停一秒后继续读取数据”。在编程中，有时候我们需要等待一段时间后再继续执行后续的操作，而这个技巧可以帮助我们实现这个目标。无论是用于网络请求的延时操作，还是为了避免某些耗时的操作影响程序的执行效率，这个技巧都能发挥重要的作用。下面，我们将详细介绍如何在php中实现这个功能。
问题内容
我正在使用curl从端点获取数据并将其传输到程序中。程序的main函数读取数据是这样的
reader := bufio.NewReader(os.Stdin)
var buf bytes.Buffer
line, err := reader.ReadString(`\n`)
for {
if err != nil{
buf.WriteString(line)
break
}
buf.WriteString(line)
}
var data Memstats
err = 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('\n')
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 Memstats
err = json.Marshal(buf.Bytes(), &data)
rt.Memstats = append(rt.Memstats, &record)
}解决方法
用于解析 JSON
您还可以通过自定义函数或更改 bash 脚本来使用扫描仪。但我相信两者都比下面的代码更复杂。
package main
import (
"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 main
import (
"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
输出：
Start Thu Jan 18 22:59:31 +03 2024 Thu Jan 18 22:59:32 +03 2024 Thu Jan 18 22:59:33 +03 2024 Thu Jan 18 22:59:34 +03 2024
使用不同的管道（每次都是新实例）
while 睡眠 1;做 echo "$(date)" | ./我的程序；完成
输出：
Start Thu Jan 18 22:58:46 +03 2024 End Start Thu Jan 18 22:58:47 +03 2024 End
