目录

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