C# socket demo

1. 服务器端代码

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

namespace Sever
{
    class Program
    {
        private static Socket severSocket = null;

        /// <summary>
        /// 服务端程序
        /// 1. 新建 socket，并绑定端口
        /// 2. 接收客户端连接
        /// 3. 给客户端发送信息
        /// 4. 接收客户端信息
        /// 5. 断开连接
        /// </summary>
        /// <param name="args"></param>
        static void Main(string[] args)
        {
            severSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPEndPoint endPoint = new IPEndPoint(IPAddress.Any, 9999);
            severSocket.Bind(endPoint);                 // 绑定
            severSocket.Listen(10);                     // 设置最大连接数
            Console.WriteLine("开始监听");
            Thread thread = new Thread(ListenClientConnect);        // 开启线程监听客户端连接
            thread.Start();
            Console.ReadKey();
        }

        /// <summary>
        /// 监听客户端连接
        /// </summary>
        private static void ListenClientConnect()
        {
            Socket clientSocket = severSocket.Accept();         // 接收客户端连接
            Console.WriteLine("客户端连接成功 信息： " + clientSocket.AddressFamily.ToString());
            clientSocket.Send(Encoding.Default.GetBytes("你连接成功了"));
            Thread revThread = new Thread(ReceiveClientManage);
            revThread.Start(clientSocket);
        }

        private static void ReceiveClientManage(object clientSocket)
        {
            Socket socket = clientSocket as Socket;
            byte[] buffer = new byte[1024];
            int length = socket.Receive(buffer);        // 从客户端接收消息
            Console.WriteLine("收到消息：" + Encoding.Default.GetString(buffer));
        }
    }
}

2. 客户端代码

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

namespace client
{
    /// <summary>
    /// 客户端程序
    /// 1. 新建 Socket
    /// 2. 连接服务器
    /// 3. 接收服务器信息
    /// 4. 向服务器发送信息
    /// </summary>
    class Program
    {
        private static Socket clientSocket = null;

        static void Main(string[] args)
        {
            clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            // 客户端不需要绑定， 需要连接
            IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9999);   // 端口号要与服务器对应
            clientSocket.Connect(endPoint);
            Console.WriteLine("连接到服务器");
            // 接收服务器信息
            byte[] buffer = new byte[1024];
            int length = clientSocket.Receive(buffer);
            Console.WriteLine("收到消息： " + Encoding.Default.GetString(buffer));
            // 向服务器发送消息
            clientSocket.Send(Encoding.Default.GetBytes("你好服务器"));
            Console.ReadKey();
        }
    }
}

3. 运行截图