diff --git a/Connector/Connector.v11.suo b/Connector/Connector.v11.suo index c344e47..2fa5dee 100644 Binary files a/Connector/Connector.v11.suo and b/Connector/Connector.v11.suo differ diff --git a/Connector/Connector/Program.cs b/Connector/Connector/Program.cs index b89be48..37e6248 100644 --- a/Connector/Connector/Program.cs +++ b/Connector/Connector/Program.cs @@ -2,15 +2,28 @@ using System.Collections.Generic; using System.Linq; using System.Text; +using System.Threading; using System.Threading.Tasks; namespace Connector { class Program { + static void connect() + { + Thread t1, t2; + Receiver receiver = new Receiver(); + Sender sender = new Sender(); + String message = Console.ReadLine(); + t1 = new Thread(() => receiver.receive()); + t2 = new Thread(() => sender.send(message)); + t1.Start(); + t2.Start(); + } + static void Main(string[] args) { - + connect(); } } } diff --git a/Connector/Connector/Receiver.cs b/Connector/Connector/Receiver.cs index 8bfbb45..ce33c67 100644 --- a/Connector/Connector/Receiver.cs +++ b/Connector/Connector/Receiver.cs @@ -10,13 +10,22 @@ namespace Connector { class Receiver { + Int32 port = 80; private TcpClient client; private NetworkStream inStream; + Byte[] data; public void receive() { - client = new TcpClient("localhost", 80); + client = new TcpClient("localhost", port); inStream = client.GetStream(); + data = new Byte[256]; + String responseData = String.Empty; + Int32 bytes = inStream.Read(data, 0, data.Length); + responseData = System.Text.Encoding.ASCII.GetString(data, 0, bytes); + Console.WriteLine("Received: {0}", responseData); + inStream.Close(); + client.Close(); } } } diff --git a/Connector/Connector/Sender.cs b/Connector/Connector/Sender.cs index 3dfee3a..6395537 100644 --- a/Connector/Connector/Sender.cs +++ b/Connector/Connector/Sender.cs @@ -10,19 +10,23 @@ namespace Connector { class Sender { + Int32 port = 80; private TcpClient client; private NetworkStream outStream; - ASCIIEncoding encoder; - byte[] buffer; + Byte[] data; + // ASCIIEncoding encoder; + // byte[] buffer; public void send(string message) { - buffer = encoder.GetBytes(message); - client = new TcpClient("localhost", 80); + //buffer = encoder.GetBytes(message); + client = new TcpClient("localhost", port); + data = System.Text.Encoding.ASCII.GetBytes(message); outStream = client.GetStream(); - message = Console.ReadLine(); - outStream.Write(buffer, 0, buffer.Length); - outStream.Flush(); + //message = Console.ReadLine(); + outStream.Write(data, 0, data.Length); + Console.WriteLine("Sent: {0}", message); + outStream.Close(); client.Close(); } }