webscoket 连接成功后如何发送消息到特定的 URI？

本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的，希望这篇《webscoket 连接成功后如何发送消息到特定的 URI？》对你有很大帮助！欢迎收藏，分享给更多的需要的朋友学习~

我有一个安全的 websocket 服务器在 localhost:443/server-demo （jetty websocket 服务器）上运行。 现在我正在编写一个可以与websocket服务器通信的go客户端。我可以使用正确的证书连接到 websocket 服务器。这是示例代码。

package main
import (
    "crypto/tls"
    "crypto/x509"
    "fmt"
    "io"
    "log"
)
func main() {
    cert, err := tls.loadx509keypair("nifi-1.10.0-bin/nifi-1.10.0/extras/gen-certs/certs/admin.pem", "nifi-1.10.0-bin/nifi-1.10.0/extras/gen-certs/certs/admin-key.pem")
    if err != nil {
        log.fatalf("server: loadkeys: %s", err)
    }
    config := tls.config{certificates: []tls.certificate{cert}, insecureskipverify: true}
    conn, err := tls.dial("tcp", "127.0.0.1:443", &config)
    if err != nil {
        log.fatalf("client: dial: %s", err)
    }
    defer conn.close()
    log.println("client: connected to: ", conn.remoteaddr())
    state := conn.connectionstate() 
    for _, v := range state.peercertificates {
        fmt.println(x509.marshalpkixpublickey(v.publickey))
        fmt.println(v.subject)
    }
    log.println("client: handshake: ", state.handshakecomplete)
    log.println("client: mutual: ", state.negotiatedprotocolismutual)
    message := "hello\n"
    n, err := io.writestring(conn, message)
    if err != nil {
        log.fatalf("client: write: %s", err)
    }
    log.printf("client: wrote %q (%d bytes)", message, n)
    reply := make([]byte, 256)
    n, err = conn.read(reply)
    log.printf("client: read %q (%d bytes)", string(reply[:n]), n)
    log.print("client: exiting")
}

上面的代码抛出这个错误：

"HTTP/1.1 400 No URI\r\nContent-Type: text/html;charset=iso-8859-1\r\nContent-Length: 49\r\nConnection: close\r\nServer: Jetty(9.4.19.v20190610)\r\n\r\n<h1>Bad Message 400</h1><pre>reason: No URI</pre>" (188 bytes)

我的问题是建立连接后如何将消息发送到特定的 uri？即我想向 wss://localhost:443/server-demo 发送消息。

解决方案

问题中的代码未建立与服务器的 websocket 连接。

要建立 websocket 连接，应用程序必须将 websocket 握手写入 conn 并接收握手响应。详情请见RFC。

大多数应用程序使用 websocket 包来处理所有这些细节。 gorilla/websocket 套餐是一个受欢迎的选择。

此代码应该可以帮助您开始使用 gorilla：

cert, err := tls.LoadX509KeyPair("nifi-1.10.0-bin/nifi-1.10.0/extras/gen-certs/certs/admin.pem", "nifi-1.10.0-bin/nifi-1.10.0/extras/gen-certs/certs/admin-key.pem")
if err != nil {
    log.Fatalf("server: loadkeys: %s", err)
}
config := tls.Config{Certificates: []tls.Certificate{cert}, InsecureSkipVerify: true}
d := websocket.Dialer{
    TLSClientConfig: &config,
}
c, _, err := d.Dial("wss://localhost:443/server-demo", nil)
if err != nil {
    log.Fatal(err)
}

defer c.Close()
// Use `c` to send and receive messages

今天关于《webscoket 连接成功后如何发送消息到特定的 URI？》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！