从几天前开始,我们一直努力用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即可编译代码。