C說話編寫基於TCP和UDP協定的Socket通訊法式示例。本站提示廣大學習愛好者:(C說話編寫基於TCP和UDP協定的Socket通訊法式示例)文章只能為提供參考,不一定能成為您想要的結果。以下是C說話編寫基於TCP和UDP協定的Socket通訊法式示例正文
Tcp多線程辦事器和客戶端法式
辦事器法式:
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <arpa/inet.h> #include <sys/types.h> #include <sys/socket.h> #include <unistd.h> #define PORT 8082 #define BUFSIZE 512 char buf[BUFSIZE+1]; void* fun(void* x) { //printf("enter thread!\r\n"); int new_fd=*((int*)x); while(1) { int z=read(new_fd,buf,BUFSIZE);//第 6 步 讀取套接字 if(z==0){printf("client close !");break;}; buf[z]='\0'; printf("%s\r\n",buf);//打印 }; } int newfd[512]; int inewfd=0; int main() { //第 1 步 創立套接字 int sockfd=socket(AF_INET,SOCK_STREAM,0); //第 2 步 設置地址構造體 struct sockaddr_in svraddr; svraddr.sin_family=AF_INET;//應用 internet 協定 svraddr.sin_port=htons(PORT); inet_aton("0.0.0.0",&svraddr.sin_addr); //第 3 步 綁定 int ret=bind(sockfd,(struct sockaddr*)&svraddr,sizeof(svraddr)); if(ret<0){printf("error bind!\r\n");exit(-1);}; //第 4 步 監聽 listen(sockfd,128); while(1) { newfd[inewfd++]=accept(sockfd,NULL,NULL); //第 5 步 吸收 pthread_t ntid; pthread_create(&ntid,NULL,fun,(void*)&(newfd[inewfd-1])); } }
留意:
gcc server.c -o server -lpthread
客戶端法式 cli.c
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <arpa/inet.h> #include <sys/types.h> #include <sys/socket.h> #include <unistd.h> #define PORT 8082 #define BUFSIZE 512 char buf[BUFSIZE+1]; int main() { //第 1 步 創立一個別套接字 int sockfd=socket(AF_INET,SOCK_STREAM,0); //第 2 步 設置 addr 構造體 struct sockaddr_in svraddr; svraddr.sin_family=AF_INET;//應用 internet 協定 svraddr.sin_port=htons(PORT); inet_aton("127.0.0.1",&svraddr.sin_addr); //第 3 步 銜接辦事器 connect(sockfd,(struct sockaddr*)&svraddr,sizeof(svraddr)); while(1) { scanf("%s",buf); write(sockfd,buf,strlen(buf)); //第 4 步 向套接字中寫入字符串 } }
Udp的辦事器法式和客戶端法式
辦事器法式:
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <arpa/inet.h> #include <sys/types.h> #include <sys/socket.h> #include <unistd.h> #define PORT 8082 #define BUFSIZE 512 char buf[BUFSIZE+1]; int main() { //第 1 步 創立套接字 int sockfd=socket(AF_INET,SOCK_DGRAM,0); //第 2 步 設置地址構造體 struct sockaddr_in svraddr; svraddr.sin_family=AF_INET;//應用 internet 協定 svraddr.sin_port=htons(PORT); inet_aton("0.0.0.0",&svraddr.sin_addr); //第 3 步 綁定 int ret=bind(sockfd,(struct sockaddr*)&svraddr,sizeof(svraddr)); if(ret<0){printf("cannot bind!\r\n");exit(-1);}; while(1) { struct sockaddr_in cli; int len=sizeof(cli); int z=recvfrom(sockfd,buf,BUFSIZE,0,(struct sockaddr*)&cli,&len);//第 6 步 讀取套接字 buf[z]='\0'; printf("%s\r\n",buf);//打印 } }
客戶端法式 cli.c
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <arpa/inet.h> #include <sys/types.h> #include <sys/socket.h> #include <unistd.h> #define PORT 8082 #define BUFSIZE 512 char buf[BUFSIZE+1]; int main() { //第 1 步 創立一個別套接字 int sockfd=socket(AF_INET,SOCK_DGRAM,0); //第 2 步 設置 addr 構造體 struct sockaddr_in svraddr; svraddr.sin_family=AF_INET;//應用 internet 協定 svraddr.sin_port=htons(PORT); inet_aton("127.0.0.1",&svraddr.sin_addr); //第 3 步 銜接辦事器 //connect(sockfd,(struct sockaddr*)&svraddr,sizeof(svraddr)); while(1) { scanf("%s",buf); sendto(sockfd,buf,strlen(buf),0,(struct sockaddr*)&svraddr,sizeof(svraddr)); //第 4 步 向套接字中寫入字符串 } }