C# Tcp和Socket 网络(五)

TcpReceive

public Form1()
        {
            InitializeComponent();
            new Thread(() =>
            {
                IPAddress ip = IPAddress.Parse(ip地址);
                Int32 port = 13745;
                TcpListener listen = new TcpListener(ip, port);
                listen.Start();
                TcpClient tc = listen.AcceptTcpClient();

                NetworkStream ns = tc.GetStream();
                StreamReader sr = new StreamReader(ns);
                string result = sr.ReadToEnd();

                Invoke(new MethodInvoker(delegate() { textBox1.Text = result; }));
                sr.Close();
                ns.Close();
                tc .Close();
                listen.Stop();


            }).Start();
        }

TcpSend

 public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }

        private void button1_Click(object sender, EventArgs e)
        {
            TcpClient client = new TcpClient(ip地址, Int32.Parse(端口号));
            NetworkStream ns = client.GetStream();
            FileStream fs = File.Open("Form1.cs", FileMode.Open);
            int data = fs.ReadByte();
            while(data!=-1)
            {
                ns.WriteByte((byte)data);
                data = fs.ReadByte();
            }
            fs.Close();
            ns.Close();
            client.Close();
        }
    }

Socket Client

static void Main(string[] args)
        {

            IPHostEntry ipHsot = Dns.Resolve(ip地址);
            IPAddress ipAddress = ipHsot.AddressList[0];
            IPEndPoint ipEndPoint = new IPEndPoint(ipAddress, 13745);
            Console.WriteLine("Starting : Creating Socket object");
            Socket s = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            s.Connect(ipEndPoint);
            Console.WriteLine("Successfully Connected to {0}", s.RemoteEndPoint);
            while (true)
            {
                byte[] receivedBytes = new byte[1024];
                string sendMessage = Console.ReadLine();
                if (sendMessage.Contains("exit"))
                    break;
                Console.WriteLine("Creating message : {0}", sendMessage);
                byte[] forwardMessage = new UTF8Encoding().GetBytes(sendMessage + "[FINAL]");

                if (s.Connected)
                {
                    try
                    {
                        s.Send(forwardMessage);
                        int totalBytesReceived = s.Receive(receivedBytes);
                        Console.WriteLine("Message provided from server :{0}", new UTF8Encoding().GetString(receivedBytes, 0, totalBytesReceived));
                    }
                    catch (Exception ex)
                    {
                        throw ex;
                    }
                }
            }
            s.Shutdown(SocketShutdown.Both);
            s.Close();

        }

Socket Server

 static void Main(string[] args)
        {
            Console.WriteLine("Starting : Createing Socket object");
            Socket lisner = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            lisner.Bind(new IPEndPoint(IPAddress.Any, 13745));
            lisner.Listen(10);
            Console.WriteLine("Waiting for connection on port 13745");
            Socket socket = lisner.Accept();
            while (true)
            {  
                string receivedValue = string.Empty;
                while (true)
                {
                    byte[] receivedBytes = new byte[1024];
                    int numBytes = socket.Receive(receivedBytes);
                    Console.WriteLine("Receiving / ");
                    receivedValue += new UTF8Encoding().GetString(receivedBytes, 0, numBytes);
                    if (receivedValue.IndexOf("[FINAL]") > -1)
                        break;
                }
                Console.WriteLine("Received value: {0}", receivedValue);

                string replyValue = Console.ReadLine();
                byte[] replyMessage = new UTF8Encoding().GetBytes(replyValue);
                socket.Send(replyMessage);
               // socket.Shutdown(SocketShutdown.Both);
                //socket.Close();
            }
           
        }
    }