websocket(一)基础

基础

项目中需要用到WebSocket,自己结合wikimedia/WebSocket学习一些基础知识,记录下来,方便复习。

  1. websocket是communication protocal(通信协议)
  2. full-duplex(全双工)
  3. over single TCP
  4. websocket设计之初用于browserweb server之间通信,现在可用于任意实现websocket协议的client和server
  5. 一次handshake(握手)后进行Upgrader request(协议升级)
  6. low overload(低负荷,不需要header信息),实时
  7. 通讯使用http 80端口或者https 443端口
  8. 允许流式信息
  9. HTML5
  10. 发送敏感数据需要使用token或者其它手段对websocket进行加密,比如聊天应用
  11. 使用代理时(proxy),客户端通过HTTP CONNECT方法建立tunnal

实践,搭建Echo服务器

echo服务器是websocket的典型应用,这里根据gorilla/websocket里面的例子搭建一个echo服务器,具体代码在Github/adolphlwq/wsecho,demo地址:https://echo.ws.adolphlwq.xyz/

echo代码:

package main


import (
	"net/http"


	"github.com/Sirupsen/logrus"
	"github.com/gorilla/websocket"
)


var upgrader = websocket.Upgrader{
	CheckOrigin: func(r *http.Request) bool {
		return true
	},
}


func echo(w http.ResponseWriter, r *http.Request) {
	ws, err := upgrader.Upgrade(w, r, nil)
	if err != nil {
		logrus.Println("upgrade connection to websocket error: ", err)
		return
	}
	defer ws.Close()


	for {
		mt, message, err := ws.ReadMessage()
		if err != nil {
			logrus.Println("read message from websocket error: ", err)
			break
		}


		err = ws.WriteMessage(mt, message)
		if err != nil {
			logrus.Warnln("write message to websocket error: ", err)
			break
		}
	}
}

这里有个注意的地方,在使用websocket.Upgrader时,要指定CheckOrigin函数,否则后端server会报403错误。

var upgrader = websocket.Upgrader{
	CheckOrigin: func(r *http.Request) bool {
		return true
	},
}
comments powered by Disqus