Является ли отправка/получение веб-сокета потокобезопасным (безопасным для рутины)?

При написании сервера веб-сокетов в GO (в моем случае с использованием кодека JSON) безопасно ли иметь две разные процедуры Go для обработки отправки и получения данных по одному и тому же соединению?

Поскольку websocket.JSON.Receiveделает паузу и ожидает получения данных, я подумал, что отдельная процедура Go для обработки отправки данных была бы рабочим решением, если одновременная отправка/получение невозможна в одном и том же соединении. .

Итак, можно ли считать рабочий пример плохой практикой?

package main

import (
    "fmt"
    "net/http"
    "code.google.com/p/go.net/websocket"
)

const queueSize = 20

type Input struct {
    Cmd    string
}

type Output struct {
    Cmd    string
}

func Handler(ws *websocket.Conn) {

    msgWrite := make(chan *Output, queueSize)
    var in Input

    go writeHandler(ws, msgWrite)

    for {

        err := websocket.JSON.Receive(ws, &in)

        if err != nil {
            fmt.Println(err)
            break
        } else {
            msgWrite <- &Output{Cmd: "Thanks for your message: " + in.Cmd}
        }
    }
}

func writeHandler(ws *websocket.Conn, out chan *Output) {
    var d *Output
    for {
        select {
        case d = <-out:
            if err := websocket.JSON.Send(ws, &d); err != nil {
                fmt.Println(err.Error())
            } else {
                fmt.Println("> ", d.Cmd)
            }
        }
    }
}

func main() {
    http.Handle("/echo", websocket.Handler(Handler));
    err := http.ListenAndServe(":1235", nil);
    if err != nil {
        panic("ListenAndServe: " + err.Error())
    }
    fmt.Println("Server running")
}
6
задан ANisus 11 June 2012 в 19:03
поделиться