修改qos

mqtt_binding/mqtt_client/mqtt_client.go

@@ -146,7 +146,7 @@ func (c *MqttClient) GetRouter(group string, handlers []router.Handler) *router.
 }
 
 func (c *MqttClient) Response(item *router.Item, data []byte) error {
-	token := c.client.Publish(item.Topic+"/reply", 2, false, data)
+	token := c.client.Publish(item.Topic+"/reply", 0, false, data)
 	if token.Wait(); token.Error() != nil {
 		return token.Error()
 	}
@@ -220,7 +220,7 @@ func (c *MqttClient) rangeRouters(rangeFunc func(router *router.Router) error) e
 }
 
 func (c *MqttClient) subscribe(item *router.Item) error {
-	token := c.client.Subscribe(item.Topic, 2, func(client mqtt.Client, message mqtt.Message) {
+	token := c.client.Subscribe(item.Topic, 0, func(client mqtt.Client, message mqtt.Message) {
 		item.CallHandlers(message.Payload())
 	})
 	if token.Wait(); token.Error() != nil {