|
|
|
@@ -54,7 +54,7 @@ namespace BPA.MES.Base.Application |
|
|
|
MessageLen = JSON.Serialize(input.Payload).Length |
|
|
|
}; |
|
|
|
//组装MQTT消息 |
|
|
|
var tem = await $"http://{mqttentity.Address}/api/v5/publish".SetHeaders(new |
|
|
|
var tem = await $"http://{mqttentity.Address}{mqttentity.MsgPublishRoute}".SetHeaders(new |
|
|
|
{ |
|
|
|
Authorization = "Basic " + Convert.ToBase64String(Encoding.UTF8.GetBytes($"{mqttentity.Account}:{mqttentity.Pwd}")) |
|
|
|
}).SetBody(new |
|
|
|
|
