标签：
使用beego框架进行整个社区的restful api的开发，查找资料后决定使用github.com/gorilla/websocket 作为websocket的包,
定义websocket的属性
var upgrader = websocket.Upgrader{
ReadBufferSize: 1024,
WriteBufferSize: 1024,
}
都是按照官方的例子来，期间也参考了beego的一个聊天室的实例。
ws, err := upgrader.Upgrade(this.Ctx.ResponseWriter, this.Ctx.Request, nil) defer ws.Close()
因为是使用beego框架，所以实例化websocket的时候，传输的参数是使用beego的获取方式
实例化ws以后，使用了一个for循环，等待接收数据，并且对数据进行处理
_, p, err := ws.ReadMessage()
这里我没有对内容进行判断，所以第一个参数，返回的数据类型，我直接抛弃了，因为功能很简单，所以也就不做数据类型验证,对数据进行一堆处理之后，返回json
if err = ws.WriteJSON(resMap); err != nil {
fmt.Println(err)
ws.Close()
break
}
测试方便，把报错信息直接打出，ws包带着返回json的方式，直接把map传递过来就可以了，如果报错一定要直接ws.Close() 不然会被后台信息淹没掉
其实用法很简单，麻烦的是公司的nginx版本太低，部署的时候先升级了nginx，然后做了个反向代理，监听了脚本的端口，
设置了cgi的存活时间，否则是按照php的设置来的，所以单独给websocket程序的段增加了持续时间
因为程序逻辑里还有一个延迟等待的功能，开始是使用一个time.sleep来实现，后来读了go语言程序设计后，学会了一招，可以用channel来做处理。
设置nginx的方法
因为部署在php的服务器上，所以直接使用supertctl做了一个进程监控，让go作为一个后台进程运行，然后使用nginx做了一个反向代理，设置如下
首先。修改nginx.conf文件， 要在 http 里面添加配置，也就是 跟server同级
map $http_upgrade $connection_upgrade {
default upgrade;
‘‘ close;
}
#limit_zone crawler $binary_remote_addr 10m;
upstream websocket {
server 127.0.0.1:8198;
}
设置反向代理 我的是监听本机8198端口
然后设置 访问的目录
location /backapi/ {
proxy_set_header Host $host;
proxy_pass http://websocket;
proxy_http_version 1.1;
proxy_read_timeout 86400s;
keepalive_timeout 86400s;
#proxy_redirect off;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection "upgrade";
#proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
}
设置了nginx获取到对目录的访问的时候，调用go的脚本进行解析，并且设置了读取的时间为86400秒，防止ngxin对客户端自动关闭
标签：
原文地址：http://www.cnblogs.com/bingciwei/p/5104077.html
