前言
我们上一章已经熟悉了理论知识,这一章来练习一下
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;
}