当前位置：首页 > news >正文

llfc项目TCP服务器笔记

news 来源：原创 2025/7/15 5:07:33

ChatServer

一个TCP服务器必然会有连接的接收，维持，收发数据等逻辑。那我们就要基于asio完成这个服务的搭建。主服务是这个样子的

#include "LogicSystem.h"
#include <csignal>
#include <thread>
#include <mutex>
#include "AsioIOServicePool.h"
#include "CServer.h"
#include "ConfigMgr.h"
using namespace std;
bool bstop = false;
std::condition_variable cond_quit;
std::mutex mutex_quit;
int main()
{
try {
auto &cfg = ConfigMgr::Inst();
auto pool = AsioIOServicePool::GetInstance();
boost::asio::io_context io_context;
boost::asio::signal_set signals(io_context, SIGINT, SIGTERM);
signals.async_wait([&io_context, pool](auto, auto) {
io_context.stop();
pool->Stop();
});
auto port_str = cfg["SelfServer"]["Port"];
CServer s(io_context, atoi(port_str.c_str()));
io_context.run();
}
catch (std::exception& e) {
std::cerr << "Exception: " << e.what() << endl;
}
}

CServer类的声明

#include <boost/asio.hpp>
#include "CSession.h"
#include <memory.h>
#include <map>
#include <mutex>
using namespace std;
using boost::asio::ip::tcp;
class CServer
{
public:
CServer(boost::asio::io_context& io_context, short port);
~CServer();
void ClearSession(std::string);
private:
void HandleAccept(shared_ptr<CSession>, const boost::system::error_code & error);
void StartAccept();
boost::asio::io_context &_io_context;
short _port;
tcp::acceptor _acceptor;
std::map<std::string, shared_ptr<CSession>> _sessions;
std::mutex _mutex;
};

构造函数中监听对方连接

CServer::CServer(boost::asio::io_context& io_context, short port):_io_context(io_context), _port(port),
_acceptor(io_context, tcp::endpoint(tcp::v4(),port))
{
cout << "Server start success, listen on port : " << _port << endl;
StartAccept();
}

接受连接的函数

void CServer::StartAccept() {
auto &io_context = AsioIOServicePool::GetInstance()->GetIOService();
shared_ptr<CSession> new_session = make_shared<CSession>(io_context, this);
_acceptor.async_accept(new_session->GetSocket(), std::bind(&CServer::HandleAccept, this, new_session, placeholders::_1));
}

AsioIOServicePool

从AsioIOServicePool中返回一个可用的iocontext构造Session，然后将接受的新链接的socket写入这个Session保管。

AsioIOServicePool已经在前面讲解很多次了，它的声明如下

#include <vector>
#include <boost/asio.hpp>
#include "Singleton.h"
class AsioIOServicePool:public Singleton<AsioIOServicePool>
{
friend Singleton<AsioIOServicePool>;
public:
using IOService = boost::asio::io_context;
using Work = boost::asio::io_context::work;
using WorkPtr = std::unique_ptr<Work>;
~AsioIOServicePool();
AsioIOServicePool(const AsioIOServicePool&) = delete;
AsioIOServicePool& operator=(const AsioIOServicePool&) = delete;
// 使用 round-robin 的方式返回一个 io_service
boost::asio::io_context& GetIOService();
void Stop();
private:
AsioIOServicePool(std::size_t size = std::thread::hardware_concurrency());
std::vector<IOService> _ioServices;
std::vector<WorkPtr> _works;
std::vector<std::thread> _threads;
std::size_t _nextIOService;
};

AsioIOServicePool具体实现

#include "AsioIOServicePool.h"
#include <iostream>
using namespace std;
AsioIOServicePool::AsioIOServicePool(std::size_t size):_ioServices(size),
_works(size), _nextIOService(0){
for (std::size_t i = 0; i < size; ++i) {
_works[i] = std::unique_ptr<Work>(new Work(_ioServices[i]));
}
//遍历多个ioservice，创建多个线程，每个线程内部启动ioservice
for (std::size_t i = 0; i < _ioServices.size(); ++i) {
_threads.emplace_back([this, i]() {
_ioServices[i].run();
});
}
}
AsioIOServicePool::~AsioIOServicePool() {
std::cout << "AsioIOServicePool destruct" << endl;
}
boost::asio::io_context& AsioIOServicePool::GetIOService() {
auto& service = _ioServices[_nextIOService++];
if (_nextIOService == _ioServices.size()) {
_nextIOService = 0;
}
return service;
}
void AsioIOServicePool::Stop(){
//因为仅仅执行work.reset并不能让iocontext从run的状态中退出
//当iocontext已经绑定了读或写的监听事件后，还需要手动stop该服务。
for (auto& work : _works) {
//把服务先停止
work->get_io_context().stop();
work.reset();
}
for (auto& t : _threads) {
t.join();
}
}

CServer的处理连接逻辑

void CServer::HandleAccept(shared_ptr<CSession> new_session, const boost::system::error_code& error){
if (!error) {
new_session->Start();
lock_guard<mutex> lock(_mutex);
_sessions.insert(ma

llfc项目TCP服务器笔记

ChatServer 一个TCP服务器必然会有连接的接收，维持，收发数据等逻辑。那我们就要基于asio完成这个服务的搭建。主服务是这个样子的 #include "LogicSystem.h"#include <csignal>#include <thread>#include <mutex>#include "AsioIOServiceP…...

编程日记 2025/7/15 5:07:33

NPP库中libnppi模块介绍

1. libnppi 模块简介 libnppi 是 NPP 库中专门用于图像处理的模块，提供高度优化的 GPU 加速函数，支持： 图像滤波（卷积、形态学操作） 几何变换（旋转、缩放、透视变换） 颜色空间转换&#xf…...

编程日记 2025/7/15 4:09:45

从头训练小模型: 3 传统RLHF与DPO的区别

这个步骤我其实是忽略了。如果我的目标是建立一个安全领域的模型，我个人理解这步骤并不太必要。关于人类偏好对齐：在前面的训练步骤中，模型已经具备了基本的对话能力。此时模型还不知道什么是好的回答，什么是不好的回答。我们希…...

编程日记 2025/7/14 10:28:46

Python-Django系列—视图

一、通用显示视图以下两个基于类的通用视图旨在显示数据。在许多项目中，它们通常是最常用的视图。 1、DetailView class django.views.generic.detail.DetailView 当该视图执行时，self.object 将包含该视图正在操作的对象。祖先（MRO&a…...

编程日记 2025/6/29 8:06:02

el-input Vue 3 focus聚焦

https://andi.cn/page/622173.html...

编程日记 2025/6/29 6:25:33

动态规划（5）路径问题--剑指offer -珠宝的最大值

题目： 现有一个记作二维矩阵 frame 的珠宝架，其中 frame[i][j] 为该位置珠宝的价值。拿取珠宝的规则为： 只能从架子的左上角开始拿珠宝每次可以移动到右侧或下侧的相邻位置到达珠宝架子的右下角时，停止拿取注意&#xff1…...

编程日记 2025/6/29 7:57:50

ZArchiver正版：高效文件管理，完美解压体验

在使用安卓设备的过程中，文件管理和压缩文件的处理是许多用户常见的需求。无论是解压下载的文件、管理手机存储中的文件，还是进行日常的文件操作，一款功能强大且操作简便的文件管理工具都能极大地提升用户体验。今天，我们要介绍的…...

编程日记 2025/6/29 6:54:08

Netlink在SONiC中的应用

Netlink在SONiC中的应用 Netlink介绍 Netlink 是 Linux 内核态程序与用户空间程序之间进行通信的机制之一，原本是用于传递网络协议栈中的各种控制消息。它采用和套接字（socket）编程接口相同的形式，常用于配置内核网络子系统&…...

编程日记 2025/6/29 5:50:13

ReentrantLock实现公平锁和非公平锁

在 Java 里，公平锁和非公平锁是多线程编程中用于同步的两种锁机制，它们的主要差异在于获取锁的顺序规则。下面是对二者的详细介绍： 公平锁公平锁遵循 “先来先服务” 原则，也就是线程获取锁的顺序和请求锁的顺序一致。先请求锁…...

编程日记 2025/6/29 5:12:08

【C++】 —— 笔试刷题day_25

一、笨小猴题目解析这道题，给定一个字符str，让我们找到这个字符串中出现次数最多字母的出现次数maxn和出现次数最少字母的出现次数minn； 然后判断maxn - minn是否是一个质数，如果是就输出Lucky Word和maxn - minn；如…...

编程日记 2025/6/29 7:34:42

terraform resource创建了5台阿里云ecs，如要使用terraform删除其中一台主机，如何删除？

在 Terraform 中删除阿里云 5 台 ECS 实例中的某一台，具体操作取决于你创建资源时使用的多实例管理方式（count 或 for_each）。以下是详细解决方案： 方法一：使用 for_each（推荐） 如果创建时使…...

编程日记 2025/6/29 8:09:28

Office 三大组件Excel、Word、Access 里 VBA 区别对比

以下是Excel、Word和Access在VBA中的主要区别对比及详细说明：核心对象模型 Excel Workbook（工作簿）→ Worksheet（工作表）→ Range（单元格区域）核心围绕单元格数据处理，如 Cells(1,1).Value = "数据" Word Document（文档）→ Range（文本范围）→ Paragrap…...

编程日记 2025/6/29 5:12:12

Linux 进程基础（二）：操作系统

目录一、什么是操作系统：用户和电脑之间的「翻译官」🌐 OS 的层状结构🧩 案例解析：双击鼠标的「跨层之旅」二、操作系统的必要性探究：缺乏操作系统的环境面临的挑战剖析🔑 OS 的「管理者」属性&#xff1…...

编程日记 2025/6/29 5:12:15

Java高并发处理核心技术详解：从理论到实战

高并发处理能力是衡量系统性能的重要指标。Java作为企业级开发的主力语言，提供了丰富的并发编程工具和框架。一、Java并发基础 1.1 Java内存模型（JMM） 主内存与工作内存：每个线程拥有独立的工作内存，通过JMM协议与主…...

编程日记 2025/6/29 6:14:25

单细胞测序数据分析试验设计赏析（二）

单细胞测序数据分析试验设计赏析（二） 这次的单细胞测序数据分析的试验设计是单细胞测序分析机器学习（with SHAP分析），也是常见的试验设计之一，重点是可以用于筛选鉴定基因调控网络，也可以是构建…...

编程日记 2025/7/15 2:52:38

Docker 服务搭建

💢欢迎来到张翊尘的开源技术站 💥开源如江河，汇聚众志成。代码似星辰，照亮行征程。开源精神长，传承永不忘。携手共前行，未来更辉煌💥 文章目录 Docker 服务搭建在 Ubuntu 上安装 Docker更新软件…...

编程日记 2025/7/3 11:40:35

4电池_基于开关电容的均衡

基于开关电容的均衡系统（Switched-Capacitor Equalization System） 开关电容均衡（Switched-Capacitor Equalization, SCE）是一种广泛应用于电池组（如锂电池、超级电容组） 的主动均衡技术，通过电…...

编程日记 2025/6/29 5:12:11

Matlab/Simulink - BLDC直流无刷电机仿真基础教程（七） - 波形解析专题P2

Matlab/Simulink - BLDC直流无刷电机仿真基础教程（七） - 波形解析专题P2 前言一、缺相与相线错接解析二、电源电压波动三、电机感量及磁链变化四、负载突变及堵转五、换相时机不当及换相错误参考链接前言本系列文章分享如何使用Matlab的Simulink功能来…...

编程日记 2025/7/13 17:20:19

如何从GitHub上调研优秀的开源项目，并魔改应用于工作中？

在 Go 语言学习中，我们经常会去学习一些优秀的开源项目。但是学完之后，发现很快就忘记了或者学习效果并不好。学习一个开源项目最好的方式就是围绕这个开源项目进行实战。例如，直接魔改这个开源项目并应用于工作中。本文来介绍下如何调用&…...

编程日记 2025/6/29 7:19:20

【Java学习笔记】构造器

构造器(constructor)（又名构造方法） 作用：可以在创建对象时就初始化属性，注意不是创建基本结构 [修饰符] 方法名（形参列表）{方法体； }代码示例 public class 构造器 {public static void m…...

编程日记 2025/6/29 7:16:54

Redis 数据类型详解（一）：String 类型全解析

文章目录前言一、什么是 Redis 的 String 类型？二、常用命令1.SET2.GET3.MSET4.MGET5.INCR6.INCRBY7.INCRBYFLOAT8.SETNX9.SETEX 三、注意事项总结前言提示：这里可以添加本文要记录的大概内容： 在学习 Redis 的过程中，最基础也…...

编程日记 2025/6/29 5:22:38

JAVA---多态

面向对象三大特征：封装、继承、多态多态定义：同类型的对象，表现出的不同形态。它允许不同类的对象通过同一个接口进行调用，并且在运行时根据实际对象类型执行不同的方法。多态主要通过继承、接口和方法重写来实现。表现形式…...

编程日记 2025/6/29 5:39:45

K8S的使用（部署pod\service）+安装kubesphere图形化界面使用和操作

master节点中通过命令部署一个tomcat 查看tomcat被部署到哪个节点上在节点3中进行查看在节点3中进行停止容器，K8S会重新拉起一个服务如果直接停用节点3（模拟服务器宕机），则K8S会重新在节点2中拉起一个服务暴露tomcat访…...

编程日记 2025/6/29 7:16:17

【Linux系统】第二节—基础指令（2）

hello ~ 好久不见自己想要的快乐要自己好好争取！ 云边有个稻草人-个人主页 Linux—本篇文章所属专栏—欢迎订阅—持续更新中目录本节课核心指令知识点总结本节基本指令详解 07.man 指令 08.cp 指令 09.mv 指令 10.cat 指令 11.more 指令 12.less 指令 …...

编程日记 2025/6/29 7:39:06

Java设计模式: 实战案例解析

Java设计模式: 实战案例解析在软件开发中，设计模式是一种用来解决特定问题的可复用解决方案。它们是经过实践验证的最佳实践，能够帮助开发人员设计出高质量、易于维护的代码。本文将介绍一些常见的Java设计模式，并通过实战案例解析它们在实际…...

编程日记 2025/6/29 8:27:24

ASP.NET MVC 入门与提高指南九

51. 时空数据处理与 MVC 应用拓展 51.1 时空数据概念时空数据是指与时间和空间相关的数据，如地理信息系统（GIS）数据、交通流量数据、气象数据等，这些数据随时间和空间变化而变化。 51.2 在 MVC 应用中处理时空数据地理信息系…...

编程日记 2025/6/29 5:12:10

算法学习时段效能分布

算法学习时段效能分布晨间时段（06:00-09:00）核心优势最佳任务午后时段（14:00-17:00）核心优势最佳任务夜间时段（20:00-23:00）核心优势最佳任务实证数据支持晨间时段（06:00-09:00&#xff09…...

编程日记 2025/7/3 10:46:50

Linux环境部署iview-admin项目

环境：阿里云服务系统：CentOS7.X系统 1、下载源码安装包 wget https://nodejs.org/dist/v14.17.3/node-v14.17.3-linux-x64.tar.xz2、解压并放入指定目录 tar -xf node-v14.17.3-linux-x64.tar.xz && mv node-v14.17.3-linux-x64 /usr/local/no…...

编程日记 2025/6/29 5:56:05

在 Ubuntu 系统中，查看已安装程序的方法

在 Ubuntu 系统中，查看已安装程序的方法取决于软件的安装方式（如通过 apt、snap、flatpak 或手动安装）。以下是几种常见方法： 通过 apt 包管理器安装的软件适用于通过 apt 或 dpkg 安装的 .deb 包。列出所有已安装的软件包&…...

编程日记 2025/6/29 5:30:33

c++26新功能——Pack indexing

一、模板编程在模板编程中，有一个问题比较突出，就是对变参模板中参数的控制，比较麻烦。因为是变参，所以想把参数单独拿出来处理，就需要借助一些特殊的技巧，而这种特殊的技巧，往往为大多数开发…...

编程日记 2025/6/29 5:22:57

VSCode通过SSH连接VMware虚拟机

以下是关于VSCode通过SSH连接VMware虚拟机的原理、必要条件及注意事项的说明： 一、连接原理 SSH协议通信：SSH（Secure Shell）是一种加密网络协议，VSCode通过Remote-SSH插件将本地开发环境与虚拟机终端绑定&a…...

编程日记 2025/7/9 17:34:38

7 微调黑盒蒸馏突破伦理限制

简介 SecGPT-Distill 是我自己做的一个实验模型, 开源地址: 主要功能是进行模型微调和知识蒸馏而来这次是运用微调技术，来突破现有模型在处理安全相关问题时的各种限制和约束代码开源: https://github.com/godzeo/SecGPT-distill-boundless 不回答原理大部…...

编程日记 2025/7/15 3:40:03

基于51单片机的温湿度控制器proteus仿真

地址： https://pan.baidu.com/s/1cENHPmF0XobqKg_7baZX3Q 提取码：1234 仿真图： 芯片/模块的特点： AT89C52/AT89C51简介： AT89C51 是一款常用的 8 位单片机，由 Atmel 公司（现已被 Microchip 收…...

编程日记 2025/6/29 6:52:41

牛客月赛115 C题-命运之弹题解

原题链接 https://ac.nowcoder.com/acm/contest/107879/C 题目描述解题思路记录每个数字出现的次数。枚举使用「转瞬即逝」的位置，统计后边比当前数字更大的数的数量，进而统计、更新答案。详细细节见代码，代码里有详细的注释解释。代…...

编程日记 2025/6/29 7:51:25

视频转GIF

视频转GIF 以下是一个使用 Python 将视频转换为 GIF 的脚本，使用了 imageio 和 opencv-python 库： import cv2 import imageio import numpy as np """将视频转换为GIF图参数:video_path -- 输入视频的路径gif_path -- 输出GIF的路径fp…...

编程日记 2025/6/29 5:12:51

day15 python 复习日

作业： 尝试找到一个kaggle或者其他地方的结构化数据集，用之前的内容完成一个全新的项目，这样你也是独立完成了一个专属于自己的项目。要求： 1.有数据地址的提供数据地址，没有地址的上传网盘贴出地址即可。 2.尽可能与…...

编程日记 2025/6/29 7:35:28

性能优化实践：渲染性能优化

性能优化实践：渲染性能优化在Flutter应用开发中，渲染性能直接影响用户体验。本文将从渲染流程分析入手，深入探讨Flutter渲染性能优化的关键技术和最佳实践。一、Flutter渲染流程解析 1.1 渲染流水线 Flutter的渲染流水线主要包含以下几…...

编程日记 2025/7/7 6:24:48

【SimSession 】3：中继服务 linux和windows实现及MFC集成实现

实现目标在 echo 测试程序启动时启动中继服务，并在 echo 程序退出时杀死中继进程。我们可以通过以下方式实现这一目标： linux设计 1 Process Management: 流程管理： Added fork() functionality to create a child process for the relay service添加了 fork（）功能，…...

编程日记 2025/6/29 6:18:11

表驱动 FSM 在 STM32 上的高效实现与内存压缩优化——源码、性能与实践

目录一、引言与背景二、前提环境与依赖三、表驱动 FSM 核心原理四、内存压缩方案详解 4.1 稠密二维表（Dense Table） 4.2 稀疏表压缩（Sparse Table） 4.3 行压缩＋Offset 4.4 位域打包（Bit‑Packing）...

编程日记 2025/6/29 7:47:06

windows鼠标按键自定义任意设置

因为用惯了Linux的鼠标中键的复制黏贴，发现windows下有完全可以实现类似自定义功能的软件，推荐一下： X Mouse Button Control。免费版足够好用。软件简介： X Mouse Button Control是一款专业的重新映射鼠标按钮的软件工具&…...

编程日记 2025/6/29 5:26:42

安装Miniconda wget https://mirrors.tuna.tsinghua.edu.cn/anaconda/miniconda/Miniconda3-py310_22.11.1-1-Linux-x86_64.shpython 换清华源 pip config set global.index-url https://pypi.tuna.tsinghua.edu.cn/simple鱼香ros wget http://fishros.com/install -O fishr…...

编程日记 2025/7/13 9:11:55

【图书管理系统】环境介绍、设计数据库和表、配置文件、引入依赖

0. 环境介绍 （1）JDK版本：JDK_8（JDK_1.8） （2）Java语言版本：8 （3）SpringBoot版本：2.6.13 （4）Maven仓库：阿里云 …...

编程日记 2025/6/29 6:09:54

【Linux】日志与策略模式、线程池

在了解了线程的基本概念和线程互斥与同步之后，我们可以以此设计一个简单的线程池。【Linux】线程-CSDN博客【Linux】线程同步与互斥-CSDN博客线程池也是一种池化技术。提前申请一些线程，等待有任务时就直接让线程去执行，不用再收到任务之…...

编程日记 2025/6/29 7:39:34

【神经网络与深度学习】生成模型-单位高斯分布 Generating Models-unit Gaussian distribution

引言在生成模型的研究与应用中，单位高斯分布（标准正态分布）作为数据采样的基础扮演着至关重要的角色。其数学特性、潜在空间的连续性、灵活性以及通用性，使得生成模型能够高效且稳定地学习和生成样本。本文将详细探讨从单位高斯…...

编程日记 2025/7/11 17:01:50

通讯协议开发实战：从零到一打造企业级通信解决方案

简介从工业控制到物联网，掌握主流通信协议开发是构建现代智能系统的核心能力。本文将通过深入分析CAN FD和MQTT两种关键协议的原理、特性及应用场景，结合TypeScript和Node.js技术栈，设计一个完整的实时运动控制系统开发案例。从协议解析到数据转换，再到系统集成，全程提供…...

编程日记 2025/6/29 6:51:46

《MATLAB实战训练营：从入门到工业级应用》工程实用篇-自动驾驶初体验：车道线检测算法实战（MATLAB2016b版）

《MATLAB实战训练营：从入门到工业级应用》工程实用篇-🚗 自动驾驶初体验：车道线检测算法实战（MATLAB2016b版） 大家好！今天我要带大家一起探索自动驾驶中一个非常基础但又至关重要的技术——车道线检测。我…...

编程日记 2025/7/12 12:08:59

【网络】什么是串口链路（Serial Link）？

在路由器上，串口链路（Serial Link）就是指路由器之间通过串行接口（serial interface）和串行电缆（通常是V.35、RS-232或同步串行线路）直接点对点相连的那一段连线。它和我们平常在局域网里用的以太…...

编程日记 2025/6/29 5:42:46

为了结合后端而学习前端的学习日志——【黑洞光标特效】

前端设计专栏今天给大家带来一个超酷的前端特效——黑洞光标！让你的鼠标变成一个会吞噬光粒子的迷你黑洞，点击时还会喷射出绿色能量粒子！🌠 🚀 效果预览想象一下：你的鼠标变成一个旋转的黑洞&#xff0…...

编程日记 2025/6/29 6:32:18

set autotrace报错

报错： SQL> set autotrace traceonly SP2-0618: Cannot find the Session Identifier. Check PLUSTRACE role is enabled SP2-0611: Error enabling STATISTICS report原因分析： 根据上面的错误提示“SP2-0618: Cannot find the Session Identifie…...

编程日记 2025/6/29 6:15:31

算法每日一题 | 入门-顺序结构-大象喝水

大象喝水题目描述一只大象口渴了，要喝 20 升水才能解渴，但现在只有一个深 h 厘米，底面半径为 r 厘米的小圆桶 （h 和 r 都是整数）。问大象至少要喝多少桶水才会解渴。这里我们近似地取圆周率 π 3.14 \pi3.14 π…...

编程日记 2025/7/5 0:46:33

ChatServer

AsioIOServicePool

相关文章：