从几天前开始,我们一直努力用go语言重写物联网设备的云网关代码;
因为,随着设备数量的增加以及设备通信数据量的增大,
目前的云网关已不堪重负,特别是智能鱼塘增氧泵即将量产,
云网关的优化迫在眉睫。
现在,已经完成了socket服务器、websocket服务器,
以及socket客户端、websocket客户端之间的相互寻址、数据转发。
但是整个项目 使用gopath来管理包, 具有版本不好管理,不易于与github等对接的缺点。
今天晚上,花了一点时间,使用go module对整个项目进行了重构,做一下记录,同时分享给网友。
一、总体设计
云网关的主要功能包括如下:
1)作为TCP服务端,与作为客户端的设备建立长连接,为局域网内的设备提供网络穿透通道,从而在设备与设备、设备和浏览器之间实现即时通信。
2)作为websocket服务端,与用户打开的浏览器或者手机APP建立基于websocket的长连接,将用户发送的控制命令转发给设备,同时将来自设备的数据即时推送给用户。
3)采用redis作为内存数据库,缓存来自设备端的数据,用于在云上实现对设备的故障诊断,当有事件发生时,推送VX消息,拨打报警电话,以及设备之间的逻辑编程功能。
4)采用mysql作为永久数据库,用于记录设备和用户的设置信息。
…
使用github上的开源代码gorilla/websocket设计websocket服务端。
使用github上的开源代码go-redis/redis设计redis客户端。
自己编写业务逻辑代码,实现网关数据转发,redis数据存取,故障判断报警等功能。
把公共函数设计成单独的包,自己编写的代码托管在码云gitee.com上。
二、操作步骤
1) 在码云(gitee.com)上创建公共包utils以及网关代码tcpserver的代码仓库,如下图:
2) 以/gomodule文件夹下创建tcpserver文件夹,
将编写好的main.go文件拷至该文件夹,
在main.go文件中包含了websocket和redis的软件包,如下:
在文件夹执行go mod init gitee.com/xxxx/tcpserver,
此时会在tcpserver文件夹下生成go.mod文件。
再执行go mod tidy,此时go将从github以及gitee仓库拉取最新代码。
可能会报连接错误,这是因为你懂得的原因,无法访问github所致。
go get github.com/go-redis/redis/v8: module github.com/go-redis/redis/v8: Get “h
ttps://proxy.golang.org/github.com/go-redis/redis/v8/@v/list”: dial tcp 216.58.2
00.241:443: connectex: A connection attempt failed because the connected party d
id not properly respond after a period of time, or established connection failed
because connected host has failed to respond.
需要将GOPROXY修改为aliyun的url。如下:
go env -w GOPROXY=
3) 生成自定义的包并提供到gitee进行版本管理,
在/gomodule文件夹下创建utils文件夹,
进入utils文件夹执行git clone ,与码云仓库进行代码同步。
执行go mod init gitee.com/xxxx/utils,同样会在该文件夹下生成go.mod文件。
将前几天编的utils文件夹下的funcs.go复制到该文件下。
执行“git add.”->”git commit”->”git push” 将代码提交到gitee仓库。
再进入/gomodule/tcpsever文件夹。
打开go.mod,输入下面代码将远程仓库的代码替换为本地代码;
最后,在tcpserver文件夹下执行go build即可编译代码。