Podczas pisania aplikacji w C# mającej za zadanie wysyłać/odbierać dane (tekst, pliki) poprzez port COM natknąłem się na pewną przeszkodę, mianowicie nie wiem jak rozwiązać kwestię nasłuchiwania na porcie i automatycznego wypisania odebranych danych na elemencie WPF (TextView). Chodzi tu o stworzenie swego rodzaju chatu przy użyciu transmisji szeregowej. Wydaje mi się, że problemem jest fakt, iż nie można odwołać się do wątku głównego (z UI) z poziomu innego wątku. Znalazłem kilka rozwiązań, m.in. wykorzystanie BackgroundWorker'a czy też Dispatcher.BeginInvoke, aczkolwiek nie potrafię poradzić sobie z ich poprawnym użyciem. Poniżej wklejam kod programu. Bardzo proszę o jakieś wskazówki.
MainWindow.xaml.cs
[syntax=csharp]using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Navigation;
using System.Windows.Shapes;
using System.IO.Ports;
using System.Threading;
using System.IO;
namespace Telekomunikacja___XModem
{
/// <summary>
/// Interaction logic for MainWindow.xaml
/// </summary>
public partial class MainWindow : Window
{
static Port port;
static bool _continue = false;
static Thread readThread;
public static MainWindow myMainWindow;
public MainWindow()
{
myMainWindow = this;
readThread = new Thread(ReceiveMessages);
List<int> predkosci = new List<int>
{
75, 110, 134, 150, 300, 600, 1200, 1800, 2400, 4800, 7200,
9600, 14400, 19200, 38400, 57600, 115200, 128000
};
List<int> bityDanych = new List<int>
{
4, 5, 6, 7, 8
};
InitializeComponent();
foreach (int i in predkosci)
{
baudRateCB.Items.Add(i);
}
foreach (string s in SerialPort.GetPortNames())
{
portNameCB.Items.Add(s);
}
foreach (int i in bityDanych)
{
dataBitsCB.Items.Add(i);
}
foreach (Parity p in Enum.GetValues(typeof(Parity)))
{
parityCB.Items.Add(p);
}
foreach (StopBits s in Enum.GetValues(typeof(StopBits)))
{
stopBitsCB.Items.Add(s);
}
foreach (Handshake h in Enum.GetValues(typeof(Handshake)))
{
handshakeCB.Items.Add(h);
}
portNameCB.SelectedIndex = 0;
baudRateCB.SelectedIndex = 15;
dataBitsCB.SelectedIndex = 4;
parityCB.SelectedIndex = 0;
stopBitsCB.SelectedIndex = 1;
handshakeCB.SelectedIndex = 0;
sendBT.IsEnabled = false;
wyslijPlikBT.IsEnabled = false;
odbierzPlikBT.IsEnabled = false;
}
public void ReceiveMessages()
{
while (_continue)
{
try
{
string message = port.SerialPort.ReadLine();
MainWindow.myMainWindow.Dispatcher.BeginInvoke(new Action(delegate() { MainWindow.myMainWindow.ChatContent.AppendText(message); }));
}
catch (TimeoutException) { }
}
}
private void otwieraniePortu(object sender, RoutedEventArgs e)
{
if (_continue == false)
{
port = new Port();
port.Init((string)portNameCB.SelectedValue, (int)baudRateCB.SelectedValue, (Parity)parityCB.SelectedValue, (int)dataBitsCB.SelectedValue, (StopBits)stopBitsCB.SelectedValue, (Handshake)handshakeCB.SelectedValue);
port.SerialPort.Open();
initPortBT.Content = "Zamknij port";
_continue = true;
sendBT.IsEnabled = true;
wyslijPlikBT.IsEnabled = true;
odbierzPlikBT.IsEnabled = true;
portNameCB.IsEnabled = false;
baudRateCB.IsEnabled = false;
dataBitsCB.IsEnabled = false;
parityCB.IsEnabled = false;
stopBitsCB.IsEnabled = false;
handshakeCB.IsEnabled = false;
readThread.Start();
}
else
{
initPortBT.Content = "Otwórz port";
_continue = false;
sendBT.IsEnabled = false;
wyslijPlikBT.IsEnabled = false;
odbierzPlikBT.IsEnabled = false;
portNameCB.IsEnabled = true;
baudRateCB.IsEnabled = true;
dataBitsCB.IsEnabled = true;
parityCB.IsEnabled = true;
stopBitsCB.IsEnabled = true;
handshakeCB.IsEnabled = true;
readThread.Join();
port.SerialPort.Close();
}
}
private void wyslanieWiadomosci(object sender, RoutedEventArgs e)
{
string tekst = uzytkownik.Text.ToString() + ": " + wiadomosc.Text.ToString();
port.SerialPort.WriteLine(tekst);
ChatContent.AppendText(tekst);
wiadomosc.Clear();
}
private void wybieraniePliku(object sender, RoutedEventArgs e)
{
var okno = new Microsoft.Win32.OpenFileDialog();
var pokaz = okno.ShowDialog();
if (pokaz == false) return;
sciezkaPliku.Text = okno.FileName;
}
private void wysylaniePliku(object sender, RoutedEventArgs e)
{
string path = sciezkaPliku.Text.ToString();
using (StreamReader sr = File.OpenText(path))
{
string s = "";
while ((s = sr.ReadLine()) != null)
{
port.SerialPort.WriteLine(s);
}
}
}
private void odbieraniePliku(object sender, RoutedEventArgs e)
{
}
}
}[/syntax]
Port.cs
[syntax=csharp]using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.IO.Ports;
using System.Windows.Controls;
namespace Telekomunikacja___XModem
{
class Port
{
private SerialPort _serialPort;
public Port()
{
_serialPort = new SerialPort();
}
public void Init(string name, int rate, Parity par, int data, StopBits stop, Handshake hand)
{
_serialPort.PortName = name;
_serialPort.BaudRate = rate;
_serialPort.Parity = par;
_serialPort.DataBits = data;
_serialPort.StopBits = stop;
_serialPort.Handshake = hand;
_serialPort.ReadTimeout = 500;
_serialPort.WriteTimeout = 500;
}
public SerialPort SerialPort
{
get { return _serialPort; }
}
}
}[/syntax]Statystyki: Napisane przez jogproof — 27 maja 2014, o 15:51
]]>