使用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对客户端自动关闭