利用TCP通信实现文件传输和通信

前言

我们上一章已经熟悉了理论知识，这一章来练习一下

1.实现文件的传输

1.1 客户端

dir_client.c

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include<sys/types.h>
#include<sys/stat.h>
#include<fcntl.h>



//服务端和客户端通信，实现文件的发送（但是服务单只负责接收，客户端负责发送）
//客户端程序

int main(int argc,char** argv)
{
    //1.创建待连接套接字
    int socket_fd = socket(AF_INET,SOCK_STREAM,0);
    if(socket_fd == -1){
        printf("创建套接字失败\n");
        return -1;
    }

    //2.绑定套接字与网络地址
    //第二个参数需要这个结构体
    struct sockaddr_in s_addr;
    s_addr.sin_family = AF_INET;
    s_addr.sin_port = htons(atoi(argv[2]));//设置端口//主机字节序的短整型数据，atoi将字符串转为整形
    s_addr.sin_addr.s_addr = inet_addr(argv[1]);//将点分十进制转为无符号的32位网络地址

    int bind_ok = bind(socket_fd,(struct sockaddr*)&s_addr,sizeof(s_addr));
    if(bind_ok==-1){
        perror("bind failed");
    }


    //3.请求连接
    int socket_ok = connect(socket_fd,(struct sockaddr*)&s_addr,sizeof(s_addr));
    if(socket_ok==-1){
        perror("连接失败\n");
        return -1;
    }

    //开始文件传输吧
    //打开一个文件
    int fd  = open("./1.txt",O_RDWR);
    if(fd==-1){
        perror("文件打开失败");
        return -1;
    }
    
    char buf[128];
    while(1){

        memset(buf,0,sizeof(buf));

        //读取文件内容
        ssize_t n = read(fd,buf,sizeof(buf)-1);

        //发送文件的内容
        send(socket_fd,buf,sizeof(buf),0);

        if(n==0){
            printf("—————发送文件成功—————\n");
            close(fd);
            break;
        }

    }

    close(socket_fd);
    return 0;
}

1.2 服务端

dir_server.c

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include<sys/types.h>
#include<sys/stat.h>
#include<fcntl.h>

//服务端和客户端通信，实现文件的发送（但是服务单只负责接收，客户端负责发送）
//服务端程序

int main(int argc,char** argv)
{
    //1.创建待连接套接字
    int socket_fd = socket(AF_INET,SOCK_STREAM,0);
    if(socket_fd == -1){
        printf("创建套接字失败\n");
        return -1;
    }

    //2.绑定套接字与网络地址
    //第二个参数需要这个结构体
    struct sockaddr_in s_addr;
    s_addr.sin_family = AF_INET;
    s_addr.sin_port = htons(atoi(argv[2]));//设置端口 //主机字节序的短整型数据 ，atoi将字符串转为整形
    s_addr.sin_addr.s_addr = inet_addr(argv[1]);//将将点分十进制转转为无符号的32位网络地址

    int bind_ok = bind(socket_fd,(struct sockaddr*)&s_addr,sizeof(s_addr));
    if(bind_ok==-1){
        perror("bind failed");
    }

    //3.设置监听
    int socket_listen = listen(socket_fd,4);
    if(socket_listen==-1){
        perror("监听失败");
        return -1;
    }

    //4.等待对端连接请求
    printf("等待连接\n");
    int socket_ok = accept(socket_fd,NULL,NULL);
    if(socket_ok==-1){
        perror("连接失败\n");
        return -1;
    }
    printf("连接成功\n");

    //开始接收文件
    //创建一个文件
    int fd2  = open("./2.txt",O_WRONLY | O_CREAT,0777);
    if(fd2==-1){
        perror("文件打开失败");
        return -1;
    }

    char buf[128];
    while(1){
        memset(buf,0,sizeof(buf));
        //5.接收文件
        recv(socket_ok,buf,sizeof(buf),0);//阻塞等待

        //将文件内容写入另一个文件，实现文件的传输
        ssize_t n = write(fd2,buf,strlen(buf));

        //退出
        if(n==0){
            printf("————接收文件成功————\n");
            close(fd2);
            break;
        }
        
    }
    close(socket_fd);
    close(socket_ok);
    return 0;
}

2. 实现服务客户端的双向通信

shuangxiang_server.c

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <fcntl.h>
#include <pthread.h>
#include <sys/stat.h>


//服务端和客户端双向通信
//服务端程序
int socket_ok = -1;

void* fasong(void* arg){
    char msg[128];

    while(1){
        memset(msg,0,sizeof(msg));

        fgets(msg,sizeof(msg),stdin);//键盘输入
        //发送数据
        send(socket_ok,msg,sizeof(msg),0);
        printf("服务端发送：%s",msg);

        //退出
        if(strcmp("bye\n",msg)==0){
            break;
        }

    }
}


int main(int argc,char** argv)
{
    //1.创建待连接套接字
    int socket_fd = socket(AF_INET,SOCK_STREAM,0);
    if(socket_fd == -1){
        printf("创建套接字失败\n");
        return -1;
    }

    //2.绑定套接字与网络地址
    //第二个参数需要这个结构体
    struct sockaddr_in s_addr;
    s_addr.sin_family = AF_INET;
    s_addr.sin_port = htons(atoi(argv[2]));//设置端口 //主机字节序的短整型数据
    s_addr.sin_addr.s_addr = inet_addr(argv[1]);//将将点分十进制转转为无符号的32位网络地址

    int bind_ok = bind(socket_fd,(struct sockaddr*)&s_addr,sizeof(s_addr));
    if(bind_ok==-1){
        perror("bind failed");
    }

    //3.设置监听
    int socket_listen = listen(socket_fd,4);
    if(socket_listen==-1){
        perror("监听失败");
        return -1;
    }

    //4.等待对端连接请求
    printf("等待连接\n");
    struct sockaddr_in c_addr;//保存客户端地址信息
    socklen_t size_len = sizeof(c_addr);//因为第三个参数需要socklen_t类型，所以我们提前转一下类型
    socket_ok = accept(socket_fd,(struct sockaddr*)&c_addr,&size_len);
    if(socket_ok==-1){
        perror("连接失败\n");
        return -1;
    }
    printf("连接成功\n");

    //开始畅聊吧
    //创建线程
    pthread_t tid;
    pthread_create(&tid,NULL,&fasong,NULL);

    char buf[128];
    while(1){
        memset(buf,0,sizeof(buf));
        //5.接收消息
        recv(socket_ok,buf,sizeof(buf),0);//阻塞等待
        printf("服务端接收到：%s",buf);

        //退出
        if(strcmp("bye\n",buf)==0){
            break;
        }
    }
    close(socket_fd);
    close(socket_ok);
    return 0;
}

shuangxiang_client.c

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <fcntl.h>
#include <pthread.h>
#include <sys/stat.h>


//服务端和客户端双向通信
//客户端程序
int socket_fd = -1;

void* jieshou(void* arg){

    char msg[128];
    while(1){
        memset(msg,0,sizeof(msg));
        //5.接收消息
        recv(socket_fd,msg,sizeof(msg),0);//阻塞等待
        printf("客户端接收到：%s",msg);

        //退出
        if(strcmp("bye\n",msg)==0){
            break;
        }
    }
}


int main(int argc,char** argv)
{
    //1.创建待连接套接字
    socket_fd = socket(AF_INET,SOCK_STREAM,0);
    if(socket_fd == -1){
        printf("创建套接字失败\n");
        return -1;
    }

    //2.绑定套接字与网络地址
    //第二个参数需要这个结构体
    struct sockaddr_in s_addr;
    s_addr.sin_family = AF_INET;
    s_addr.sin_port = htons(atoi(argv[2]));//设置端口//主机字节序的短整型数据
    s_addr.sin_addr.s_addr = inet_addr(argv[1]);//将点分十进制转为无符号的32位网络地址

    int bind_ok = bind(socket_fd,(struct sockaddr*)&s_addr,sizeof(s_addr));
    if(bind_ok==-1){
        perror("bind failed");
    }


    //3.请求连接
    connect(socket_fd,(struct sockaddr*)&s_addr,sizeof(s_addr));
    

    //开始畅聊吧
    //创建线程
    pthread_t tid;
    pthread_create(&tid,NULL,&jieshou,NULL);

    char buf[128];
    while(1){

        memset(buf,0,sizeof(buf));

        fgets(buf,sizeof(buf),stdin);//从键盘获取输入
        //发送消息
        send(socket_fd,buf,sizeof(buf),0);
        printf("客户端发送：%s",buf);

        //退出
        if(strcmp("bye\n",buf)==0){
            break;
        }
    }

    close(socket_fd);
    return 0;
}

3. 实现多个客户端和服务端通信

more_one_server.c

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <fcntl.h>
#include <pthread.h>
#include <sys/stat.h>


//多个客户端通信和服务端单向通信
//服务端程序

//自己创建的结构体，用于保存已连接套接字，和客户端端口号
struct message{
    unsigned short port;
    int socket_ok1;  
};

void* jieshou(void* arg){

    char msg[128];

    //取出客户端端口号
    // unsigned short* port = (unsigned short*)arg;

    //取出客户端端口号
    // unsigned short* port = calloc(1,2);
    // port = (unsigned short*)arg;

    //取出客户端的信息
    struct message* ms = (struct message*)arg;
    unsigned short port1 = ms->port;
    int socket_ok = ms->socket_ok1;

    while(1){

        memset(msg,0,sizeof(msg));
        //接收数据
        recv(socket_ok,msg,sizeof(msg),0);

        printf("服务端接收到端口号为%u：%s",port1,msg);

        //退出
        if(strcmp("bye\n",msg)==0){
            break;
        }

    }
}


int main(int argc,char** argv)
{
    //1.创建待连接套接字
    int socket_fd = socket(AF_INET,SOCK_STREAM,0);
    if(socket_fd == -1){
        printf("创建套接字失败\n");
        return -1;
    }

    //2.绑定套接字与网络地址
    //第二个参数需要这个结构体
    struct sockaddr_in s_addr;
    s_addr.sin_family = AF_INET;
    s_addr.sin_port = htons(atoi(argv[2]));//设置端口 //主机字节序的短整型数据
    s_addr.sin_addr.s_addr = inet_addr(argv[1]);//将将点分十进制转转为无符号的32位网络地址

    int bind_ok = bind(socket_fd,(struct sockaddr*)&s_addr,sizeof(s_addr));
    if(bind_ok==-1){
        perror("bind failed");
    }

    //3.设置监听
    int socket_listen = listen(socket_fd,4);
    if(socket_listen==-1){
        perror("监听失败");
        return -1;
    }

    

    //开始畅聊吧
    //创建线程
    pthread_t tid;
    
    int socket_ok;
    char buf[128];
    while(1){

        //4.等待对端连接请求
        printf("等待连接\n");
        struct sockaddr_in c_addr;//保存客户端地址信息
        socklen_t size_len = sizeof(c_addr);//因为第三个参数需要socklen_t类型，所以我们提前转一下类型
        socket_ok = accept(socket_fd,(struct sockaddr*)&c_addr,&size_len);
        if(socket_ok==-1){
            perror("连接失败\n");
            return -1;
        }
        printf("连接成功\n");


        //取出客户端端口号
        // unsigned short* port = calloc(1,2);
        // *port = ntohs(c_addr.sin_port);

        //取出客户端端口号
        // unsigned short p = ntohs(c_addr.sin_port);//取出客户端端口号
        // short* port = &p;


        //自己创建的结构体，用于保存已连接套接字，和客户端端口号
        struct message ms;
        ms.port = ntohs(c_addr.sin_port);
        ms.socket_ok1 = socket_ok;
        
        pthread_create(&tid,NULL,&jieshou,(void*)&ms);
        
    }

    close(socket_fd);
    close(socket_ok);
    return 0;
}

more_one_client.c

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <string.h>
#include <unistd.h>
#include <stdlib.h>
#include <fcntl.h>
#include <pthread.h>
#include <sys/stat.h>


//多个客户端通信和服务端单向通信
//客户端程序
int socket_fd = -1;

void* jieshou(void* arg){

    char msg[128];
    while(1){
        memset(msg,0,sizeof(msg));
        //5.接收消息
        recv(socket_fd,msg,sizeof(msg),0);//阻塞等待
        printf("客户端接收到：%s",msg);

        //退出
        if(strcmp("bye\n",msg)==0){
            break;
        }
    }
}


int main(int argc,char** argv)
{
    //1.创建待连接套接字
    socket_fd = socket(AF_INET,SOCK_STREAM,0);
    if(socket_fd == -1){
        printf("创建套接字失败\n");
        return -1;
    }

    //2.绑定套接字与网络地址
    //第二个参数需要这个结构体
    struct sockaddr_in s_addr;
    s_addr.sin_family = AF_INET;
    s_addr.sin_port = htons(atoi(argv[2]));//设置端口//主机字节序的短整型数据
    s_addr.sin_addr.s_addr = inet_addr(argv[1]);//将点分十进制转为无符号的32位网络地址

    int bind_ok = bind(socket_fd,(struct sockaddr*)&s_addr,sizeof(s_addr));
    if(bind_ok==-1){
        perror("bind failed");
    }


    //3.请求连接
    connect(socket_fd,(struct sockaddr*)&s_addr,sizeof(s_addr));
    

    //开始畅聊吧
    //创建线程
    pthread_t tid;
    pthread_create(&tid,NULL,&jieshou,NULL);

    char buf[128];
    while(1){

        memset(buf,0,sizeof(buf));

        fgets(buf,sizeof(buf),stdin);//从键盘获取输入
        //发送消息
        send(socket_fd,buf,sizeof(buf),0);
        printf("客户端发送：%s",buf);

        //退出
        if(strcmp("bye\n",buf)==0){
            break;
        }
    }

    close(socket_fd);
    return 0;
}