多线程在网络编程中的应用

1.服务器端程序

class Threadtcpserver

    {

        private Socket ss;

        public Threadtcpserver()

        {

            IPAddress local = IPAddress.Parse("127.0.0.1");

            IPEndPoint iep = new IPEndPoint(local, 13000);

            ss = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            ss.Bind(iep); // 将套接字与本地终结点绑定

            //在本地13000端口号上进行监听

            ss.Listen(20);

            Console.WriteLine("等待客户机进行连接......");

            while (true)

            {

                Socket client = ss.Accept(); // 得到包含客户端信息的套接字

                ClientThread newclient = new ClientThread(client); //创建消息服务线程对象

                //把ClientThread 类的ClientService方法委托给线程

                Thread newthread = new Thread(new ThreadStart(newclient.ClientService));

                newthread.Start(); // 启动消息服务线程

            }

        }

        static void Main(string[] args)

        {

            Threadtcpserver instance = new Threadtcpserver();

        }

    }

    class ClientThread  //负责处理客户端与服务器端之间的通信

    {

        public static int connections = 0;   //connections变量表示连接数

        public Socket service;

        int i;

        public ClientThread(Socket clientsocket)

        {

          this.service = clientsocket;  //service对象接管对消息的控制

        }

        public void ClientService()

        {

            String data = null;

            byte[] bytes = new byte[1024];

            if (service != null)

            {

                connections++;

            }

            Console.WriteLine("新客户连接建立:{0} 个连接数", connections);

            while ((i = service.Receive(bytes)) != 0)

            {

                data = System.Text.Encoding.ASCII.GetString(bytes, 0, i);

                Console.WriteLine("收到的数据: {0}", data);

                // 处理客户端发来的消息，这里是转化为大写字母

                data = data.ToUpper();

                byte[] msg = System.Text.Encoding.ASCII.GetBytes(data);

                // 发送一条应答消息

                service.Send(msg);

                Console.WriteLine("发送的数据: {0}", data);

            }

            //关闭套接字

            service.Close();

            connections--;

            Console.WriteLine("客户关闭连接:{0} 个连接数", connections);

        }

    }

2.客户端程序

class multithreadclient

    {

        static void Main(string[] args)

        {

            Socket client;

            byte[] buf = new byte[1024];

            string input;

            IPAddress local = IPAddress.Parse("127.0.0.1");

            IPEndPoint iep = new IPEndPoint(local, 13000);

            try

            {

                client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

                client.Connect(iep);

            }

            catch (SocketException)

            {

                Console.WriteLine("无法连接到服务器!");

                return;

            }

            while (true)

            {

                //在控制台上输入一条消息

                input = Console.ReadLine();

                //输入exit，可以断开与服务器的连接

                if (input == "exit")

                { break;}

                client.Send(Encoding.ASCII.GetBytes(input));

                //得到实际收到的字节总数

                int rec = client.Receive(buf);

                Console.WriteLine(Encoding.ASCII.GetString(buf, 0, rec));

            }

            Console.WriteLine("断开与服务器的连接......");

            client.Close();

        }

    }