使用golang开发websocket的记录

bingciwei · · 6169 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

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


有疑问加站长微信联系(非本文作者)

本文来自:博客园

感谢作者:bingciwei

查看原文:使用golang开发websocket的记录

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

6169 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传