本文最后更新于 2024-07-31，文章可能存在过时内容，如有过时内容欢迎留言或者联系我进行反馈。

Socket服务端 {#socket%E6%9C%8D%E5%8A%A1%E7%AB%AF}

代码示例 {#%E4%BB%A3%E7%A0%81%E7%A4%BA%E4%BE%8B}

using System;
using System.IO;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Windows.Forms;
using System.Text.RegularExpressions;
namespace SocketDemo
{
public class SocketServer
{
//声明一个Socket对象
private Socket socketSever;
    //创建字典集合，键是ClientIp,值是SocketClient
    private Dictionary<string, Socket> CurrentClientlist = new Dictionary<string, Socket>();
/// <summary>
/// 开启服务
/// </summary>
public void StartService(string ip,int port)
{
    // 调用socket()函数创建一个用于通信的套接字
    socketSever = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

    // 给已经创建的套接字绑定一个端口号，这一般通过设置网络套接口地址和调用bind()函数来实现。
    IPEndPoint ipe = new IPEndPoint(IPAddress.Parse(ip), port);

    try
    {
        socketSever.Bind(ipe);
    }
    catch (Exception ex)
    {
        //写入日志
        Console.WriteLine("服务器开启失败：" + ex.Message);
        return;
    }

    // 调用listen()函数使套接字成为一个监听套接字。
    socketSever.Listen(10);

    //创建一个监听的线程
    var listenThread = new Thread(new ThreadStart(CheckListening));
    listenThread.IsBackground = true;
    listenThread.Start();
}

/// <summary>
/// 发送消息
/// </summary>
/// <param name="ip">客户端ip</param>
/// <param name="msg">消息</param>
public void SendMsg(string ip, string msg)
{
    byte[] buffer = Encoding.UTF8.GetBytes(msg);
    if (CurrentClientlist.ContainsKey(ip))
    {
        Socket client = CurrentClientlist[ip];
        client.Send(buffer);
    }
}

/// <summary>
/// 检查监听的线程方法体
/// </summary>
private void CheckListening()
{
    while (true)
    {
        // 调用accept()函数来接受客户端的连接，这时就可以和客户端通信了。
        Socket socketClient = socketSever.Accept();

        string client = socketClient.RemoteEndPoint.ToString();

        Console.WriteLine(client + "上线了");

        CurrentClientlist.Add(client, socketClient);

        Thread receiveMsgTread = new Thread(new ParameterizedThreadStart(ReceiveMessage));
        receiveMsgTread.Start(socketClient);
    }
}

/// <summary>
/// 接收客户端数据的方法
/// </summary>
/// <param name="socketClient"></param>
private void ReceiveMessage(object socketClient)
{
    Socket socket = (Socket)socketClient;
    while (true)
    {
        // 创建一个缓冲区
        byte[] buffer = new byte[1024 * 1024 * 10];

        int length = -1;

        string client = socket.RemoteEndPoint.ToString();

        // 处理客户端的连接请求。
        try
        {
            length = socket.Receive(buffer);
        }
        catch (Exception ex)
        {
            Console.WriteLine("Error：" + ex.Message);
            Console.WriteLine(client + "下线了");
            CurrentClientlist.Remove(client);
            break;
        }

        if (length > 0)
        {
            string msg = Encoding.UTF8.GetString(buffer, 0, length);
            Console.WriteLine(client + "：" + msg);
        }
        else
        {
            Console.WriteLine(client + "下线了");
            CurrentClientlist.Remove(client);
            break;
        }
    }
}

}

}

使用 {#%E4%BD%BF%E7%94%A8}

using System;
using System.Collections.Generic;
using System.Text;
`namespace SocketDemo
{
public class MainServer
{
SocketServer server;
public MainServer()
{
server = new SocketServer();
// 开启服务并监听客户端发送的数据
server.StartService("127.0.0.1",9997);
// 向指定客户端发送消息
server.Send("127.0.0.1","Hello");
}
}
}`

Socket客户端 {#socket%E5%AE%A2%E6%88%B7%E7%AB%AF}

代码示例 {#%E4%BB%A3%E7%A0%81%E7%A4%BA%E4%BE%8B-1}

using System;
using System.Collections.Generic;
using System.Text;
using System.Net.Sockets;
using System.Net;
using System.Threading;
namespace SocketDemo
{
public class SocketClient
{
private Socket socketClient;
    /// <summary>
    /// 建立连接
    /// </summary>
    /// <param name="ip"> IP地址 </param>
    /// <param name="port"> 端口 </param>
    public void Connect(string ip, int port)
    {
        socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    IPEndPoint ipe = new IPEndPoint(IPAddress.Parse(ip), port);
    try
    {
        socketClient.Connect(ipe);
    }
    catch (Exception ex)
    {
        Console.WriteLine("连接服务器失败：" + ex.Message);
        return;
    }

    // 创建一个监听线程
    var checkReceiveMsgThread = new Thread(new ThreadStart(CheckReceiveMsg));
    checkReceiveMsgThread.IsBackground = true;
    checkReceiveMsgThread.Start();

    Console.WriteLine("成功连接至服务器");
}

/// <summary>
/// 关闭连接
/// </summary>
public void Close()
{
    if (socketClient != null)
    {
        socketClient.Close();
        Console.WriteLine("与服务器断开连接");
    }
}

/// <summary>
/// 发送消息
/// </summary>
/// <param name="msg"></param>
public void SendMsg(string msg)
{
    byte[] buffer = Encoding.UTF8.GetBytes(msg);
    if (socketClient != null)
    {
        socketClient.Send(buffer);
        Console.WriteLine("发送内容：" + msg);
    }
}

/// <summary>
/// 接收数据
/// </summary>
public void CheckReceiveMsg()
{
    while (true)
    {
        // 创建一个缓冲区
        byte[] buffer = new byte[1024 * 1024 * 10];

        int length = -1;
        try
        {
            length = socketClient.Receive(buffer);
        }
        catch (Exception)
        {
            break;
        }

        if (length > 0)
        {
            string msg = string.Empty;
            msg = Encoding.UTF8.GetString(buffer, 0, length);
            Console.WriteLine("服务器：" + msg);
        }
        else
            break;
    }
}

}

}

使用 {#%E4%BD%BF%E7%94%A8-1}

using System;
using System.Collections.Generic;
using System.Text;
`namespace SocketDemo
{
public class MainClient
{
SocketClient client;
public MainClient()
{
client = new SocketClient();
// 建立连接
client.Connect("127.0.0.1",9997);
// 发送数据
client.SendMsg("Hello，小小笔记大大用处");
}
}
}`