除了编写一个简单的 http 服务器之外,绝对是 golang 的初学者。我正在研究 Go 作为编写异步进程的可能性。如果可以,请提供一个快速示例,说明如何完成此操作:
Http 请求“a”进来,一个操作基于这个请求中的 POST 有效负载开始(在 post 或 url 中有某种唯一标识符)。由“a”启动的异步进程将使用原始唯一标识符(请求“b”)响应同一服务器,而请求“a”仍处于打开状态。我想根据请求“b”响应将该响应传达回请求“a”。
除了编写一个简单的 http 服务器之外,绝对是 golang 的初学者。我正在研究 Go 作为编写异步进程的可能性。如果可以,请提供一个快速示例,说明如何完成此操作:
Http 请求“a”进来,一个操作基于这个请求中的 POST 有效负载开始(在 post 或 url 中有某种唯一标识符)。由“a”启动的异步进程将使用原始唯一标识符(请求“b”)响应同一服务器,而请求“a”仍处于打开状态。我想根据请求“b”响应将该响应传达回请求“a”。
尽管可以使用通道来执行此操作,但我更喜欢受互斥锁保护的哈希(映射),因为在这种情况下更容易。
给你一个想法并让你继续前进:
package main
import (
"fmt"
"net/http"
"sync"
)
type state struct {
*sync.Mutex // inherits locking methods
Vals map[string]string // map ids to values
}
var State = &state{&sync.Mutex{}, map[string]string{}}
func get(rw http.ResponseWriter, req *http.Request) {
State.Lock()
defer State.Unlock() // ensure the lock is removed after leaving the the function
id := req.URL.Query().Get("id") // if you need other types, take a look at strconv package
val := State.Vals[id]
delete(State.Vals, id)
rw.Write([]byte("got: " + val))
}
func post(rw http.ResponseWriter, req *http.Request) {
State.Lock()
defer State.Unlock()
id := req.FormValue("id")
State.Vals[id] = req.FormValue("val")
rw.Write([]byte("go to http://localhost:8080/?id=42"))
}
var form = `<html>
<body>
<form action="/" method="POST">
ID: <input name="id" value="42" /><br />
Val: <input name="val" /><br />
<input type="submit" value="submit"/>
</form>
</body>
</html>`
func formHandler(rw http.ResponseWriter, req *http.Request) {
rw.Write([]byte(form))
}
// for real routing take a look at gorilla/mux package
func handler(rw http.ResponseWriter, req *http.Request) {
switch req.Method {
case "POST":
post(rw, req)
case "GET":
if req.URL.String() == "/form" {
formHandler(rw, req)
return
}
get(rw, req)
}
}
func main() {
fmt.Println("go to http://localhost:8080/form")
// thats the default webserver of the net/http package, but you may
// create custom servers as well
err := http.ListenAndServe("localhost:8080", http.HandlerFunc(handler))
if err != nil {
fmt.Println(err)
}
}