【Linux网络】TCP_Socket

目录

TCP协议(传输控制协议)

listen状态

accept和connect

TCP_echo_server

(1)创建套接字

(2)绑定

(3)设置listen状态

(4)loop

(5)客户端

多线程远程执行命令


TCP协议(传输控制协议)

传输层协议
有连接
可靠传输(前提网络要联通,复杂,维护性要更强)
面向字节流

tcp和udp在创建套接字和绑定部分是一样的;

不同的是,tcp在服务端绑定后需要将套接字的状态设置为listen状态,除此之外,在通信前要获取新连接;在客户端也要connect;

因为tcp是面向连接的,tcp需要未来不断地能够做到获取连接;

listen状态

accept和connect


  

 


 在TCP(传输控制协议)的服务端中获取新连接是至关重要的,原因如下:

  •  建立连接

TCP是面向连接的协议。客户端发起连接请求(通过 connect 函数),服务端需要接受这些请求(通过 accept 函数)来建立连接。这个连接是双向的通信链路,允许数据在客户端和服务端之间可靠地传输。例如,当你访问一个网站时,你的浏览器(客户端)向Web服务器(服务端)发起TCP连接请求,服务器接受这个请求后,两者之间就建立了一条可靠的通信链路,用于传输网页数据。

  •  并发处理

服务端通常需要同时处理多个客户端的请求。通过获取新连接,服务端可以为每个客户端创建一个独立的连接,从而实现并发处理。例如,一个在线游戏服务器可能需要同时处理成千上万的玩家连接。每个玩家的客户端都会向服务器发起TCP连接请求,服务器接受这些请求并创建对应的连接,这样就能同时为多个玩家提供服务。

  • 数据交互

获取新连接是数据传输的起点。一旦连接建立,客户端和服务端就可以通过读写套接字( read 和 write 函数,或者 recv 和 send 函数)来交换数据。例如,在一个文件传输服务中,客户端请求下载文件,服务端接受连接后,就可以通过已建立的连接将文件数据发送给客户端。
 

TCP_echo_server

下面我们来手动实现一下tcp_echo_server;按照下面的流程来实现:

(1)创建套接字

// 1、创建套接字
_listensockfd = ::socket(AF_INET, SOCK_STREAM, 0);
if (_listensockfd < 0)
{LOG(FATAL, "socket error\n");exit(SOCKET_ERROR);
}
LOG(DEBUG, "socket create sucess\n");

(2)绑定

struct sockaddr_in local;
memset(&local, 0, sizeof(local));
local.sin_family = AF_INET;
local.sin_port = htons(_port);
local.sin_addr.s_addr = INADDR_ANY;int n = ::bind(_listensockfd, (struct sockaddr *)&local, sizeof(local));

(3)设置listen状态

// 3、设置套接字为listen状态
// 因为tcp是面向连接的,tcp需要未来不断地能够做到获取连接
int m = listen(_listensockfd, MAXCOUNT);
if (m < 0)
{LOG(FATAL, "listen error\n");
}
LOG(INFO, "listen sucess\n");

(4)loop

(1)获取新连接

// 获取新连接
struct sockaddr_in client;
socklen_t len = sizeof(client);
int sockfd = ::accept(_listensockfd, (struct sockaddr *)&client, &len);
if (sockfd < 0)
{LOG(WARNING, "accept error\n");continue;
}
InetAddr addr(client);
LOG(INFO, "get a new link,client info :%s\n", addr.Addrstr().c_str());

(2)

因为下面的几个版本都需要用的Service函数,我先提前放到这里;

    void Service(int sockfd, InetAddr addr){while (true){char inbuffer[2048];ssize_t n = ::read(sockfd, inbuffer, sizeof(inbuffer) - 1); // 读消息,-1是因为它是系统调用不会做字符串处理if (n > 0){inbuffer[n] = 0;string echo_string = "[server echo]# ";echo_string += inbuffer;n = ::write(sockfd, echo_string.c_str(), echo_string.size()); // 写消息}else if (n == 0) // 读到文件结尾,也就是通信结束{LOG(INFO, "client %s quit\n", addr.Addrstr().c_str());break;}else{LOG(ERROR, "read server error:%s\n", addr.Addrstr().c_str());break;}}}

1、version 0 版本

Service(sockfd, addr);

2、version 1 ----多进程版本

 pid_t id =fork();
if(id==0)
{
::close(_listensockfd);
if(fork()>0)exit(0);//子进程退出
Service(sockfd, addr);//孙进程会造成僵尸进程
exit(0);
}
//father
::close(sockfd);
int n=waitpid(id,nullptr,0);//1、忽略;2、父子孙
if(n>0)
{
LOG(INFO,"wait child sucess\n");
}

3、version 2 ----多线程版本

pthread_t tid;
ThreadDate *td = new ThreadDate(sockfd, this, addr);
pthread_create(&tid, nullptr, Execute, td); // 新线程分离

4、version 3 ---线程池版本

task_t aa=std::bind(&TcpServer::Service,this,sockfd,addr);
ThreadPool<task_t>::GetInstance()->Equeue(aa);

(5)客户端

以上我们就完成了tcp_echo_server,也就是用tcp实现的一个简单的通信;

多线程远程执行命令

这里我们用version 2 多线程版本来实现远程执行命令;

为了使代码更加美观,我们在version2版本的基础上,将Service函数进行封装;将它封装到command.hpp的HandlerCommand函数里面;

这样我们调用回调函数,然后再主函数中进行绑定即可;

using command_server_t =std::function<void(int sockfd, InetAddr addr)>;
void HandlerCommand(int sockfd, InetAddr addr)
{while (true){char inbuffer[2048];ssize_t n = ::recv(sockfd, inbuffer, sizeof(inbuffer) - 1,0); // 读消息,-1是因为它是系统调用不会做字符串处理             if (n > 0){inbuffer[n] = 0;string result = Excute(inbuffer);n = ::send(sockfd, result.c_str(), result.size(),0); // 写消息}else if (n == 0) // 读到文件结尾,也就是通信结束{LOG(INFO, "client %s quit\n", addr.Addrstr().c_str());break;}else{LOG(ERROR, "read server error:%s\n", addr.Addrstr().c_str());break;}}
}

完成上面的准备工作,怎么执行命令?

在之前我写过手写shell的文章,可以直接用里面的代码,文章用的是exec*函数来执行命令;但是这里我们用一个更加简单的函数:popen直接执行即可;

string Excute(const string &cmdstr)
{FILE *fp=popen(cmdstr.c_str(),"r");string result;if(fp){char line[1024];while(fgets(line,sizeof(line),fp))//读文件{result+=line;}return result;}else{return "execute error";}
}

完整代码:

tcp_echo_server:

登录 - Gitee.com

远程执行命令:

登录 - Gitee.com

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/461233.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

摄像机实时接入分析平台LiteAIServer视频智能分析软件视频诊断中的抖动检测功能

在现代社会中&#xff0c;视频监控系统扮演着至关重要的角色&#xff0c;而视频质量直接影响到监控系统的可靠性和有效性。随着技术的不断进步&#xff0c;视频智能分析软件LiteAIServer作为一款领先的视频智能分析软件&#xff0c;通过引入抖动检测功能&#xff0c;进一步提升…

Excel重新踩坑4:快捷键;逻辑函数;文本函数;日期相关函数;查找与引用函数;统计类函数;数组公式

0、excel常用快捷键 基础快捷键&#xff1a; alt&#xff1a;快速区域求和&#xff1b; ★ altenter&#xff1a;强制换行&#xff08;因为在excel单元格中没法用enter换行&#xff09;&#xff1b;altj&#xff1a;强制换行符的替换删除&#xff0c;这里altj就是在替换中输入…

ABAP RFC SQL 模糊查询和多个区间条件

对于非选择屏幕的情况&#xff0c;RFC接口输入数据后&#xff0c;如何处理字符串模糊查询、日期区间查询、数字区间查询&#xff1a; 一、所有字符支持模糊查询&#xff0c;在SAP SQL中&#xff0c;使用 %S%来实现。 二、区间查询有3种情况&#xff1a; 1、没有值输入&#xf…

python通过pyperclip库操作剪贴板

pyperclip介绍 pyperclip是一个python库用于操作剪贴板&#xff0c;可以非常方便地将文本复制到剪贴板或从剪贴板获取文本。 通过pip进行安装&#xff1a;pip install pyperclip pyperclip的github地址 pyperclip使用 复制到剪贴板 import pypercliptext "Hello, Wo…

Golang | Leetcode Golang题解之第516题最长回文子序列

题目&#xff1a; 题解&#xff1a; func longestPalindromeSubseq(s string) int {n : len(s)dp : make([][]int, n)for i : range dp {dp[i] make([]int, n)}for i : n - 1; i > 0; i-- {dp[i][i] 1for j : i 1; j < n; j {if s[i] s[j] {dp[i][j] dp[i1][j-1] …

Virtuoso使用layout绘制版图、使用Calibre验证DRC和LVS

1 绘制版图 1.1 进入Layout XL 绘制好Schmatic后&#xff0c;在原理图界面点击Launch&#xff0c;点击Layout XL进入版图绘制界面。 1.2 导入元件 1、在Layout XL界面左下角找到Generate All from Source。 2、在Generate Layout界面&#xff0c;选中“Instance”&#…

摩科智能化一体化防盗门(物联网)项目

一&#xff0c;选题依据及意义 ①理论意义 目前国内外学者对智能门锁的研究取得了一些成果&#xff0c;但都局限于猫眼和门锁设计上。本课题在产品设计、服务设计等理论基础上&#xff0c;深入研究在安全与防护的背景下简约化即智能应用的门锁创新。在理论与实际探索上建立了…

记录一下方便的条件编译

1. 需要准备&#xff1a; 1-1、npm i cross-env -D 是跨平台的自定义编译 1-2、构造工具&#xff1a;vite/webpack > vite: import.meta.env.VITE_NODE_ENV > webpack:process.env.NODE_ENV这里使用vite为例子 1-3、 package.json 2. 思路与步骤 首先我们知道 axio…

企业数据泄露安全演练(分享)

该文章主要分享作者在XXX企业内部做的一次【数据泄露安全演练】&#xff0c;涉及演练背景、目的、演练流程、剧本设定、预期行为、结果等等。 以下是完整的演练方案&#xff0c;有不足的地方希望大家指出&#xff01;&#xff01; 需要原版方案电子版的可以联系作者获取。 演练…

[前端面试]计算机网络

TCP/IP 与OSI TCP/IP TCP/IP 四层模型是一个分层网络通信模型&#xff0c; 它将网络通信过程分为四个层次&#xff0c;这四层分别是&#xff1a;网络接口层、互联网层、传输层和应用层。 网络接口层负责在计算机和网络硬件之间传输数据&#xff0c;负责在物理网络上发送和接…

Conmi的正确答案——在Kibana中进入Elasticsearch的索引管理页面

Elasticsearch版本&#xff1a;7.17.25 Kibana版本&#xff1a;7.17.25 注&#xff1a;索引即类似mysql的表。 0、进入首页 1、未创建任何“索引模式”时&#xff1a; 1.1、点击左边的三横菜单&#xff1b; 1.2、点击“Discover”&#xff0c;进入“发现”页面&#xff1b; 2…

Marin说PCB之电源的Surface Current Density知多少?

小编我是一位资深的国漫迷&#xff0c;像什么仙逆&#xff0c;斗破&#xff0c;斗罗&#xff0c;完美世界&#xff0c;遮天&#xff0c;凡人修仙传&#xff0c;少年歌行等&#xff0c;为了可以看这些视频小编我不惜花费了攒了很多年的私房钱去开了这个三个平台的会员啊&#xf…

安卓开发之数据库的创建与删除

目录 前言&#xff1a;基础夯实&#xff1a;数据库的创建数据库的删除注意事项 效果展示&#xff1a;遇到问题&#xff1a;如何在虚拟机里面找到这个文件首先&#xff0c;找到虚拟机文件的位置其次&#xff0c;找到数据库文件的位置 核心代码&#xff1a; 前言&#xff1a; 安…

UV紫外相机

在产业设备领域&#xff0c;运用相机进行检测的需求很大&#xff0c;应用也很多样&#xff0c;对于图像传感器性能的期望逐年提升。在这样的背景下&#xff0c;可拍摄紫外线&#xff08;UV&#xff1a;Ultra Violet&#xff09;图像的相机拥有越来越广泛的应用场景。将UV照明和…

Python学习的自我理解和想法(22)

学的是b站的课程&#xff08;千锋教育&#xff09;&#xff0c;跟老师写程序&#xff0c;不是自创的代码&#xff01; 今天是学Python的第22天&#xff0c;学的内容是正则表达式&#xff0c;明天会出一篇详细实例介绍。电脑刚修好&#xff01;开学了&#xff0c;时间不多&…

ARM base instruction -- bfi

Bitfield Insert copies a bitfield of <width> bits from the least significant bits of the source register to bit position <lsb> of the destination register, leaving the other destination bits unchanged. 位域插入将<width>位的位域从源寄存器的…

Python实现深度学习模型预测控制(tensorflow)DL-MPC(Deep Learning Model Predictive Control

链接&#xff1a;深度学习模型预测控制 &#xff08;如果认为有用&#xff0c;动动小手为我点亮github小星星哦&#xff09;&#xff0c;持续更新中…… 链接&#xff1a;WangXiaoMingo/TensorDL-MPC&#xff1a;DL-MPC&#xff08;深度学习模型预测控制&#xff09;是基于 P…

ubuntu交叉编译expat库给arm平台使用

1.下载expat库源码: https://github.com/libexpat/libexpat/release?page=2 wget https://github.com/libexpat/libexpat/release/download/R_2_3_0/expat-2.3.0.tar.bz2 下载成功: 2.解压expat库,并进入解压后的目录: tar xjf expat-2.3.0.tar.bz2 cd expat-2.3.0 <…

C# 编程语言学习教程

C# 编程语言学习教程 目录 C# 简介 1.1 什么是 C#1.2 C# 的特点1.3 C# 的应用领域 环境搭建 2.1 安装 Visual Studio2.2 创建第一个 C# 项目 基础语法 3.1 数据类型3.2 控制结构3.3 数组与字符串 面向对象编程 4.1 类与对象4.2 继承与多态4.3 接口与抽象类 常用库与框架 5.1 .…

文件上传知识梳理:原理、工具、绕过、利用与防御

文章简介&#xff1a; 本文全面梳理了文件上传相关知识&#xff0c;包括文件上传漏洞的原理及危害&#xff0c;介绍了 Webshell 相关工具&#xff08;如冰蝎、哥斯拉、蚁剑&#xff09;&#xff0c;详细阐述了文件上传绕过检测的多种方法&#xff08;前端检测、服务端检测的各…