Как сделать так, чтобы сообщение было отправлено на определенный URI после успешного подключения к Интернету? - PullRequest
Новая
       34

Как сделать так, чтобы сообщение было отправлено на определенный URI после успешного подключения к Интернету?

0 голосов
/ 10 февраля 2020

У меня есть защищенный сервер веб-сокетов, работающий на локальном хосте: 443 / server-demo (сервер веб-сокетов Jetty). Сейчас я пишу 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")
}

Приведенный выше код выдает эту ошибку: 

<code> "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
"(188 байт)

У меня вопрос после установления соединения, как я могу отправить сообщение определенному URI? Т.е. я хочу отправить сообщение на wss://localhost:443/server-demo.

1 Ответ

3 голосов
/ 10 февраля 2020

Код в вопросе не устанавливает sh соединение WebSocket с сервером.

Чтобы установить sh соединение WebSocket, приложение должно записать рукопожатие WebSocket в conn и получить ответ рукопожатия. Подробнее см. RF C.

В большинстве приложений используется пакет websocket, который обрабатывает все эти детали. Пакет gorilla / websocket является популярным выбором.

Этот код поможет вам начать работу с гориллой: 

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
...