目录
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