MqttClient 类

public class MqttClient : NetworkXBase, IDisposable

Public Class MqttClient
	Inherits NetworkXBase
	Implements IDisposable

public ref class MqttClient : public NetworkXBase, 
	IDisposable

type MqttClient =  
    class
        inherit NetworkXBase
        interface IDisposable
    end

// 简单的实例化例子
MqttClient mqttClient = new MqttClient( new MqttConnectionOptions( )
{
    ClientId = "ABC",                     // 客户端的唯一的ID信息
    IpAddress = "127.0.0.1",              // 服务器的地址
} );

// 如果有密码的情况
MqttClient mqttClient = new MqttClient( new MqttConnectionOptions( )
{
    ClientId = "ABC",                                            // 客户端的唯一的ID信息
    IpAddress = "127.0.0.1",                                     // 服务器的地址
    Credentials = new MqttCredential( "admin", "123456" )        // 设置了用户名和密码
} );

// 如果有证书的情况
MqttClient mqttClient = new MqttClient( new MqttConnectionOptions( )
{
    ClientId = "ABC",                                            // 客户端的唯一的ID信息
    IpAddress = "127.0.0.1",                                     // 服务器的地址
    Credentials = new MqttCredential( "admin", "123456" ),       // 设置了用户名和密码

    CertificateFile = @"D:\emqx\etc\certs\cacert.pem",           // 指定证书的路径，这里选择的是emqx的测试证书
} );

// 如果连接的hslcommunication自身的服务器，还支持直接使用通信加密技术，配置非常的简单，这样就可以防止通讯的过程中，被抓包发现账户名，密码，通信数据等信息
MqttClient mqttClient = new MqttClient( new MqttConnectionOptions( )
{
    ClientId = "ABC",                                            // 客户端的唯一的ID信息
    IpAddress = "127.0.0.1",                                     // 服务器的地址
    Credentials = new MqttCredential( "admin", "123456" ),       // 设置了用户名和密码

    UseRSAProvider = true
} );

// 连接服务器
HslCommunication.OperateResult connect =  mqttClient.ConnectServer( );
if (connect.IsSuccess)
{
    // 连接成功
}
else
{
    // 连接失败，过会就需要重新连接了
}

// 重点说明。如果过会网络不行了，断开了，内部会自动连接服务器的，你只管publish就可以了

// 发布示例
HslCommunication.OperateResult connect = mqttClient.PublishMessage( new MqttApplicationMessage( )
{
    Topic = "A",                                                           // 主题
    QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce,          // 如果是实时数据，适合用这个
    Payload = Encoding.UTF8.GetBytes("Test data")                          // 发布的数据
} );
if (connect.IsSuccess)
{
    // 发布成功
}
else
{
    // 发布失败
}

// 重点说明。如果过会网络不行了，断开了，内部会自动连接服务器的，你只管publish就可以了

// 订阅示例
mqttClient.OnMqttMessageReceived += ( MqttClient client, MqttApplicationMessage message ) =>
{
    Console.WriteLine( "Time:" + DateTime.Now.ToString( ) );
    Console.WriteLine( "Topic:" + message.Topic );
    Console.WriteLine( "Payload:" + Encoding.UTF8.GetString( message.Payload ) );
};

// 然后添加订阅
HslCommunication.OperateResult sub = mqttClient.SubscribeMessage( "A" );
if (sub.IsSuccess)
{
    // 订阅成功
}
else
{
    // 订阅失败
}

// 网络失败的情况，需要自己来手动控制重连，实例化后进行事件绑定
mqttClient.OnNetworkError += ( object sender, EventArgs e ) =>
{
    // 当网络异常的时候触发，可以在此处重连服务器
    if (sender is MqttClient client)
    {
        // 开始重连服务器，直到连接成功为止
        client.LogNet?.WriteInfo( "网络异常，准备10秒后重新连接。" );
        while (true)
        {
            // 每隔10秒重连
            System.Threading.Thread.Sleep( 10_000 );
            client.LogNet?.WriteInfo( "准备重新连接服务器..." );
            HslCommunication.OperateResult connect = client.ConnectServer( );
            if (connect.IsSuccess)
            {
                // 连接成功后，可以在下方break之前进行订阅，或是数据初始化操作
                client.LogNet?.WriteInfo( "连接服务器成功！" );
                break;
            }
            client.LogNet?.WriteInfo( "连接失败，准备10秒后重新连接。" );
        }
    }
};

// 如果有证书的情况
MqttClient mqttClient = new MqttClient( new MqttConnectionOptions( )
{
    ClientId = "ABC",                                            // 客户端的唯一的ID信息
    IpAddress = "127.0.0.1",                                     // 服务器的地址
    Credentials = new MqttCredential( "admin", "123456" ),       // 设置了用户名和密码

    CertificateFile = @"D:\emqx\etc\certs\cacert.pem",           // 指定证书的路径，这里选择的是emqx的测试证书
} );

namespace HslCommunicationDemo.MQTT
{
    public partial class FormMqttSubscribe : Form
    {
        // 将 mqttClient 传递给子窗体
        public FormMqttSubscribe( MqttClient mqttClient )
        {
            InitializeComponent( );

            this.mqttClient = mqttClient;
        }

        private void FormMqttSubscribe_Load( object sender, EventArgs e )
        {
            button8.Enabled = false;
        }


        MqttClient mqttClient = null;

        private void button7_Click( object sender, EventArgs e )
        {
            // 子窗体订阅操作，在子窗体订阅的情况下，一般来说每个子窗体不同的topic主题
            OperateResult send = mqttClient.SubscribeMessage( new string[] { textBox5.Text } );

            if (!send.IsSuccess) MessageBox.Show( "SubscribeMessage Failed:" + send.Message );
            else
            {
                // 获取订阅的信息，绑定本类的触发事件
                SubscribeTopic subscribeTopic = mqttClient.GetSubscribeTopic( textBox5.Text );
                if (subscribeTopic != null) subscribeTopic.OnMqttMessageReceived += FormMqttSubscribe_OnMqttMessageReceived;
                button7.Enabled = false;
                button8.Enabled = true;
            }
        }

        private void FormMqttSubscribe_OnMqttMessageReceived( MqttClient client, MqttApplicationMessage message )
        {
            // 订阅触发，这里举例是显示出来
            try
            {
                string topic = message.Topic;
                byte[] payload = message.Payload;
                Invoke( new Action( ( ) =>
                {
                    receiveCount++;
                    label10.Text = "Receive Count: " + receiveCount;
                    string msg = string.Empty;
                    if (radioButton_binary.Checked)
                    {
                        msg = payload.ToHexString( ' ' );
                    }
                    else if (radioButton_text.Checked)
                    {
                        msg = Encoding.UTF8.GetString( payload );
                    }
                    else if (radioButton_xml.Checked)
                    {
                        try
                        {
                            msg = XElement.Parse( Encoding.UTF8.GetString( payload ) ).ToString( );
                        }
                        catch
                        {
                            msg = Encoding.UTF8.GetString( payload );
                        }
                    }
                    else if (radioButton_json.Checked)
                    {
                        try
                        {
                            msg = Newtonsoft.Json.Linq.JObject.Parse( Encoding.UTF8.GetString( payload ) ).ToString( );
                        }
                        catch
                        {
                            msg = Encoding.UTF8.GetString( payload );
                        }
                    }

                    if (checkBox_long_message_hide.Checked)
                    {
                        if (msg?.Length > 200)
                        {
                            msg = msg.Substring( 200 );
                        }
                    }
                    if (radioButton2.Checked)
                        textBox8.AppendText( DateTime.Now.ToString( "yyyy-MM-dd HH:mm:ss.fff" ) + $" Topic[{topic}]: " + msg + Environment.NewLine );
                    else if (radioButton1.Checked)
                        textBox8.Text = DateTime.Now.ToString( "yyyy-MM-dd HH:mm:ss.fff" ) + $" Topic[{topic}]: " + msg;
                } ) );
            }
            catch
            {

            }
        }

        private long receiveCount = 0;


        private void button8_Click( object sender, EventArgs e )
        {
            // 取消订阅操作，需要先解绑注册事件
            SubscribeTopic subscribeTopic = mqttClient.GetSubscribeTopic( textBox5.Text );
            if (subscribeTopic != null)
            {
                subscribeTopic.OnMqttMessageReceived -= FormMqttSubscribe_OnMqttMessageReceived;

                // 取消订阅，为了不影响其他的界面的订阅信息（可能其他子界面也有订阅相同的主题），这里先判断订阅计数，减到 0 才真正的取消订阅
                // 如果你的主题只有一个窗体使用到的话，那么这里就不需要判断，直接取消订阅即可
                if (subscribeTopic.RemoveSubscribeTick( ) <= 0)
                {
                    OperateResult send = mqttClient.UnSubscribeMessage( textBox5.Text );

                    if (!send.IsSuccess) MessageBox.Show( "UnSubscribeMessage Failed:" + send.Message );
                    else
                    {
                        button7.Enabled = true;
                        button8.Enabled = false;
                    }
                }
                else
                {
                    button7.Enabled = true;
                    button8.Enabled = false;
                }
            }
        }

        private void button4_Click( object sender, EventArgs e )
        {
            // 清空文本的操作
            textBox8.Clear( );
        }
    }
}