這次是個(gè)點(diǎn)對(duì)點(diǎn)，不過(guò)我自己設(shè)計(jì)包，包中包括發(fā)送的字符串的長(zhǎng)度，和實(shí)際的字符串，使用結(jié)構(gòu)體來(lái)表示。

　　客戶端跟服務(wù)器在接收?qǐng)?bào)文時(shí)，首先接收字符串的長(zhǎng)度這一數(shù)值，然后將這一數(shù)值作為參數(shù)傳入readn接收固定長(zhǎng)度的字節(jié)數(shù)字符串。

　　看代碼，首先是服務(wù)器端：

　　

1 /*使用發(fā)送固定字節(jié)數(shù)報(bào)文的點(diǎn)對(duì)點(diǎn)聊天程序*/ 2 #include<stdio.h> 3 #include<unistd.h> 4 #include<sys/types.h> 5 #include<sys/socket.h> 6 #include<errno.h> 7 #include<netinet/in.h> 8 #include<string.h> 9 #include<stdlib.h> 10 struct packet{ 11 int len; 12 char buf[1024]; 13 }; 14 //讀取固定字節(jié)數(shù)目count 15 ssize_t readn(int fd,void* buf,size_t count) 16 { 17 size_t nleft=count; 18 ssize_t nread; 19 char *bufp=(char*)buf; 20 while(nleft>0) 21 { 22 if((nread=read(fd,bufp,nleft))<0) 23 { 24 if(errno==EINTR) 25 continue; 26 return -1; 27 } 28 if(nread==0) 29 return count-nleft; 30 bufp+=nread; 31 nleft-=nread; 32 } 33 return count; 34 } 35 36 ssize_t writen(int fd,void *buf,size_t count) 37 { 38 size_t nleft=count; 39 size_t nwrite; 40 char*bufp=(char*)buf; 41 while(nleft>0) 42 { 43 if((nwrite=write(fd,bufp,nleft))<0) 44 { 45 //注意這里不要將bufp寫成了buf 46 if(errno==EINTR) 47 { 48 continue; 49 } 50 return -1; 51 52 } 53 else if(nwrite==0) 54 continue; 55 bufp+=nwrite; 56 nleft-=nwrite; 57 } 58 return count; 59 } 60 61 62 //服務(wù)器處理連接的子進(jìn)程調(diào)用的服務(wù)函數(shù)，conn_fd是已連接描述符 63 void doservice(int conn_fd) 64 { 65 struct packet recvbuf; 66 int packet_len; 67 while(1) 68 { 69 memset(&recvbuf,0,sizeof(recvbuf)); 70 int ret=readn(conn_fd,&recvbuf.len,sizeof(recvbuf.len));//首先讀取自己設(shè)計(jì)的報(bào)文中真正的字符串的實(shí)際長(zhǎng)度 71 if(ret==-1) 72 { 73 perror("readn"); 74 exit(EXIT_FAILURE); 75 } 76 else if(ret==0) 77 { 78 printf("client has closed!!!\n");// 79 break; 80 } 81 packet_len=ntohl(recvbuf.len);//注意網(wǎng)絡(luò)上傳送的數(shù)字都應(yīng)該以網(wǎng)絡(luò)字節(jié)序發(fā)送，同理，收到之后，首先應(yīng)該將其轉(zhuǎn)換為主機(jī)字節(jié)序 82 ret=readn(conn_fd,&recvbuf.buf,packet_len);//接下來(lái)讀取真正的報(bào)文，其中將上一次收到包中的字符串長(zhǎng)度作為第3個(gè)參數(shù)傳入，表示確定讀取這么多字節(jié)數(shù) 83 if(ret==-1) 84 { 85 perror("readn"); 86 exit(EXIT_FAILURE); 87 } 88 else if(0==ret) 89 { 90 printf("client has closed"); 91 break; 92 } 93 fputs(recvbuf.buf,stdout); 94 writen(conn_fd,&recvbuf,4+packet_len);//其中4是表示包中字符串長(zhǎng)度的整數(shù)所需的4個(gè)字節(jié) 95 } 96 97 } 98 99 int main() 100 { 101 int sockfd=socket(AF_INET,SOCK_STREAM,0); 102 if(sockfd<0) perror("socket!!!!"); 103 104 int on=1; 105 int result=setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on));//啟用套接字選項(xiàng)，必須在bind之前完成 106 if(result<0) perror("setsockopt"); 107 108 struct sockaddr_in server_addr; 109 memset(&server_addr,0,sizeof(server_addr)); 110 server_addr.sin_family=AF_INET; 111 server_addr.sin_port=htons(888); 112 server_addr.sin_addr.s_addr=htonl(INADDR_ANY); 113 114 115 int res=bind(sockfd,(struct sockaddr*)&server_addr,sizeof(server_addr)); 116 if(res<0)perror("bind!!!"); 117 118 res=listen(sockfd,50); 119 if(res<0)perror("listen!!"); 120 121 int conn_fd; 122 struct sockaddr_in peeraddr; 123 int addr_len=sizeof(peeraddr); 124 pid_t pid; 125 while(1) 126 { 127 conn_fd=accept(sockfd,(struct sockaddr*)&peeraddr,&addr_len); 128 printf(" the ip of client:%s,the port of client:%d\n",inet_ntoa(peeraddr.sin_addr),ntohs(peeraddr.sin_port));//打印對(duì)等方的ip與端口 129 if(conn_fd<0)perror("accept!!"); 130 pid=fork(); 131 if(pid<0) 132 perror("fork failed"); 133 if(pid==0) 134 { //子進(jìn)程 135 close(sockfd); //子進(jìn)程首先關(guān)閉監(jiān)聽(tīng)套接字，因?yàn)樽舆M(jìn)程只利用accept返回的已連接套接字描述符處理連接 136 doservice(conn_fd); 137 exit(EXIT_SUCCESS); //子進(jìn)程處理完一個(gè)連接，直接就結(jié)束，否則又回到前面去accept，這是父進(jìn)程的工作 138 } 139 else close(conn_fd); //父進(jìn)程首先關(guān)閉已連接套接字，然后回到前面，繼續(xù)監(jiān)聽(tīng) 140 } 141 142 return 0; 143 }

然后是客戶端代碼：

1 /*使用發(fā)送固定字節(jié)數(shù)報(bào)文的點(diǎn)對(duì)點(diǎn)聊天程序*/ 2 3 4 #include<stdio.h> 5 #include<unistd.h> 6 #include<sys/types.h> 7 #include<sys/socket.h> 8 #include<errno.h> 9 #include<netinet/in.h> 10 #include<string.h> 11 #include<stdlib.h> 12 struct packet{ 13 int len; 14 char buf[1024]; 15 }; 16 17 18 ssize_t readn(int fd,void* buf,size_t count) 19 { 20 size_t nleft=count; 21 ssize_t nread; 22 char *bufp=(char*)buf; 23 while(nleft>0) 24 { 25 if((nread=read(fd,bufp,nleft))<0) 26 { 27 if(errno==EINTR) 28 continue; 29 return -1; 30 } 31 else if(nread==0) 32 return count-nleft; 33 bufp+=nread; 34 nleft-=nread; 35 } 36 return count; 37 38 } 39 ssize_t writen(int fd,void *buf,size_t count){ 40 size_t nleft=count; 41 size_t nwrite=0; 42 char*bufp=(char*)buf; 43 while(nleft>0) 44 { 45 if((nwrite=write(fd,bufp,nleft))<0) 46 { 47 //注意這里不要將bufp寫成了buf 48 if(errno==EINTR){ 49 continue; 50 } 51 return -1; 52 53 } 54 else if(nwrite==0) 55 continue; 56 bufp+=nwrite; 57 nleft-=nwrite; 58 59 } 60 return count; 61 } 62 63 int main(){ 64 int sockfd= socket(AF_INET,SOCK_STREAM,0); 65 if(sockfd<0)perror("socket"); 66 67 struct sockaddr_in server_addr; 68 memset(&server_addr,0,sizeof(server_addr)); 69 server_addr.sin_family=AF_INET; 70 server_addr.sin_port=htons(888); //this port number is owned by server,and client's port number is appointed by random 71 server_addr.sin_addr.s_addr=inet_addr("127.0.0.1");//服務(wù)器端的ip地址 72 73 int res=connect(sockfd,(struct sockaddr*)&server_addr,sizeof(server_addr)); 74 if(res<0)perror("connect!!!!!!!"); 75 76 struct packet recvbuf; 77 struct packet sendbuf; 78 memset(&recvbuf,0,sizeof(recvbuf)); 79 memset(&sendbuf,0,sizeof(sendbuf)); 80 while(fgets(sendbuf.buf,sizeof(sendbuf.buf),stdin)!=NULL) 81 { 82 int packet_len=strlen(sendbuf.buf); 83 sendbuf.len=htonl(packet_len); 84 writen(sockfd,&sendbuf,4+packet_len);// 85 //readn(sockfd,&recvbuf.len,sizeof(recvbuf.len)); 86 int ret=readn(sockfd,&recvbuf.len,sizeof(recvbuf.len));// 87 if(ret==-1) 88 { 89 perror("readn"); 90 exit(EXIT_FAILURE); 91 } 92 else if(ret<4) 93 { 94 printf("client has closed!!!\n");// 95 break; 96 } 97 packet_len=ntohl(recvbuf.len); 98 ret=readn(sockfd,&recvbuf.buf,packet_len); 99 if(ret==-1) 100 { 101 perror("readn"); 102 exit(EXIT_FAILURE); 103 } 104 else if(ret<packet_len) 105 { 106 printf("client has closed"); 107 break; 108 } 109 fputs(recvbuf.buf,stdout); 110 //writen(conn_fd,&recvbuf,4+packet_len); 111 112 113 //fputs(recvbuf,stdout); 114 } 115 close(sockfd); 116 117 return 0; 118 }

?

轉(zhuǎn)載于:https://www.cnblogs.com/chess/p/4684741.html

總結(jié)

以上是生活随笔為你收集整理的服务器客户端回射程序-自己设计包的结构的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。