我需要使用go lang连接到现有的websocket服务器

SudoPlz：

在我的本地主机上运行一个websocket ws://localhost:8080/ws

我需要可以创建websocket客户端并连接到该服务器的lang代码。

我的Google-Fu技能未能教会我执行此操作的简单方法。

谢谢。

SudoPlz：

没关系，我在网上找到了一些帮助代码。现在我的代码如下所示，以防其他人需要此代码：

package main

import (
        "net/http"
        "text/template"
        "code.google.com/p/go.net/websocket"
        "fmt"
        "os"
        "time"
)


const address string = "localhost:9999"

func main() {

    initWebsocketClient()
}


func initWebsocketClient() {
    fmt.Println("Starting Client")
    ws, err := websocket.Dial(fmt.Sprintf("ws://%s/ws", address), "", fmt.Sprintf("http://%s/", address))
    if err != nil {
        fmt.Printf("Dial failed: %s\n", err.Error())
        os.Exit(1)
    }
    incomingMessages := make(chan string)
    go readClientMessages(ws, incomingMessages)
    i := 0
    for {
        select {
        case <-time.After(time.Duration(2e9)):
            i++
            response := new(Message)
            response.RequestID = i
            response.Command = "Eject the hot dog."
            err = websocket.JSON.Send(ws, response)
            if err != nil {
                fmt.Printf("Send failed: %s\n", err.Error())
                os.Exit(1)
            }
        case message := <-incomingMessages:
            fmt.Println(`Message Received:`,message)


        }
    }
}

func readClientMessages(ws *websocket.Conn, incomingMessages chan string) {
    for {
        var message string
        // err := websocket.JSON.Receive(ws, &message)
        err := websocket.Message.Receive(ws, &message)
        if err != nil {
            fmt.Printf("Error::: %s\n", err.Error())
            return
        }
        incomingMessages <- message
    }
}

就像recoba在评论中建议的那样，这里有一个新的大猩猩示例，供那些寻求更好解决方案的示例使用。

本文收集自互联网，转载请注明来源。

如有侵权，请联系 [email protected] 删除。