70 lines
2.1 KiB
C#
70 lines
2.1 KiB
C#
using MesWorkMqtt;
|
|
using MisDataFunction;
|
|
using MQTTnet;
|
|
using MQTTnet.Client.Connecting;
|
|
using MQTTnet.Client.Disconnecting;
|
|
using MQTTnet.Client.Receiving;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.ComponentModel;
|
|
using System.Configuration;
|
|
using System.Data;
|
|
using System.Drawing;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using System.Windows.Forms;
|
|
|
|
namespace MisDataSaveDate
|
|
{
|
|
public partial class SaveData : Form
|
|
{
|
|
public SaveData()
|
|
{
|
|
InitializeComponent();
|
|
}
|
|
|
|
private void SaveData_Load(object sender, EventArgs e)
|
|
{
|
|
//Task.Run(() => StartAsync());
|
|
|
|
Mqtt.StartAsync();
|
|
Mqtt.mqttClient.ConnectedHandler = new MqttClientConnectedHandlerDelegate(OnSubscriberConnected);
|
|
Mqtt.mqttClient.DisconnectedHandler = new MqttClientDisconnectedHandlerDelegate(OnSubscriberDisconnected);
|
|
Mqtt.mqttClient.ApplicationMessageReceivedHandler = new MqttApplicationMessageReceivedHandlerDelegate(OnSubscriberMessageReceived);
|
|
|
|
string url;
|
|
string topic;
|
|
url = ConfigurationManager.AppSettings["MqttUrl"];
|
|
topic = ConfigurationManager.AppSettings["MqttTargetTopicTagTypeCodeID"];
|
|
new InitMqtt2(url, topic);
|
|
|
|
|
|
MesServerWork.MIS_BASE.InitHashtable_MesServerCode();
|
|
|
|
|
|
}
|
|
private void OnSubscriberConnected(MqttClientConnectedEventArgs x)
|
|
{
|
|
var rec = x.AuthenticateResult.ResultCode.ToString();
|
|
//label_State.Text = rec;
|
|
}
|
|
|
|
private void OnSubscriberDisconnected(MqttClientDisconnectedEventArgs x)
|
|
{
|
|
//var rec = x.AuthenticateResult.ResultCode.ToString();
|
|
//label_State.Text = rec;
|
|
}
|
|
|
|
private void OnSubscriberMessageReceived(MqttApplicationMessageReceivedEventArgs x)
|
|
{
|
|
var rec = x.ApplicationMessage.ConvertPayloadToString();
|
|
ThreadPool.QueueUserWorkItem(MisDataSaveDate.Funtion.MIS_Funtion, rec);
|
|
}
|
|
|
|
|
|
|
|
}
|
|
}
|