C# 超简洁的TCP服务端开发

@[toc]

前言

在前一篇文章《BytesIO系列(一) 轻松实现TCP客户端》，我们实现了从零开始开发一个TCP通信客户端程序，利用BytesIO的便捷手写代码不超过三十行。
本章将继续利用BytesIO开发TCP的服务端，简洁明了依然是主旋律，我们要在三十行代码内除了实现一个TCP服务端以外，使其支持聊天室（消息转发）、连接数限制、心跳超时检测等功能。
现在，一起跟着视频敲一敲吧！

视频教程

https://player.bilibili.com/player.html?aid=897096259

核心代码

服务端代码

Visual Studio已经帮我们完成了大部分工作，真正需要我们手敲的代码不超过30行：

using STTech.BytesIO.Core;
using STTech.BytesIO.Tcp;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Windows.Forms;

namespace Demo.BytesIO.Server
{
   
    public partial class ServerForm : Form
    {
   
        private TcpServer server;
        public ServerForm()
        {
   
            InitializeComponent();
            CheckForIllegalCrossThreadCalls = false;

            server = new TcpServer();
            server.Port =int.Parse(tbPort.Text);

            server.Started += Server_Started;
            server.Closed += Server_Closed;
            server.ClientConnected += Server_ClientConnected;
            server.ClientDisconnected += Server_ClientDisconnected;

            server.ClientConnectionAcceptedHandle = (s, e) => {
   
                if (server.Clients.Count() < 3)
                {
   
                    return true;
                }
                else
                {
   
                    Print($"服务器已满，关闭客户端[{e.ClientSocket.RemoteEndPoint}]的连接.");
                    return false;
                }
            };
        }

        private void Server_ClientDisconnected(object sender, STTech.BytesIO.Tcp.Entity.ClientDisconnectedEventArgs e)
        {
   
            Print($"客户端[{e.Client.Host}:{e.Client.Port}]断开连接");
        }

        private void Server_ClientConnected(object sender, STTech.BytesIO.Tcp.Entity.ClientConnectedEventArgs e)
        {
   
            Print($"客户端[{e.Client.Host}:{e.Client.Port}]连接成功");
            e.Client.OnDataReceived += Client_OnDataReceived;
            e.Client.UseHeartbeatTimeout(3000);
        }

        private void Client_OnDataReceived(object sender, STTech.BytesIO.Core.Entity.DataReceivedEventArgs e)
        {
   
            TcpClient tcpClient = (TcpClient)sender;
            Print($"来自客户端[{tcpClient.RemoteEndPoint}]的消息: {e.Data.EncodeToString("GBK")}");

            foreach(TcpClient client in server.Clients)
            {
   
                if(client != tcpClient)
                {
   
                    client.SendAsync(e.Data);
                }
            }
        }

        private void Server_Closed(object sender, EventArgs e)
        {
   
            Print("停止监听");
        }

        private void Server_Started(object sender, EventArgs e)
        {
   
            Print("开始监听");
        }

        private void tsmiStart_Click(object sender, EventArgs e)
        {
   
            server.StartAsync();
        }

        private void tsmiClose_Click(object sender, EventArgs e)
        {
   
            server.CloseAsync();
        }

        private void Print(string msg)
        {
   
            tbLog.AppendText($"[{DateTime.Now}] {msg}\r\n");
        }
    }
}

消息转发

可以看到源码中，实现聊天室功能的核心代码：

            foreach(TcpClient client in server.Clients)
            {
   
                if(client != tcpClient)
                {
   
                    client.SendAsync(e.Data);
                }
            }

心跳超时检测

在BytesIO中，进行心跳超时检测只需要一行代码：

<客户端对象>.UseHeartbeatTimeout(<超时时间/毫秒>);

源码下载

下载地址：https://download.csdn.net/download/lgj123xj/85513898

结束语

如果非IT行业的女朋友都能学会的话，应该就算0基础入门的教学视频了吧！
超简单的C#TCP服务端开发入门，短短的代码，完整的功能，掏出你的VS码一个试试手吧！

关于BytesIO还有很多的开发技巧可以分享 ，在其余教程未完成之前，如果有使用上的疑问可以加群讨论。
QQ群：738018341