DotNETWork: Generische TCP/IP und UDP Klasse

φConst · 7. Juli 2016, 18:06

Guten Abend,

momentan( seit gestern ) entwickle ich eine Network-Klasse (DotNETWork) und möchte
seinen Fortschritt hier dokumentieren.

Es verfügt zurzeit über zwei Klassen , dem DotTcpClient und den DotTcpServer<T> , und drei weiteren Klassen die wichtige Funktionalitäten implementieren.

Die Methode "Send()" der DotTcpClient-Klasse erlaubt dem Programmierer Typen beliebiger (!) Art zu versenden(Serialisierung).
Die Klasse DotTcpServer<T> erwartet als Typparameter eine Klasse die von IClient erbt.

Ein Beispiel-Programm:

Die Klasse die von IClient erbt:

C#-Quellcode

public class User : IClient
{
public IPEndPoint ClientEndPoint { get; set; }
public TcpClient TcpClient { get; set; }
public BinaryReader BinReader { get; set; }
public BinaryWriter BinWriter { get; set; }
public void Call(object parameter)
{
int length = BinReader.ReadInt32();
BinWriter.Write(length);
BinWriter.Write(BinReader.ReadBytes(length));
}
}

Die Konsolenanwendung:

C#-Quellcode

DotTcpServer<User> tcpServer = new DotTcpServer<User>(225);
tcpServer.Run();
Console.WriteLine("Server is running!");
DotTcpClient client = new DotTcpClient("192.168.0.215", 225);
if (client.Connect(60))
{
Console.WriteLine("Connected !");
//SEND IMAGE
client.Send(new Bitmap(@"image.png"));
Console.WriteLine("SENT!");
//RECEIVE IMAGE!
Bitmap bitMap = client.Receive();
bitMap.Save(@"received.png");
Console.WriteLine("RECEIVED!");
}

Unschwer zu erkennen ist, dass der Parameter der Methode "Send()" vom Typ "Objekt" ist.
Auch individuelle Klassen können versendet werden ( Stichwort : Serialisierung msdn.microsoft.com/de-de/libra…rializable(v=vs.110).aspx)

Zur Klasse : GitHub (Oder Dateianhang, danke an die Moderation)

RodFromGermany · 8. Juli 2016, 07:30

φConst schrieb:

C#-Quellcode

DotTcpClient client = new DotTcpClient("192.168.0.215", 225);

Was muss ich tun, damit Dein Codebeispiel bei mir läuft?
Ich hab da lediglich meine eigene IP-Adresse reingeschrieben. Diese funktioniert zwischen zwei anderen Programmen auf demselben Rechner problemlos.

φConst · 8. Juli 2016, 14:54

Starte einen Server ( exemplarisch hw-group.com/products/hercules/index_de.html ) , oder benutze gleich das Codebeispiel, setze den Port auf 225.. dann
muss es klappen.

RodFromGermany · 8. Juli 2016, 16:41

@φConst OK. Unter W10 läuft das, unter W8.1 nicht

======

φConst schrieb:

C#-Quellcode

new System.Threading.ManualResetEvent(false).WaitOne(sendInterval);

So geht das nicht.
Erstelle eine Klassen-Instanz von ManualResetEvent und schalte die entsprechend mit .Set() bzw. .Reset().

φConst · 8. Juli 2016, 17:07

Ist provisorisch gewesen

.

Echt? Bei mir klappt alles wunderbar.
Worin liegt denn das Problem, verbindet er sich nicht?

Mal eine Frage OT

, ich implementiere grade die Verschlüsselung ( msdn ), bin aber misstrauisch geworden, was die Methode Encyrpt anbelangt.
Die MSDN Seite zeigt folgende Methode zu Encryption:

C#-Quellcode

private void EncryptFile(string inFile)
{
// Create instance of Rijndael for
// symetric encryption of the data.
RijndaelManaged rjndl = new RijndaelManaged();
rjndl.KeySize = 256;
rjndl.BlockSize = 256;
rjndl.Mode = CipherMode.CBC;
ICryptoTransform transform = rjndl.CreateEncryptor();
// Use RSACryptoServiceProvider to
// enrypt the Rijndael key.
// rsa is previously instantiated:
// rsa = new RSACryptoServiceProvider(cspp);
byte[] keyEncrypted = rsa.Encrypt(rjndl.Key, false);
// Create byte arrays to contain
// the length values of the key and IV.
byte[] LenK = new byte[4];
byte[] LenIV = new byte[4];
int lKey = keyEncrypted.Length;
LenK = BitConverter.GetBytes(lKey);
int lIV = rjndl.IV.Length;
LenIV = BitConverter.GetBytes(lIV);
// Write the following to the FileStream
// for the encrypted file (outFs):
// - length of the key
// - length of the IV
// - ecrypted key
// - the IV
// - the encrypted cipher content
int startFileName = inFile.LastIndexOf("\\") + 1;
// Change the file's extension to ".enc"
string outFile = EncrFolder + inFile.Substring(startFileName, inFile.LastIndexOf(".")- startFileName) + ".enc";
using (FileStream outFs = new FileStream(outFile, FileMode.Create))
{
outFs.Write(LenK, 0, 4);
outFs.Write(LenIV, 0, 4);
outFs.Write(keyEncrypted, 0, lKey);
outFs.Write(rjndl.IV, 0, lIV);
// Now write the cipher text using
// a CryptoStream for encrypting.
using (CryptoStream outStreamEncrypted = new CryptoStream(outFs, transform, CryptoStreamMode.Write))
{
// By encrypting a chunk at
// a time, you can save memory
// and accommodate large files.
int count = 0;
int offset = 0;
// blockSizeBytes can be any arbitrary size.
int blockSizeBytes = rjndl.BlockSize / 8;
byte[] data = new byte[blockSizeBytes];
int bytesRead = 0;
using (FileStream inFs = new FileStream(inFile, FileMode.Open))
{
do
{
count = inFs.Read(data, 0, blockSizeBytes);
offset += count;
outStreamEncrypted.Write(data, 0, count);
bytesRead += blockSizeBytes;
}
while (count > 0);
inFs.Close();
}
outStreamEncrypted.FlushFinalBlock();
outStreamEncrypted.Close();
}
outFs.Close();
}
}

Quelle : msdn.microsoft.com/de-de/library/bb397867(v=vs.110).aspx

Meine Frage:
Beim Schreiben in die CryptoStream :

C#-Quellcode

using (CryptoStream outStreamEncrypted = new CryptoStream(outFs, transform, CryptoStreamMode.Write))
{
// By encrypting a chunk at
// a time, you can save memory
// and accommodate large files.
int count = 0;
int offset = 0;
// blockSizeBytes can be any arbitrary size.
int blockSizeBytes = rjndl.BlockSize / 8;
byte[] data = new byte[blockSizeBytes];
int bytesRead = 0;
using (FileStream inFs = new FileStream(inFile, FileMode.Open))
{
do
{
count = inFs.Read(data, 0, blockSizeBytes);
offset += count;
outStreamEncrypted.Write(data, 0, count);
bytesRead += blockSizeBytes;
}
while (count > 0);
inFs.Close();
}
outStreamEncrypted.FlushFinalBlock();
outStreamEncrypted.Close();
}

was wird das?
Erstmal, wieso wird ein offset deklariert, der gar nicht benutzt wird?
Müsste das nicht bei

C#-Quellcode

outStreamEncrypted.Write(data, 0, count);

eingesetzt werden.
Und wieso

C#-Quellcode

bytesRead += blockSizeBytes

, das ja wie ersichtlich konstant ist.
Müsste das nicht mit "count" addiert werden?

Lieben Dank

Edit: Flusht der CryptoStream direkt den Puffer und ist deswegen startIndex immer bei null?

RodFromGermany · 8. Juli 2016, 17:14

φConst schrieb:

CryptoStream

Da kann ich jeztz nix zu sagen. Vielleicht solltest Du dazu einen separaten Thread aufmachen.

φConst · 8. Juli 2016, 18:15

Lol, hat funktioniert.

Das Senden wird mit einem PublicKey verschlüsselt..
der Programmierer übernimmt lediglich die Aufgabe der Server-Seite ( zum Entschlüsseln ).

GitHub wird in Kürze geupdated.

Ein Exempel ist im Anhang zu finden.

Der Code :

C#-Quellcode

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using DotNETWork.Tcp;
using System.Drawing;
using System.Net.Sockets;
using System.IO;
using System.Net;
using System.Threading;
using DotNETWork.Udp;
using DotNETWork.Globals;
using DotNETWork.Udp.ACK;
namespace TestingDotNETWork
{
class Program
{
static void Main(string[] args)
{
DotTcpServer<User> tcpServer = new DotTcpServer<User>(225);
tcpServer.Run();
Console.WriteLine("Server is running!");
DotTcpClient client = new DotTcpClient("192.168.0.215", 225);
if (client.Connect(60))
{
Console.WriteLine("Connected !");
client.Send("Encrypted!");
Console.WriteLine("RECEIVED: " + client.Receive());
}
Console.ReadLine();
}
}
public class User : IClient
{
public IPEndPoint ClientEndPoint { get; set; }
public TcpClient TcpClient { get; set; }
public BinaryReader BinReader { get; set; }
public BinaryWriter BinWriter { get; set; }
public void Call(object parameter)
{
DotTcpServer<User> serverParam = (DotTcpServer<User>)parameter;
int length = BinReader.ReadInt32();
byte[] enryptedBuffer = serverParam.RijndaelDecryption.DecryptStream(BinReader.ReadBytes(length));
BinWriter.Write(enryptedBuffer.Length);
BinWriter.Write(enryptedBuffer);
BinWriter.Flush();
}
}
}

Post scriptum: Weil das Dekompilieren von Anwendung in Deutschland imho mit dem deutschen Recht kollidiert, ( jetzt mal ganz richterlich ) permittiere ich jedem meine Applikationen die ich
in diesem Forum publiziere zu dekompilieren.

Edit: Aktualisiert.

*facepalm* klar.. hier habt auch alle die IP : 192.168.0.215

ErfinderDesRades · 8. Juli 2016, 19:15

jo, die "Kryptografie" sieht mir auch sehr eigentümlich aus. Funktioniert das denn? Also kannst du die verschlüsselte Datei mit einer anderen Programm-Instanz wirklich wieder entschlüsseln?

φConst · 8. Juli 2016, 19:31

Ist auch meine Frage, ich teste das mal jetzt am Laptop zu Pc , Pc zu Laptop Test.

Huhu

klappt wunderbar.

Hab nun auch den Client geupdated.

Das Schema der Verschlüsselung:

Client konnektiert zum Server ( registriert sich ) und erhält einen Public-Key.
Client sendet darauffolgend seinen Public -Key.
Server fügt Client in Client-Liste.

Client übermittelt Nachricht an den Server ( verschlüsselt wohlgemerkt ), Server decrypted dies mit dem privaten Schlüssel und encrypted die Nachricht mit dem speziellen Public-Key das er vom Client zugesandt bekam.
Ergo, verschlüsselt sowohl ausgehend wie auch eingehend!

Anhang : Server und Client!

Edit: Eigentümlich ist es wohl kaum.
Ich glaube die Crypto-Klassen generieren den Private-Key spezifisch für die Maschine, die die Methode aufrief,
sonst ergäbe es keinen Sinn, einen Public-Key exportieren zu dürfen.

Anwendungen außerhalb des Showrooms sind nicht erlaubt!
*Anhang entfernt*

ErfinderDesRades · 9. Juli 2016, 12:39

was soll ich denn mit einer Exe?

φConst · 9. Juli 2016, 16:39

Hier, bitte schön.

RodFromGermany · 9. Juli 2016, 18:12

@φConst
@ErfinderDesRades und @Solaris meinen, da Du sowieso oben schon die Quellen gepostet hast, kannst Du jetzt auch die aktuellen Quellen posten.

φConst · 10. Juli 2016, 00:20

Entschuldigt wirklich..
die Quelle ist angegeben, MSDN ( Kryptologie ), die Progressbar war von einem User zur Verfügung gestellt worden.
Wenn ich etwas vergessen habe: Seid so freundlich und ergänzt die Quellen, will ja nicht plagieren.

Rijndael : msdn.microsoft.com/de-de/library/bb397867(v=vs.110).aspx
ASCII Progressbar: gist. github. com/DanielSWolf/0ab6a96899cc5377bf54

Edit: Ahh haha

, ihr redet von Source :
Server:

C#-Quellcode

class Program
{
static void Main(string[] args)
{
Console.Write("Port: ");
DotTcpServer<User> tcpServer = new DotTcpServer<User>(int.Parse(Console.ReadLine()));
tcpServer.MaximumClients = 2;
tcpServer.Run();
Console.WriteLine("Server is running!");
}
}
public class User : IClient
{
public IPEndPoint ClientEndPoint { get; set; }
public TcpClient TcpClient { get; set; }
public BinaryReader BinReader { get; set; }
public BinaryWriter BinWriter { get; set; }
public string PublicKeyXML { get; set; }
DotRijndaelEncryption rEncryptor;
private string UserId;
public void Call(object parameter)
{
ClientParameters<User> clientParameters = (ClientParameters<User>)parameter;
try
{
string text = clientParameters.DecryptedBytes.DeserializeToDynamicType();
if (text.Contains("$$$USER"))
{
this.UserId = text.Split(new char[]
{
'='
})[1];
}
else if (text.Contains("$$§$$CMD"))
{
User user = clientParameters.ServerHandler.ClientList.Find((User p) => p.UserId != this.UserId);
this.rEncryptor = new DotRijndaelEncryption(user.PublicKeyXML);
byte[] array = this.rEncryptor.EncryptStream(clientParameters.DecryptedBytes);
user.BinWriter.Write(array.Length);
user.BinWriter.Write(array);
}
else
{
for (int i = 0; i < clientParameters.ServerHandler.ClientList.Count; i++)
{
this.rEncryptor = new DotRijndaelEncryption(clientParameters.ServerHandler.ClientList[i].PublicKeyXML);
byte[] array2 = this.rEncryptor.EncryptStream(clientParameters.DecryptedBytes);
clientParameters.ServerHandler.ClientList[i].BinWriter.Write(array2.Length);
clientParameters.ServerHandler.ClientList[i].BinWriter.Write(array2);
}
}
Console.WriteLine("Received..!");
}
catch (Exception ex)
{
Console.WriteLine("Error...!" + ex.Message);
}
}
}

Client:

C#-Quellcode

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using DotNETWork;
using DotNETWork.Globals;
using DotNETWork.Security;
using DotNETWork.Tcp;
using System.Threading;
using System.Diagnostics;
namespace ClientExampleDotNETWork
{
public partial class Client : Form
{
public Client()
{
InitializeComponent();
}
private DotTcpClient dotTcpClient;
private bool startedAnalyzing, isTyping;
private Stopwatch stopWatch = new Stopwatch();
private Random randomInt = new Random();
private void Client_Load(object sender, EventArgs e)
{
string inputString = Microsoft.VisualBasic.Interaction.InputBox("Type in ip and port (Scheme: ip:port)");
string serverIp = inputString.Split(':')[0];
int serverPort = int.Parse(inputString.Split(':')[1]);
dotTcpClient = new DotTcpClient(serverIp, serverPort);
if (!dotTcpClient.Connect(1000))
{
MessageBox.Show("Connection refused!", "Message", MessageBoxButtons.OK, MessageBoxIcon.Error, MessageBoxDefaultButton.Button1, MessageBoxOptions.DefaultDesktopOnly);
tbInput.Enabled = false;
return;
}
pbAvatar.Image = new Bitmap(1, 1);
// Eindeutige ID , damit das Avatar und der Status des Schreibens an den Sender erneut verschickt werden.
string clientId = "Id_" + randomInt.Next(0, 1000);
dotTcpClient.Send("$$$USER=" + clientId);
//dotTcpClient.Send("$$$AVATAR");
//dotTcpClient.Send(pbAvatar.Image);
new Thread(new ThreadStart(() =>
{
while (true)
{
string messageIn = dotTcpClient.Receive();
if (messageIn.Contains("$$§$$CMD"))
{
this.Invoke(new Action(() =>
{
statusLb.Text = "Status " + (messageIn.Split('=')[1].Equals("TRUE") ? "is writing..." : "idle");
}));
}
//else if (messageIn.Contains("$$$AVATAR"))
//{
// this.Invoke(new Action(() =>
// {
// pbAvatar.Image = (Image)dotTcpClient.Receive();
// }));
//}
else
this.Invoke(new Action(() =>
{
receivingLb.Items.Add(messageIn);
}));
}
})).Start();
}
private void tbInput_KeyDown(object sender, KeyEventArgs e)
{
if (!startedAnalyzing)
{
startedAnalyzing = true;
Task.Run(() =>
{
dotTcpClient.Send("$$§$$CMD_WRITING=TRUE");
while (startedAnalyzing)
{
if (isTyping)
{
stopWatch.Reset();
stopWatch.Start();
}
else
{
if (stopWatch.Elapsed.TotalMilliseconds >= 500)
{
break;
}
}
new ManualResetEvent(false).WaitOne(1);
}
startedAnalyzing = false;
dotTcpClient.Send("$$§$$CMD_WRITING=FALSE");
});
}
if (e.KeyCode == Keys.Enter && !isTyping)
{
sendBttn.PerformClick();
e.SuppressKeyPress = true;
}
isTyping = true;
}
private void tbInput_KeyUp(object sender, KeyEventArgs e)
{
isTyping = false;
}
private void sendBttn_Click(object sender, EventArgs e)
{
dotTcpClient.Send(tbInput.Text);
tbInput.Clear();
}
}
public static class Extension
{
public static void InvokeI(this Form frm, Action aDelegate)
{
frm.Invoke(aDelegate);
}
}
}

ErfinderDesRades · 10. Juli 2016, 10:04

ich bins müde.
Ist mir zu dumm, vom Bildschirm abschreiben zu müssen, und dran herumergänzen, damits bei mir so funktioniert wie bei dir (was damit ja noch lange nicht gesichert ist). Statt dass du deine Sources einfach zippst, dass ich sie einfach im VS öffnen kann.

φConst · 10. Juli 2016, 18:23

@ErfinderDesRades
DotNETWork: Generische TCP/IP und UDP Klasse ?
Das war das aktuellste Beispiel.

ErfinderDesRades · 10. Juli 2016, 18:40

Mag sein, aber das enthält nicht die wesentlichen Sourcen.
Stattdessen eine Dll - da hätteste auch die Exe lassen können.

ThuCommix · 10. Juli 2016, 21:50

Es ist alles in der Program.cs, du Schelm.

ErfinderDesRades · 11. Juli 2016, 00:58

ist es nicht. Weder von DotTcpClient noch von DotTcpServer<T> sind Sources dabei.

φConst · 11. Juli 2016, 02:10

Ah komm schon, wirklich ?
Ein Klick mehr: Zu github navigieren und exportieren als Zip... ist doch redundant alles auf VBP hochzuladen, wenn
ich mein VS mit der Repo synchronisieren kann.

ErfinderDesRades · 11. Juli 2016, 05:16

dann sollteste aber auch auf dein repo verlinken statt einen zip anzuhängen, wo die Sources nicht drin sind.

DotNETWork: Generische TCP/IP und UDP Klasse

DotNETWork: Generische TCP/IP und UDP Klasse

C#-Quellcode

C#-Quellcode

φConst schrieb:

C#-Quellcode

φConst schrieb:

C#-Quellcode

C#-Quellcode

C#-Quellcode

C#-Quellcode

C#-Quellcode

φConst schrieb:

C#-Quellcode

C#-Quellcode

C#-Quellcode

Tags

Ähnliche Themen

8 Benutzer haben hier geschrieben