C# TCP服务器代码(支持多用户链接)

【实例简介】

【实例截图】

【核心代码】

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;

using System.Threading;
using System.IO;
using System.Net;
using System.Net.Sockets;


namespace TCPMultiLink
{
    public partial class Form1 : Form
    {
        Thread listenThread = null;//监听进程

        public Form1()
        {
            InitializeComponent();
        }
        private static void StartListening() //main listening thread
        {
            IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 5555);//绑定5555端口
            Socket newsock = new Socket(AddressFamily.InterNetwork,SocketType.Stream, ProtocolType.Tcp);//tcp协议
            newsock.Bind(ipep);
            newsock.Listen(10);
            while (true)
            {

                Socket client = newsock.Accept();//等待TCP客户端的链接请求

                ThreadClientProc p = new ThreadClientProc();
                p.tempSocket = client;
  
                Thread clientService = new Thread(new ThreadStart(p.ServiceClient));

                clientService.IsBackground = true;
                clientService.Start();
            }
        }

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            DialogResult dr = MessageBox.Show("确定要退出程序吗？", "退出提示", MessageBoxButtons.OKCancel);

            if (dr.Equals(DialogResult.OK))
            {
                // Application.Exit();
                if (listenThread != null)
                    listenThread.Abort();

                this.Dispose();
                this.Close();
            }
            else
            {
                e.Cancel = true;
            }  
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            //创建监听进程
            listenThread = new Thread(new ThreadStart(StartListening));
            listenThread.IsBackground = true;
            listenThread.Start();
        }
    }



    //客户端请求处理类
    public class ThreadClientProc
    {
        public Socket tempSocket;

        public ThreadClientProc()
        {

        }

        public void CloseThread()
        {
            Thread th = Thread.CurrentThread;
            th.Abort();
        }
     
      
        public void ServiceClient()
        {
            IPEndPoint newclient = (IPEndPoint)this.tempSocket.RemoteEndPoint;

            NetworkStream ns = new NetworkStream(tempSocket);
            StreamReader sr = new StreamReader(ns);
            StreamWriter sw = new StreamWriter(ns);
            //string welcome = "Welcome to tcp server!";
            //sw.WriteLine(welcome);
            //sw.Flush();
            sw.AutoFlush = true;

            char[] myReadBuffer = new char[1024];

            int count;
            while (true)
            {
                try
                {
                    count = sr.Read(myReadBuffer, 0, myReadBuffer.Length);//读取数据
                    if (count > 0)
                    {
                        sw.Write(myReadBuffer, 0, count);//将原返回数据
                        //sw.Flush();

                    }
                }
                catch
                {
                    break;
                }
            }
            sw.Close();
            sr.Close();
            ns.Close();
        }


    }
}