Tcp server

Author: durongze

c#/base/TCPServer.cs

@@ -0,0 +1,60 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Net;
+using System.Net.Sockets;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+ 
+namespace TCPServer
+{
+    class Program
+    { 
+        static void Main(string[] args)
+        { 
+            TcpListener tcpListener = new TcpListener(IPAddress.Parse("127.0.0.1"), 9000);
+            tcpListener.Start(); 
+            while (true)
+            {
+                if (tcpListener.Pending())
+                {
+                    TcpClient client = tcpListener.AcceptTcpClient(); 
+                    Task.Run(() =>
+                    { 
+                        NetworkStream stream = client.GetStream();
+                        var remote = client.Client.RemoteEndPoint;
+                        while (true)
+                        {
+                            if (stream.DataAvailable)
+                            {
+                                byte[] data = new byte[1024];
+                                int len = stream.Read(data, 0, 1024);
+                                string Name = Encoding.UTF8.GetString(data,0,len);
+                                var senddata = Encoding.UTF8.GetBytes("Hello:" + Name);
+                                stream.Write(senddata, 0, senddata.Length);
+                            }
+ 
+                            if (!client.IsOnline())
+                            {
+                                Console.WriteLine("Connect Closed.");
+                                break;
+                            }
+                            Thread.Sleep(1);
+                        }
+                    });
+                }
+                Thread.Sleep(1);
+            }
+        }
+    }
+ 
+    public static class TcpClientEx
+    {
+        public static bool IsOnline(this TcpClient client)
+        {
+            return !((client.Client.Poll(15000, SelectMode.SelectRead) && (client.Client.Available == 0)) || !client.Client.Connected);
+        }
+    }
+}

c#/base/TcpClient.cs

@@ -0,0 +1,89 @@
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.IO;
+using System.Linq;
+using System.Net.Sockets;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+ 
+namespace TCPClient
+{
+    class Program
+    {
+        static void Main(string[] args)
+        {
+            ThreadPool.SetMinThreads(100, 100);
+            ThreadPool.SetMaxThreads(200, 200); 
+
+            Parallel.For(1, 10, x =>
+            {
+                SendData("Tom");
+            });
+
+            Console.WriteLine("All Completed!");
+            Console.ReadKey();
+        }
+
+        private static void SendData(string Name)
+        {
+            Task.Run(() =>
+            {
+                Console.WriteLine("Start");
+                TcpClient tcpClient = new TcpClient();
+                tcpClient.Connect("127.0.0.1", 9000);
+                Console.WriteLine("Connected");
+                NetworkStream netStream = tcpClient.GetStream();
+
+                Task.Run(() =>
+                {
+                    Thread.Sleep(100);
+                    while (true)
+                    {
+                        if (!tcpClient.Client.Connected)
+                        {
+                            break;
+                        }
+
+                        if (netStream == null)
+                        {
+                            break;
+                        }
+
+                        try
+                        {
+                            if (netStream.DataAvailable)
+                            {
+                                byte[] data = new byte[1024];
+                                int len = netStream.Read(data, 0, 1024);
+                                var message = Encoding.UTF8.GetString(data, 0, len);
+                                Console.WriteLine(message);
+                            }
+                        }
+                        catch
+                        {
+                            break;
+                        }
+
+                        Thread.Sleep(10);
+                    }
+                });
+
+                for (int i = 0; i < 100; i++)
+                {
+                    byte[] datas = Encoding.UTF8.GetBytes(Name);
+                    int Len = datas.Length;
+                    netStream.Write(datas, 0, Len);
+                    Thread.Sleep(1000);
+                }
+
+                netStream.Close();
+                netStream = null;
+                tcpClient.Close();
+
+                Console.WriteLine("Completed");
+            });
+        }  
+    }
+}

c#/base/build.bat

@@ -1,5 +1,5 @@
 @echo off
-set cmd_srcs=MyThread.cs
+set cmd_srcs=MyThread.cs TcpServer.cs TcpClient.cs
 set app_srcs=MyApp.cs
 set dll_srcs=MyDll.cs