C# Socket实现简易多人聊天室：客户端连接与收发消息

using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Windows.Forms;

namespace FinalChatRoomClient
{
    public partial class Client : Form
    {
        // 负责接收服务端发来的数据消息的线程
        Thread threadClient = null;
        // 创建客户端套接字，负责连接服务器
        Socket socketClient = null;

        public Client()
        {
            InitializeComponent();
            // 关闭对文本框跨线程操作的检查（仅在简单演示中使用）
            TextBox.CheckForIllegalCrossThreadCalls = false;
        }
    }
}

private void start_Click(object sender, EventArgs e)
{
    // 获得文本框中的IP地址对象
    IPAddress address = IPAddress.Parse(txtIp.Text.Trim());
    // 创建包含IP和端口的网络节点对象
    IPEndPoint endPoint = new IPEndPoint(address, int.Parse(txtPort.Text.Trim()));
    // 创建客户端套接字，负责连接服务器
    socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

    try
    {
        // 客户端连接到服务器
        socketClient.Connect(endPoint);
        ShowMsg("客户端连接服务器成功");

        // 连接成功后，启动后台接收线程
        threadClient = new Thread(ReceiveMsg);
        threadClient.IsBackground = true; // 设为后台线程，随主进程退出而结束
        threadClient.Start();
    }
    catch (SocketException ex)
    {
        ShowMsg("客户端连接服务器发生异常：" + ex.Message);
    }
    catch (Exception ex)
    {
        ShowMsg("客户端连接服务器发生其他错误：" + ex.Message);
    }
}

private void btnSend_Click(object sender, EventArgs e)
{
    string strMsg = txtMsg.Text.Trim();
    if(string.IsNullOrEmpty(strMsg)) return;

    // 将字符串转成方便网络传送的二进制数组
    byte[] arrMsg = Encoding.UTF8.GetBytes(strMsg);
    // 开辟新数组，多出一位作为类型标识位
    byte[] arrMsgSend = new byte[arrMsg.Length + 1];
    
    arrMsgSend[0] = 0; // 设置标识位，0代表发送的是文字
    Buffer.BlockCopy(arrMsg, 0, arrMsgSend, 1, arrMsg.Length);

    try
    {
        socketClient.Send(arrMsgSend);
        // 清空发送消息文本框中的消息
        this.txtMsg.Text = "";
    }
    catch (Exception ex)
    {
        ShowMsg("客户端发送消息时发生异常：" + ex.Message);
    }
}

private void ReceiveMsg()
{
    while (true)
    {
        // 定义一个接收消息用的字节数组缓冲区
        byte[] arrMsgRev = new byte[1024 * 1024 * 2];
        int length = -1;
        try
        {
            // 阻塞等待数据，返回接收到的字节长度
            length = socketClient.Receive(arrMsgRev);
        }
        catch (SocketException ex)
        {
            ShowMsg("客户端接收消息时连接断开或出错：" + ex.Message);
            break; // 退出循环
        }
        catch (Exception ex)
        {
            MessageBox.Show("接收消息系统级异常：" + ex.Message);
            break;
        }

        // 只有当服务器关闭连接或错误导致length为0时才停止（视具体协议而定）
        if (length == 0) break;

        // 使用 UTF-8 编码将接收到的真实有效字节转为字符串
        string strMsgReceive = Encoding.UTF8.GetString(arrMsgRev, 0, length);
        ShowMsg(strMsgReceive);
    }
}

// UI 刷新辅助方法
private void ShowMsg(string msg)
{
    txtRecord.AppendText(msg + "\r\n");
}