Golang websocket客户端,获取结果后关闭连接

标签 go websocket gorilla

我如何实现这种场景:

1.我有接收一些用户数据的 LoginHandler - 电子邮件和 signedXml:

func LoginHandler(c *gin.Context) {
    var (
        err  error
        data LoginPost
    )
    if err = c.BindJSON(&data); err != nil {
        c.JSON(http.StatusBadRequest, gin.H{"status": "error"})
        return
    }

    ...

    c.JSON(http.StatusOK, gin.H{"status": "ok"})
}

2.我需要通过websocket将signedXml发送到另一台服务器

3.保存结果(成功或错误)

4.关闭连接

每个 HTTP 请求都会打开连接,发送 1 条消息,得到 1 个结果,最后关闭套接字。我正在尝试使用 channel ,但没有成功。这有可能实现我的案例吗?

更新

package main

import (
    "log"
    "net/url"

    "github.com/gorilla/mux"
    "github.com/gorilla/websocket"
    "net/http"
)

func indexHandler(w http.ResponseWriter, r *http.Request) {
    message := r.FormValue("message")
    w.Write([]byte(message))
}

func postHandler(w http.ResponseWriter, r *http.Request) {
    var (
        message = r.FormValue("message")
        u = url.URL{Scheme: "ws", Host: "echo.websocket.org", Path: "/"}
        err error
        out []byte
        conn *websocket.Conn
    )
    log.Printf("message: %s\n", message)
    log.Printf("connecting to %s\n", u.String())
    conn, _, err = websocket.DefaultDialer.Dial(u.String(), nil)
    if err != nil {
        log.Fatal("dial:", err)
    }
    log.Println("write")
    if err = conn.WriteMessage(websocket.TextMessage, []byte(message)); err != nil {
        log.Fatal("write:", err)
    }
    log.Println("read")
    if _, out, err = conn.ReadMessage(); err != nil {
        log.Fatal("read:", err)
    }
    w.Write(out)
    log.Println("close")
    conn.Close()
}

func main() {
    r := mux.NewRouter()
    r.HandleFunc("/", indexHandler).Methods("GET")
    r.HandleFunc("/post", postHandler).Methods("POST")
    http.Handle("/", r)
    http.ListenAndServe(":8080", nil)
}

最佳答案

调用Dial , WriteMessage , ReadMessageClose按顺序。

c, _, err := websocket.DefaultDialer.Dial(url, nil)
if err != nil {
    // handle error
}
err := c.WriteMessage(websocket.TextMessage, signedXML)
if err != nil {
     // handle error
}
_, p, err := c.ReadMessage()
if err != nil {
     // handle error
}
c.Close()

// p is a []byte with the first received message.

关于Golang websocket客户端,获取结果后关闭连接,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46583181/

相关文章:

go - 何时使用缓冲 channel ?

java - Jetty Websocket : can't find SimpleEchoSocket

ssl - RabbitMQ - Tls 连接 - Golang

go - 如何分配给golang中的nil struct字段

java - Jetty - WebSocket.sendMessage(String data) 和 void sendMessage(byte frame,String data) 有什么区别?

go - 如何使用带有 http.TimeoutHandler 的 gorilla 多路复用器

go - 使用 golang 和 gorilla websocket 库,为什么 WriteJson 会返回错误?

go - 在 Golang 中处理 URL 中的动态参数

go - 运行 go mod vendor 更新我的库

c# - 网络套接字帮助!