udp小程序

快来打我* 2024-04-18 21:24 55阅读 0赞

//代码比较简单，就不说太多了！ //客户端源码：

#include <stdlib.h>
    #include <stdio.h>
    #include <errno.h>
    #include <string.h>
    #include <unistd.h>
    #include <netdb.h>
    #include <sys/socket.h>
    #include <sys/types.h>
    #include <netinet/in.h>
    #include <arpa/inet.h>
    
    #define SERVER_PORT 9999
    #define MAX_BUF_SIZE 1024
    
    void udpc_requ(int sockfd,const struct sockaddr_in *addr,int len) {
    	char buffer[MAX_BUF_SIZE];
    //	int n;
    	while(1) {
    		printf("Please input char:\n");
    		fgets(buffer,MAX_BUF_SIZE,stdin);
    		sendto(sockfd,buffer,strlen(buffer),0,(struct sockaddr*)addr,len);
    		bzero(buffer,MAX_BUF_SIZE);
    	}
    }
    
    int main(int argc, char * *argv) {
    	int sockfd;
    	struct sockaddr_in addr;
    	
    	if(argc !=  2){
    		fprintf(stderr,"usage:%s server_ip\n",argv[0]);
    		exit(1);
    		}
    		
    		sockfd = socket(AF_INET,SOCK_DGRAM,0);
    		if(sockfd < 0) {
    			fprintf(stderr,"Socket error:%s\n",strerror(errno));
    			exit(1);
    		}
    			
    		bzero(&addr,sizeof(struct sockaddr_in));
    		addr.sin_family = AF_INET;
    		addr.sin_port = htons(SERVER_PORT);
    			
    		if(inet_aton(argv[1],&addr.sin_addr)<0) {
    			fprintf(stderr,"IP error:%s\n",strerror(errno));
    			exit(1);
    		}
    				
    		udpc_requ(sockfd,&addr,sizeof(struct sockaddr_in));
    		close(sockfd);
    		
    		return 0;
    }

服务端源码：

#include <stdlib.h>
    #include <stdio.h>
    #include <errno.h>
    #include <string.h>
    #include <unistd.h>
    #include <netdb.h>
    #include <sys/socket.h>
    #include <netinet/in.h>
    #include <sys/types.h>
    #include <arpa/inet.h>
    
    #define SERVER_PORT 9999
    #define MAX_MSG_SIZE 1024
    
    void udps_respon(int sockfd) {
    	struct sockaddr_in addr;
    	int saddr_len,n;
    	char msg[MAX_MSG_SIZE];
    	while(1) {
    		bzero(msg,sizeof(msg));
    		saddr_len = sizeof(struct sockaddr);
    		n = recvfrom(sockfd,msg,MAX_MSG_SIZE,0,(struct sockaddr*)&addr,&saddr_len);
    		if(n == 0){
    			perror("recvfrom error\n");
    		}
    		msg[n] = 0;
    		fprintf(stdout,"Server have received %s", msg);
    	}
    }
    
    int main(void) {
    	int sockfd;
    	struct sockaddr_in addr;
    	sockfd = socket(AF_INET,SOCK_DGRAM,0);
    	
    	if(sockfd < 0) {
    		fprintf(stderr,"socket error:%s\n",strerror(errno));
    		exit(1);
    	}
    	
    	bzero(&addr,sizeof(struct sockaddr_in));
    	addr.sin_family = AF_INET;
    	addr.sin_addr.s_addr = htonl(INADDR_ANY);
    	addr.sin_port = htons(SERVER_PORT);
    	
    	if(bind(sockfd,(struct sockaddr *)&addr,sizeof(struct sockaddr_in))<0) {
    		fprintf(stderr,"Bind error:%s\n",strerror(errno));
    		exit(1);
    		}
    		printf("server star\n");
    		udps_respon(sockfd);
    		close(sockfd);
    		
    		return 0;
    }