• Linux--socket编程--双方收发


    socket编程–客户端代码

    /*
    1、调用 socket 创建套接字
    2、connect 连接客户端的listen
    3、send
    4、read
    
    */
    
    #include 
    #include 
    #include 
    //#include 
    #include 
    #include 
    #include 
    #include 
    
    
    int main()
    {
    	int c_fd;
    	int n_read;
    	char redBuf[128];
    	
    	char *retmessage = "message from client!";
    	
    	//定义结构体
    	struct sockaddr_in c_addr;
    	
    	//数据清空
    
    	memset(&c_addr,0,sizeof(struct sockaddr_in));
    	
    
    //1、创建套接字 socket
    	c_fd = socket(AF_INET,SOCK_STREAM,0);//用到IPV4,TCP协议,0自动配合起来
    	if(c_fd == -1){						//返回-1,错误
    		perror("socket");
    		exit(-1);
    	}
    	
    	c_addr.sin_family = AF_INET;	//协议族
    	c_addr.sin_port = htons(8989);	//端口号,一般为5000--9000
    	//电脑为x86是小端字节序,网络字节序为大端字节序。所以要进行转换用htons
    	inet_aton("172.0.0.1",&c_addr.sin_addr);
    	//把字符串形式的127.0.0.1转换成网络能识别的格式。用 到inet_aton
    
    
    //2、connect 连接客户端的listen
    
    	
    	if(connect(c_fd,(struct sockaddr *)&c_addr,sizeof(struct sockaddr)) == -1){
    		perror("connect");
    		exit(-1);
    	}
    
    	printf("get connect : %s\n",inet_ntoa(c_addr.sin_addr));//把网络格式的IP转换为字符格式
    
    //3、send
    	write(c_fd,retmessage,strlen(retmessage));	
    
    
    //4、read
    	n_read = read(c_fd,redBuf,128);
    	if(n_read == -1){
    		perror("read");
    	}else{
    		printf("get message from server! : %d,%s\n",n_read,redBuf);
    	}
    
    	
    	return 0;
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72
    • 73

    双方多次互通:
    服务端:

    //Linux--socket编程--多次互通--服务端server
    
    /*
    1、调用 socket 创建套接字
    2、调用 bind 添加地址
    3、listen 监听
    4、accept 连接
    5、read
    6、write
    */
    
    #include 
    #include 
    #include 
    //#include 
    #include 
    #include 
    #include 
    #include 
    
    
    int main(int argc,char **argv)//配置端口
    {
    	int s_fd;
    	int c_fd;
    	int n_read;
    	char redBuf[128];
    	
    	//char *retmessage = "I get your message!";
    	char retmessage[128] = {0};
    	
    	
    	struct sockaddr_in s_addr;		//定义结构体
    	struct sockaddr_in c_addr;
    	
    	if(argc != 3){
    		printf("param is not good");	//参数不好
    		exit(-1);
    	}
    	
    	
    	//数据清空
    	memset(&s_addr,0,sizeof(struct sockaddr_in));
    	memset(&c_addr,0,sizeof(struct sockaddr_in));
    	
    
    //1、创建套接字 socket
    	s_fd = socket(AF_INET,SOCK_STREAM,0);//用到IPV4,TCP协议,0自动配合起来
    	if(s_fd == -1){						//返回-1,错误
    		perror("socket");
    		exit(-1);
    	}
    	
    	
    //2、添加地址 bind		
    	
    	s_addr.sin_family = AF_INET;	//协议族
    	s_addr.sin_port = htons(atoi(argv[2]));	//端口号,一般为5000--9000
    	//电脑为x86是小端字节序,网络字节序为大端字节序。所以要进行转换用htons
    	inet_aton(argv[1],&s_addr.sin_addr);
    	//把字符串形式的127.0.0.1转换成网络能识别的格式。用到inet_aton
    
    
    	bind(s_fd,(struct sockaddr *)&s_addr,sizeof(struct socket_in));
    	
    
    //3、监听listen
    	listen(s_fd,10);//监听10个
    	
    //4、连接 accept
    	int clen = sizeof(struct socket_in);
    	while(1){
    
    		c_fd = accept(s_fd,(struct sockaddr *)&c_addr ,&clen);
    		//连接到客户端之后,后续的操作用返回值c_fd来操作
    	
    		if(c_fd == -1){
    			perror("accept");
    		}
    
    		printf("get connect : %s\n",inet_ntoa(c_addr.sin_addr));//把网络格式的IP转换为字符格式
    	
    		if(fork() == 0){		//fock返回值=0进入子进程,>0进入父进程
    			
    			if(fork() == 0){		//输入
    				printf("input : ");
    				memset(retmessage,0,sizeof(retmessage));//初始化
    				gets(retmessage);
    //6、write
    				write(c_fd,retmessage,strlen(retmessage));
    			}
    			
    //5、read
    			n_read = read(c_fd,redBuf,128);
    			if(n_read == -1){
    				perror("read");
    			}else{
    				printf("get message : %d,%s\n",n_read,redBuf);
    			}
    			
    
    			break;		//进行一次
    		}
    	}
    	
    	
    	return 0;
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72
    • 73
    • 74
    • 75
    • 76
    • 77
    • 78
    • 79
    • 80
    • 81
    • 82
    • 83
    • 84
    • 85
    • 86
    • 87
    • 88
    • 89
    • 90
    • 91
    • 92
    • 93
    • 94
    • 95
    • 96
    • 97
    • 98
    • 99
    • 100
    • 101
    • 102
    • 103
    • 104
    • 105
    • 106
    • 107
    • 108

    客户端:

    //Linux--socket编程--多次互通--客户端client
    
    /*
    1、调用 socket 创建套接字
    2、connect 连接客户端的listen
    3、send
    4、read
    
    */
    
    #include 
    #include 
    #include 
    //#include 
    #include 
    #include 
    #include 
    #include 
    
    
    int main(int argc,char **argv)
    {
    	int c_fd;
    	int n_read;
    	char redBuf[128];
    	
    	//char *retmessage = "message from client!";
    	char retmessage[128] = {0};
    	
    	//定义结构体
    	struct sockaddr_in c_addr;
    	
    	//数据清空
    
    	memset(&c_addr,0,sizeof(struct sockaddr_in));
    	
    	if(argc != 3){
    		printf("param is not good");	//参数不好
    		exit(-1);
    	}
    
    //1、创建套接字 socket
    	c_fd = socket(AF_INET,SOCK_STREAM,0);//用到IPV4,TCP协议,0自动配合起来
    	if(c_fd == -1){						//返回-1,错误
    		perror("socket");
    		exit(-1);
    	}
    	
    	c_addr.sin_family = AF_INET;	//协议族
    	c_addr.sin_port = htons(atoi(argv[2]));	//端口号,一般为5000--9000
    	//电脑为x86是小端字节序,网络字节序为大端字节序。所以要进行转换用htons
    	inet_aton(argv[1],&c_addr.sin_addr);
    	//把字符串形式的127.0.0.1转换成网络能识别的格式。用 到inet_aton
    
    
    //2、connect 连接客户端的listen
    
    	
    	if(connect(c_fd,(struct sockaddr *)&c_addr,sizeof(struct sockaddr)) == -1){
    		perror("connect");
    		exit(-1);
    	}
    
    	printf("get connect : %s\n",inet_ntoa(c_addr.sin_addr));//把网络格式的IP转换为字符格式
    
    	while(1){
    		
    		if(fork() == 0){		//fock返回值=0进入子进程,写数据
    			printf("input : ");
    			memset(retmessage,0,sizeof(retmessage));//初始化
    			gets(retmessage);
    //3、send
    			write(c_fd,retmessage,strlen(retmessage));	
    		}
    		
    //4、read
    		n_read = read(c_fd,redBuf,128);
    		if(n_read == -1){
    			perror("read");
    		}else{
    			printf("get message from server! : %d,%s\n",n_read,redBuf);
    		}
    	}
    
    	return 0;
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72
    • 73
    • 74
    • 75
    • 76
    • 77
    • 78
    • 79
    • 80
    • 81
    • 82
    • 83
    • 84
    • 85
    • 86

    服务端运行:./文件名 + IP + 端口号
    在客户端运行:./文件名 + IP + 端口号

    服务端得到:并且不会退出

    get connect : ip
    input : 			//输入
    get message : 			//客户端输入的东西
    
    • 1
    • 2
    • 3

    客户端得到:

    input : 		//输入
    get message : 			//服务端输入的东西
    
    • 1
    • 2

    多方收发,服务端server自动回复:

    /*
    1、调用 socket 创建套接字
    2、调用 bind 添加地址
    3、listen 监听
    4、accept 连接
    5、read
    6、write
    */
    
    #include 
    #include 
    #include 
    //#include 
    #include 
    #include 
    #include 
    #include 
    
    
    int main(int argc,char **argv)//配置端口
    {
    	int s_fd;
    	int c_fd;
    	int n_read;
    	char redBuf[128];
    	
    	//char *retmessage = "I get your message!";
    	char retmessage[128] = {0};
    	
    	int mark = 0;	//标记连接的顺序
    	
    	struct sockaddr_in s_addr;		//定义结构体
    	struct sockaddr_in c_addr;
    	
    	if(argc != 3){
    		printf("param is not good");	//参数不好
    		exit(-1);
    	}
    	
    	
    	//数据清空
    	memset(&s_addr,0,sizeof(struct sockaddr_in));
    	memset(&c_addr,0,sizeof(struct sockaddr_in));
    	
    
    //1、创建套接字 socket
    	s_fd = socket(AF_INET,SOCK_STREAM,0);//用到IPV4,TCP协议,0自动配合起来
    	if(s_fd == -1){						//返回-1,错误
    		perror("socket");
    		exit(-1);
    	}
    	
    	
    //2、添加地址 bind		
    	
    	s_addr.sin_family = AF_INET;	//协议族
    	s_addr.sin_port = htons(atoi(argv[2]));	//端口号,一般为5000--9000
    	//电脑为x86是小端字节序,网络字节序为大端字节序。所以要进行转换用htons
    	inet_aton(argv[1],&s_addr.sin_addr);
    	//把字符串形式的127.0.0.1转换成网络能识别的格式。用到inet_aton
    
    
    	bind(s_fd,(struct sockaddr *)&s_addr,sizeof(struct socket_in));
    	
    
    //3、监听listen
    	listen(s_fd,10);//监听10个
    	
    //4、连接 accept
    	int clen = sizeof(struct socket_in);
    	while(1){
    
    		c_fd = accept(s_fd,(struct sockaddr *)&c_addr ,&clen);
    		//连接到客户端之后,后续的操作用返回值c_fd来操作
    	
    		if(c_fd == -1){
    			perror("accept");
    		}
    
    		mark++;
    		printf("get connect : %s\n",inet_ntoa(c_addr.sin_addr));//把网络格式的IP转换为字符格式
    	
    		if(fork() == 0){		//fock返回值=0进入子进程,>0进入父进程
    			
    			if(fork() == 0){		//输入
    				memset(retmessage,0,sizeof(retmessage));//初始化
    				sprint(retmessage,"welcom No : %d client ",mark);
    				sleep(3);
    				//每隔三秒发一个状况,确认连接是否丢失
    //6、write
    				write(c_fd,retmessage,strlen(retmessage));
    			}
    			
    //5、read
    			n_read = read(c_fd,redBuf,128);
    			if(n_read == -1){
    				perror("read");
    			}else{
    				printf("get message : %d,%s\n",n_read,redBuf);
    			}
    			
    
    			break;		//进行一次
    		}
    	}
    	
    	
    	return 0;
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72
    • 73
    • 74
    • 75
    • 76
    • 77
    • 78
    • 79
    • 80
    • 81
    • 82
    • 83
    • 84
    • 85
    • 86
    • 87
    • 88
    • 89
    • 90
    • 91
    • 92
    • 93
    • 94
    • 95
    • 96
    • 97
    • 98
    • 99
    • 100
    • 101
    • 102
    • 103
    • 104
    • 105
    • 106
    • 107
    • 108
    • 109
  • 相关阅读:
    绘制核密度估计图
    CMOS图像传感器——Remosaic技术
    Docker 搭建 LNMP + Wordpress(详细步骤)
    vue - 路由守卫
    LeetCode 67. 二进制求和
    dreamweaver家乡主题网页设计 DIV布局个人介绍网页模板代码 DW学生个人网站制作成品下载 HTML5期末大作业
    公共数据这座金矿,授权运营为何是赋能的关键路径?
    Linux:工具(vim,gcc/g++,make/Makefile,yum,git,gdb)
    postgresql-索引与优化
    面向订单生产型电子制造企业,如何快速响应客户?
  • 原文地址:https://blog.csdn.net/weixin_48208102/article/details/133530373