1、先上图看帅照
这个案例还是布局加视图模型,样式应用,业务逻辑,该项目是一个mqtt服务器和客户端的通信工具,这里不去分析mqtt的通信原理,关注在于wpf技能的应用,能够掌握这个例子,离项目开发也差不多了,只是没有跟db打交道,本项目重点在于理解mvvm模式,开发环境依然是vs2022,.netframework 4.8,wpf应用程序。
默认启动的效果
最大化的效果,控件没有变形没有走样,说明wpf的技术还是不错的,界面没有变形,不象winform,控件会走样。
2、服务器这么搞
1、创建项目
2、添加包组件MQTTNET
3、创建相关的目录及文件
4、设置UI布局界面
完全代码:
<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)属性绑定
2)视图绑定
3)命令绑定
4)样式应用
6、启动看效果
3、客户端跟着搞
1、添加项目MQTTNETClientWPF
2、添加客户端的组件
3、创建相关的类文件及目录
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>
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、启动客户端
4、测试效果
最大化效果
5、完整代码打包
链接:https://pan.baidu.com/s/1sfQnGEEcsRTBKUSDOdCeTA
提取码:z2hj
--来自百度网盘超级会员V9的分享
分享不易,讲解不易,思路不易,原创不易,整理不易,伙伴们动动你的金手指,你的支持是我最大的动力。
文章来源:https://www.toymoban.com/news/detail-798172.html
文章来源地址https://www.toymoban.com/news/detail-798172.html
到了这里,关于WPF真入门教程28--项目案例--MQTT服务器和客户端的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!