客服电话
APP下载
迪恩网络APP
随时随地掌握行业动态
官方微信
扫描二维码
关注迪恩网络微信公众号
开源软件名称：SI-MQTT开源软件地址：https://gitee.com/Ljolan/si-mqtt开源软件介绍：gitee.com/Ljolan/si-mqtt介绍golang mqtt服务器，集群版，目前支持DB集群和直连集群 使用说明
客户端调用测试
// 本地启动broker服务之后// 可以将此代码直接粘贴在paho的client_test.go里面运行即可测试func TestClientTest(t *testing.T) { conn, _ := net.Dial("tcp","127.0.0.1:1883") c := NewClient(ClientConfig{ Conn: conn, Router: NewSingleHandlerRouter(func(p *Publish) { fmt.Println(p.String()) }), }) c.serverProps.SharedSubAvailable = true require.NotNil(t, c) c.SetDebugLogger(log.New(os.Stderr, "CONNECT: ", log.LstdFlags)) cp := &Connect{ KeepAlive: 30, ClientID: "testClient", CleanStart: true, Properties: &ConnectProperties{ ReceiveMaximum: Uint16(200), }, WillMessage: &WillMessage{ Topic: "will/topic", Payload: []byte("am gone"), }, WillProperties: &WillProperties{ WillDelayInterval: Uint32(200), }, } ca, err := c.Connect(context.Background(), cp) require.Nil(t, err) assert.Equal(t, uint8(0), ca.ReasonCode) time.Sleep(10 * time.Millisecond) s := &Subscribe{ Subscriptions: map[string]SubscribeOptions{ "test/1": {QoS: 1}, "test/2": {QoS: 2}, "test/3": {QoS: 0}, "$share/aa/test/1": {QoS: 0}, }, } _, err = c.Subscribe(context.Background(), s) require.Nil(t, err) //assert.Equal(t, []byte{1, 2, 0}, sa.Reasons) time.Sleep(10 * time.Millisecond) var p *Publish p = &Publish{ Topic: "test/0", QoS: 0, Payload: []byte("test payload"), } _, err = c.Publish(context.Background(), p) require.Nil(t, err) time.Sleep(10 * time.Millisecond) p = &Publish{ Topic: "test/1", QoS: 1, Payload: []byte("test payload"), } pa, err := c.Publish(context.Background(), p) require.Nil(t, err) assert.Equal(t, uint8(0), pa.ReasonCode) time.Sleep(20 * time.Millisecond) p = &Publish{ Topic: "test/2", QoS: 2, Payload: []byte("test payload"), } pr, err := c.Publish(context.Background(), p) require.Nil(t, err) assert.Equal(t, uint8(0), pr.ReasonCode) time.Sleep(30 * time.Millisecond) }目前支持的方案1. Mongo集群设计2. Mysql集群设计
3. 静态配置启动多节点启动
MQTTX使用
待优化实现
旧设计思路
系统领域uml设计 |
请发表评论