func main() {
go func() {
err := http.ListenAndServe(":9998", websocket.Server{websocket.Config{},
nil, ChatroomServer})
if err != nil {
panic("ListenAndServe: " + err.Error())
}
}()
err := http.ListenAndServe(":9999", nil)
if err != nil {
panic("ListenAndServe: " + err.Error())
}
}
func ChatroomServer(ws *websocket.Conn) {
defer func(){
ws.Close()
}()
var msgReceive string
var msgToSend string
for{
if err := websocket.Message.Receive(ws,&msgReceive);err!=nil{
fmt.Println("Can't receive")
}
if err := websocket.Message.Send(ws,&msgToSend);err!=nil{
fmt.Println("Can't send")
}
}
}
直接使用http.handler("/", websocket.Handler(ChatroomServer))這種方式會報錯.
目前猜測應(yīng)該是websocket不能和其它的玩意共享一個端口,必須是獨立使用一個端口..僅為個人猜測
