Baipyrus/CSharpSocketServer
1
0
Fork 0
mirror of https://gitlab1.ptb.de/waltem01/csharpsocketserver synced 2024-02-04 23:19:43 +00:00
Code Issues Projects Releases Wiki Activity

client to client functionality

Browse Source
This commit is contained in:
waltem01 2022-06-30 12:23:59 +02:00
parent 2a2b3fa773
commit 2d3378fb6b
1 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
SocketLib/SocketLib.cs
View File

@ -10,12 +10,13 @@ public static class Connection {
public static Socket self;
private static byte[] buffer;
private static string ipAddress;
private static int listeners = 0;
private static int listeners = 0, port;
public static Action<Socket> disconnectMethod;
public static List<MessageEvent> messageEvents;
public static void Initialize() {
public static void Initialize(int _port=3000) {
// Initialize global variables
port = _port;
buffer = new byte[1024];
messageEvents = new List<MessageEvent>();
disconnectMethod = new Action<Socket>((other)=>{});
@ -33,7 +34,7 @@ public static class Connection {
public static void ServerStart() {
// Create a new socket server and listen for connections
self = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
self.Bind(new IPEndPoint(IPAddress.Parse(ipAddress), 3000));
self.Bind(new IPEndPoint(IPAddress.Parse(ipAddress), port));
self.Listen(10);
// Accept any client asynchronously
@ -51,20 +52,29 @@ public static class Connection {
public static void ClientConnect(string ipAndPort) {
// Split ipAndPort into the ipAddress and Port
string ipAddr = ipAddress;
int port = 3000;
int _port = port;
if (ipAndPort != "") {
string[] splits = ipAndPort.Split(':');
ipAddr = splits[0];
port = int.Parse(splits[1]);
_port = int.Parse(splits[1]);
}
// Create a new socket client and connect to a server
self = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
self.Connect(new IPEndPoint(IPAddress.Parse(ipAddr), port));
self.Connect(new IPEndPoint(IPAddress.Parse(ipAddr), _port));
self.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallback), self);
}
public static void ClientListen() {
// Create a new socket server and listen for connections
Socket self = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
self.Bind(new IPEndPoint(IPAddress.Parse(ipAddress), port));
self.Listen(1);
// Accept any client, stop listening after first client is connected and return client
self.BeginAccept(new AsyncCallback(AcceptCallback), self);
}
// End off the message send-callback
private static void SendCallback(IAsyncResult AR) {
Socket other = AR.AsyncState as Socket;