Как вы размещаете параллельные соединения через сокет Golang Gorilla / mux? - PullRequest
Новая
       26

Как вы размещаете параллельные соединения через сокет Golang Gorilla / mux?

0 голосов
/ 25 марта 2019

заранее спасибо за любую помощь или совет!

Я создаю шахматное приложение, интерфейс в Reactjs, а сервер - сервер, написанный на Golang с использованием библиотеки мультиплексора Gorilla.Бэкэнд - это шахматный движок, с которым пользователь может играть.Реагирующий интерфейс создает соединение WebSocket с сервером в конструкторе верхнего уровня.

Приложение хорошо работает для одного подключения.Однако при открытии второй вкладки браузера соединение Websocket первой вкладки браузера теряется.

Сервер сообщает об ошибке, 

read error: websocket: close 1001 (going away)

, а затем, 

read error: read tcp 127.0.0.1:8081-\u003e127.0.0.1:64146: use of closed network connection

Я посмотрел документацию Gorrilla / mux для веб-сокетов и читаю / пишувсе из одной и той же функции, чтобы избежать одновременного чтения или записи по одному и тому же соединению.

Конструктор внешнего интерфейса React находится здесь: 

class Game extends React.Component {
  constructor(props) {
    super(props);
    this.state = {
      history: [{
        position: this.props.chess.fen(),
        move: "",
      }],
      ply: 0,
      selectedSq: null,
      engineName: "",
      engineAuthor: "",
      uciOK: false,
      isReady: false,
      engineThinking: false,
      playersTurn: true,
      playerColor: WHITE,
    };
    this.ws = websocketConnect("ws://localhost:8081/uci");
    this.ws.onmessage = (event) => {
      const msg = event.data
      this.processEngineMessage(msg)
    }
  }

Он ссылается на websocket.js, который находится здесь: 

export function websocketConnect(url) {
  const ws = new WebSocket(url);
  ws.addEventListener('open', (event) => {
    ws.send('uci');
  });
  return ws;
}

Здесь находится пакет Goland Websocket 

package websocket

import (
    "net/http"

    "github.com/namsral/flag"
    log "github.com/sirupsen/logrus"

    "github.com/gorilla/websocket"
)

type WebsocketServer struct {
    upgrader websocket.Upgrader
    addr     *string
    conn     *websocket.Conn
}

func NewWebsocketServer() *WebsocketServer {
    w := new(WebsocketServer)
    w.addr = flag.String("addr", "localhost:8081", "http service address")
    flag.Parse()
    w.upgrader = websocket.Upgrader{} // use default options
    http.HandleFunc("/uci", w.uciHandler)
    return w
}

func (w *WebsocketServer) uciHandler(rw http.ResponseWriter, r *http.Request) {
    var err error
    log.Error("upgrading to websocket connection")
    w.upgrader.CheckOrigin = func(r *http.Request) bool { return true }
    w.conn, err = w.upgrader.Upgrade(rw, r, nil)
    if err != nil {
        log.Print("upgrade:", err)
        return
    }
    go w.UCI(rw, r)
}

func (w *WebsocketServer) Start() {
    log.Info("starting websocket server")
    http.ListenAndServe(*w.addr, nil)
}

func (w *WebsocketServer) CloseConnection() {
    w.conn.Close()
}

func (w *WebsocketServer) StartReader(channel chan string) {
    for {
        _, message, err := w.conn.ReadMessage()
        if err != nil {
            log.Println("read error:", err)
            break
        }
        log.Printf("recv: %s", message)
        channel <- string(message)
    }
}

func (w *WebsocketServer) Write(msg string) {
    err := w.conn.WriteMessage(websocket.TextMessage, []byte(msg))
    if err != nil {
        log.Println("write:", err)
    }
}

Полный код здесь: сервер: https://github.com/tonyOreglia/glee веб-интерфейс: https://github.com/tonyOreglia/chess-board-react

Я надеюсь, что смогу поддерживать несколько одновременных пользователей, использующих веб-сайт.В настоящее время он находится на DigitalOcean.

1 Ответ

0 голосов
/ 25 марта 2019

Конструкция вашей структуры WebServer допускает только одно соединение.

В каждом начальном http-запросе на /uci происходит обновление соединения, и каждый раз, когда вы обновляете http-запрос на ws-соединение, вы заменяете предыдущее соединение в структуре WebServer этим.

Кроме того, он не является потокобезопасным, так как каждый запрос обрабатывается в другой программе.

Я предлагаю вам передать соединение вашему методу UCI вместо того, чтобы подключать его к серверу. 

type WebsocketServer struct {
    upgrader websocket.Upgrader
    addr     *string
}

func (w *WebsocketServer) uciHandler(rw http.ResponseWriter, r *http.Request) {
    var err error
    log.Error("upgrading to websocket connection")
    w.upgrader.CheckOrigin = func(r *http.Request) bool { return true }
    // here is the difference
    conn, err := w.upgrader.Upgrade(rw, r, nil)
    if err != nil {
        log.Print("upgrade:", err)
        return
    }
    // and here
    go w.UCI(rw, r, conn)
}

Вы также можете хранить фрагмент / карту с мьютексом, в котором хранятся все ваши соединения. Только не забудьте удалить его, когда ваше соединение закрывается.

...