1. Toy模板网首页
  2. > Toy博客

WPF真入门教程28--项目案例--MQTT服务器和客户端

7月前 作者：hqwest 分类：Toy博客 阅读(38) 违法举报

这篇具有很好参考价值的文章主要介绍了WPF真入门教程28--项目案例--MQTT服务器和客户端。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

1、先上图看帅照

这个案例还是布局加视图模型，样式应用，业务逻辑，该项目是一个mqtt服务器和客户端的通信工具，这里不去分析mqtt的通信原理，关注在于wpf技能的应用，能够掌握这个例子，离项目开发也差不多了，只是没有跟db打交道，本项目重点在于理解mvvm模式，开发环境依然是vs2022，.netframework 4.8，wpf应用程序。

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel 

默认启动的效果

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel 

最大化的效果，控件没有变形没有走样，说明wpf的技术还是不错的，界面没有变形，不象winform，控件会走样。

2、服务器这么搞

1、创建项目

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel 

2、添加包组件MQTTNET  

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

3、创建相关的目录及文件  

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

4、设置UI布局界面  

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

完全代码：

<Window x:Class="MQTTNETServerWPF.MainWindow"
        xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
        xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
        xmlns:d="http://schemas.microsoft.com/expression/blend/2008"
        xmlns:mc="http://schemas.openxmlformats.org/markup-compatibility/2006"
        xmlns:local="clr-namespace:MQTTNETServerWPF.ViewModel"
        mc:Ignorable="d" Background="Transparent" WindowStartupLocation="CenterScreen"
        FontSize="13" FontFamily="Microsoft YaHei" FontWeight="ExtraLight" Foreground="#333"
        Title="MainWindow" Height="550" Width="890">
    <WindowChrome.WindowChrome>
        <WindowChrome GlassFrameThickness="-1"/>
    </WindowChrome.WindowChrome>
    <Window.DataContext>
        <local:MainWindowViewModel/>
    </Window.DataContext>
    <Grid ShowGridLines="true"  >
        <Grid.RowDefinitions>
            <RowDefinition Height="70"/>
            <RowDefinition/>
        </Grid.RowDefinitions>
        <TextBlock Grid.Row="0" FontWeight="Bold" Background="BlanchedAlmond"  Text="WPF版MQTT服务器程序" FontSize="25" VerticalAlignment="Center" Margin="6,20,0,0" Foreground="#666"   />
        <Grid Grid.Row="1">
            <Grid.ColumnDefinitions>
                <ColumnDefinition Width="220"/>
                <ColumnDefinition/>
            </Grid.ColumnDefinitions>
            <Border BorderBrush="#EEE" BorderThickness="0,0,1,0"/>

            <!--左侧布局-->
            <StackPanel Grid.Column="0" Margin="20" >
                <TextBlock Text="主机地址"/>
                <TextBox Text="{Binding Server.ServerIP}" Height="30" VerticalContentAlignment="Center" Padding="5,0" Margin="0,10"  />
                <TextBlock Text="端口号" Margin="0,10,0,0"/>
                <TextBox Text="{Binding Server.ServerPort}" Height="30" VerticalContentAlignment="Center" Padding="5,0" Margin="0,10"  />
                <TextBlock Text="连接账号" Margin="0,10,0,0"/>
                <TextBox Text="{Binding Server.ServerName}"  Height="30" VerticalContentAlignment="Center" Padding="5,0" Margin="0,10"    />
                <TextBlock Text="连接密码" Margin="0,10,0,0"/>
                <TextBox Text="{Binding Server.ServerPwd}" Height="30" VerticalContentAlignment="Center" Padding="5,0" Margin="0,10"  />
                <Button Content="启动服务" Margin="0,30,0,0" Height="30"  Command="{Binding StartCommand}" Style="{StaticResource ButtonStyle}" />
                <Button Content="停止服务" Margin="0,10" Height="30"  Command="{Binding StopCommand}"  Style="{StaticResource ButtonStyle}"/>
            </StackPanel>

            <!--右侧布局-->
            <Grid Grid.Column="1">
                <Grid.RowDefinitions>
                    <RowDefinition Height="2*"/>
                    <RowDefinition Height="3*"/>
                </Grid.RowDefinitions>
                <Grid.ColumnDefinitions>
                    <ColumnDefinition/>
                    <ColumnDefinition/>
                </Grid.ColumnDefinitions>
                <GridSplitter VerticalAlignment="Bottom" HorizontalAlignment="Stretch" Height="4" Background="#F7F9FA" Grid.ColumnSpan="2" Margin="0,0,3,0"/>

                <Grid Margin="20,20,10,15">
                    <Grid.RowDefinitions>
                        <RowDefinition Height="30"/>
                        <RowDefinition/>
                    </Grid.RowDefinitions>
                    <TextBlock Text="在线Client列表"/>
                    <ListBox Grid.Row="1"   ItemsSource="{Binding ClientsList}"/>
                </Grid>

                <Grid Margin="10,20,20,15" Grid.Column="1">
                    <Grid.RowDefinitions>
                        <RowDefinition Height="30"/>
                        <RowDefinition/>
                    </Grid.RowDefinitions>
                    <TextBlock Text="Topic主题列表"/>
                    <ListView Grid.Row="1"   ItemsSource="{Binding TopicsList}">
                    </ListView>
                </Grid>

                <Grid Grid.Row="1" Grid.ColumnSpan="2" Margin="20,10,20,20">
                    <Grid.RowDefinitions>
                        <RowDefinition Height="30"/>
                        <RowDefinition/>
                    </Grid.RowDefinitions>
                    <TextBlock Text="消息"/>
                    <TextBox  Grid.Row="1"   x:Name="txtRich" ToolTip="右键清理内容" Text="{Binding ConnectWords}" Height="200" Background="White" VerticalContentAlignment="Top" Padding="3,0" Margin="10,9,10,10"    >
                        <!--添加一个右键菜单的功能，即清空-->
                        <TextBox.ContextMenu>
                            <ContextMenu>
                                <MenuItem x:Name="menuClear" Click="miClear_Click"  Header="清空内容"></MenuItem>
                            </ContextMenu>
                        </TextBox.ContextMenu>
                    </TextBox>
                </Grid>
            </Grid>
        </Grid>
    </Grid>
</Window>

 5、视图模型，属性绑定和命令绑定

using MQTTnet.Client.Receiving;
using MQTTnet;
using MQTTnet.Server;
using MQTTNETServerWPF.Command;
using MQTTNETServerWPF.Model;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Input;
using System.Collections.ObjectModel;
using MQTTnet.Certificates;
using MQTTnet.Protocol;
using System.Runtime.Remoting.Messaging;

namespace MQTTNETServerWPF.ViewModel
{
    public class MainWindowViewModel : ViewModelBase
    {
       
        private IMqttServer mqttserver;//mqtt服务器
        List<TopicItem> Topics = new List<TopicItem>();

        public MainWindowViewModel()
        {
            //创建服务器对象
            mqttserver = new MqttFactory().CreateMqttServer();
            mqttserver.ApplicationMessageReceivedHandler =
                new MqttApplicationMessageReceivedHandlerDelegate(new Action<MqttApplicationMessageReceivedEventArgs>(Server_ApplicationMessageReceived));//绑定消息接收事件
            mqttserver.ClientConnectedHandler =
                new MqttServerClientConnectedHandlerDelegate(new Action<MqttServerClientConnectedEventArgs>(Server_ClientConnected));//绑定客户端连接事件
            mqttserver.ClientDisconnectedHandler = new MqttServerClientDisconnectedHandlerDelegate(new Action<MqttServerClientDisconnectedEventArgs>(Server_ClientDisconnected));//绑定客户端断开事件
            mqttserver.ClientSubscribedTopicHandler = new MqttServerClientSubscribedHandlerDelegate(new Action<MqttServerClientSubscribedTopicEventArgs>(Server_ClientSubscribedTopic));//绑定客户端订阅主题事件
            mqttserver.ClientUnsubscribedTopicHandler = new MqttServerClientUnsubscribedTopicHandlerDelegate(new Action<MqttServerClientUnsubscribedTopicEventArgs>(Server_ClientUnsubscribedTopic));//绑定客户端退订主题事件
            mqttserver.StartedHandler = new MqttServerStartedHandlerDelegate(new Action<EventArgs>(Server_Started));//绑定服务端启动事件
            mqttserver.StoppedHandler = new MqttServerStoppedHandlerDelegate(new Action<EventArgs>(Server_Stopped));//绑定服务端停止事件
        }

        #region 方法

        /// 绑定消息接收事件
        /// </summary>
        /// <param name="e"></param>
        private void Server_ApplicationMessageReceived(MqttApplicationMessageReceivedEventArgs e)
        {
            string msg = e.ApplicationMessage.ConvertPayloadToString();
            WriteLog(">>> 收到消息：" + msg + "，QoS =" + e.ApplicationMessage.QualityOfServiceLevel + "，客户端=" + e.ClientId + "，主题：" + e.ApplicationMessage.Topic);
        }

        /// <summary>
        /// 绑定客户端连接事件
        /// </summary>
        /// <param name="e"></param>
        private void Server_ClientConnected(MqttServerClientConnectedEventArgs e)
        {
            Task.Run(() =>
            {
                App.Current.Dispatcher.Invoke(() =>
                {
                    this.ClientsList.Add(e.ClientId);
                });
                WriteLog(">>> 客户端" + e.ClientId + "连接");
            });
        }

        /// <summary>
        /// 绑定客户端断开事件
        /// </summary>
        /// <param name="e"></param>
        private void Server_ClientDisconnected(MqttServerClientDisconnectedEventArgs e)
        {
            Task.Run(() =>
            {
                App.Current.Dispatcher.Invoke(() =>
                {
                    this.ClientsList.Remove(e.ClientId);
                });
                WriteLog(">>> 客户端" + e.ClientId + "断开");
            });
        }

        /// <summary>
        /// 绑定客户端订阅主题事件
        /// </summary>
        /// <param name="e"></param>
        private void Server_ClientSubscribedTopic(MqttServerClientSubscribedTopicEventArgs e)
        {
            Task.Run(() =>
            {
                App.Current.Dispatcher.Invoke(() =>
                {
                    var topic = Topics.FirstOrDefault(t => t.Topic == e.TopicFilter.Topic);
                    if (topic == null)
                    {
                        topic = new TopicItem { Topic = e.TopicFilter.Topic, Count = 0 };
                        Topics.Add(topic);
                    }
                    if (!topic.Clients.Exists(c => c == e.ClientId))
                    {
                        topic.Clients.Add(e.ClientId);
                        topic.Count++;
                    }

                    this.TopicsList.Clear();
                    foreach (var item in this.Topics)
                    {
                        this.TopicsList.Add($"{item.Topic}:{item.Count}");
                    }
                });
                WriteLog(">>> 客户端" + e.ClientId + "订阅主题" + e.TopicFilter.Topic);
            });
        }

        /// <summary>
        /// 绑定客户端退订主题事件
        /// </summary>
        /// <param name="e"></param>
        private void Server_ClientUnsubscribedTopic(MqttServerClientUnsubscribedTopicEventArgs e)
        {
            Task.Run(() =>
            {
                App.Current.Dispatcher.Invoke(() =>
                {
                    var topic = Topics.FirstOrDefault(t => t.Topic == e.TopicFilter);
                    if (topic != null)
                    {
                        topic.Count--;
                        topic.Clients.Remove(e.ClientId);
                    }

                    this.TopicsList.Clear();
                    foreach (var item in this.Topics)
                    {
                        this.TopicsList.Add($"{item.Topic}:{item.Count}");
                    }
                });
                WriteLog(">>> 客户端" + e.ClientId + "退订主题" + e.TopicFilter);
            });
        }

        /// <summary>
        /// 绑定服务端启动事件
        /// </summary>
        /// <param name="e"></param>
        private void Server_Started(EventArgs e)
        {
            WriteLog(">>> 服务端已启动！");
        }

        /// <summary>
        /// 绑定服务端停止事件
        /// </summary>
        /// <param name="e"></param>
        private void Server_Stopped(EventArgs e)
        {
            WriteLog(">>> 服务端已停止！");
        }

        /// <summary>
        /// 显示日志
        /// </summary>
        /// <param name="message"></param>
        public void WriteLog(string message)
        {
            Task.Run(() =>
            {
                App.Current.Dispatcher.Invoke(() =>
                {
                    ConnectWords = message + "\r";
                });
            });
        }

        #endregion



        #region 属性
        private MqttServerModel server = new MqttServerModel("127.0.0.1", "1869", "boss", "1234");//服务器实体
        /// <summary>
        /// 当前服务器对象
        /// </summary>
        public MqttServerModel Server
        {
            get { return server; }
            set
            {
                server = value;
                OnPropertyChanged();
            }
        }

        private string connectWords = "";
        /// <summary>
        /// 连接状态
        /// </summary>
        public string ConnectWords
        {
            get { return connectWords; }
            set
            {
                connectWords = value;
                OnPropertyChanged();
            }
        }

        private ObservableCollection<string> clientsList = new ObservableCollection<string>();
        /// <summary>
        /// 客户列表
        /// </summary>
        public ObservableCollection<string> ClientsList
        {
            get { return clientsList; }
            set
            {
                clientsList = value;
                OnPropertyChanged();
            }
        }

        private ObservableCollection<string> topicsList = new ObservableCollection<string>();
        /// <summary>
        /// 主题列表
        /// </summary>
        public ObservableCollection<string> TopicsList
        {
            get { return topicsList; }
            set
            {
                topicsList = value;
                OnPropertyChanged();
            }
        }
        #endregion




        #region 命令
        /// <summary>
        /// 启动命令
        /// </summary>
        [Obsolete]
        public ICommand StartCommand
        {
            get
            {
                return new RelayCommand(async o =>
                {
                    var optionBuilder = new MqttServerOptionsBuilder()
                .WithDefaultEndpointBoundIPAddress(System.Net.IPAddress.Parse(Server.ServerIP))
                .WithDefaultEndpointPort(int.Parse(Server.ServerPort))
                .WithDefaultCommunicationTimeout(TimeSpan.FromMilliseconds(5000))
                .WithConnectionValidator(t =>
                {
                    string un = "", pwd = "";
                    un = Server.ServerName;
                    pwd = Server.ServerPwd;
                    if (t.Username != un || t.Password != pwd)
                    {
                        t.ReturnCode = MqttConnectReturnCode.ConnectionRefusedBadUsernameOrPassword;
                    }
                    else
                    {
                        t.ReturnCode = MqttConnectReturnCode.ConnectionAccepted;
                    }
                });
                    var option = optionBuilder.Build();
                    //启动
                    await mqttserver.StartAsync(option);
                }
                );
            }
        }

        /// <summary>
        /// 启动命令
        /// </summary>
        [Obsolete]
        public ICommand StopCommand
        {
            get
            {
                return new RelayCommand(async o =>
                { 
                    if (server != null)
                    {
                        await mqttserver.StopAsync();
                    } 
                });
            }
        }
        #endregion

    }
}
1）属性绑定

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

2）视图绑定

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel 

 3）命令绑定

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

4）样式应用

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel 

 6、启动看效果

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

3、客户端跟着搞

1、添加项目MQTTNETClientWPF

2、添加客户端的组件

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

3、创建相关的类文件及目录  

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

4、设计UI布局 

完整代码 ：

<Window x:Class="MQTTNETClientWPF.MainWindow"
        xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
        xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
        xmlns:d="http://schemas.microsoft.com/expression/blend/2008"
        xmlns:mc="http://schemas.openxmlformats.org/markup-compatibility/2006"
        xmlns:local="clr-namespace:MQTTNETClientWPF.ViewModel"
              mc:Ignorable="d" Background="Transparent" WindowStartupLocation="CenterScreen"
        FontSize="13" FontFamily="Microsoft YaHei" FontWeight="ExtraLight" Foreground="#333"
        Title="MainWindow" Height="600" Width="850">
    <WindowChrome.WindowChrome>
        <WindowChrome GlassFrameThickness="-1"/>
    </WindowChrome.WindowChrome>
    <Window.DataContext>
        <local:MainWindowViewModel/>
    </Window.DataContext>
    <Grid  ShowGridLines="true" >
        <Grid.RowDefinitions>
            <RowDefinition Height="70"/>
            <RowDefinition/>
        </Grid.RowDefinitions>
        <TextBlock Grid.Row="0" FontWeight="Bold"  Text="WPF版MQTT客户端程序" FontSize="25" VerticalAlignment="Center" Margin="6,20,0,0" Foreground="#666" Background="BlanchedAlmond"  />

        <Grid Grid.Row="1">
            <Grid.ColumnDefinitions>
                <ColumnDefinition Width="220"/>
                <ColumnDefinition/>
            </Grid.ColumnDefinitions>
            <Border BorderBrush="#EEE" BorderThickness="0,0,1,0"/>

            <StackPanel Margin="20">
                <TextBlock Text="主机地址"/>
                <TextBox Text="{Binding Client.ServerIP}" Height="30" VerticalContentAlignment="Center" Padding="5,0" Margin="0,10" Name="tbHostAddr"/>
                <TextBlock Text="端口号" Margin="0,5,0,0"/>
                <TextBox  Text="{Binding Client.ServerPort}" Height="30" VerticalContentAlignment="Center" Padding="5,0" Margin="0,10"   Name="tbHostPort"/>
                <TextBlock Text="连接账号" Margin="0,5,0,0"/>
                <TextBox  Text="{Binding Client.ServerName}" Height="30" VerticalContentAlignment="Center" Padding="5,0" Margin="0,10" Name="tbUsername"/>
                <TextBlock Text="连接密码" Margin="0,5,0,0"/>
                <TextBox Text="{Binding Client.ServerPwd}" Height="30" VerticalContentAlignment="Center" Padding="5,0" Margin="0,10"  Name="tbPassword"/>
                <TextBlock Text="客户端ID" Margin="0,5,0,0"/>
                <TextBox Text="{Binding Client.ClientId}" Height="30" VerticalContentAlignment="Center" Padding="5,0" Margin="0,10"   Name="tbClientId"/>
                <Button Content="连接" Margin="0,30,0,0" Height="30" Command="{Binding OpenCommand}"  Style="{StaticResource ButtonStyle}"/>
                <Button Content="断开" Margin="0,10" Height="30"  Command="{Binding CloseCommand}" Style="{StaticResource ButtonStyle}"/>
            </StackPanel>

            <Grid Grid.Column="1" Margin="20,10">
                <Grid.RowDefinitions>
                    <RowDefinition Height="auto"/>
                    <RowDefinition Height="auto"/>
                    <RowDefinition/>
                </Grid.RowDefinitions>

                <Grid>
                    <Grid.RowDefinitions>
                        <RowDefinition Height="30"/>
                        <RowDefinition Height="50"/>
                    </Grid.RowDefinitions>
                    <Grid.ColumnDefinitions>
                        <ColumnDefinition Width="auto"/>
                        <ColumnDefinition/>
                        <ColumnDefinition Width="auto"/>
                    </Grid.ColumnDefinitions>
                    <Border Background="#F7F9FA" Grid.ColumnSpan="3"/>
                    <TextBlock Text="订阅" VerticalAlignment="Center" Margin="5,0"/>
                    <TextBlock Text="主题" Grid.Row="1" VerticalAlignment="Center" HorizontalAlignment="Center" Margin="5,0"/>
                    <TextBox Text="{Binding Topic}" Grid.Row="1" Height="30" Padding="5,0" VerticalContentAlignment="Center" Grid.Column="1"  Name="tbTopic"/>
                    <Button Width="50" Grid.Row="1" Height="30" Content="订阅" Grid.Column="2" Margin="5,10,0,10"   Command="{Binding SubscriteCommand}"  Style="{StaticResource ButtonStyle}"  HorizontalAlignment="Left"/>
                </Grid>

                <Grid Grid.Row="1" Margin="0,20">
                    <Grid.RowDefinitions>
                        <RowDefinition Height="30"/>
                        <RowDefinition Height="50"/>
                        <RowDefinition Height="30"/>
                        <RowDefinition/>
                    </Grid.RowDefinitions>
                    <Grid.ColumnDefinitions>
                        <ColumnDefinition Width="auto"/>
                        <ColumnDefinition/>
                        <ColumnDefinition Width="auto"/>
                    </Grid.ColumnDefinitions>
                    <Border Background="#F7F9FA" Grid.ColumnSpan="3"/>
                    <TextBlock Text="发布" VerticalAlignment="Center" Margin="5,0"/>
                    <TextBlock Text="主题" Grid.Row="1" VerticalAlignment="Center" HorizontalAlignment="Center" Margin="5,0"/>
                    <TextBox Text="{Binding Topic}" Grid.Row="1" Height="30" Padding="5,0" VerticalContentAlignment="Center" Grid.Column="1"   Name="tbPubTopic"/>
                    <TextBlock Text="内容" Grid.Row="2" VerticalAlignment="Center" HorizontalAlignment="Center" Margin="5,0"/>
                    <TextBox Text="{Binding Pubmsg}"  Grid.Row="2" Height="30" Padding="5,0" VerticalContentAlignment="Center" Grid.Column="1"  Name="tbContent"/>
                    <Button Width="50" Grid.Row="2" Height="30"  Content="发布" Grid.Column="2" Margin="5,0,5,0"  Command="{Binding PublishCommand}"  Style="{StaticResource ButtonStyle}"  VerticalAlignment="Top"/>
                </Grid>

                <Grid Grid.Row="2" Margin="0,10,0,0">
                    <Grid.RowDefinitions>
                        <RowDefinition Height="30"/>
                        <RowDefinition/>
                    </Grid.RowDefinitions>
                    <Border Background="#F7F9FA" Grid.ColumnSpan="3"/>
                    <TextBlock Text="消息" VerticalAlignment="Center" Margin="5,0"/>
                    <TextBox  Grid.Row="1"  x:Name="txtRich" ToolTip="右键清理内容" Text="{Binding ConnectWords}" Height="200"  Background="White" VerticalContentAlignment="Top"  Padding="3,0" Margin="10,9,75,10"  >
                        <!--添加一个右键菜单的功能，即清空-->
                        <TextBox.ContextMenu>
                            <ContextMenu>
                                <MenuItem x:Name="menuClear" Click="miClear_Click"  Header="清空内容"></MenuItem>
                            </ContextMenu>
                        </TextBox.ContextMenu>
                    </TextBox>
                </Grid>
            </Grid>
        </Grid>
    </Grid>
</Window>

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

 5、视图模型viewmodel

using MQTTnet.Client.Options;
using MQTTnet.Client;
using MQTTnet.Extensions.ManagedClient;
using MQTTNETClientWPF.Command;
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Input;
using MQTTNETClientWPF.Model;
using MQTTnet;

namespace MQTTNETClientWPF.ViewModel
{
    public class MainWindowViewModel : ViewModelBase
    {
        private IManagedMqttClient mqttClient; //mqtt客户端


        public MainWindowViewModel()
        {
            var factory = new MqttFactory();
            mqttClient = factory.CreateManagedMqttClient();//创建客户端对象

            //绑定断开事件
            mqttClient.UseDisconnectedHandler(async ee =>
            {
                WriteLog(DateTime.Now.ToString() + "与服务器之间的连接断开了，正在尝试重新连接");
                // 等待 5s 时间
                await Task.Delay(TimeSpan.FromSeconds(5));
                try
                {
                    mqttClient.UseConnectedHandler(cc =>
                    {
                        WriteLog(">>> 连接到服务成功！");
                    });
                }
                catch (Exception ex)
                {
                    Console.WriteLine($"重新连接服务器失败:{ex}");
                }
            });

            //绑定接收事件
            mqttClient.UseApplicationMessageReceivedHandler(aa =>
            {
                 try
                {
                    string msg = aa.ApplicationMessage.ConvertPayloadToString();
                    WriteLog(">>> 消息：" + msg + "，QoS =" + aa.ApplicationMessage.QualityOfServiceLevel + "，客户端=" + aa.ClientId + "，主题：" + aa.ApplicationMessage.Topic);
                }
                catch (Exception ex)
                {
                    WriteLog($"+ 消息 = " + ex.Message);
                } 
            });

            //绑定连接事件
            mqttClient.UseConnectedHandler(ee =>
            {
                WriteLog(">>> 连接到服务器成功");
            });
        }

        /// <summary>
        /// 显示日志
        /// </summary>
        /// <param name="message"></param> 
        public void WriteLog(string message)
        {
            Task.Run(() =>
            {
                App.Current.Dispatcher.Invoke(() =>
                {
                    ConnectWords = message + "\r";
                });
            });
        }

        #region 属性

        private MqttClientModel client = new MqttClientModel("127.0.0.1", "1869", "boss", "1234", "c1");//服务器实体

        /// <summary>
        /// 连接对象
        /// </summary>
        public MqttClientModel Client
        {
            get { return client; }
            set
            {
                client = value;
                OnPropertyChanged();
            }
        }

        private string connectWords = "";
        /// <summary>
        /// 连接状态
        /// </summary>
        public string ConnectWords
        {
            get { return connectWords; }
            set
            {
                connectWords = value;
                OnPropertyChanged();
            }
        }

        private string topic = "shanghai";
        /// <summary>
        /// 主题
        /// </summary>
        public string Topic
        {
            get { return topic; }
            set
            {
                topic = value;
                OnPropertyChanged();
            }
        }

        private string pubmsg = "0103";
        /// <summary>
        /// 发布
        /// </summary>
        public string Pubmsg
        {
            get { return pubmsg; }
            set
            {
                pubmsg = value;
                OnPropertyChanged();
            }
        }
        #endregion


        #region 命令
        /// <summary>
        /// 连接命令
        /// </summary> 
        public ICommand OpenCommand
        {
            get
            {
                return new RelayCommand(async o =>
                {
                    var mqttClientOptions = new MqttClientOptionsBuilder()
                             .WithClientId(this.Client.ClientId)
                             .WithTcpServer(this.Client.ServerIP, int.Parse(this.Client.ServerPort))
                             .WithCredentials(this.Client.ServerName, this.Client.ServerPwd);

                    var options = new ManagedMqttClientOptionsBuilder()
                                .WithAutoReconnectDelay(TimeSpan.FromSeconds(5))
                                .WithClientOptions(mqttClientOptions.Build())
                                .Build();
                    //开启
                    var t = mqttClientOptions;
                    await mqttClient.StartAsync(options);
                });
            }
        }

        /// <summary>
        /// 断开命令
        /// </summary> 
        public ICommand CloseCommand
        {
            get
            {
                return new RelayCommand(async o =>
                {
                    if (mqttClient != null)
                    {
                        if (mqttClient.IsStarted)
                        {
                            await mqttClient.StopAsync();
                        }
                        mqttClient.Dispose();
                    }
                });
            }
        }

        /// <summary>
        /// 订阅命令
        /// </summary> 
        [Obsolete]
        public ICommand SubscriteCommand
        {
            get
            {
                return new RelayCommand(async o =>
                {
                    if (string.IsNullOrWhiteSpace(this.Topic))
                    {
                        WriteLog(">>> 请输入主题");
                        return;
                    }

                    //在 MQTT 中有三种 QoS 级别： 
                    //At most once(0) 最多一次
                    //At least once(1) 至少一次
                    //Exactly once(2) 恰好一次
                    //await mqttClient.SubscribeAsync(new TopicFilterBuilder().WithTopic(this.tbTopic.Text).WithAtMostOnceQoS().Build());//最多一次， QoS 级别0
                    await mqttClient.SubscribeAsync(new TopicFilterBuilder().WithTopic(this.Topic).WithAtLeastOnceQoS().Build());//恰好一次， QoS 级别1 

                    WriteLog($">>> 成功订阅 {this.Topic}");
                });
            }
        }

        /// <summary>
        /// 发布命令
        /// </summary> 
        public ICommand PublishCommand
        {
            get
            {
                return new RelayCommand(async o =>
                {
                    if (string.IsNullOrWhiteSpace(this.Topic))
                    {
                        WriteLog(">>> 请输入主题");
                        return;
                    }
                    var result = await mqttClient.PublishAsync(
                        this.Topic,
                        this.Pubmsg,
                        MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce);//恰好一次， QoS 级别1 
                    WriteLog($">>> 主题：{this.Topic}，消息：{this.Pubmsg}，结果： {result.ReasonCode}");
                });
            }
        }

        #endregion

    }
}
1）属性绑定
2）视图绑定
3）命令绑定
4）样式应用

6、启动客户端

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

4、测试效果

 WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

 最大化效果

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

5、完整代码打包

链接：https://pan.baidu.com/s/1sfQnGEEcsRTBKUSDOdCeTA 
提取码：z2hj 
--来自百度网盘超级会员V9的分享

 分享不易，讲解不易，思路不易，原创不易，整理不易，伙伴们动动你的金手指，你的支持是我最大的动力。

WPF真入门教程28--项目案例--MQTT服务器和客户端,WPF真入门教程,wpf,wpf案例,WPF布局,wpf ui,C#,.NET,viewmodel

 文章来源地址https://www.toymoban.com/news/detail-798172.html

到了这里，关于WPF真入门教程28--项目案例--MQTT服务器和客户端的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处： 如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：
领支付宝红包 赞助服务器费用

相关文章

  • WPF真入门教程01--WPF简介

            Windows Presentation Foundation (简称 WPF)，WPF是微软推出的基于Windows 的用户界面框架，属于.NET Framework 3.0的一部分。它提供了统一的编程模型、语言和框架，真正做到了分离界面设计人员与开发人员的工作；同时它提供了全新的多媒体交互用户图形界面。因与“我佩服”拼

    2024年02月06日
    浏览(39)
  • WPF真入门教程02--新建WPF工程

    WPF真入门教程02--新建WPF工程

    在VS开发环境安装完成之后，首先我们先新建一个WPF工程，然后对工程目录结构啥的要有所了解才行。 打开VS2019      工程建好之后，WPF应用程序”会在“引用”里面自动添加下图中所示的 PresentationCore、PresentationFramework、WindowsBase三大核心程序集，就是下面这个样子   默认

    2024年02月03日
    浏览(49)

  • Gradio入门到进阶全网最详细教程[一]：快速搭建AI算法可视化部署演示(侧重项目搭建和案例分享)

    常用的两款AI可视化交互应用比较： Gradio Gradio的优势在于易用性，代码结构相比Streamlit简单，只需简单定义输入和输出接口即可快速构建简单的交互页面，更轻松部署模型。适合场景相对简单，想要快速部署应用的开发者。便于分享：gradio可以在启动应用时设置share=True参数

    2023年04月25日
    浏览(31)
  • WPF 入门教程DockPanel介绍

    WPF 入门教程DockPanel介绍

    在 DockPanel中 可以很容易地停靠在所有四个方向的内容（上，下，左，右）。这使它在许多情况下成为一个很好的选择，您希望将窗口划分为特定区域，特别是因为默认情况下，DockPanel 内的最后一个元素，除非此功能被明确禁用，否则将自动填充其余空间（中心）。 我们在

    2024年02月05日
    浏览(28)
  • WPF入门教程系列一——基础

    WPF入门教程系列一——基础

    一、 前言            最近在学习WPF，学习WPF首先上的是微软的MSDN，然后再搜索了一下网络有关WPF的学习资料。为了温故而知新把学习过程记录下来，以备后查。这篇主要讲WPF的开发基础，介绍了如何使用Visual Studio 2013创建一个WPF应用程序。 首先说一下学习WPF的基础知

    2024年02月07日
    浏览(35)

  • WPF教程_编程入门自学教程_菜鸟教程-免费教程分享

    WPF教程 WPF - 概述 WPF - 环境设置 WPF - Hello World WPF - XAML概述 WPF - Elements Tree WPF - 依赖属性 WPF - 路由事件 WPF - 控件 WPF - 布局 WPF - 布局嵌套 WPF - 输入 WPF - 命令行 WPF - 数据绑定 WPF - 资源 WPF - 模板 WPF - 样式 WPF - 触发器 WPF - 调试 WPF - 自定义控件 WPF - 异常处理 WPF - 本地化 WPF - 互

    2023年04月27日
    浏览(33)
  • WPF真入门教程12--ListView控件

    WPF真入门教程12--ListView控件

           ListView 控件在Windows应用程序中常用，用于表示数据列表。如果您以前使用过 WinForms，那么您对ListView的实用性有一个很好的了解，但您应该意识到 WPF中的ListView 不像WinForms版本那样使用。再一次的主要区别在于，虽然WinForms ListView只是调用Windows API 函数来呈现常见的

    2024年02月04日
    浏览(33)
  • WPF 入门教程Grid使用技巧

    WPF 入门教程Grid使用技巧

    在上一章中，我们向您介绍了出色的 Grid 面板，并向您展示了一些有关如何使用它的基本示例。在本章中，我们将进行一些更高级的布局，因为这是 Grid 真正闪耀的地方。首先，让我们加入更多的列甚至一些行，以获得真正的表格布局： 总共九个按钮，每个按钮都放置在自己

    2024年02月06日
    浏览(33)
  • WPF 入门教程DispatcherTimer计时器

    WPF 入门教程DispatcherTimer计时器

    https://www.zhihu.com/tardis/bd/art/430630047?source_id=1001 在 WinForms 中，有一个名为 Timer 的控件，它可以在给定的时间间隔内重复执行一个操作。WPF 也有这种可能性，但我们有 DispatcherTimer 控件，而不是不可见的控件。它几乎做同样的事情，但不是将它放在表单上，​​而是专门从代码

    2024年01月22日
    浏览(29)
  • WPF真入门教程23--MVVM简单介绍

    WPF真入门教程23--MVVM简单介绍

            在WPF开发中，经典的编程模式是MVVM，是为WPF量身定做的模式，该模式充分利用了WPF的数据绑定机制，最大限度地降低了Xmal文件和CS文件的耦合度，也就是UI显示和逻辑代码的耦合度，如需要更换界面时，逻辑代码修改很少，甚至不用修改。与WinForm开发相比，我们一般

    2024年02月03日
    浏览(28)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包，优惠每天领

二维码1

领取红包

二维码2

领红包