快速使用

获取 mqantserver：

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

mqant 2x开始支持分布式服务发现

请务必先查看2x跟1x版本差异

依赖组件

必须启动的组件有

1. consul

   consul agent --dev

2. nats

   gnats

由社区提供的docker环境

mqant-docker

go.mod 用法

mqantserver 只支持golang1.2版本以上的go.mod方式编译

翻墙

golang.org/x/net 等库无法下载的问题

export GOPROXY=https://goproxy.io

编译 mqantserver：

go install server/main.go

go build server/main.go

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

./main --conf bin/conf/server.json --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

猜数字游戏

猜数字游戏无网页模块,而是实现了一个golang的后端机器人来模拟整个逻辑

机器人代码在src/robot下,需要依赖github.com/liangdas/armyant

Demo演示说明

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

分布式跟踪系统功能测试

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

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

示意图：

项目目录结构

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

bin		
	|-conf/server.json			服务端配置文件
	|-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":"大家好!!"}