百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 热门文章 > 正文

10分钟学会Socket通讯,学不会你打我

bigegpt 2024-09-08 11:26 8 浏览

Socket通讯是软硬件直接常用的一种通讯方式,分为TCP和UDP通讯。

在我的职业生涯中,有且仅用过一次UDP通讯。而TCP通讯系统却经常写,正好今天写了一个TCP通讯的软件。总结一下内容

软件使用C#编程原因写的,为了能够使用所有的电脑,采用了NET Framework 4.0。

启动服务端

服务端启动的时候,先写一个Task任务启动一个服务端的链接,注意服务端的ip,最好设置为0.0.0.0,这样所有的客户端都可以通过服务器ip地址链接到服务端。

Task.Factory.StartNew(() =>
{
    Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    EndPoint point = new IPEndPoint(IPAddress.Parse(ip), port);
    server.Bind(point);
    server.Listen(1000);
    while (true)
    {
        Socket client = server.Accept();
    }
}

服务端会启动一个无限循环的while,在这个循环中,通过Accept方法不断的接收链接的客户端。

接收客户端消息

在这个循环里面可以记录一下客户端的信息,并启动另一个Task任务,去接受客户端给服务端发送的消息。

Task.Factory.StartNew(() =>
{
    while (true) {
        byte[] buffer = new byte[1024];
        if (!client.Connected) {
            break;
        }
        int cnt = 0;
        try {
            cnt = client.Receive(buffer);
            if (cnt <= 0)
            {
                Thread.Sleep(1000);
                continue;
            }
        }
        catch (Exception ex) {
            break;
        }
        //因为buffer数组是1024长度,如果实际数据长度小于1024 则会出现0x00的空白数据,需要删除,只保留有效数据
        List<byte> lstBuffer = new List<byte>();
        for (int i = buffer.Length - 1; i >= 0; i--) {
            if (buffer[i] == 0x00 && lstBuffer.Count<=0)
                continue;
            lstBuffer.Insert(0, buffer[i]);
        }
        //接收到的消息
        Business.queueReceiver.Enqueue(new Tuple<string, byte[]>(pointClient.ToString(), lstBuffer.ToArray<byte>()));
        ReceiveCount += 1;
    }
});

对于服务端来说,任何一个链接到服务端的客户端,在服务端都应该启动一个Task去实时接收客户端的消息。

而由于客户端有可能会随时关闭或者断开,所以对Receive方法加异常判断,防止因为某一次的接收消息异常造成Task任务过期关闭。

对于服务端,一旦发现客户端的消息没有接收成功,或者判断到客户端已经断开,则可以推出while循环,然后关闭Task任务,结束与客户端的链接。


业务逻辑处理

对于任何项目的Socket通讯软件,都会有相关的通信协议,对照业务相关的通信协议和上面接收的客户端信息对业务逻辑进行处理即可。

业务处理需要,如果数据量比较小,则正常处理即可。

如果业务量大,并发大,数据量大等则需要考虑粘包的问题。

为了后期方面查询问题,需要对所有接收和处理的数据做日志处理,在处理日志时,如果有redis最好,如果没有,建议日志信息写入自己定义的队列中(比如:ConcurrentQueue),不建议直接写入文件或者数据库,这样会造成数据处理的效率缓慢。

为了使业务处理的逻辑不影响正常的客户端和服务端的通讯,建议对业务处理在其他的Task任务中进行处理。这样可以保证客户端和服务端之间接收和发送的通道正常。

对客户端发送消息

对于所有链接到服务端的客户端,都应该对客户端进行记录,并在新的Task任务中,分别对服务端需要发送的信息进行发送。这样就可以保证发送消息的统一性,在一个任务中进行发送,方便数据控制。

由于客户端数量不知道,所以发送的时候,把需要发送的消息放入队列中,然后在队列有消息的时候在进行异步发送。只要发送队列中有消息,则不需要对发送任务进行暂停控制,保证消息及时有效。

Task.Factory.StartNew(() =>
{
    while (true)
    {
        try 
        {
            if (Business.queueSender.IsEmpty)
            {
                Thread.Sleep(1000);
                continue;
            }
            Business.queueSender.TryDequeue(out Tuple<string, byte[]> tuple);
            if (tuple == null)
                continue;
            Socket client = Business.dicClient[tuple.Item1];
            if (!client.Connected)
            {
                Business.dicClient.TryRemove(tuple.Item1, out Socket outSocket);
                continue;
            }
            List<byte> buffer = new List<byte>();
            client_name = tuple.Item1;
            buffer.AddRange(tuple.Item2);
            client.BeginSend(buffer.ToArray(), 0, buffer.Count, SocketFlags.None, SendCallback, new Object[] { tuple, client, buffer });
            Thread.Sleep(1);
        }catch (Exception ex) {

        }
    }
});

业务数据入库

在通讯稳定的情况下,如果没有redis缓存等,建议把需要写入数据库的数据也放入队列中,每隔一段时间进行保存。而不要实时保存,数据库的写入需要更多的IO,放到一个Task任务中进行处理,可以保证数据保存的一致性。

Task.Factory.StartNew(() =>
{
    while (true) {
        string[] tablenames = Business.dicSaveData.Keys.ToArray();
        foreach (string table in tablenames) {
            if (Business.dicSaveData[table].IsEmpty) {
                continue;
            }
            var datas= Business.GetDataFromQueue(table);
            DataTable dt = DicToTable(table, datas);
            DbAccess.BatchAdd(table, dt,DbAccess.log_connectionstring);
        }
        Thread.Sleep(30000);
    }
});

日志处理

所有的消息都需要实施显示在系统上,并供用户查询,定位问题。而在CS软件中,如果对界面控件进行操作,就要进入主线程。主线程的频繁操作或者大数据量处理、显示,会造成系统卡顿。影响整个系统的性能。

日志处理也放到一个Task任务中,并定时清空系统软件的界面显示的数据

对于日志信息,也要进行物理保存。在日志信息达到一定的数量,或者达到一段时间后,可以把日志信息保存到文本中。

Task.Factory.StartNew(() =>
{
    List<string> msgs = new List<string>();
    while (true) {
        if (Business.queueMsg.IsEmpty) {
            Thread.Sleep(1000);
            continue;
        }
        while (!Business.queueMsg.IsEmpty) {
            if (msgs.Count > 1000) {
                break;
            }
            Business.queueMsg.TryDequeue(out string msg);
            if (string.IsNullOrEmpty(msg))
                continue;
            msgs.Add(msg);
        }
        try
        {
            string file = #34;{logdir}/{DateTime.Now.ToString("yyyyMMddHH")}.txt";
            string data = string.Join("\r\n", msgs);
            using (StreamWriter writer = new StreamWriter(file, true, Encoding.Default))
            {
                writer.WriteLine(data);
            }
            msgs.Clear();
        }
        catch (Exception ex) {
            Business.AddFailLogs(#34;写日志失败,错误描述:{ex.Message}");
        }
        if (Business.queueMsg.Count > 1000) {
            Thread.Sleep(10);
            continue;
        }
        Thread.Sleep(10000);
    }
});

队列处理

在整个业务逻辑过程中,使用了大量的队列,字典等,需要在软件的界面上显示队列的数量或者字典的详细信息。

说一个碰到的问题:

刚开始写的时候,由于链接的客户端比较少,所以日志的数量比较少,很快就写入数据库了,后来随着客户端的增多,日志的数量翻倍的增加,发现问题后,查询日志竟然找不到。

后来,把日志队列的数量显示在界面上,发现所有的客户端设备上线后,竟然在内存中有5万条日志信息。处理特别缓慢。

客户端测试

在写完服务端后,需要写一个客户端进行所有的协议测试。根据协议文档,在客户端发送相关协议,并收集服务端返回的信息。

客户端测试,可以写单客户端测试,也可以写多客户端测试,通过在软件上定义多个Task任务,分别启动多个客户端进行压力测试和并发测试。

总结

在整个软件的编码过程中,碰到的问题包括

  1. 大端小端的数据处理问题
  2. 协议文档对接过程中对于字节的定义和编码问题
  3. 怎么保证服务端软件持续在线。在前期的测试中,发现有的时候服务端显示正常,但是经常不返回消息,就是因为客户端断开后,服务端的Task关闭了,造成服务端对应的客户端没有反馈。
  4. 经常需要与各种设备进行协议对接和修改验证。经常需要给设备端查看相关的协议过程,这就是日志的功劳了
  5. 使用Task作业进行异步编程,可以提高软件的使用效率,防止软件出现未响应的情况。


最后

写了这么多年的软件,写过委托处理、多线程处理、Task作业、并行编程、异步编程。

虽然技术发展的很快,业务处理的性能得到的极大的提升。但是看到现在的大数据处理,感觉还得靠提升硬件性能和网络带宽来提升性能。

说一个有趣的事情:

以前写过一个服务端软件,需要接收1000个客户端软件持续发送的大量数据。当时服务端放到了阿里云上,怎么测试都是不行。后来在登录服务器看了看,CPU一直100%。内存倒是不多。

你猜最后怎么解决的,客户把阿里云的CPU提升到128核,CPU马上降到2%。

技术解决性能问题到最后都要钞能力

相关推荐

恢复软件6款汇总推荐,帮你减轻数据恢复压力!

在当今数字化生活中,数据丢失的风险如影随形。无论是误删文件、硬盘故障,还是遭遇病毒攻击,丢失的数据都可能给我们带来不小的麻烦。此时,一款优秀的数据恢复软件就成为了挽救数据的关键。今天,为大家汇总推荐...

中兴星星一号刷回官方原版recovery的教程

【搞科技教程】中兴星星一号的官方recovery也来说一下了,因为之前给大家分享过了第三方的recovery了,之前给大家分享的第三方recovery也是采用一键刷入的方式,如果细心的朋友会发现,之前...

新玩机工具箱,Uotan柚坛工具箱软件体验

以前的手机系统功能比较单调,各厂商的重视程度不一样,所以喜欢玩机的朋友会解锁手机系统的读写权限,来进行刷机或者ROOT之类的操作,让使用体验更好。随着现在的手机系统越来越保守,以及自身功能的增强,...

三星g906k刷recovery教程_三星g906k中文recovery下载

【搞科技教程】看到有一些机友在找三星g906k的第三方recovery,下面就来说一下详细的recovery的刷入方法了,因为手机只有有了第三方的recovery之后才可以刷第三方的root包和系统包...

中兴星星2号刷recovery教程_星星二号中文recovery下载

【搞科技教程】咱们的中兴星星2手机也就是中兴星星二号手机的第三方recovery已经出来了,并且是中文版的,有了这个recovery之后,咱们的手机就可以轻松的刷第三方的系统包了,如果没有第三方的re...

数据恢复软件有哪些值得推荐?这 6 款亲测好用的工具汇总请收好!

在数字生活中,数据丢失的阴霾常常突如其来。无论是误删工作文档、格式化重要磁盘,还是遭遇系统崩溃,都可能让我们陷入焦虑。关键时刻,一款得力的数据恢复软件便是那根“救命稻草”。今天,为大家精心汇总6...

中兴u956刷入recovery的教程(中兴e5900刷机)

【搞科技教程】这次主要来给大家说说中兴u956手机如何刷入第三方的recovery,因为第三方的recovery工具是咱们刷第三方rom包的基础,可是很我欠却不会刷,所以太这里来给大家整理了一下详细的...

联想A850+刷recovery教程 联想A850+第三方recovery下载

【搞科技教程】联想A850+的第三方recovery出来了,这个第三方的recovery是非常的重要的,比如咱们的手机要刷第三方的系统包的时候,都是需要用到这个第三方的recovery的,在网上也是有...

工具侠重大更新 智能机上刷机一条龙完成

工具侠是针对玩机的机油开发的一款工具,不管是发烧级别的粉丝,还是普通小白用户,都可以在工具侠上找到你喜欢的工具应用。这不,最新的工具侠2.0.16版本,更新了专门为小白准备的刷机助手工具,以及MTK超...

shift+delete删除的文件找回6种硬盘数据恢复工具

硬盘作为电脑的重要存储设备,如同一个巨大的数字仓库,承载着我们日常工作、学习和生活中的各种文件,从珍贵的照片、重要的工作文档到喜爱的视频、音乐等,都依赖硬盘来安全存放。但有时,我们可能会不小心用sh...

使用vscode+Deepseek 实现AI编程 基于Cline和continue

尊敬的诸位!我是一名专注于嵌入式开发的物联网工程师。关注我,持续分享最新物联网与AI资讯和开发实战。期望与您携手探寻物联网与AI的无尽可能。这两天deepseek3.0上线,据说编程能力比肩Cl...

详解如何使用VSCode搭建TypeScript环境(适合小白)

搭建Javascript环境因为TypeScript不能直接在浏览器上运行。它需要编译器来编译并生成JavaScript文件。所以需要首先安装好javascript环境,可以参考文章:https://...

使用VSCode来书写你的Jupyter Notebooks

现在你可以在VScode里面来书写你的notebook了,使用起来十分的方便。下面来给大家演示一下环境的搭建。首先需要安装一个jupyter的包,使用下面的命令安装:pip3install-ih...

使用VSCode模板提高Vue开发效率(vscode开发vue插件)

安装VSCode安装Vetur和VueHelper插件,安装完成后需要重启VScode。在扩展插件搜索框中找到如下Vetur和VueHelper两个插件,注意看图标。添加Vue模板打...

干货!VsCode接入DeepSeek实现AI编程的5种主流插件详解

AI大模型对编程的影响非常之大,可以说首当其冲,Cursor等对话式编程工具渐渐渗透到开发者的工作中,作为AI编程的明星产品,Cursor虽然好用,但是贵啊,所以咱们得找平替,最好免费那种。俗话说,不...