完成telnet 、fetch功能

Client.c

@@ -9,6 +9,7 @@
 
 #define buf_SIZE 1024
 #define SIZE 1024 //每次发送文件的大小
+#define NameSize 32
 
 //服务器信息
 int serv_sock;
@@ -21,13 +22,18 @@ int fd_max;
 
 //缓存定义
 char Recvbuf[buf_SIZE];
-char Name[32]; //名字
+char Name[NameSize]; //名字
+char Inputbuf[buf_SIZE / 2];
+char Filename[NameSize];
+
+int telnet_sock = -1;
 
 void error_handling(char *message);
 void Shell();
 void Read_a_send(char *filename);
 void Excute();
 void ReturnFile(char *filename);
+void RecvFile(char *filename);
 
 int main(int argc, char *argv[])
 {
@@ -44,7 +50,7 @@ int main(int argc, char *argv[])
         error_handling("connect() error\n");
 
     strcpy(Name, argv[2]);
-    printf("Name:%s", Name);
+    printf("Name:%s\n", Name);
     printf("Connect Ok ServerIp %s \t%d\n", inet_ntoa(serv_adr.sin_addr), ntohs(serv_adr.sin_port));
 
     FD_ZERO(&reads);
@@ -55,15 +61,10 @@ int main(int argc, char *argv[])
     while (1)
     {
         cpy_reads = reads;
-        struct timeval time_out;
-        time_out.tv_sec = 1;
-        time_out.tv_usec = 0;
-        int ret = select(fd_max + 1, &cpy_reads, NULL, NULL, &time_out);
+        int ret = select(fd_max + 1, &cpy_reads, NULL, NULL, NULL);
 
         if (ret == -1)
             error_handling("select() error");
-        else if (ret == 0)
-            continue;
         else
             Shell();
     }
@@ -76,16 +77,40 @@ void Shell()
 
     if (FD_ISSET(0, &cpy_reads)) //从键盘读取数据
     {
-        // char Sendbuf[buf_SIZE + 32 + 1];
-        //memset(Sendbuf, 0, buf_SIZE);
         memset(Recvbuf, 0, buf_SIZE);
-        read(0, Recvbuf, buf_SIZE - 1);
-        //sprintf(Sendbuf, "[%s]%s", Name, Recvbuf);
-        //write(serv_sock, Recvbuf, sizeof(Sendbuf));
-        write(serv_sock, Recvbuf, strlen(Recvbuf)); //这里测试用strlen();
+        read(0, Recvbuf, buf_SIZE);
+
+        char Tempbuf[buf_SIZE];
+        char telnet_char[32];
+        memcpy(Tempbuf, Recvbuf, sizeof(Recvbuf));
+        char *p = strtok(Tempbuf, " ");
+        if (p != NULL)
+        {
+            char *pnext = strtok(NULL, " ");
+            if (pnext != NULL)
+            {
+                memcpy(telnet_char, p + 1, pnext - p);
+            }
+        }
+        if (0 == strcmp(telnet_char, "telnet"))
+        {
+            printf("Telnet Open\n");
+            telnet_sock = atoi(p);
+        }
+
+        if (Recvbuf[0] == ':' || Recvbuf[0] == '$')
+            write(serv_sock, Recvbuf, strlen(Recvbuf));
+        else
+        {
+            char Messagebuf[buf_SIZE + NameSize + 2];
+            memset(Messagebuf, 0, sizeof(Messagebuf));
+            sprintf(Messagebuf, "[%s]%s", Name, Recvbuf);
+            write(serv_sock, Messagebuf, strlen(Messagebuf));
+        }
     }
     if (FD_ISSET(serv_sock, &cpy_reads)) //接受数据，输出到屏幕
     {
+
         memset(Recvbuf, 0, sizeof(Recvbuf));
         int str_len = read(serv_sock, Recvbuf, buf_SIZE);
         if (str_len == 0) //如果收到长度为0的数据，说明服务器没了
@@ -95,7 +120,7 @@ void Shell()
             return;
         }
 
-        //对字符串进行分解，提取命令，方便进行不同命令操作
+        //对字符串进行分解，分解之后，可以知道是「命令」还是「信息」
         char deliver[buf_SIZE];
         memcpy(deliver, Recvbuf, sizeof(Recvbuf));
         char *p;
@@ -108,43 +133,57 @@ void Shell()
                 break;
         }
 
-        // if (p != NULL)
-        //     printf("Command :%s\n", p);
-
         char cmd[32];
         if (p != NULL)
             sprintf(cmd, "%s", p);
-        if (0 == strcmp(cmd, "ls"))
-        {
-            Excute(); //执行命令
-        }
-        else if (0 == strcmp(cmd, "pwd"))
-        {
-            Excute(); //执行命令
-        }
+
+        if (Recvbuf[0] == '[') ////默认为聊天
+            write(1, Recvbuf, sizeof(Recvbuf));
         else if (0 == strcmp(cmd, "fetch"))
         {
             p = strtok(NULL, " ");
             if (p != NULL)
-                ReturnFile(p);
-            printf("fetch filename :%s\n", p);
+            {
+                sprintf(Filename, "%s", p);
+                Filename[strlen(Filename) - 1] = '\0';
+                printf("fetch filename :%s\n", Filename);
+                ReturnFile(Filename);
+            }
         }
-        else if (0 == strcmp(cmd, "touch") || 0 == strcmp(cmd, "mkdri"))
-            Excute();
-        else if (0 == strcmp(cmd, "echo"))
+        else if (0 == strcmp(cmd, "return"))
+        {
+            write(1, "成功fetch文件", strlen("成功fetch文件"));
+            //接受文件
+            char create_cmd[64];
+            sprintf(create_cmd, "%s %s", "touch", "Hello.txt");
+            RecvFile(Filename);
+        }
+        else if (Recvbuf[0] == 'e')
             Excute();
-        else if (0 == strcmp(cmd, "push"))
-            ;
-        else //默认为聊天
-            if (Recvbuf[0] != 'e')
+        else if (Recvbuf[0] != '[')
             write(1, Recvbuf, sizeof(Recvbuf));
-        else
-            Excute();
     }
 }
 
+void ReturnFile(char *filename)
+{
+    // char cmd[32];
+    // memset(cmd, 0, sizeof(cmd));
+    // strcpy(cmd, "return fetch");
+    // write(serv_sock, cmd, strlen(cmd)); //返回命令
+
+    sleep(1);
+    char name[32];
+    // strcpy(name, filename);
+    sprintf(name, "%s", filename);
+    //write(serv_sock, name, 32);
+    Read_a_send(filename);
+}
+
 void Excute()
 {
+    //system("echo \"\" > cmd.txt ");
+    system("touch cmd.txt");
     puts(Recvbuf);
     int ret = system(Recvbuf);
     if (ret < 0)
@@ -158,11 +197,16 @@ void Read_a_send(char *p)
 {
     char filename[32];
     sprintf(filename, "%s", p);
+
     FILE *fp;
     int totlen;
     char Recvbuf[buf_SIZE];
+
     if ((fp = fopen(filename, "rb")) == NULL)
+    {
         puts("fopen() error\n");
+        return;
+    }
     fseek(fp, 0, SEEK_END);
     totlen = ftell(fp);
 
@@ -193,13 +237,83 @@ void Read_a_send(char *p)
     send(serv_sock, Recvbuf, lenlast, 0);
 }
 
-void ReturnFile(char *filename)
+void RecvFile(char *filename)
 {
-    char cmd[32];
-    memset(cmd, 0, sizeof(cmd));
-    strcpy(cmd, "return fetch");
-    send(serv_sock, cmd, strlen(cmd), 0);
-    Read_a_send(filename);
+    char recvBuf[buf_SIZE];
+    int ret = read(serv_sock, recvBuf, buf_SIZE);
+    int Total = atoi(recvBuf); //先接收，文件大小
+    //接受
+    FILE *fp;
+    fp = fopen("Hello.txt", "wb");
+    if (fp == NULL)
+        error_handling("fopen() error\n");
+
+    int cnt = 0;
+    sleep(0.5);
+    while (1)
+    {
+        memset(recvBuf, 0, sizeof(recvBuf));
+        ret = read(serv_sock, recvBuf, SIZE);
+        fwrite(recvBuf, ret, 1, fp);
+        if (recvBuf[0] == '\0')
+        {
+            printf("recvBuf[0] == 0\n");
+            printf("ret == %d\n", ret);
+        }
+        else
+        {
+            printf("recvBuf[0] = %c\n", recvBuf[0]);
+        }
+        cnt += ret;
+        if (cnt >= Total || ret == -1)
+            break;
+    }
+    fclose(fp);
+    puts("End of Recv\n");
+}
+
+void Read(char *p)
+{
+    char filename[32];
+    sprintf(filename, "%s", p);
+
+    FILE *fp;
+    int totlen;
+    char Recvbuf[buf_SIZE];
+
+    if ((fp = fopen(filename, "rb")) == NULL)
+    {
+        puts("fopen() error\n");
+        return;
+    }
+    fseek(fp, 0, SEEK_END);
+    totlen = ftell(fp);
+
+    //发送文件长度，方便服务器
+    memset(Recvbuf, 0, sizeof(Recvbuf));
+    sprintf(Recvbuf, "%d", totlen);
+    send(serv_sock, Recvbuf, strlen(Recvbuf) + 1, 0);
+
+    int cnt = totlen / SIZE;
+    int len1 = SIZE;
+    int lenlast;
+    if (totlen % SIZE)
+    {
+        lenlast = totlen - cnt * SIZE;
+        cnt = cnt + 1;
+    }
+    rewind(fp);
+
+    for (int i = 0; i < cnt - 1; i++)
+    {
+        fread(Recvbuf, SIZE, 1, fp);
+        sleep(0.1);
+        send(serv_sock, Recvbuf, SIZE, 0);
+        memset(Recvbuf, 0, sizeof(Recvbuf));
+    }
+    fread(Recvbuf, lenlast, 1, fp);
+    fclose(fp);
+    send(serv_sock, Recvbuf, lenlast, 0);
 }
 
 void error_handling(char *message)

Hello.txt

+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+#include <arpa/inet.h>
+#include <sys/socket.h>
+#include <sys/select.h>
+#include <sys/time.h>
+#define Max_clnt_cnt 100
+#define BUF_SIZE 1024
+#define SIZE 1024
+#define NameSize 32
+#define Passwdsize 32
+
+int clnt_cnt = 0; //客户端连接数
+socklen_t socklen_IPV4;
+int clnt_socks[Max_clnt_cnt];               //客户端的socket数组
+struct sockaddr_in clnt_adrs[Max_clnt_cnt]; //客户端socket数组对应的ip地址
+char clnt_Name[Max_clnt_cnt][NameSize];     //名字数组
+int telnet_sock = -1;                       //远程连接的socket号
+int self_sock = -1;
+
+/*要连接的服务器信息*/
+int serv_sock;               //服务器socket
+struct sockaddr_in serv_adr; //服务器地址
+
+/*用于Select的全局变量*/
+fd_set reads;
+fd_set cpy_reads;
+int fd_max;
+
+/*全局缓冲区*/
+char buf[BUF_SIZE];
+
+char password[Passwdsize];
+char Filename[NameSize];
+
+void error_handling(char *message);
+void socket_handling();
+void Execute(int sock, int cmd_len);
+void Message_handle(int sock);
+void Server_ls(int sock);
+void Recv_a_Send(int sock, char *filename);
+void Fetch(int sock, int cmd_len);
+void Sendfile(int sock, char *p);
+
+int main(int argc, char *argv[])
+{
+
+    serv_sock = socket(AF_INET, SOCK_STREAM, 0);
+    memset(&serv_adr, 0, sizeof(serv_adr));
+    serv_adr.sin_family = AF_INET;
+    serv_adr.sin_addr.s_addr = inet_addr("100.2.169.8");
+    serv_adr.sin_port = htons(atoi(argv[1]));
+    //serv_adr.sin_port = htons(9991);
+
+    if (bind(serv_sock, (struct sockaddr *)&serv_adr, sizeof(serv_adr)) == -1)
+        error_handling("bind() error\n");
+    printf("bind Ok ServerIp %s \t%d\n", inet_ntoa(serv_adr.sin_addr), ntohs(serv_adr.sin_port));
+    if (listen(serv_sock, Max_clnt_cnt) == -1)
+        error_handling("listen() error\n");
+
+    FD_ZERO(&reads);
+    fd_max = serv_sock;
+    FD_SET(serv_sock, &reads);
+
+    while (1)
+    {
+        /* SELECT 处理连接 */
+        cpy_reads = reads;
+        // struct timeval time_out;
+        // time_out.tv_sec = 2;
+        // time_out.tv_usec = 0;
+        int ret = select(fd_max + 1, &cpy_reads, NULL, NULL, NULL);
+        if (ret == -1)
+            error_handling("select() error\n");
+        // else if (ret == 0)
+        // continue;
+        else
+            socket_handling();
+    }
+    close(serv_sock);
+
+    return 0;
+}
+
+void socket_handling()
+{
+    for (int i = 0; i < fd_max + 1; i++)
+    {
+        if (FD_ISSET(i, &cpy_reads))
+        {
+            if (i == serv_sock)
+            {
+                struct sockaddr_in tmp_cln_adr;
+                int tongxunsock = accept(serv_sock, (struct sockaddr *)&tmp_cln_adr, &socklen_IPV4);
+
+                struct timeval Recvtimeout; //测试了很多次，给接受设置个超时比较好
+                Recvtimeout.tv_sec = 3;
+                Recvtimeout.tv_usec = 0;
+                setsockopt(tongxunsock, SOL_SOCKET, SO_RCVTIMEO, &Recvtimeout, sizeof(Recvtimeout));
+
+                clnt_adrs[clnt_cnt++] = tmp_cln_adr;
+                clnt_socks[clnt_cnt - 1] = tongxunsock;
+                FD_SET(tongxunsock, &reads);
+                if (fd_max < tongxunsock)
+                    fd_max = tongxunsock;
+                printf("connected client :%d\t %s %d\n", tongxunsock, inet_ntoa(tmp_cln_adr.sin_addr), ntohs(tmp_cln_adr.sin_port));
+            }
+            else
+            {
+                sleep(0.2); //睡0.2秒确保一次性收取所有信息
+                int str_len;
+                memset(buf, 0, BUF_SIZE);
+                str_len = read(i, buf, BUF_SIZE);
+                if (str_len == 0)
+                {
+                    printf("client:%d 断开连接\n", i);
+                    FD_CLR(i, &reads);
+                    close(i);
+                    int location;
+                    for (int k = 0; k < sizeof(clnt_socks); k++) //TODO 这里只是将某个数组上的位置置0，可以做到移动数组
+                    {
+                        if (clnt_socks[k] == i)
+                        {
+                            clnt_socks[k] = -1;
+                            clnt_adrs[k].sin_addr.s_addr = 0;
+                            clnt_adrs[k].sin_port = 0;
+                        }
+                    }
+                }
+                else //对客户端的数据进行处理
+                {
+                    printf("buf[0] = %c\n", buf[0]);
+
+                    //如果客户端返回return fetch命令，我就可以提取第一个单词，看是不是return
+                    char temp[BUF_SIZE];
+                    memcpy(temp, buf, sizeof(buf));
+                    char *p;
+                    p = strtok(temp, " ");
+                    char retcmd[32];
+                    if (p != NULL)
+                    {
+                        sprintf(retcmd, "%s", p + 1);
+                        printf("retcmd :%s\n", retcmd);
+                    }
+
+                    if (buf[0] == '$') //执行服务端命令
+                    {
+                        if (buf[1] == 'l' && buf[2] == 's')
+                            Server_ls(i); //处理  服务端「$ls」 命令
+                    }
+                    else if (buf[0] == ':' && 0 == strcmp(retcmd, "fetch"))
+                    { //TODO 服务端要把文件接受下来，再发送
+                        p = strtok(NULL, " ");
+                        sprintf(Filename, "%s", p);
+                        printf("filename :%s\n", Filename);
+                        Fetch(i, str_len);
+                    }
+                    else if (buf[0] == ':' && 0 == strcmp(retcmd, "telnet"))
+                    {
+                        p = strtok(NULL, " ");
+                        if (p != NULL)
+                            telnet_sock = atoi(p);
+                        self_sock = i;
+                        printf("telsock = %d\n", telnet_sock);
+                    }
+                    else if (buf[0] == ':') //执行客户端命令
+                        Execute(i, str_len);
+                    else
+                        Message_handle(i);
+                }
+            }
+        }
+    }
+}
+
+void Message_handle(int sock)
+{
+    char temp[BUF_SIZE];
+    memcpy(temp, buf, sizeof(buf));
+    char *p;
+    char Name[32];
+    p = strtok(temp, "]");
+    if (p != NULL)
+    {
+        char *pre = p;
+        p = strtok(NULL, "]");
+        if (p != NULL)
+            memcpy(Name, pre + 1, p - pre - 1);
+    }
+    printf("Name:%s\n", Name);
+    memcpy(clnt_Name[sock], Name, strlen(Name));
+    printf("Clnt_Name[%d]:%s\n", sock, clnt_Name[sock]);
+
+    for (int j = serv_sock + 1; j < fd_max + 1; j++)
+    {
+        if (j != sock)
+        {
+            write(j, buf, strlen(buf));
+            printf("返回数据给 %s --> client:%d", j, buf);
+        }
+    }
+}
+
+void Execute(int sock, int cmd_len)
+{
+    char prefix[] = "echo 8002904 | sudo -S";
+    //char backfix[] = "> cmd.txt 2>&1";
+    char backfix[] = " 2>&1";
+    char cmd_buf[BUF_SIZE + 40];
+    char tmp[BUF_SIZE];
+    memset(tmp, 0, sizeof(tmp));
+    strncpy(tmp, buf + 1, strlen(buf) - 1);
+    tmp[cmd_len - 1] = '\0';
+    printf("tmp == %s\n", tmp);
+    sprintf(cmd_buf, "%s %s %s", prefix, tmp, backfix);
+    puts(cmd_buf);
+
+    if (telnet_sock > -1)
+        write(telnet_sock, cmd_buf, strlen(cmd_buf));
+    int ret = system("touch Temp.txt");
+    if (ret == -1)
+    {
+        puts("system(\"touch Temp.txt\") error");
+        return;
+    }
+    Recv_a_Send(sock, "Temp.txt");
+}
+
+void Recv_a_Send(int sock, char *p)
+{
+    char filename[32];
+    if (p != NULL)
+        sprintf(filename, "%s", p);
+    printf("filename:%s\n", filename);
+
+    char recvBuf[BUF_SIZE];
+    int ret;
+    if (telnet_sock > -1)
+        ret = recv(telnet_sock, recvBuf, BUF_SIZE, 0);
+    int Total = atoi(recvBuf); //先接收，文件大小
+    //接受
+    FILE *fp;
+    fp = fopen(filename, "wb");
+    if (fp == NULL)
+        error_handling("fopen() error\n");
+
+    int cnt = 0;
+    sleep(1);
+    while (1)
+    {
+        memset(recvBuf, 0, sizeof(recvBuf));
+        if (telnet_sock > -1)
+            ret = read(telnet_sock, recvBuf, SIZE);
+        fwrite(recvBuf, ret, 1, fp);
+        if (recvBuf[0] == '\0')
+        {
+            printf("recvBuf[0] == 0\n");
+            printf("ret == %d\n", ret);
+        }
+        else
+        {
+            printf("recvBuf[0] = %c\n", recvBuf[0]);
+        }
+        write(sock, recvBuf, ret); //接完就发
+        cnt += ret;
+        if (cnt >= Total || ret == -1)
+            break;
+    }
+
+    fclose(fp);
+}
+
+void Recvfile(int sock, char *p)
+{
+    char filename[32];
+    if (p != NULL)
+        sprintf(filename, "%s", p);
+    printf("filename:%s\n", filename);
+
+    char recvBuf[BUF_SIZE];
+    int ret;
+    if (telnet_sock > -1)
+        ret = recv(telnet_sock, recvBuf, BUF_SIZE, 0);
+    int Total = atoi(recvBuf); //先接收，文件大小
+    //接受
+    FILE *fp;
+    fp = fopen(filename, "wb");
+    if (fp == NULL)
+        error_handling("fopen() error\n");
+
+    int cnt = 0;
+    sleep(1);
+    while (1)
+    {
+        memset(recvBuf, 0, sizeof(recvBuf));
+        if (telnet_sock > -1)
+            ret = read(telnet_sock, recvBuf, SIZE);
+        fwrite(recvBuf, ret, 1, fp);
+        if (recvBuf[0] == '\0')
+        {
+            printf("recvBuf[0] == 0\n");
+            printf("ret == %d\n", ret);
+        }
+        else
+        {
+            printf("recvBuf[0] = %c\n", recvBuf[0]);
+        }
+        cnt += ret;
+        if (cnt >= Total || ret == -1)
+            break;
+    }
+    fclose(fp);
+}
+
+void Fetch(int sock, int cmd_len)
+{
+    char prefix[] = "echo 8002904 | sudo -S";
+    char backfix[] = " 2>&1";
+    char cmd_buf[BUF_SIZE + 40];
+    char tmp[BUF_SIZE];
+    memset(tmp, 0, sizeof(tmp));
+    strncpy(tmp, buf + 1, strlen(buf) - 1);
+    tmp[cmd_len - 1] = '\0';
+    printf("tmp == %s\n", tmp);
+    sprintf(cmd_buf, "%s %s %s", prefix, tmp, backfix);
+    puts(cmd_buf);
+
+    if (telnet_sock > -1)
+        write(telnet_sock, cmd_buf, strlen(cmd_buf));
+
+    char create_cmd[64];
+    sprintf(create_cmd, "%s %s", "touch", Filename);
+    int ret = system(create_cmd);
+    if (ret == -1)
+    {
+        puts(create_cmd);
+        puts("error");
+        return;
+    }
+
+    //先发命令给  主动的客户端
+
+    Recvfile(sock, "world.txt");
+    sleep(2);
+    Sendfile(sock, "world.txt");
+}
+
+void Sendfile(int sock, char *p)
+{
+    char ret_cmd[64] = "echo return  return return return return return";
+    write(sock, ret_cmd, strlen(ret_cmd));
+    write(1, ret_cmd, strlen(ret_cmd));
+    sleep(1);
+    char filename[32];
+    sprintf(filename, "%s", p);
+
+    FILE *fp;
+    int totlen;
+    char Recvbuf[BUF_SIZE];
+
+    if ((fp = fopen(filename, "rb")) == NULL)
+    {
+        puts("fopen() error\n");
+        return;
+    }
+    fseek(fp, 0, SEEK_END);
+    totlen = ftell(fp);
+
+    //发送文件长度，方便客户端
+    memset(Recvbuf, 0, sizeof(Recvbuf));
+    sprintf(Recvbuf, "%d", totlen);
+    write(sock, Recvbuf, strlen(Recvbuf) + 1);
+
+    sleep(1);
+    int cnt = totlen / SIZE;
+    int len1 = SIZE;
+    int lenlast;
+    if (totlen % SIZE)
+    {
+        lenlast = totlen - cnt * SIZE;
+        cnt = cnt + 1;
+    }
+    rewind(fp);
+
+    for (int i = 0; i < cnt - 1; i++)
+    {
+        fread(Recvbuf, SIZE, 1, fp);
+        sleep(0.1);
+        send(sock, Recvbuf, SIZE, 0);
+        memset(Recvbuf, 0, sizeof(Recvbuf));
+    }
+    fread(Recvbuf, lenlast, 1, fp);
+    fclose(fp);
+    send(sock, Recvbuf, lenlast, 0);
+}
+
+void Server_ls(int sock)
+{
+    for (int k = 0; k < clnt_cnt; k++)
+    {
+        char hostMess[50];
+        char port[8];
+        char sockNum[8];
+        char Name[32];
+        strcpy(hostMess, inet_ntoa(clnt_adrs[k].sin_addr));
+        strcat(hostMess, "\t");
+        sprintf(port, "%d", ntohs(clnt_adrs[k].sin_port));
+        strcat(port, "\t");
+        strcat(hostMess, port);
+        strcat(hostMess, "sockNum\t");
+        sprintf(sockNum, "%d", clnt_socks[k]);
+        strcat(hostMess, sockNum);
+        strcat(hostMess, "\t");
+        strcat(hostMess, clnt_Name[k + 4]);
+        strcat(hostMess, "\n");
+        send(sock, hostMess, strlen(hostMess), 0);
+    }
+}
+
+void error_handling(char *message)
+{
+    printf("%s", message);
+    exit(0);
+}

Server.c

@@ -9,12 +9,16 @@
 #define Max_clnt_cnt 100
 #define BUF_SIZE 1024
 #define SIZE 1024
+#define NameSize 32
+#define Passwdsize 32
 
 int clnt_cnt = 0; //客户端连接数
 socklen_t socklen_IPV4;
 int clnt_socks[Max_clnt_cnt];               //客户端的socket数组
 struct sockaddr_in clnt_adrs[Max_clnt_cnt]; //客户端socket数组对应的ip地址
-int telnet_data[Max_clnt_cnt];
+char clnt_Name[Max_clnt_cnt][NameSize];     //名字数组
+int telnet_sock = -1;                       //远程连接的socket号
+int self_sock = -1;
 
 /*要连接的服务器信息*/
 int serv_sock;               //服务器socket
@@ -28,12 +32,17 @@ int fd_max;
 /*全局缓冲区*/
 char buf[BUF_SIZE];
 
+char password[Passwdsize];
+char Filename[NameSize];
+
 void error_handling(char *message);
 void socket_handling();
 void Execute(int sock, int cmd_len);
 void Message_handle(int sock);
-void Command_ls(int sock);
+void Server_ls(int sock);
 void Recv_a_Send(int sock, char *filename);
+void Fetch(int sock, int cmd_len);
+void Sendfile(int sock, char *p);
 
 int main(int argc, char *argv[])
 {
@@ -59,14 +68,14 @@ int main(int argc, char *argv[])
     {
         /* SELECT 处理连接 */
         cpy_reads = reads;
-        struct timeval time_out;
-        time_out.tv_sec = 2;
-        time_out.tv_usec = 0;
-        int ret = select(fd_max + 1, &cpy_reads, NULL, NULL, &time_out);
+        // struct timeval time_out;
+        // time_out.tv_sec = 2;
+        // time_out.tv_usec = 0;
+        int ret = select(fd_max + 1, &cpy_reads, NULL, NULL, NULL);
         if (ret == -1)
             error_handling("select() error\n");
-        else if (ret == 0)
-            continue;
+        // else if (ret == 0)
+        // continue;
         else
             socket_handling();
     }
@@ -86,7 +95,7 @@ void socket_handling()
                 struct sockaddr_in tmp_cln_adr;
                 int tongxunsock = accept(serv_sock, (struct sockaddr *)&tmp_cln_adr, &socklen_IPV4);
 
-                struct timeval Recvtimeout;
+                struct timeval Recvtimeout; //测试了很多次，给接受设置个超时比较好
                 Recvtimeout.tv_sec = 3;
                 Recvtimeout.tv_usec = 0;
                 setsockopt(tongxunsock, SOL_SOCKET, SO_RCVTIMEO, &Recvtimeout, sizeof(Recvtimeout));
@@ -100,7 +109,7 @@ void socket_handling()
             }
             else
             {
-                sleep(0.2); //睡1秒确保一次性收取所有信息
+                sleep(0.2); //睡0.2秒确保一次性收取所有信息
                 int str_len;
                 memset(buf, 0, BUF_SIZE);
                 str_len = read(i, buf, BUF_SIZE);
@@ -123,25 +132,41 @@ void socket_handling()
                 else //对客户端的数据进行处理
                 {
                     printf("buf[0] = %c\n", buf[0]);
-                    // char *p;
-                    // p = strtok(buf, " ");
-                    // char retcmd[32];
-                    // if (p != NULL)
-                    //     sprintf(retcmd, "%s", p);
-                    if (buf[0] == ':') //执行客户端命令
-                        Execute(i, str_len);
-                    else if (buf[0] == '$') //执行服务端命令
+
+                    //如果客户端返回return fetch命令，我就可以提取第一个单词，看是不是return
+                    char temp[BUF_SIZE];
+                    memcpy(temp, buf, sizeof(buf));
+                    char *p;
+                    p = strtok(temp, " ");
+                    char retcmd[32];
+                    if (p != NULL)
+                    {
+                        sprintf(retcmd, "%s", p + 1);
+                        printf("retcmd :%s\n", retcmd);
+                    }
+
+                    if (buf[0] == '$') //执行服务端命令
                     {
                         if (buf[1] == 'l' && buf[2] == 's')
-                            Command_ls(i); //处理  服务端「$ls」 命令
+                            Server_ls(i); //处理  服务端「$ls」 命令
                     }
-                    // else if (0 == strcmp(retcmd, "return"))
-                    // { //TODO 服务端要把文件接受下来，再发送
-                    //     char filename[32];
-                    //     memset(filename, 0, sizeof(filename));
-                    //     recv(i, filename, sizeof(filename), 0);
-                    //     Recv_a_Send(i - 1, filename);
-                    // }
+                    else if (buf[0] == ':' && 0 == strcmp(retcmd, "fetch"))
+                    { //TODO 服务端要把文件接受下来，再发送
+                        p = strtok(NULL, " ");
+                        sprintf(Filename, "%s", p);
+                        printf("filename :%s\n", Filename);
+                        Fetch(i, str_len);
+                    }
+                    else if (buf[0] == ':' && 0 == strcmp(retcmd, "telnet"))
+                    {
+                        p = strtok(NULL, " ");
+                        if (p != NULL)
+                            telnet_sock = atoi(p);
+                        self_sock = i;
+                        printf("telsock = %d\n", telnet_sock);
+                    }
+                    else if (buf[0] == ':') //执行客户端命令
+                        Execute(i, str_len);
                     else
                         Message_handle(i);
                 }
@@ -152,12 +177,28 @@ void socket_handling()
 
 void Message_handle(int sock)
 {
+    char temp[BUF_SIZE];
+    memcpy(temp, buf, sizeof(buf));
+    char *p;
+    char Name[32];
+    p = strtok(temp, "]");
+    if (p != NULL)
+    {
+        char *pre = p;
+        p = strtok(NULL, "]");
+        if (p != NULL)
+            memcpy(Name, pre + 1, p - pre - 1);
+    }
+    printf("Name:%s\n", Name);
+    memcpy(clnt_Name[sock], Name, strlen(Name));
+    printf("Clnt_Name[%d]:%s\n", sock, clnt_Name[sock]);
+
     for (int j = serv_sock + 1; j < fd_max + 1; j++)
     {
         if (j != sock)
         {
             write(j, buf, strlen(buf));
-            printf("返回数据给client:%d-->%s", j, buf);
+            printf("返回数据给 %s --> client:%d", j, buf);
         }
     }
 }
@@ -166,19 +207,24 @@ void Execute(int sock, int cmd_len)
 {
     char prefix[] = "echo 8002904 | sudo -S";
     //char backfix[] = "> cmd.txt 2>&1";
-    char backfix[] = "";
+    char backfix[] = " 2>&1";
     char cmd_buf[BUF_SIZE + 40];
     char tmp[BUF_SIZE];
     memset(tmp, 0, sizeof(tmp));
-    strncpy(tmp, buf + 1, strlen(buf));
-    //tmp[str_len - 2] = '\0';
-    tmp[cmd_len - 2] = '\0';
+    strncpy(tmp, buf + 1, strlen(buf) - 1);
+    tmp[cmd_len - 1] = '\0';
     printf("tmp == %s\n", tmp);
     sprintf(cmd_buf, "%s %s %s", prefix, tmp, backfix);
     puts(cmd_buf);
 
-    write(sock + 1, cmd_buf, strlen(cmd_buf));
-    //printf("return cmd result\n");
+    if (telnet_sock > -1)
+        write(telnet_sock, cmd_buf, strlen(cmd_buf));
+    int ret = system("touch Temp.txt");
+    if (ret == -1)
+    {
+        puts("system(\"touch Temp.txt\") error");
+        return;
+    }
     Recv_a_Send(sock, "Temp.txt");
 }
 
@@ -187,13 +233,16 @@ void Recv_a_Send(int sock, char *p)
     char filename[32];
     if (p != NULL)
         sprintf(filename, "%s", p);
+    printf("filename:%s\n", filename);
 
     char recvBuf[BUF_SIZE];
-    int ret = recv(sock + 1, recvBuf, BUF_SIZE, 0);
+    int ret;
+    if (telnet_sock > -1)
+        ret = recv(telnet_sock, recvBuf, BUF_SIZE, 0);
     int Total = atoi(recvBuf); //先接收，文件大小
     //接受
     FILE *fp;
-    fp = fopen("Temp.txt", "wb");
+    fp = fopen(filename, "wb");
     if (fp == NULL)
         error_handling("fopen() error\n");
 
@@ -202,7 +251,8 @@ void Recv_a_Send(int sock, char *p)
     while (1)
     {
         memset(recvBuf, 0, sizeof(recvBuf));
-        ret = recv(sock + 1, recvBuf, SIZE, 0);
+        if (telnet_sock > -1)
+            ret = read(telnet_sock, recvBuf, SIZE);
         fwrite(recvBuf, ret, 1, fp);
         if (recvBuf[0] == '\0')
         {
@@ -222,20 +272,148 @@ void Recv_a_Send(int sock, char *p)
     fclose(fp);
 }
 
-void Command_ls(int sock)
+void Recvfile(int sock, char *p)
+{
+    char filename[32];
+    if (p != NULL)
+        sprintf(filename, "%s", p);
+    printf("filename:%s\n", filename);
+
+    char recvBuf[BUF_SIZE];
+    int ret;
+    if (telnet_sock > -1)
+        ret = recv(telnet_sock, recvBuf, BUF_SIZE, 0);
+    int Total = atoi(recvBuf); //先接收，文件大小
+    //接受
+    FILE *fp;
+    fp = fopen(filename, "wb");
+    if (fp == NULL)
+        error_handling("fopen() error\n");
+
+    int cnt = 0;
+    sleep(1);
+    while (1)
+    {
+        memset(recvBuf, 0, sizeof(recvBuf));
+        if (telnet_sock > -1)
+            ret = read(telnet_sock, recvBuf, SIZE);
+        fwrite(recvBuf, ret, 1, fp);
+        if (recvBuf[0] == '\0')
+        {
+            printf("recvBuf[0] == 0\n");
+            printf("ret == %d\n", ret);
+        }
+        else
+        {
+            printf("recvBuf[0] = %c\n", recvBuf[0]);
+        }
+        cnt += ret;
+        if (cnt >= Total || ret == -1)
+            break;
+    }
+    fclose(fp);
+}
+
+void Fetch(int sock, int cmd_len)
+{
+    char prefix[] = "echo 8002904 | sudo -S";
+    char backfix[] = " 2>&1";
+    char cmd_buf[BUF_SIZE + 40];
+    char tmp[BUF_SIZE];
+    memset(tmp, 0, sizeof(tmp));
+    strncpy(tmp, buf + 1, strlen(buf) - 1);
+    tmp[cmd_len - 1] = '\0';
+    printf("tmp == %s\n", tmp);
+    sprintf(cmd_buf, "%s %s %s", prefix, tmp, backfix);
+    puts(cmd_buf);
+
+    if (telnet_sock > -1)
+        write(telnet_sock, cmd_buf, strlen(cmd_buf));
+
+    char create_cmd[64];
+    sprintf(create_cmd, "%s %s", "touch", Filename);
+    int ret = system(create_cmd);
+    if (ret == -1)
+    {
+        puts(create_cmd);
+        puts("error");
+        return;
+    }
+
+    //先发命令给  主动的客户端
+
+    Recvfile(sock, "world.txt");
+    sleep(2);
+    Sendfile(sock, "world.txt");
+}
+
+void Sendfile(int sock, char *p)
+{
+    char ret_cmd[64] = "echo return  return return return return return";
+    write(sock, ret_cmd, strlen(ret_cmd));
+    write(1, ret_cmd, strlen(ret_cmd));
+    sleep(1);
+    char filename[32];
+    sprintf(filename, "%s", p);
+
+    FILE *fp;
+    int totlen;
+    char Recvbuf[BUF_SIZE];
+
+    if ((fp = fopen(filename, "rb")) == NULL)
+    {
+        puts("fopen() error\n");
+        return;
+    }
+    fseek(fp, 0, SEEK_END);
+    totlen = ftell(fp);
+
+    //发送文件长度，方便客户端
+    memset(Recvbuf, 0, sizeof(Recvbuf));
+    sprintf(Recvbuf, "%d", totlen);
+    write(sock, Recvbuf, strlen(Recvbuf) + 1);
+
+    sleep(1);
+    int cnt = totlen / SIZE;
+    int len1 = SIZE;
+    int lenlast;
+    if (totlen % SIZE)
+    {
+        lenlast = totlen - cnt * SIZE;
+        cnt = cnt + 1;
+    }
+    rewind(fp);
+
+    for (int i = 0; i < cnt - 1; i++)
+    {
+        fread(Recvbuf, SIZE, 1, fp);
+        sleep(0.1);
+        send(sock, Recvbuf, SIZE, 0);
+        memset(Recvbuf, 0, sizeof(Recvbuf));
+    }
+    fread(Recvbuf, lenlast, 1, fp);
+    fclose(fp);
+    send(sock, Recvbuf, lenlast, 0);
+}
+
+void Server_ls(int sock)
 {
     for (int k = 0; k < clnt_cnt; k++)
     {
         char hostMess[50];
-        strcpy(hostMess, inet_ntoa(clnt_adrs[k].sin_addr));
         char port[8];
-        sprintf(port, "%d", ntohs(clnt_adrs[k].sin_port));
+        char sockNum[8];
+        char Name[32];
+        strcpy(hostMess, inet_ntoa(clnt_adrs[k].sin_addr));
         strcat(hostMess, "\t");
+        sprintf(port, "%d", ntohs(clnt_adrs[k].sin_port));
+        strcat(port, "\t");
         strcat(hostMess, port);
-        strcat(hostMess, "\tsockNum\t");
-        char sockNum[8];
+        strcat(hostMess, "sockNum\t");
         sprintf(sockNum, "%d", clnt_socks[k]);
         strcat(hostMess, sockNum);
+        strcat(hostMess, "\t");
+        strcat(hostMess, clnt_Name[k + 4]);
         strcat(hostMess, "\n");
         send(sock, hostMess, strlen(hostMess), 0);
     }

Temp.txt

+Client
+Client.c
+cmd.txt
+Hello.txt
+LICENSE
+README.en.md
+README.md
+Server
+Server.c
+strlen.c
+Temp.txt
+Test.c
+Test.c
+
+world.txt

Test.c

+#include <stdio.h>
\ No newline at end of file

Test.c

+#include <stdio.h>
\ No newline at end of file

cmd.txt

-total 80
-drwxr-xr-x 1 coderon coderon   512 May 18 21:06 .
-drwxr-xr-x 1 coderon coderon   512 May 16 23:56 ..
--rw-r--r-- 1 coderon coderon     0 May 18 20:42 123.txt
--rwxr-xr-x 1 coderon coderon 18304 May 18 21:03 Client
--rw-r--r-- 1 coderon coderon  5216 May 18 21:02 Client.c
--rwxrwxrwx 1 root    root        0 May 18 21:15 cmd.txt
-drwxr-xr-x 1 coderon coderon   512 May 17 11:38 .git
--rw-r--r-- 1 coderon coderon   430 May 16 23:56 .gitignore
--rw-r--r-- 1 coderon coderon   496 May 16 23:56 LICENSE
--rw-r--r-- 1 coderon coderon   903 May 16 23:56 README.en.md
--rw-r--r-- 1 coderon coderon   992 May 16 23:56 README.md
--rwxr-xr-x 1 coderon coderon 22592 May 18 21:03 Server
--rw-r--r-- 1 coderon coderon  7507 May 18 21:02 Server.c
--rw-r--r-- 1 coderon coderon     0 May 18 21:14 Temp.txt
+Client
+Client.c
+cmd.txt
+Hello.txt
+LICENSE
+README.en.md
+README.md
+Server
+Server.c
+strlen.c
+Temp.txt
+Test.c
+Test.c
+
+world.txt

world.txt

+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+#include <arpa/inet.h>
+#include <sys/socket.h>
+#include <sys/select.h>
+#include <sys/time.h>
+#define Max_clnt_cnt 100
+#define BUF_SIZE 1024
+#define SIZE 1024
+#define NameSize 32
+#define Passwdsize 32
+
+int clnt_cnt = 0; //客户端连接数
+socklen_t socklen_IPV4;
+int clnt_socks[Max_clnt_cnt];               //客户端的socket数组
+struct sockaddr_in clnt_adrs[Max_clnt_cnt]; //客户端socket数组对应的ip地址
+char clnt_Name[Max_clnt_cnt][NameSize];     //名字数组
+int telnet_sock = -1;                       //远程连接的socket号
+int self_sock = -1;
+
+/*要连接的服务器信息*/
+int serv_sock;               //服务器socket
+struct sockaddr_in serv_adr; //服务器地址
+
+/*用于Select的全局变量*/
+fd_set reads;
+fd_set cpy_reads;
+int fd_max;
+
+/*全局缓冲区*/
+char buf[BUF_SIZE];
+
+char password[Passwdsize];
+char Filename[NameSize];
+
+void error_handling(char *message);
+void socket_handling();
+void Execute(int sock, int cmd_len);
+void Message_handle(int sock);
+void Server_ls(int sock);
+void Recv_a_Send(int sock, char *filename);
+void Fetch(int sock, int cmd_len);
+void Sendfile(int sock, char *p);
+
+int main(int argc, char *argv[])
+{
+
+    serv_sock = socket(AF_INET, SOCK_STREAM, 0);
+    memset(&serv_adr, 0, sizeof(serv_adr));
+    serv_adr.sin_family = AF_INET;
+    serv_adr.sin_addr.s_addr = inet_addr("100.2.169.8");
+    serv_adr.sin_port = htons(atoi(argv[1]));
+    //serv_adr.sin_port = htons(9991);
+
+    if (bind(serv_sock, (struct sockaddr *)&serv_adr, sizeof(serv_adr)) == -1)
+        error_handling("bind() error\n");
+    printf("bind Ok ServerIp %s \t%d\n", inet_ntoa(serv_adr.sin_addr), ntohs(serv_adr.sin_port));
+    if (listen(serv_sock, Max_clnt_cnt) == -1)
+        error_handling("listen() error\n");
+
+    FD_ZERO(&reads);
+    fd_max = serv_sock;
+    FD_SET(serv_sock, &reads);
+
+    while (1)
+    {
+        /* SELECT 处理连接 */
+        cpy_reads = reads;
+        // struct timeval time_out;
+        // time_out.tv_sec = 2;
+        // time_out.tv_usec = 0;
+        int ret = select(fd_max + 1, &cpy_reads, NULL, NULL, NULL);
+        if (ret == -1)
+            error_handling("select() error\n");
+        // else if (ret == 0)
+        // continue;
+        else
+            socket_handling();
+    }
+    close(serv_sock);
+
+    return 0;
+}
+
+void socket_handling()
+{
+    for (int i = 0; i < fd_max + 1; i++)
+    {
+        if (FD_ISSET(i, &cpy_reads))
+        {
+            if (i == serv_sock)
+            {
+                struct sockaddr_in tmp_cln_adr;
+                int tongxunsock = accept(serv_sock, (struct sockaddr *)&tmp_cln_adr, &socklen_IPV4);
+
+                struct timeval Recvtimeout; //测试了很多次，给接受设置个超时比较好
+                Recvtimeout.tv_sec = 3;
+                Recvtimeout.tv_usec = 0;
+                setsockopt(tongxunsock, SOL_SOCKET, SO_RCVTIMEO, &Recvtimeout, sizeof(Recvtimeout));
+
+                clnt_adrs[clnt_cnt++] = tmp_cln_adr;
+                clnt_socks[clnt_cnt - 1] = tongxunsock;
+                FD_SET(tongxunsock, &reads);
+                if (fd_max < tongxunsock)
+                    fd_max = tongxunsock;
+                printf("connected client :%d\t %s %d\n", tongxunsock, inet_ntoa(tmp_cln_adr.sin_addr), ntohs(tmp_cln_adr.sin_port));
+            }
+            else
+            {
+                sleep(0.2); //睡0.2秒确保一次性收取所有信息
+                int str_len;
+                memset(buf, 0, BUF_SIZE);
+                str_len = read(i, buf, BUF_SIZE);
+                if (str_len == 0)
+                {
+                    printf("client:%d 断开连接\n", i);
+                    FD_CLR(i, &reads);
+                    close(i);
+                    int location;
+                    for (int k = 0; k < sizeof(clnt_socks); k++) //TODO 这里只是将某个数组上的位置置0，可以做到移动数组
+                    {
+                        if (clnt_socks[k] == i)
+                        {
+                            clnt_socks[k] = -1;
+                            clnt_adrs[k].sin_addr.s_addr = 0;
+                            clnt_adrs[k].sin_port = 0;
+                        }
+                    }
+                }
+                else //对客户端的数据进行处理
+                {
+                    printf("buf[0] = %c\n", buf[0]);
+
+                    //如果客户端返回return fetch命令，我就可以提取第一个单词，看是不是return
+                    char temp[BUF_SIZE];
+                    memcpy(temp, buf, sizeof(buf));
+                    char *p;
+                    p = strtok(temp, " ");
+                    char retcmd[32];
+                    if (p != NULL)
+                    {
+                        sprintf(retcmd, "%s", p + 1);
+                        printf("retcmd :%s\n", retcmd);
+                    }
+
+                    if (buf[0] == '$') //执行服务端命令
+                    {
+                        if (buf[1] == 'l' && buf[2] == 's')
+                            Server_ls(i); //处理  服务端「$ls」 命令
+                    }
+                    else if (buf[0] == ':' && 0 == strcmp(retcmd, "fetch"))
+                    { //TODO 服务端要把文件接受下来，再发送
+                        p = strtok(NULL, " ");
+                        sprintf(Filename, "%s", p);
+                        printf("filename :%s\n", Filename);
+                        Fetch(i, str_len);
+                    }
+                    else if (buf[0] == ':' && 0 == strcmp(retcmd, "telnet"))
+                    {
+                        p = strtok(NULL, " ");
+                        if (p != NULL)
+                            telnet_sock = atoi(p);
+                        self_sock = i;
+                        printf("telsock = %d\n", telnet_sock);
+                    }
+                    else if (buf[0] == ':') //执行客户端命令
+                        Execute(i, str_len);
+                    else
+                        Message_handle(i);
+                }
+            }
+        }
+    }
+}
+
+void Message_handle(int sock)
+{
+    char temp[BUF_SIZE];
+    memcpy(temp, buf, sizeof(buf));
+    char *p;
+    char Name[32];
+    p = strtok(temp, "]");
+    if (p != NULL)
+    {
+        char *pre = p;
+        p = strtok(NULL, "]");
+        if (p != NULL)
+            memcpy(Name, pre + 1, p - pre - 1);
+    }
+    printf("Name:%s\n", Name);
+    memcpy(clnt_Name[sock], Name, strlen(Name));
+    printf("Clnt_Name[%d]:%s\n", sock, clnt_Name[sock]);
+
+    for (int j = serv_sock + 1; j < fd_max + 1; j++)
+    {
+        if (j != sock)
+        {
+            write(j, buf, strlen(buf));
+            printf("返回数据给 %s --> client:%d", j, buf);
+        }
+    }
+}
+
+void Execute(int sock, int cmd_len)
+{
+    char prefix[] = "echo 8002904 | sudo -S";
+    //char backfix[] = "> cmd.txt 2>&1";
+    char backfix[] = " 2>&1";
+    char cmd_buf[BUF_SIZE + 40];
+    char tmp[BUF_SIZE];
+    memset(tmp, 0, sizeof(tmp));
+    strncpy(tmp, buf + 1, strlen(buf) - 1);
+    tmp[cmd_len - 1] = '\0';
+    printf("tmp == %s\n", tmp);
+    sprintf(cmd_buf, "%s %s %s", prefix, tmp, backfix);
+    puts(cmd_buf);
+
+    if (telnet_sock > -1)
+        write(telnet_sock, cmd_buf, strlen(cmd_buf));
+    int ret = system("touch Temp.txt");
+    if (ret == -1)
+    {
+        puts("system(\"touch Temp.txt\") error");
+        return;
+    }
+    Recv_a_Send(sock, "Temp.txt");
+}
+
+void Recv_a_Send(int sock, char *p)
+{
+    char filename[32];
+    if (p != NULL)
+        sprintf(filename, "%s", p);
+    printf("filename:%s\n", filename);
+
+    char recvBuf[BUF_SIZE];
+    int ret;
+    if (telnet_sock > -1)
+        ret = recv(telnet_sock, recvBuf, BUF_SIZE, 0);
+    int Total = atoi(recvBuf); //先接收，文件大小
+    //接受
+    FILE *fp;
+    fp = fopen(filename, "wb");
+    if (fp == NULL)
+        error_handling("fopen() error\n");
+
+    int cnt = 0;
+    sleep(1);
+    while (1)
+    {
+        memset(recvBuf, 0, sizeof(recvBuf));
+        if (telnet_sock > -1)
+            ret = read(telnet_sock, recvBuf, SIZE);
+        fwrite(recvBuf, ret, 1, fp);
+        if (recvBuf[0] == '\0')
+        {
+            printf("recvBuf[0] == 0\n");
+            printf("ret == %d\n", ret);
+        }
+        else
+        {
+            printf("recvBuf[0] = %c\n", recvBuf[0]);
+        }
+        write(sock, recvBuf, ret); //接完就发
+        cnt += ret;
+        if (cnt >= Total || ret == -1)
+            break;
+    }
+
+    fclose(fp);
+}
+
+void Recvfile(int sock, char *p)
+{
+    char filename[32];
+    if (p != NULL)
+        sprintf(filename, "%s", p);
+    printf("filename:%s\n", filename);
+
+    char recvBuf[BUF_SIZE];
+    int ret;
+    if (telnet_sock > -1)
+        ret = recv(telnet_sock, recvBuf, BUF_SIZE, 0);
+    int Total = atoi(recvBuf); //先接收，文件大小
+    //接受
+    FILE *fp;
+    fp = fopen(filename, "wb");
+    if (fp == NULL)
+        error_handling("fopen() error\n");
+
+    int cnt = 0;
+    sleep(1);
+    while (1)
+    {
+        memset(recvBuf, 0, sizeof(recvBuf));
+        if (telnet_sock > -1)
+            ret = read(telnet_sock, recvBuf, SIZE);
+        fwrite(recvBuf, ret, 1, fp);
+        if (recvBuf[0] == '\0')
+        {
+            printf("recvBuf[0] == 0\n");
+            printf("ret == %d\n", ret);
+        }
+        else
+        {
+            printf("recvBuf[0] = %c\n", recvBuf[0]);
+        }
+        cnt += ret;
+        if (cnt >= Total || ret == -1)
+            break;
+    }
+    fclose(fp);
+}
+
+void Fetch(int sock, int cmd_len)
+{
+    char prefix[] = "echo 8002904 | sudo -S";
+    char backfix[] = " 2>&1";
+    char cmd_buf[BUF_SIZE + 40];
+    char tmp[BUF_SIZE];
+    memset(tmp, 0, sizeof(tmp));
+    strncpy(tmp, buf + 1, strlen(buf) - 1);
+    tmp[cmd_len - 1] = '\0';
+    printf("tmp == %s\n", tmp);
+    sprintf(cmd_buf, "%s %s %s", prefix, tmp, backfix);
+    puts(cmd_buf);
+
+    if (telnet_sock > -1)
+        write(telnet_sock, cmd_buf, strlen(cmd_buf));
+
+    char create_cmd[64];
+    sprintf(create_cmd, "%s %s", "touch", Filename);
+    int ret = system(create_cmd);
+    if (ret == -1)
+    {
+        puts(create_cmd);
+        puts("error");
+        return;
+    }
+
+    //先发命令给  主动的客户端
+
+    Recvfile(sock, "world.txt");
+    sleep(2);
+    Sendfile(sock, "world.txt");
+}
+
+void Sendfile(int sock, char *p)
+{
+    char ret_cmd[64] = "echo return  return return return return return";
+    write(sock, ret_cmd, strlen(ret_cmd));
+    write(1, ret_cmd, strlen(ret_cmd));
+    sleep(1);
+    char filename[32];
+    sprintf(filename, "%s", p);
+
+    FILE *fp;
+    int totlen;
+    char Recvbuf[BUF_SIZE];
+
+    if ((fp = fopen(filename, "rb")) == NULL)
+    {
+        puts("fopen() error\n");
+        return;
+    }
+    fseek(fp, 0, SEEK_END);
+    totlen = ftell(fp);
+
+    //发送文件长度，方便客户端
+    memset(Recvbuf, 0, sizeof(Recvbuf));
+    sprintf(Recvbuf, "%d", totlen);
+    write(sock, Recvbuf, strlen(Recvbuf) + 1);
+
+    sleep(1);
+    int cnt = totlen / SIZE;
+    int len1 = SIZE;
+    int lenlast;
+    if (totlen % SIZE)
+    {
+        lenlast = totlen - cnt * SIZE;
+        cnt = cnt + 1;
+    }
+    rewind(fp);
+
+    for (int i = 0; i < cnt - 1; i++)
+    {
+        fread(Recvbuf, SIZE, 1, fp);
+        sleep(0.1);
+        send(sock, Recvbuf, SIZE, 0);
+        memset(Recvbuf, 0, sizeof(Recvbuf));
+    }
+    fread(Recvbuf, lenlast, 1, fp);
+    fclose(fp);
+    send(sock, Recvbuf, lenlast, 0);
+}
+
+void Server_ls(int sock)
+{
+    for (int k = 0; k < clnt_cnt; k++)
+    {
+        char hostMess[50];
+        char port[8];
+        char sockNum[8];
+        char Name[32];
+        strcpy(hostMess, inet_ntoa(clnt_adrs[k].sin_addr));
+        strcat(hostMess, "\t");
+        sprintf(port, "%d", ntohs(clnt_adrs[k].sin_port));
+        strcat(port, "\t");
+        strcat(hostMess, port);
+        strcat(hostMess, "sockNum\t");
+        sprintf(sockNum, "%d", clnt_socks[k]);
+        strcat(hostMess, sockNum);
+        strcat(hostMess, "\t");
+        strcat(hostMess, clnt_Name[k + 4]);
+        strcat(hostMess, "\n");
+        send(sock, hostMess, strlen(hostMess), 0);
+    }
+}
+
+void error_handling(char *message)
+{
+    printf("%s", message);
+    exit(0);
+}