Socket-基礎客戶端/伺服器資料傳輸
阿新 • • 發佈:2019-01-06
客戶端傳送程式碼
/*回射客戶端*/ #include<unistd.h> #include<stdio.h> #include<sys/socket.h> #include<sys/types.h> #include<stdlib.h> #include<stdio.h> #include<errno.h> #include<netinet/in.h> #include<arpa/inet.h> #include<string.h> #define ERR_EXIT(m) (perror(m),exit(EXIT_FAILURE)) /*do { perror(m); exit(EXIT_FAILURE); } while(0))/ //錯誤巨集定義*/ int main(void) { //建立套介面 int sock; if((sock=socket(PF_INET,SOCK_STREAM,IPPROTO_TCP))<0) /*if((sock=socket(PF_INET,SOCK_TREAM,0))<0)*/ ERR_EXIT("socket"); struct sockaddr_in servaddr;//IPv4地址結構 memset(&servaddr,0,sizeof(servaddr));//伺服器地址 //初始化地址 servaddr.sin_family=AF_INET;//地址族 servaddr.sin_port=htons(5188);//埠號(需要兩個位元組的網路埠號) servaddr.sin_addr.s_addr=inet_addr("192.168.241.129");//地址(選用本機任意地址) /*servaddr.sin_addr.s_addr=inet_addr("192.168.241.129");//選用指定地址*/ /*inet_aton("192.168.241.129",&servaddr.sin_addr);//將本機地址轉換為網路地址*/ //連線 if(connect(sock,(struct sockaddr*)&servaddr,sizeof(servaddr))<0) ERR_EXIT("connect"); char sendbuf[1024]={0}; char recvbuf[1024]={0}; while(fgets(sendbuf,sizeof(sendbuf),stdin)!=NULL) { write(sock,sendbuf,strlen(sendbuf));//傳送資料 read(sock,recvbuf,sizeof(recvbuf)); fputs(recvbuf,stdout); memset(sendbuf,0,sizeof(sendbuf)); memset(recvbuf,0,sizeof(recvbuf)); } close(sock); return 0; }
伺服器接收程式碼
/*回射伺服器*/ #include<unistd.h> #include<stdio.h> #include<sys/socket.h> #include<sys/types.h> #include<stdlib.h> #include<stdio.h> #include<errno.h> #include<netinet/in.h> #include<arpa/inet.h> #include<string.h> #define ERR_EXIT(m) (perror(m),exit(EXIT_FAILURE)) /*do { perror(m); exit(EXIT_FAILURE); } while(0))/ //錯誤巨集定義*/ int main(void) { //建立套介面 int listenfd; if((listenfd=socket(PF_INET,SOCK_STREAM,IPPROTO_TCP))<0) /*if((listenfd=socket(PF_INET,SOCK_TREAM,0))<0)*/ ERR_EXIT("socket"); struct sockaddr_in servaddr;//IPv4地址結構 memset(&servaddr,0,sizeof(servaddr));//伺服器地址 //初始化地址 servaddr.sin_family=AF_INET;//地址族 servaddr.sin_port=htons(5188);//埠號(需要兩個位元組的網路埠號) servaddr.sin_addr.s_addr=htonl(INADDR_ANY);//地址(選用本機任意地址) /*servaddr.sin_addr.s_addr=inet_addr("192.168.241.129");//選用指定地址*/ /*inet_aton("192.168.241.129",&servaddr.sin_addr);//將本機地址轉換為網路地址*/ //繫結 if((bind(listenfd,(struct sockaddr*)&servaddr,sizeof(servaddr)))<0) ERR_EXIT("bind");//繫結失敗 //監聽 if((listen(listenfd,SOMAXCONN))<0) ERR_EXIT("listen");//監聽失敗 //監聽後變成被動套接字 struct sockaddr_in peeraddr;//定義對方地址結構 socklen_t peerlen=sizeof(peeraddr);//對方地址長度 int conn;//已連線socket獲得的資料 if((conn=accept(listenfd,(struct sockaddr*)&peeraddr,&peerlen))<0) ERR_EXIT("accept");//接收失敗 //接收連線成功 char recvbuf[1024]; while(1) { memset(recvbuf,0,sizeof(recvbuf));//接收資料 int ret=read(conn,recvbuf,sizeof(recvbuf));//讀取資料 fputs(recvbuf,stdout);//輸出資料(標準輸出) write(conn,recvbuf,ret);//回射資料 } return 0; close(conn); close(listenfd); }