using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
​
public class TcpServer
{
    private Socket _serverSocket;
    private Socket _clientSocket;
    private byte[] _buffer = new byte[1024];
​
    public void Start(string ipAddress, int port)
    {
        _serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        _serverSocket.Bind(new IPEndPoint(IPAddress.Parse(ipAddress), port));
        _serverSocket.Listen(10);
        Console.WriteLine($"服务器启动，监听 {ipAddress}:{port}");
​
        _clientSocket = _serverSocket.Accept();
        Console.WriteLine("客户端已连接");
​
        // 接收数据线程
        Thread receiveThread = new Thread(ReceiveData);
        receiveThread.Start();
    }
​
    private void ReceiveData()
    {
        try
        {
            while (true)
            {
                int bytesReceived = _clientSocket.Receive(_buffer);
                string message = Encoding.UTF8.GetString(_buffer, 0, bytesReceived);
                Console.WriteLine($"收到消息: {message}");
​
                // 回显消息
                byte[] response = Encoding.UTF8.GetBytes($"ECHO: {message}");
                _clientSocket.Send(response);
            }
        }
        catch (SocketException ex)
        {
            Console.WriteLine($"Socket异常: {ex.Message}");
        }
    }
​
    public void Stop()
    {
        _clientSocket.Shutdown(SocketShutdown.Both);
        _clientSocket.Close();
        _serverSocket.Close();
    }
}

using System;
using System.Net.Sockets;
using System.Text;
​
public class TcpClientDemo
{
    private Socket _clientSocket;
    private byte[] _buffer = new byte[1024];
​
    public void Connect(string serverIp, int port)
    {
        _clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        _clientSocket.Connect(new IPEndPoint(IPAddress.Parse(serverIp), port));
        Console.WriteLine("已连接到服务器");
    }
​
    public void SendMessage(string message)
    {
        byte[] data = Encoding.UTF8.GetBytes(message);
        _clientSocket.Send(data);
        
        // 接收回显
        int bytesReceived = _clientSocket.Receive(_buffer);
        string response = Encoding.UTF8.GetString(_buffer, 0, bytesReceived);
        Console.WriteLine($"服务器响应: {response}");
    }
​
    public void Disconnect()
    {
        _clientSocket.Shutdown(SocketShutdown.Both);
        _clientSocket.Close();
    }
}

using System;
using System.Net;
using System.Net.Sockets;
​
public class UdpServer
{
    private UdpClient _udpServer;
​
    public void Start(int port)
    {
        _udpServer = new UdpClient(port);
        Console.WriteLine($"UDP服务器启动，监听端口 {port}");
​
        IPEndPoint remoteEP = new IPEndPoint(IPAddress.Any, 0);
        byte[] receiveBytes = _udpServer.Receive(ref remoteEP);
        string message = Encoding.UTF8.GetString(receiveBytes);
        Console.WriteLine($"收到来自 {remoteEP} 的消息: {message}");
​
        // 回显消息
        byte[] response = Encoding.UTF8.GetBytes($"ECHO: {message}");
        _udpServer.Send(response, response.Length, remoteEP);
    }
​
    public void Stop()
    {
        _udpServer.Close();
    }
}

using System;
using System.Net;
using System.Net.Sockets;
​
public class UdpClientDemo
{
    private UdpClient _udpClient;
​
    public void Send(string serverIp, int port, string message)
    {
        _udpClient = new UdpClient();
        IPEndPoint remoteEP = new IPEndPoint(IPAddress.Parse(serverIp), port);
        byte[] data = Encoding.UTF8.GetBytes(message);
        _udpClient.Send(data, data.Length, remoteEP);
​
        // 接收回显
        IPEndPoint receiveEP = new IPEndPoint(IPAddress.Any, 0);
        byte[] receiveBytes = _udpClient.Receive(ref receiveEP);
        string response = Encoding.UTF8.GetString(receiveBytes);
        Console.WriteLine($"服务器响应: {response}");
​
        _udpClient.Close();
    }
}

// 服务端启动
var tcpServer = new TcpServer();
tcpServer.Start("127.0.0.1", 8888);
​
// 客户端连接
var tcpClient = new TcpClientDemo();
tcpClient.Connect("127.0.0.1", 8888);
tcpClient.SendMessage("Hello Server!");
tcpClient.Disconnect();

// 服务端启动
var udpServer = new UdpServer();
udpServer.Start(9999);
​
// 客户端发送
var udpClient = new UdpClientDemo();
udpClient.Send("127.0.0.1", 9999, "Hello UDP Server!");
udpServer.Stop();

try
{
    // 网络操作
}
catch (SocketException ex)
{
    Console.WriteLine($"Socket错误: {ex.SocketErrorCode} - {ex.Message}");
}
catch (ObjectDisposedException)
{
    Console.WriteLine("套接字已关闭");
}

// 使用异步方法提升性能
public async Task ReceiveAsync()
{
    while (true)
    {
        SocketAsyncEventArgs e = new SocketAsyncEventArgs();
        e.SetBuffer(_buffer, 0, _buffer.Length);
        e.Completed += OnReceiveCompleted;
        await _clientSocket.ReceiveAsync(e);
    }
}

// 定时发送心跳包
Timer heartbeatTimer = new Timer(30000);
heartbeatTimer.Elapsed += (s, e) => 
{
    byte[] heartbeat = Encoding.UTF8.GetBytes("HEARTBEAT");
    _clientSocket.Send(heartbeat);
};

// 使用固定长度头部
public void SendWithHeader(string message)
{
    byte[] data = Encoding.UTF8.GetBytes(message);
    byte[] header = BitConverter.GetBytes(data.Length);
    _clientSocket.Send(header.Concat(data).ToArray());
}

// 使用Wireshark抓包分析
// 或添加日志记录
public static class Logger
{
    public static void Log(byte[] data)
    {
        File.WriteAllBytes("debug.bin", data);
    }
}

// 压力测试代码
for (int i = 0; i < 1000; i++)
{
    var client = new TcpClientDemo();
    client.Connect("127.0.0.1", 8888);
    client.SendMessage($"Test {i}");
    client.Disconnect();
}

参考代码 C# Socket通信示例源码   www.youwenfan.com/contenttef/93545.html

using System.Net.Security;
using System.Security.Authentication;
​
public class SecureTcpServer
{
    private SslStream _sslStream;
​
    public void StartSecure(int port)
    {
        // 加载证书
        X509Certificate2 serverCert = new X509Certificate2("server.pfx", "password");
​
        TcpListener listener = new TcpListener(IPAddress.Any, port);
        listener.Start();
        TcpClient client = listener.AcceptTcpClient();
​
        _sslStream = new SslStream(client.GetStream(), false);
        _sslStream.AuthenticateAsServer(serverCert);
    }
}

public enum MessageType : byte
{
    Text = 0x01,
    File = 0x02,
    Command = 0x03
}
​
public class ProtocolParser
{
    public static (MessageType type, string content) Parse(byte[] data)
    {
        MessageType type = (MessageType)data[0];
        string content = Encoding.UTF8.GetString(data.Skip(1).ToArray());
        return (type, content);
    }
}

基于C#的Socket通信TCP和UDP两种协议实现

基于C#的Socket通信TCP和UDP两种协议实现方式

后端

编程语言

网络与通信

C# TCP/UDP通信开发指南，包含服务端与客户端完整代码示例。详解TCP面向连接通信与UDP无连接通信实现，提供异常处理、多线程优化、心跳机制等工程实践建议。适合网络编程开发者学习Socket通信原理与C#实现方法。

数据完整性

数据监控

性能测试

压力测试

服务器

4核4G3M云服务器 新用户低至38元/年！

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云AI代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

功能1上新10个字符

功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符。

功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符。

功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符

功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符

功能4上新

文章&问答评论现已支持表情

全新交互，全新视觉，新增快捷键、悬浮工具栏、高亮块等功能并同时优化现有功能，全面提升创作效率和体验

社区富文本编辑器全新改版！诚邀体验～ 

精选全网热门MCP server，让你的AI更好用 🚀

💥开发者 MCP广场重磅上线！

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

基于C#的Socket通信TCP和UDP两种协议实现

基于C#的Socket通信TCP和UDP两种协议实现

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐