WebSocket 连接维护器管理 WebSocket 连接

编程并不是一个机械性的工作，而是需要有思考，有创新的工作，语法是固定的，但解决问题的思路则是依靠人的思维，这就需要我们坚持学习和更新自己的知识。今天golang学习网就整理分享《WebSocket 连接维护器管理 WebSocket 连接》，文章讲解的知识点主要包括，如果你对Golang方面的知识点感兴趣，就不要错过golang学习网，在这可以对大家的知识积累有所帮助，助力开发能力的提升。

我正在使用 go websocket 拨号器进行测试以连接我自己的 websocket 服务器。 这是拨号器代码：

package main

import (
    "log"
    "github.com/gorilla/websocket"
)

var (
    ws  *websocket.conn
)

func main() {

    //add self as sender client
    u := "ws://localhost:5005/ws"
    log.printf("connecting to %s", u)
    ws, res, err := websocket.defaultdialer.dial(u, nil)
    if err != nil {
        log.println("[dial]", err)
    }
    log.println(ws)
    log.println(res)
}

和我的服务器代码：

package main
    
    import (
        "fmt"
        "io/ioutil"
        "log"
        "net/http"
        "pubsubserver/pubsub"
    
        "github.com/gorilla/websocket"
        uuid "github.com/satori/go.uuid"
        "github.com/valyala/fasthttp"
    )
    
    var upgrader = websocket.Upgrader{
        ReadBufferSize:  1024,
        WriteBufferSize: 1024,
    }
    
    
    func websocketHandler(w http.ResponseWriter, r *http.Request) {
        upgrader.CheckOrigin = func(r *http.Request) bool { return true }
        conn, err := upgrader.Upgrade(w, r, nil)
        if err != nil {
            log.Println(err)
            return
        }
        
        //... some process to add client
    
        fmt.Println("new client connected.")
    
        for {
           //... some process to handle client message
            }
            ps.HandleReceivedMessage(client, messageType, p)
        }
    }
    
    func main() {
        http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
            http.ServeFile(w, r, "static")
        })
        http.HandleFunc("/ws", websocketHandler)
    
        err := http.ListenAndServe(":5005", nil)
        if err != nil {
            log.Println("http server err: ",err)
    
            return
        }
}

我运行我的服务器，运行 dialer.go。我的服务器返回一些消息：

新客户端已连接。

2020/12/03 11:01:19 连接错误：读取 tcp[::1]:5005->[::1]:55227：读取：连接被对等方重置

根据日志消息，我是否可以假设连接成功，但拨号程序在连接成功后立即关闭连接？

如何让拨号器在连接到 websocket 服务器后保持连接？

解决方案

要防止申请表退出，请将以下代码行添加到函数 main() 的末尾：

select {} // block forever.

这将使连接保持打开状态，但不会执行任何有用的操作。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。