1.基于TCP通信服务器
程序代码:
1 #include<myhead.h>2 #define SER_IP "192.168.126.121"//服务器IP3 #define SER_PORT 8888//服务器端口号4 int main(int argc, const char *argv[])5 {6 //1.创建用于监听的套接字7 int sfd=-1;8 sfd=socket(AF_INET,SOCK_STREAM,0);9 //参数1:IPv4的通信10 //参数2:使用TCP通信类型11 //参数3:参数2以确定通信类型,012 if(sfd==-1)13 {14 perror("socket error");15 return -1;16 }17 printf("sfd=%d\n",sfd);//3 返回文件描述符,最小分配原则18 //2.绑定IP地址和端口号19 //2.1填充地址信息结构体20 struct sockaddr_in sin;21 sin.sin_family=AF_INET;//地址族22 sin.sin_port=htons(SER_PORT);//要2字节无符号整数端口号(网络字节序)23 //将主机字节序转换为网络字节序24 sin.sin_addr.s_addr=inet_addr(SER_IP);//IP地址(sin的sin_addr的s_addr)25 //要IP地址的网络字节序,将点分十进制数据转换为4字节无符号整数的网络字节序26 //2.2绑定27 if(bind(sfd,(struct sockaddr *)&sin,sizeof(sin))==-1)28 //要绑定的套接字文件描述符,通用地址信号结构体,结构体大小29 {30 perror("bind error");31 return -1;32 }33 printf("bind success\n");34 //3.启动监听,允许客户端连接35 if(listen(sfd,128)==-1)36 {37 perror("listen error");38 return -1;39 }40 printf("listen success\n");41 //4.客户端发来连接请求后,创建新的用于通信的套接字42 //不想接收客户端地址信息结构体,则无需传参2,参343 //想要获取客户端地址信息结构体,要传入相关参数44 struct sockaddr_in cin;//用于接收客户端地址信息结构体45 socklen_t socklen=sizeof(cin);//用于接收客户端地址信息大小46 int newfd=accept(sfd,(struct sockaddr*)&cin,&socklen);47 //阻塞等待客户端请求,客户端发来连接请求后,创建新的套接字,返回套接字文件描述符48 //参数1:服务器套接字文件描述符49 //参数2:通用地址信号结构体,接收最新连接的客户端地址信息50 //参数3:客户端套接字大小,地址传递51 if(newfd==-1)//成功返回套接字文件描述符,失败-152 {53 perror("accept error");54 return -1;55 }56 printf("newfd=%d您有新的客户已经上线\n",newfd);57 printf("客户端IP:%s,端口号:%d\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port));58 //将IP地址的网络字节序(4字节无符号整数)转换为点分十进制字符串(IP地址的网络字节序)59 //将端口的网络字节序(2字节无符号整数)转换为主机字节序(端口的网络字节序)60 //5.通信套接字与客户端进行数据收发61 char rbuf[128]="";62 while(1)63 {64 //清空容器65 bzero(rbuf,sizeof(rbuf));66 //从套接字中读取数据67 int res=read(newfd,rbuf,sizeof(rbuf));68 if(res==0)69 {70 printf("客户端已下线\n");71 break;72 }73 printf("[%s:%d]:%s\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),rbuf);74 //将收到的消息加上其他字符回过去75 strcat(rbuf,"*_*");76 write(newfd,rbuf,strlen(rbuf));77 }78 //6.关闭套接字79 close(newfd);80 close(sfd);81 return 0;82 }
运行结果:
2. 基于TCP通信客户端
程序代码:
1 #include<myhead.h>2 #define SER_IP "192.168.126.121"//服务器IP3 #define SER_PORT 8888//服务器端口号4 int main(int argc, const char *argv[])5 {6 //1.创建用于通信的套接字文件描述符7 int cfd=socket(AF_INET,SOCK_STREAM,0);8 //使用IPv4通信,使用TCP通信类型,已确定通信类型09 if(cfd==-1)10 {11 perror("socket error");12 return -1;13 }14 printf("cfd=%d\n",cfd);//返回文件描述符,最小分配315 //2.绑定(不写系统默认绑定)16 //3.连接服务器17 //3.1填充要连接的服务器地址信息结构体18 struct sockaddr_in sin;19 sin.sin_family=AF_INET;//地址族20 sin.sin_port=htons(SER_PORT);//端口号21 sin.sin_addr.s_addr=inet_addr(SER_IP);//IP地址22 //3.2连接服务器23 if(connect(cfd,(struct sockaddr*)&sin,sizeof(sin))==-1)24 {25 perror("connect error");26 return -1;27 }28 printf("connect success\n");29 //4数据收发30 char wbuf[128]="";31 while(1)32 {33 //清空数据34 bzero(wbuf,sizeof(wbuf));35 printf("请输入>>>");36 fgets(wbuf,sizeof(wbuf),stdin);//终端输入37 wbuf[strlen(wbuf)-1]=0;38 //将数据发送给服务器39 send(cfd,wbuf,strlen(wbuf),0);40 printf("发送成功\n");41 if(strcmp(wbuf,"quit")==0)42 break;43 //接收服务器发来的消息44 //清空数据45 bzero(wbuf,sizeof(wbuf));46 recv(cfd,wbuf,sizeof(wbuf),0);47 printf("收到消息为;%s\n",wbuf);48 }49 //5.关闭套接字50 close(cfd);51 return 0;52 }
~
运行结果:
3.基于UDP通信服务器
程序代码:
1 #include<myhead.h>2 #define SER_IP "192.168.126.121"//服务器IP3 #define SER_PORT 8888//服务器端口号4 int main(int argc, const char *argv[])5 {6 //1.创建用于通信的套接字7 int sfd=socket(AF_INET,SOCK_DGRAM,0);8 if(sfd==-1)9 {10 perror("socket error");11 return -1;12 }13 printf("sfd=%d\n",sfd);14 //2.绑定IP地址和端口号15 //2.1填充地址信息结构体16 struct sockaddr_in sin;17 sin.sin_family=AF_INET;//地址族18 sin.sin_port=htons(SER_PORT);//端口号19 sin.sin_addr.s_addr=inet_addr(SER_IP);//IP地址20 //2.2绑定21 if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))==-1)22 {23 perror("bind error");24 return -1;25 }26 printf("bind success\n");27 //3.收发数据28 char rbuf[128]="";29 //定义容器接收对端地址信息结构体30 struct sockaddr_in cin;31 socklen_t socklen=sizeof(cin);32 while(1)33 {34 //清空数组35 bzero(rbuf,sizeof(rbuf));36 //接收数据37 recvfrom(sfd,rbuf,sizeof(rbuf),0,(struct sockaddr*)&cin,&socklen);38 printf("收到消息为:%s\n",rbuf);39 //将消息加*_*回过去40 strcat(rbuf,"*_*");41 if(sendto(sfd,rbuf,strlen(rbuf),0,(struct sockaddr*)&cin,socklen)=42 {43 perror("sendto error");44 return -1;45 }46 }47 //4.关闭套接字48 close(sfd);49 return 0;50 }
运行结果:
4.基于UDP的客户端
程序代码:
1 #include<myhead.h>2 #define SER_IP "192.168.126.121"//IP地址3 #define SER_PORT 8888//服务器端口4 int main(int argc, const char *argv[])5 {6 //1.创建用于通信的套接字7 int cfd=socket(AF_INET,SOCK_DGRAM,0);8 if(cfd==-1)9 {10 perror("socket error");11 return -1;12 }13 printf("cfd=%d\n",cfd);14 //2.绑定IP地址和端口号15 //非必要16 //3.收发数据17 char wbuf[128]="";18 //定义容器,记录服务器的地址信息结构体19 struct sockaddr_in sin;20 sin.sin_family=AF_INET;21 sin.sin_port=htons(SER_PORT);22 sin.sin_addr.s_addr=inet_addr(SER_IP);23 while(1)24 {25 //清空数组26 bzero(wbuf,sizeof(wbuf));27 //从终端获取数据28 printf("请输入>>>");29 fgets(wbuf,sizeof(wbuf),stdin);30 wbuf[strlen(wbuf)-1]=0;31 //将数据发送给服务器32 sendto(cfd,wbuf,sizeof(wbuf),0,(struct sockaddr*)&sin,sizeof(sin));33 printf("发送成功\n");34 //接收服务器回复的消息35 bzero(wbuf,sizeof(wbuf));36 recvfrom(cfd,wbuf,sizeof(wbuf),0,NULL,NULL);37 printf("收到消息:%s\n",wbuf);38 }39 //关闭套接字40 close(cfd);41 return 0;42 }
运行结果:
流程图:
面试: