using System.IO; using System.Net; using System.Net.Sockets; using System.Collections; using System.Windows.Forms; namespace example { // Server A class ExampleS { private IPEndPoint _ipEndPoint; private Socket _socket; private Socket _aSocket; private NetworkStream _network; private StreamReader _streamReader; private StreamWriter _streamWriter; void StartServer() { _ipEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 2009); _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); _socket.Bind(_ipEndPoint); _socket.Listen(1000000000); while (true) { _aSocket = _socket.Accept(); _network = new NetworkStream(_aSocket); _streamReader = new StreamReader(_network); _streamWriter = new StreamWriter(_network); if (_socket.Connected) continue; string _messenger = _streamReader.ReadLine(); if (_messenger.Equals("X1")) { _streamWriter.WriteLine("Hello"); _streamWriter.Flush(); } else { _streamWriter.WriteLine("Goodbye"); _streamWriter.Flush(); } } } } // Client B class ExampleCB { private IPEndPoint _ipEndPoint; private Socket _socket; private NetworkStream _network; private StreamWriter _streamWriter; private StreamReader _streamReader; void StartClient() { _ipEndPoint = new IPEndPoint(Dns.Resolve(Dns.GetHostName()).AddressList[0],2009); _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); _socket.Connect(_ipEndPoint); if (!_socket.Connected) { return; } _network = new NetworkStream(_socket); _streamWriter = new StreamWriter(_network); _streamReader = new StreamReader(_network); _streamWriter.WriteLine("X1"); _streamWriter.Flush(); var readLine = _streamReader.ReadLine(); if (readLine == null) { MessageBox.Show("Error messenger"); return; } else { MessageBox.Show(readLine.ToString()); } _streamWriter.Close(); _streamReader.Close(); _network.Close(); } } // Client C class ExampleCC { private IPEndPoint _ipEndPoint; private Socket _socket; private NetworkStream _network; private StreamWriter _streamWriter; private StreamReader _streamReader; void StartClient() { _ipEndPoint = new IPEndPoint(Dns.Resolve(Dns.GetHostName()).AddressList[0], 2009); _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); _socket.Connect(_ipEndPoint); if (!_socket.Connected) { return; } _network = new NetworkStream(_socket); _streamWriter = new StreamWriter(_network); _streamReader = new StreamReader(_network); _streamWriter.WriteLine("X1"); _streamWriter.Flush(); var readLine = _streamReader.ReadLine(); if (readLine == null) { MessageBox.Show("Error messenger"); return; } else { MessageBox.Show(readLine.ToString()); } _streamWriter.Close(); _streamReader.Close(); _network.Close(); } } }
var
This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)