当前位置： > > > > REST API 中的异步函数调用

REST API 中的异步函数调用

来源：stackoverflow
2024-04-23 21:18:31
0浏览
收藏

今天米云给大家带来了《REST API 中的异步函数调用》，其中涉及到的知识点包括等等，无论你是小白还是老手，都适合看一看哦~有好的建议也欢迎大家在评论留言，若是看完有所收获，也希望大家能多多点赞支持呀！一起加油学习~

问题内容

这里我有一个函数，即 returnallarticles，它将被 rest api 调用，该函数返回一个文章列表，并且在该函数内有一个异步函数，即 doneasync 正在被调用。此 aysnc 函数可能需要一些时间来处理其自身的数据。我想要 json 值，即无论该异步函数是否完成，都应该返回所有文章。代码我粘贴在下面

func returnAllArticles(w http.ResponseWriter, r *http.Request){
    fmt.Println("Endpoint Hit: returnAllArticles")
    json.NewEncoder(w).Encode(Articles)
   
        val := DoneAsync()
    fmt.Println("Done is running ...")
    fmt.Println(<- val)

}

func DoneAsync() chan int {
    r := make(chan int)
    fmt.Println("Warming up ...")
    go func() {
        time.Sleep(3 * time.Second)
        r <- 1
        fmt.Println("Done ...")
    }()
    return r
}
func handleRequests() {
    myRouter := mux.NewRouter().StrictSlash(true)
    myRouter.HandleFunc("/articles", returnAllArticles);
   log.Fatal(http.ListenAndServe(":8080",myRouter))
}

但就我而言，在异步函数完成之前，json 值不会返回。我没有获得该异步函数的异步功能。

正确答案

此行将阻塞，直到将值写入 val：

fmt.println(<- val)

因此，您的 doneasync 函数创建了一个 goroutine，该 goroutine 继续处理某些内容，并最终写入 val 通道，但调用它的处理程序会等待，直到有内容写入该通道。

如果您希望在执行此处理时发送编码结果，则可以在响应处理程序实现 flusher 时发送，并刷新它：

if f, ok:=w.(http.Flusher); ok {
   f.Flush()
}

到这里，我们也就讲完了《REST API 中的异步函数调用》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注米云公众号，带你了解更多关于的知识点！