using CommunityToolkit.Mvvm.ComponentModel;
|
using System.Collections.ObjectModel;
|
using System.Globalization;
|
using System.Text;
|
using System.Text.RegularExpressions;
|
using System.Windows;
|
using System.Windows.Controls;
|
using System.Windows.Data;
|
using System.Windows.Documents;
|
using System.Windows.Media;
|
using TouchSocket.Core;
|
using TouchSocket.Sockets;
|
using UtilLib;
|
|
namespace Plugin.UICollection
|
{
|
public enum DataType
|
{
|
String = 0,
|
HEX = 1
|
}
|
|
public enum SupportEncode
|
{
|
GBK = 0,
|
ASCII = 1,
|
UTF8 = 2
|
}
|
|
public class EndMarkSource
|
{
|
public string Name { get; set; }
|
public int Type { get; set; }
|
}
|
|
public class ByteStringConverter : IValueConverter
|
{
|
private TcpDebugger control { get; set; }
|
|
public ByteStringConverter(TcpDebugger control)
|
{
|
this.control = control;
|
}
|
|
public static string GroupByTwo(string str)
|
{
|
if (string.IsNullOrEmpty(str))
|
return string.Empty;
|
|
StringBuilder result = new StringBuilder();
|
for (int i = 0; i < str.Length; i += 2)
|
{
|
if (i > 0)
|
result.Append(' ');
|
|
int length = Math.Min(2, str.Length - i);
|
result.Append(str.Substring(i, length));
|
}
|
return result.ToString();
|
}
|
|
public object Convert(object value, Type targetType, object parameter, CultureInfo culture)
|
{
|
DataType sendType = control.SendDataType;
|
if (sendType != DataType.HEX)
|
{
|
return value;
|
}
|
var str = value.ToString();
|
return GroupByTwo(str);
|
}
|
|
public object ConvertBack(object value, Type targetType, object parameter, CultureInfo culture)
|
{
|
DataType sendType = control.SendDataType;
|
if (sendType != DataType.HEX)
|
{
|
return value;
|
}
|
return value.ToString().Replace(" ", "");
|
}
|
}
|
|
/// <summary>
|
/// TcpDebugger.xaml 的交互逻辑
|
/// </summary>
|
[ObservableObject]
|
public partial class TcpDebugger : UserControl
|
{
|
|
[ObservableProperty]
|
private string ip = "127.0.0.1";
|
|
[ObservableProperty]
|
private int port;
|
|
[ObservableProperty]
|
private int clientPort;
|
|
[ObservableProperty]
|
private DataType receiveDataType = DataType.String;
|
|
[ObservableProperty]
|
private DataType sendDataType = DataType.String;
|
|
[ObservableProperty]
|
private bool isConnected = false;
|
|
[ObservableProperty]
|
private string sendText;
|
|
[ObservableProperty]
|
private SupportEncode receiveEncode;
|
|
[ObservableProperty]
|
private SupportEncode sendEncode;
|
|
[ObservableProperty]
|
private ObservableCollection<EndMarkSource> endMarkSource = new ObservableCollection<EndMarkSource> {
|
new EndMarkSource{ Name="无",Type=-1},
|
new EndMarkSource{ Name="\\r",Type=0},
|
new EndMarkSource{ Name="\\r\\n",Type=1},
|
new EndMarkSource{ Name="自定义",Type=2},
|
};
|
|
[ObservableProperty]
|
private int endMark;
|
|
[ObservableProperty]
|
private string customEndMark;
|
|
private ByteStringConverter bsConverter;
|
|
|
private TcpClient client;
|
|
public TcpDebugger()
|
{
|
DataContext = this;
|
InitializeComponent();
|
sendEncodeInput.ItemsSource = Enum.GetValues(typeof(SupportEncode)).Cast<SupportEncode>();
|
receiveEncodeInput.ItemsSource = Enum.GetValues(typeof(SupportEncode)).Cast<SupportEncode>();
|
DataObject.AddPastingHandler(sendBox, OnPasting);
|
bsConverter = new ByteStringConverter(this);
|
BindingOperations.SetBinding(sendBox, TextBox.TextProperty, new Binding(nameof(SendText))
|
{
|
Source = this,
|
Mode = BindingMode.TwoWay,
|
UpdateSourceTrigger = UpdateSourceTrigger.PropertyChanged,
|
Converter = bsConverter
|
});
|
}
|
|
private void Button_Click(object sender, RoutedEventArgs e)
|
{
|
var btn = (Button)sender;
|
if (btn.Tag.ToString() == "Connect")
|
{
|
TryConnect();
|
return;
|
}
|
|
if (btn.Tag.ToString() == "Send")
|
{
|
TrySend();
|
return;
|
}
|
|
}
|
|
private void TryConnect()
|
{
|
try
|
{
|
if (IsConnected) return;
|
var config = new TouchSocketConfig().SetRemoteIPHost($"tcp://{Ip}:{Port}");
|
client = new TcpClient();
|
client.Received = TcpReceived;
|
client.Connected = (sender, e) =>
|
{
|
Dispatcher.Invoke(() =>
|
{
|
Add("连接", "连接成功", Brushes.Green);
|
IsConnected = true;
|
});
|
return EasyTask.CompletedTask;
|
};
|
client.Closed = (sender, e) =>
|
{
|
Dispatcher.Invoke(() =>
|
{
|
Add("连接", "连接断开", Brushes.Red);
|
IsConnected = false;
|
});
|
return EasyTask.CompletedTask;
|
};
|
client.SetupAsync(config);
|
client.ConnectAsync();
|
}
|
catch (Exception ex)
|
{
|
IsConnected = false;
|
// throw ex;
|
}
|
}
|
|
private Task TcpReceived(object sender, ReceivedDataEventArgs e)
|
{
|
try
|
{
|
var datas = e.Memory.Span.ToArray();
|
string msg = null;
|
if (ReceiveDataType == DataType.HEX)
|
{
|
msg = HexUtil.ByteArrayToHex(datas);
|
}
|
else
|
{
|
if (ReceiveEncode == SupportEncode.GBK)
|
{
|
msg = Encoding.Default.GetString(datas);
|
}
|
else if (ReceiveEncode == SupportEncode.ASCII)
|
{
|
msg = Encoding.ASCII.GetString(datas);
|
}
|
else
|
{
|
|
msg = Encoding.UTF8.GetString(datas);
|
}
|
}
|
Add("接收", msg, Brushes.Green);
|
}
|
catch (Exception ex)
|
{
|
//log.Error($"TcpReceived Error.", ex);
|
}
|
return EasyTask.CompletedTask;
|
}
|
|
private byte[] GetBytes(out string msg)
|
{
|
msg = null;
|
if (string.IsNullOrEmpty(SendText))
|
{
|
return null;
|
}
|
if (SendDataType == DataType.String)
|
{
|
msg = SendText + GetEndMark();
|
if (SendEncode == SupportEncode.GBK)
|
{
|
return Encoding.Default.GetBytes(msg);
|
}
|
if (SendEncode == SupportEncode.ASCII)
|
{
|
return Encoding.ASCII.GetBytes(msg);
|
}
|
if (SendEncode == SupportEncode.UTF8)
|
{
|
return Encoding.UTF8.GetBytes(msg);
|
}
|
return null;
|
}
|
msg = SendText;
|
if (msg.Length % 2 != 0)
|
{
|
msg = msg.Insert(msg.Length - 1, "0");
|
}
|
msg = ByteStringConverter.GroupByTwo(msg);
|
return HexUtil.HexToByteArray(msg);
|
}
|
|
private string GetEndMark()
|
{
|
if (EndMark == -1)
|
{
|
return string.Empty;
|
}
|
if (EndMark == 0)
|
{
|
return "\r";
|
}
|
if (EndMark == 1)
|
{
|
return "\r\n";
|
}
|
if (EndMark == 2)
|
{
|
return CustomEndMark;
|
}
|
return string.Empty;
|
}
|
|
public void TrySend()
|
{
|
if (!IsConnected)
|
{
|
MessageBox.Show("请先连接", "提示");
|
return;
|
}
|
var datas = GetBytes(out string msg);
|
if (datas != null)
|
{
|
client.SendAsync(datas).Wait();
|
Add("发送", msg, Brushes.Blue);
|
// SendText = string.Empty;
|
}
|
}
|
|
public void Add(string type, string text, Brush color)
|
{
|
Dispatcher.BeginInvoke(() =>
|
{
|
string time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
Run run = new Run();
|
run.Text = $"{time} {type}\r\n";
|
run.Foreground = Brushes.Gray;
|
|
Paragraph paragraph = new Paragraph(run)
|
{
|
LineHeight = 1
|
};
|
|
run = new Run();
|
run.Text = $"{text}\r\n";
|
run.Foreground = color;
|
paragraph.Inlines.Add(run);
|
//也可以插入到最后面
|
console.Document.Blocks.InsertAfter(console.Document.Blocks.LastBlock, paragraph);
|
|
//插入到最前面
|
//rtxtLog.Document.Blocks.Add(paragraph);
|
|
// 滚动至最后行
|
//rtxtLog.ScrollToEnd();
|
//Console.ScrollToHome();
|
console.ScrollToEnd();
|
// 删除
|
//if (Console.Document.Blocks.Count > 10000)
|
//{
|
// for (int i = 1000; i < Console.Document.Blocks.Count; i++)
|
// {
|
// _ = Console.Document.Blocks.Remove(Console.Document.Blocks.FirstBlock);
|
// }
|
//}
|
|
}, System.Windows.Threading.DispatcherPriority.Normal);
|
}
|
|
private static readonly Regex HexRegex = new Regex("^[0-9A-Fa-f]+$");
|
|
private void TextBox_PreviewTextInput(object sender, System.Windows.Input.TextCompositionEventArgs e)
|
{
|
if (SendDataType != DataType.HEX)
|
{
|
return;
|
}
|
var tb = (TextBox)sender;
|
string segment = e.Text;
|
|
if (!HexRegex.IsMatch(segment))
|
{
|
tb.Text = tb.Text.Replace(segment, "");
|
tb.CaretIndex = tb.Text.Length;
|
e.Handled = true;
|
return;
|
}
|
// tb.Text = tb.Text.ToUpper();
|
|
base.OnPreviewTextInput(e);
|
}
|
|
private void OnPasting(object sender, DataObjectPastingEventArgs e)
|
{
|
if (SendDataType != DataType.HEX)
|
{
|
return;
|
}
|
|
if (e.DataObject.GetDataPresent(typeof(string)))
|
{
|
string text = (string)e.DataObject.GetData(typeof(string));
|
text = text.Replace(" ", "");
|
if (!HexRegex.IsMatch(text))
|
{
|
e.CancelCommand();
|
}
|
}
|
}
|
}
|
}
|
