using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using HslCommunication;
|
using HslCommunication.MQTT;
|
using Newtonsoft.Json;
|
using WIDESEA_Common.AGVEunm;
|
using WIDESEA_Model.Models;
|
namespace WIDESEA_Tasks
|
{
|
public partial class AGVjob
|
{
|
|
public void MqttExample()
|
{
|
|
// 创建MQTT客户端
|
HslCommunication.MQTT.MqttClient mqttClient = new HslCommunication.MQTT.MqttClient(new MqttConnectionOptions()
|
{
|
IpAddress = "192.168.2.51",
|
Port = 1883,
|
KeepAlivePeriod = TimeSpan.FromSeconds(100),
|
CleanSession = true,
|
//Credentials = new MqttCredential("admin", "123456"), // 设置了用户名和密码
|
|
});
|
// 连接
|
OperateResult connect = mqttClient.ConnectServer();
|
if (connect.IsSuccess)
|
{
|
//MessageBox.Show("Success");
|
}
|
else
|
{
|
//MessageBox.Show("Failed");
|
}
|
Thread.Sleep(2000);
|
//原材料库库报警灯
|
var taskout = _taskService.GetTasksout();
|
if (taskout != null)
|
{
|
OperateResult send = mqttClient.SubscribeMessage(new string[] { "/cmd/get/1" });
|
load load = new load();
|
{
|
load.func = "setkeyval";
|
load.key = "R";
|
load.value = 2;
|
}
|
var posy = JsonConvert.SerializeObject(load);
|
// 测试发布
|
OperateResult result = mqttClient.PublishMessage(new MqttApplicationMessage()
|
{
|
Topic = "/cmd/get/1", // 主题
|
QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce, // 消息等级
|
Payload = Encoding.UTF8.GetBytes(posy), // 数据
|
Retain = false, // 是否保留
|
});
|
load1 load1 = new load1();
|
{
|
load1.func = "setkeyval";
|
load1.key = "BU";
|
load1.value = 1;
|
}
|
var posy1 = JsonConvert.SerializeObject(load1);
|
OperateResult result1 = mqttClient.PublishMessage(new MqttApplicationMessage()
|
{
|
Topic = "/cmd/get/1", // 主题
|
QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce, // 消息等级
|
Payload = Encoding.UTF8.GetBytes(posy1), // 数据
|
Retain = false, // 是否保留
|
});
|
}
|
else
|
{
|
load load = new load();
|
{
|
load.func = "setkeyval";
|
load.key = "R";
|
load.value = 0;
|
}
|
var posy = JsonConvert.SerializeObject(load);
|
// 测试发布
|
OperateResult result = mqttClient.PublishMessage(new MqttApplicationMessage()
|
{
|
Topic = "/cmd/get/1", // 主题
|
QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce, // 消息等级
|
Payload = Encoding.UTF8.GetBytes(posy), // 数据
|
Retain = false, // 是否保留
|
});
|
load1 load1 = new load1();
|
{
|
load1.func = "setkeyval";
|
load1.key = "BU";
|
load1.value = 0;
|
}
|
var posy1 = JsonConvert.SerializeObject(load1);
|
OperateResult result1 = mqttClient.PublishMessage(new MqttApplicationMessage()
|
{
|
Topic = "/cmd/get/1", // 主题
|
QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce, // 消息等级
|
Payload = Encoding.UTF8.GetBytes(posy1), // 数据
|
Retain = false, // 是否保留
|
});
|
}
|
Thread.Sleep(2000);
|
//成品库报警灯
|
var taskin = _taskService.GetTasksoin();
|
if (taskin != null)
|
{
|
OperateResult send1 = mqttClient.SubscribeMessage(new string[] { "/cmd/get/2" });//需换成品库订阅
|
load load = new load();
|
{
|
load.func = "setkeyval";
|
load.key = "R";
|
load.value = 2;
|
}
|
var posy = JsonConvert.SerializeObject(load);
|
// 测试发布
|
OperateResult result = mqttClient.PublishMessage(new MqttApplicationMessage()
|
{
|
Topic = "/cmd/get/2", // 主题
|
QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce, // 消息等级
|
Payload = Encoding.UTF8.GetBytes(posy), // 数据
|
Retain = false, // 是否保留
|
});
|
load1 load1 = new load1();
|
{
|
load1.func = "setkeyval";
|
load1.key = "BU";
|
load1.value = 1;
|
}
|
var posy1 = JsonConvert.SerializeObject(load1);
|
OperateResult result1 = mqttClient.PublishMessage(new MqttApplicationMessage()
|
{
|
Topic = "/cmd/get/2", // 主题
|
QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce, // 消息等级
|
Payload = Encoding.UTF8.GetBytes(posy1), // 数据
|
Retain = false, // 是否保留
|
});
|
}
|
else
|
{
|
load load = new load();
|
{
|
load.func = "setkeyval";
|
load.key = "R";
|
load.value = 0;
|
}
|
var posy = JsonConvert.SerializeObject(load);
|
// 测试发布
|
OperateResult result = mqttClient.PublishMessage(new MqttApplicationMessage()
|
{
|
Topic = "/cmd/get/2", // 主题
|
QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce, // 消息等级
|
Payload = Encoding.UTF8.GetBytes(posy), // 数据
|
Retain = false, // 是否保留
|
});
|
load1 load1 = new load1();
|
{
|
load1.func = "setkeyval";
|
load1.key = "BU";
|
load1.value = 0;
|
}
|
var posy1 = JsonConvert.SerializeObject(load1);
|
OperateResult result1 = mqttClient.PublishMessage(new MqttApplicationMessage()
|
{
|
Topic = "/cmd/get/2", // 主题
|
QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce, // 消息等级
|
Payload = Encoding.UTF8.GetBytes(posy1), // 数据
|
Retain = false, // 是否保留
|
});
|
}
|
|
}
|
private HslCommunication.MQTT.MqttClient mqttClient = null;
|
|
public partial class load
|
{
|
public string func { get; set; }
|
public string key { get; set; }
|
public int value { get; set; }
|
}
|
public partial class load1
|
{
|
public string func { get; set; }
|
public string key { get; set; }
|
public int value { get; set; }
|
}
|
}
|
}
|
