快速使用
获取 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/garyburd/redigo
go get sourcegraph.com/sourcegraph/appdash
go get sourcegraph.com/sourcegraph/appdash-data
go get github.com/eclipse/paho.mqtt.golang 用于后端机器人
go get github.com/liangdas/mqant
go get github.com/liangdas/mqant-modules 牌桌模块,短信发送模块
go get github.com/liangdas/armyant 用于后端机器人
go get golang.org/x/net 安装失败处理方案
编译 mqantserver：
如果编译过程中提示缺少某个三方库的话通过 go get 命令安装即可
将mqantserver根目录设置到GOPATH
具体目录根据您自己的下载目录定
-
将mqantserver根目录设置到GOPATH
export GOPATH=$GOPATH:/work/go/mqantserver
-
打印环境变量
echo $GOPATH /work/go/gopath:/work/go/loolgame
-
在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
猜数字游戏
猜数字游戏无网页模块,而是实现了一个golang的后端机器人来模拟整个逻辑
机器人代码在src/robot下,需要依赖github.com/liangdas/armyant
Demo演示说明
1. 启动服务器
2. 启动网页客户端 (默认房间名,用户名)
3. 登陆成功后就可以聊天了
分布式跟踪系统功能测试
客户端访问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
测试协议
-
登陆接口
向服务器publish一条登陆消息 topic: Login/HD_Login/{msgid} message: {"userName": "liangdas", "passWord": "Hello,anyone!"}如果topic添加了msgid,则服务器会返回一条回复消息
-
加入聊天室
向服务器publish一条登陆消息 topic: Chat/HD_JoinChat/{msgid} message: {"roomName": "mqant"} 服务器会广播消息给所有聊天室成员 topic: Chat/OnJoin message: {"users": [“liangdas”]} -
发送一条聊天
向服务器publish一条登陆消息 topic: Chat/HD_Say/{msgid} message: {"roomName": "mqant","from":"liangdas","target":"*","content": "大家好!!"} 服务器会广播消息给所有聊天室成员 topic: Chat/OnChat message: {"roomName": "mqant","from":"liangdas","target":"*","msg":"大家好!!"}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent