快速使用

获取 mqantserver：

git clone https://github.com/liangdas/mqantserver

GOPATH 用法

GOPATH 用法可以看这边文章GOPATH 用法

mqantserver 依赖库

go get github.com/gorilla/mux
go get github.com/gorilla/websocket
go get github.com/streadway/amqp
go get github.com/golang/protobuf
go get github.com/golang/net/context
go get github.com/gogo/protobuf
go get github.com/opentracing/basictracer-go
go get github.com/opentracing/opentracing-go
go get github.com/yireyun/go-queue
go get github.com/eclipse/paho.mqtt.golang
go get github.com/liangdas/mqant
go get github.com/garyburd/redigo
go get sourcegraph.com/sourcegraph/appdash
go get sourcegraph.com/sourcegraph/appdash-data

go get golang.org/x/net 安装失败处理方案

见GOPATH用法这边文章

编译 mqantserver：

如果编译过程中提示缺少某个三方库的话通过 go get 命令安装即可

将mqantserver根目录设置到GOPATH

具体目录根据您自己的下载目录定

1. 将mqantserver根目录设置到GOPATH

   export GOPATH=$GOPATH:/work/go/mqantserver

2. 打印环境变量

   echo $GOPATH /work/go/gopath:/work/go/loolgame

3. 在mqantserver根目录执行编译

   go install server

如果一切顺利，运行 bin/server 你可以获得以下输出：

./bin/server --conf bin/conf/server.conf --log bin/logs

[release] mqant 1.0.0 starting up
[debug  ] RPCClient create success type(Gate) id(127.0.0.1:Gate)
[debug  ] RPCClient create success type(Login) id(127.0.0.1:Login)
[debug  ] RPCClient create success type(Chat) id(127.0.0.1:Chat)
[release] MySelfHost 172.16.8.4
[release] WS Listen :%!(EXTRA string=0.0.0.0:3653)
[release] TCP Listen :%!(EXTRA string=0.0.0.0:3563)

敲击 Ctrl + C 关闭游戏服务器，服务器正常关闭输出：

[debug  ] RPCServer close success id(127.0.0.1:Chat)
[debug  ] RPCServer close success id(127.0.0.1:Login)
[debug  ] RPCServer close success id(127.0.0.1:Gate)
[debug  ] RPCClient close success type(Gate) id(127.0.0.1:Gate)
[debug  ] RPCClient close success type(Login) id(127.0.0.1:Login)
[debug  ] RPCClient close success type(Chat) id(127.0.0.1:Chat)
[release] mqant closing down (signal: interrupt)

更改web服务器文件访问本地路径

bin/conf/server.conf 中

"Webapp":[
                        {
                            "Id":"Webapp001",
                            "ProcessID":"development",
                            "Settings":{
                                "StaticPath":"/work/go/mqantserver/bin"
                            }
                        }
                ],
其中StaticPath 更改为你本机上mqantserver bin的绝对路径

访问网页版本客户端

mqantserver已内置了一个web模块（源码在server/webapp），因此进程启动成功以后就可以访问了

访问地址为：http://127.0.0.1:8080/mqant/chat/index.html

小球碰撞游戏DEMO访问地址为：http://127.0.0.1:8080/mqant/hitball/index.html

启动python版本客户端

执行src/client/mqtt_chat_client.py即可 需要安装paho.mqtt库,请自行百度

Demo演示说明

1. 启动服务器
2. 启动网页客户端	(默认房间名,用户名)
3. 登陆成功后就可以聊天了

分布式跟踪系统功能测试

Appdash，用Go实现的分布式系统跟踪神器

客户端访问Chat/HD_JoinChat/{msgid}时后端将会收集访问信息，通过以下地址就可以看到了 访问地址 http://localhost:7700

示意图：

项目目录结构

https://github.com/liangdas/mqantserver 仓库中包含了mqant框架,所用到的第三方库,聊天Demo服务端,聊天代码客户端代码

bin		
	|-conf/server.conf			服务端配置文件
	|-public					web客户端静态文件
	|-hitball					小球碰撞游戏DEMO客户端文件
	|-console                   控制台web静态文件(还未完成)
src
	|-client
		|-mqtt_chat_client.py 	聊天客户端 Python版本
		|-webclient.go			聊天客户端网页版本
	|-hitball						小球碰撞游戏DEMO客户端源码
	|-server						聊天服务器Demo
		|-gate						网关模块
		|-chat						聊天模块
		|-login						登陆模块
		|-hitball					小球碰撞游戏模块
		|-tracing					分布式跟踪系统服务模块
		|-main.go					服务器启动入口

客户端快速测试

如果你需要测试其他语言的mqtt客户端，可以使用mqant提供的测试接口来测试

tcp mqtt :

host: mqant.com
port: 3563
protocol=mqtt.MQTTv31
tcp:  tls/TLSv1

如果客户端需要ca证书可以使用下面这个网站提供的
https://curl.haxx.se/docs/caextract.html

websocket mqtt :

host: ws://www.mqant.com:3653/mqant
protocol=mqtt.MQTTv31

测试协议

1. 登陆接口

    向服务器publish一条登陆消息
   
    topic:		Login/HD_Login/{msgid}
    
    message:	{"userName": "liangdas", "passWord": "Hello,anyone!"}
   

   如果topic添加了msgid,则服务器会返回一条回复消息

2. 加入聊天室

    向服务器publish一条登陆消息
   
    topic:		Chat/HD_JoinChat/{msgid}
    
    message:	{"roomName": "mqant"}
   
    服务器会广播消息给所有聊天室成员
    
    topic:		Chat/OnJoin
    	
    message:	{"users": [“liangdas”]}
   

3. 发送一条聊天

    向服务器publish一条登陆消息
   
    topic:		Chat/HD_Say/{msgid}
    
    message:	{"roomName": "mqant","from":"liangdas","target":"*","content": "大家好!!"}
   
    服务器会广播消息给所有聊天室成员
    
    topic:		Chat/OnChat
    	
    message:	{"roomName": "mqant","from":"liangdas","target":"*","msg":"大家好!!"}