@@ -29,11 +29,13 @@ func BindingJson[O any](c *mqtt_client.MqttClient, item *router.Item, request an
}
- err := json.Unmarshal(data, request)
- if err != nil {
- var zero O
- sendFunc(c, item, responseIdentifier, zero, err)
- return false
+ if request != nil {
+ err := json.Unmarshal(data, request)
+ if err != nil {
+ var zero O
+ sendFunc(c, item, responseIdentifier, zero, err)
+ return false
+ }
@@ -152,7 +152,7 @@ func jsonResponse(c *mqtt_client.MqttClient, item *router.Item, responseIdentifi
err = c.Response(item, responseIdentifier.Identifier(), jsonBytes)
if err != nil {
- fmt.Println("发送mqtt json响应失败")
+ fmt.Println("发送mqtt json响应失败: " + err.Error())
return