Hallo Frank,
ja Du hast wieder Recht. Das Projekt ist schwierig. Herauszukapseln auch.
http://www1.minpic.de/bild_anzeigen.php?id=139253&key=4033957&ende
Hauptsächlich kommt es vor, wenn ich was empfange, je nachdem was ich empfange UI Controls update.
Das darf ich wohl nicht.
Wie schon mal gesagt ich brauche Deine Klasse als Server. Vielleicht siehst Du was. Ich habe es adaptiert, aber irgendwas scheint falsch zu sein.
Suche bitte nach dem /// HIER KNALLT ES!!!!!! Kannst Du mal das und Deiner Serverklasse anschauen. Für den Server brauche ich kein UI,
wie in Deinem Beispiel.
Read sendet dann einen Event an die logische Klasse, wo der Inhalt ausgewertert wird.
public override void Read(string data, int size, int bytesRead)
{
int iExecThread = System.Threading.Thread.CurrentThread.ManagedThreadId;
System.Diagnostics.Trace.WriteLine("BUSSOCKET Read Thread ID " + iExecThread.ToString());
System.Diagnostics.Trace.WriteLine(data);
EventHandlerContentReceived(data);
}
void Bussystem_EvHaContentReceived(object sender, NotifyEventArgs e)
{
int iExecThread2 = System.Threading.Thread.CurrentThread.ManagedThreadId;
string toAnalysis = e.NotifyMessage;
//throw new NotImplementedException();
// System.Windows.Forms.MessageBox.Show(toAnalysis, "Test" );
if (toAnalysis == "WorkingPos")
{
//WorkingPos2();
State = StateProcessWorkflow.PanelAtWorkingPos;
//string s1 = ssssss_111();
Bussystem.Write("TestAntwort", 55);
}
}
Read sendet einen Event an das UserInterface.
void BMES_EvHaStateOfMES(object sender, NotifyEventArgs e)
{
//txtStateMES.Text = e.NotifyMessage; /// HIER KNALLT ES!!!!!!
}
Klasse Empfang
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Diagnostics;
using RCommunication.Definitions.Core;
//using RCommunication.Implementations.MES.OpCon.Core;
//using RCommunication.Implementations.MES.OpCon;
namespace RCommunication.Implementations.BUS.Socket.Core
{
public class BUSSocket : BaseBUS
{
Properties.Settings Props = Properties.Settings.Default;
System.Net.Sockets.Socket socket;
TcpListener tcpListener;
const int maxBuffer = 100;
Thread thread;
/// <summary>Um den Server sauber unterbrechen zu können.
/// Hiermit wird signalisiert, dass der Thread beenden soll.</summary>
ManualResetEvent threadStopEvent = new ManualResetEvent(false);
public override void Close()
{
//if (socket != null)
// socket.Close();
//if (tcpListener != null)
// tcpListener.Stop();
threadStopEvent.Set();
Thread.Sleep(50);
while (thread.IsAlive)
Thread.Sleep(10);
if (socket != null)
socket.Close();
if (tcpListener != null)
tcpListener.Stop();
Environment.Exit(0);
}
public override void Init()
{
NeuVerbinden();
int iExecThread = System.Threading.Thread.CurrentThread.ManagedThreadId;
System.Diagnostics.Trace.WriteLine("BUSSOCKET Init Thread ID " + iExecThread.ToString());
try
{
thread = new Thread(new ThreadStart(Execute));
thread.Start();
}
catch (Exception exp)
{
// System.Diagnostics.Trace.WriteLine(exp.Message);
}
}
private void NeuVerbinden()
{
IPAddress ipAdresse = null;
try
{
GetIpAdresse(ref ipAdresse, Dns.GetHostName());
tcpListener = new TcpListener(ipAdresse, Props.Port);
tcpListener.Start();
}
catch (Exception exp)
{
System.Diagnostics.Trace.WriteLine("Beim Versuch der Auflösung der Addresse: " +
ipAdresse.ToString() + " enstand folgender Fehler:\r\n" +
exp.Message);
return;
}
}
~BUSSocket()
{
}
//void Read(string msg)
//{
// txtMeldung.Invoke(new ServerTextCallback(ServerText),
// new object[] { msg + "\r\n" });
// Thread.Sleep(5);
//}
//public delegate void ServerTextCallback(string text);
//void ServerText(string text)
//{
// EventHandlerContentReceived(text);
//}
public override void Read(string data, int size, int bytesRead)
{
int iExecThread = System.Threading.Thread.CurrentThread.ManagedThreadId;
System.Diagnostics.Trace.WriteLine("BUSSOCKET Read Thread ID " + iExecThread.ToString());
System.Diagnostics.Trace.WriteLine(data);
EventHandlerContentReceived(data);
}
public override void Write(string data, int size)
{
System.Diagnostics.Trace.WriteLine(data);
//EvHaContentReceived(data);
UTF8Encoding encoding = new UTF8Encoding();
// string toSend = "ACK";
socket.Send(encoding.GetBytes(data));
System.Diagnostics.Trace.WriteLine("\r\nSende \"" + data + "\" - Meldung");
}
private IPAddress GetIpAdresse(ref IPAddress ipAdresse, string hostName)
{
IPAddress[] ipAdressen = Dns.GetHostEntry(hostName).AddressList;
foreach (IPAddress ip in ipAdressen)
{
if (ip.AddressFamily == AddressFamily.InterNetwork)
{
ipAdresse = ip;
break;
}
}
if (ipAdresse == null)
throw new Exception("Keine IPV4-IP auflösbar.");
return ipAdresse;
}
private void Execute()
{
System.Diagnostics.Trace.WriteLine("Der Server ist gestartet auf Port : " + Props.Port);
System.Diagnostics.Trace.WriteLine("Der lokale Endpunkt ist :" + tcpListener.LocalEndpoint);
System.Diagnostics.Trace.WriteLine("Warte auf Verbindung eines Clients ...");
while (!this.threadStopEvent.WaitOne(0, true))
{
Thread.Sleep(0);
try
{
if (tcpListener.Pending())
{
socket = tcpListener.AcceptSocket();
System.Diagnostics.Trace.WriteLine("Client-Verbindung akzeptiert von: " +
socket.RemoteEndPoint);
new Thread(new ThreadStart(ReceiveHandler)).Start();
}
}
catch (Exception e)
{
//"Der Client wurde zum Beispiel geschlossen" -> Neuverbinden
System.Diagnostics.Trace.WriteLine(e.Message);
}
}
}
void ReceiveHandler()
{
int received = 0;
byte[] buffer;
string empfangen;
do
{
try
{
buffer = new byte[maxBuffer];
received = socket.Receive(buffer);
if (received == 0)
{
if (socket != null)
socket.Close();
if (tcpListener != null)
tcpListener.Stop();
return;
// Application.Exit(); return;
// wenn der Client "" sendet, soll der Server beenden. (nur als Beispiel)
}
UTF8Encoding encoding = new UTF8Encoding();
empfangen = encoding.GetString(buffer, 0, received);
System.Diagnostics.Trace.WriteLine("Vom Client empfangen : \"" + empfangen + "\"");
int iExecThread = System.Threading.Thread.CurrentThread.ManagedThreadId;
System.Diagnostics.Trace.WriteLine("BUSSOCKET ReceiveHandler Thread ID " + iExecThread.ToString());
if ( empfangen.Length > 1 )
Read(empfangen, 44, 22);
//string toSend = "ACK";
//socket.Send(encoding.GetBytes(toSend));
//System.Diagnostics.Trace.WriteLine("\r\nSende \"" + toSend + "\" - Meldung");
}
catch (Exception exp)
{
System.Diagnostics.Trace.WriteLine(exp.Message);
}
}
while (received != 0);
}
}
}
