FirstMQ服务提供了TCP服务用于接口通信,并为您提供了GO语言客户端工具包及命令行工具。
几乎全部的语言都会支持TCP请求,所以FirstMQ可以被动地支持所有主流语言。
消息数据为json格式,最终会将json转换为字节形式发送至服务端。
消息格式 :
{
// 消息类型
Action int
// 话题名称
Topic string
// 消费者组
ConsumerGroup string
// 消息数据
Data string
}
消息类型 Type :
1 生产消息
2 消费消息
3 创建话题 ( 集群 )
4 获取话题列表
5 查看服务状态
6 ping
7 创建消费者组 ( 集群 )
8 创建消费者组 ( 单机 )
9 创建话题 ( 单机 )