C#socket编程之实现一个简单的TCP通信

TCP（TransmissionControl Protocol）传输控制协议。

是一种可靠的、面向连接的协议（eg:打电话）、传输效率低全双工通信（发送缓存&接收缓存）、面向字节流。使用TCP的应用：Web浏览器；电子邮件、文件传输程序。

TCP编程的服务器端一般步骤是：

　　1、创建一个socket，用函数socket()。

　　2、设置socket属性。

　　3、绑定本机的IP地址、端口等信息到socket上，用函数bind()。

　　4、开启监听，用函数listen()。

      5、接收客户端上来的连接，用函数accept()。

      6、通过accept()返回相应客户端的socket建立专用的通信通道。

　　7、收发数据，用函数send()和recv()，或者read()和write()。

　　8、关闭网络连接。

　　9、关闭监听。

TCP编程的客户端一般步骤是：

　　1、创建一个socket，用函数socket()。

　　2、设置socket属性。　

　　3、设置要连接的对方的IP地址和端口等属性。

　　4、连接服务器，用函数connect()。

　　5、收发数据，用函数send()和recv()，或者read()和write()。

　　6、关闭网络连接。　

---------------------
作者：subin_iecas
来源：CSDN
原文：https://blog.csdn.net/subin_iecas/article/details/80289513 

---

下面是一个简单的TCP的通信程序源码

主要功能是模拟一个群聊，当多个客户端连接进来后，任意一个客户端发送的消息都将被服务器端接收并群发给所有客户端

---

服务器端：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace _037_test
{
    class Program
    {
        static void Main(string[] args)
        {
            Server s = new Server("192.168.0.105", 8888);
            s.Start();
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace _037_test
{
    class Server
    {
        Socket serverSock;
        List<Socket> clientList = new List<Socket>();
        public Server(string ip, int port)
        {
            //创建socket套接字
            serverSock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            //检测ip地址是否有误
            IPAddress ipAdd;
            if (!IPAddress.TryParse(ip, out ipAdd))
            {
                Console.WriteLine("ip有误，服务器创建失败");
                return;
            }
            //绑定ip地址和端口；
            IPEndPoint point = new IPEndPoint(ipAdd, port);
            serverSock.Bind(point);
            //无限监听接收
            serverSock.Listen(0);

        }

        public void Start()
        {
            Thread th = new Thread(AcceptClient);
            th.Start();
            SendToAll();
        }

        public void AcceptClient()
        {
            Console.WriteLine("等待连接");
            while (true)
            {
                Socket client = serverSock.Accept();//等待接收用户的连接，并返回连接成功的用户
                IPEndPoint clientPoint = client.RemoteEndPoint as IPEndPoint;//获取所连接的用户的ip
                Console.WriteLine(clientPoint.Address+"已连接");
                clientList.Add(client);
                Thread clientT = new Thread(ReceiveMessage);
                clientT.Start(client);
            }
        }

        public void SendToAll()
        {
            while (true)
            {
                string message = "管理员："+Console.ReadLine();
                byte[] messageBytes = Encoding.Default.GetBytes(message);
                for (int i = 0; i < clientList.Count; i++)
                {
                    try
                    {
                        clientList[i].Send(messageBytes);
                    }
                    catch (SocketException)
                    {
                        Console.WriteLine("有一个客户端下线");
                        clientList.RemoveAt(i);
                        i--;
                    }
                    catch (Exception e)
                    {
                        Console.WriteLine(e.Message);
                    }
                }
            }
        }

        public void ReceiveMessage(object obj)
        {
            while (true)
            {
                Socket client = obj as Socket;//将线程的start方法传入的obj转回socket类型
                byte[] messageBytes = new byte[100 * 1024];//数据容器
                try
                {
                    int num = client.Receive(messageBytes);//receive方法返回字节长度，并把内容存在传入的数组中
                    IPEndPoint clientPoint = client.RemoteEndPoint as IPEndPoint;//获取所连接的用户的ip
                    Console.WriteLine(clientPoint.Address+"：" + Encoding.Default.GetString(messageBytes, 0, num));

                    //服务器端负责将从客户端收到的消息转发给所有客户端
                    string message = clientPoint.Address + ":" + Encoding.Default.GetString(messageBytes, 0, num);
                    foreach (var item in clientList)
                    {
                        if (item!=client)
                        {
                            item.Send(Encoding.Default.GetBytes(message));
                        }
                    }
                }
                catch (Exception)
                {
                    Console.WriteLine("有一个客户端离开");
                    clientList.Remove(client);
                    break;
                }
            }
            
        }
    }
}

---

客户端：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net.Sockets;
using System.Net;
using System.Threading;

namespace _038_test
{
    class Program
    {
        static void Main(string[] args)
        {
            Client c = new Client("192.168.0.105", 8888);
            c.Start();
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Net.Sockets;
using System.Net;
using System.Threading;

namespace _038_test
{
    class Client
    {
        Socket clientSock;
        public Client(string ip, int port)
        {
            clientSock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            try
            {
                IPEndPoint point = new IPEndPoint(IPAddress.Parse(ip), port);
                clientSock.Connect(point);
            }
            catch (Exception)
            {
                Console.WriteLine("服务器没有开启");
                return;
            }

            Console.WriteLine("已连接服务器");
        }

        public void Start()
        {
            Thread th = new Thread(SendMessage);
            th.Start();
            ReceiveMessage();
        }

        public void SendMessage()
        {
            try
            {
                while (true)
                {
                    string message = Console.ReadLine();
                    byte[] messageBytes = Encoding.Default.GetBytes(message);
                    clientSock.Send(messageBytes);
                }
            }
            catch (Exception)
            {
                Console.WriteLine("服务器断开");
                return;
            }
            
        }

        public void ReceiveMessage()
        {
            try
            {
                while (true)
                {
                    byte[] messageBytes = new byte[100 * 1024];
                    int num = clientSock.Receive(messageBytes);
                    Console.WriteLine(Encoding.Default.GetString(messageBytes, 0, num));
                }
            }
            catch (Exception)
            {
                Console.WriteLine("服务器断开");
                return;
            }
        }

    }
}

---

运行结果：