Почему не подключается к websocket?

Question

[4sadly]

Мой код js:

let socket = new WebSocket("ws://"+location.host+"/ws");
	console.log("Attempting Connection...");

	socket.onopen = () => {
		console.log("Successfully Connected");
		socket.send("Hi From the Client!")
	};

	socket.onclose = event => {
		console.log("Socket Closed Connection: ", event);
		socket.send("Client Closed!")
	};

	socket.onerror = error => {
		console.log("Socket Error: ", error);
	};

Мой код go:

package main

import (
	"log"
	"net/http"
)

func HelloServer(w http.ResponseWriter, req *http.Request) {
	log.Println("Connected: ")
	defer log.Println("Disonnected: ")
	_, err := w.Write([]byte("Hello, world!"))
	if err != nil {
		log.Println("error: " , err.Error())
	}
}

func main() {
	http.HandleFunc("/ws", HelloServer)
	err := http.ListenAndServe(":8080", nil)
	if err != nil {
		log.Println("error: " , err)
	}
}

Nginx:

location /ws {
                proxy_pass http://127.0.0.1:8080/ws;
                proxy_set_header Host $host;
                proxy_http_version 1.1;
                proxy_set_header Upgrade $http_upgrade;
                proxy_set_header Connection "upgrade";
        }

Что не так?
Ошибка:

WebSocket connection to 'ws://*/ws' failed: Error during WebSocket handshake: Unexpected response code: 404

Comments

[Александр Павлюк]

В логе сервера ведь мелькает строчка Connected?

[4sadly]

Александр Павлюк,
лог:

2019/11/26 12:13:08 Connected:
2019/11/26 12:13:08 Disonnected:

(index):23 Attempting Connection...
(index):22 WebSocket connection to 'ws://*/ws' failed: Error during WebSocket handshake: Unexpected response code: 200
(anonymous) @ (index):22
(index):36 Socket Error:  Event {isTrusted: true, type: "error", target: WebSocket, currentTarget: WebSocket, eventPhase: 2, …}
(index):31 Socket Closed Connection:  CloseEvent {isTrusted: true, wasClean: false, code: 1006, reason: "", type: "close", …}
(index):32 WebSocket is already in CLOSING or CLOSED state.
socket.onclose @ (index):32

Answer 1

[Александр Павлюк]

Вы отвечаете не протоколом вебсокета, а просто хеллоу ворлдом.
Нужно заиспользовать, например https://github.com/gorilla/websocket
Здесь есть пример https://github.com/gorilla/websocket/blob/master/e...

Comments

[uvelichitel]

Он делает connection upgrade на nginx. Я, например, так никогда просто не пробовал...

[4sadly]

Сработал этот код:

package main

import (
    "fmt"
    "log"
    "net/http"
    "github.com/gorilla/websocket"
)

var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
  WriteBufferSize: 1024,

  CheckOrigin: func(r *http.Request) bool { return true },
}
func reader(conn *websocket.Conn) {
    for {
    // read in a message
        messageType, p, err := conn.ReadMessage()
        if err != nil {
            log.Println(err)
            return
        }
    // print out that message for clarity
        fmt.Println(string(p))

        if err := conn.WriteMessage(messageType, p); err != nil {
            log.Println(err)
            return
        }

    }
}

// define our WebSocket endpoint
func serveWs(w http.ResponseWriter, r *http.Request) {
    fmt.Println(r.Host)

  // upgrade this connection to a WebSocket
  // connection
    ws, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println(err)
  }
    reader(ws)
}

func setupRoutes() {
  http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        fmt.Fprintf(w, "Simple Server")
  })
  // mape our `/ws` endpoint to the `serveWs` function
    http.HandleFunc("/ws", serveWs)
}

func main() {
    fmt.Println("test 0.01")
    setupRoutes()
    http.ListenAndServe(":8080", nil)
}

так же исправил

socket.onclose = event => {
    console.log("Socket Closed Connection: ", event);
    socket.send("Client Closed!")
  };

на

socket.onclose = event => {
		console.log("Socket Closed Connection: ", event);
	};

[Александр Павлюк]

uvelichitel, не делается там апгрейд на nginx, в конфиге просто прописан необходимый минимум для того, чтобы nginx НЕ МЕШАЛ апгрейду.