• 网络编程day02（socket套接字）

    今日任务：

    TCP\UDP服务端客户端通信

    TCP：代码

    服务端：

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8.  
    9. //自定义报错提示
    10. #define ERR_MSG(msg) do{\
    11. 		fprintf(stderr,"__%d__",__LINE__);\
    12. 		perror(msg);\
    13. }while(0)
    14. #define SER_PORT 8888
    15. #define SER_IP "192.168.125.2"
    16. /*
    17.  * function:    TCP服务端
    18.  * @param [ in] 
    19.  * @param [out] 
    20.  * @return      
    21.  */
    22. int main(int argc, const char *argv[])
    23. {
    24. 	//1.创建socket套接字，
    25. 	int sfd=socket(AF_INET,SOCK_STREAM,0);
    26. 	if(sfd<0){
    27. 		ERR_MSG("socket");
    28. 		return -1;
    29. 	}
    30. 	puts("socket create");
    31.  
    32. 	//允许端口快速复用
    33. 	int reuse = 1;
    34.     if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0)
    35.     {
    36.         ERR_MSG("setsockopt");
    37.         return -1;
    38.     }
    39.     printf("允许端口快速复用成功\n");
    40. 	//2.绑定服务器IP和端口号bind
    41. 	struct sockaddr_in addr;
    42. 	addr.sin_family=AF_INET;
    43. 	addr.sin_port=htons(SER_PORT);
    44. 	addr.sin_addr.s_addr=inet_addr(SER_IP);
    45. 	if(bind(sfd,(struct sockaddr*)&addr,sizeof(addr))<0){
    46. 		ERR_MSG("bind");
    47. 		return -1;
    48. 	}
    49. 	puts("bind success");
    50.  
    51.  
    52. 	//3.建立监听listen
    53. 	if(listen(sfd,128)<0){
    54. 		ERR_MSG("listen");
    55. 		return -1;
    56. 	}
    57. 	puts("listen suucess");
    58. 	//4.等待客户端连接， accept
    59. 	struct sockaddr_in cli_addr;
    60. 	socklen_t cli_addrlen=sizeof(cli_addr);
    61. 	
    62. 	int cfd=accept(sfd,(struct sockaddr*)&cli_addr,&cli_addrlen);
    63. 	if(cfd<0){
    64. 		ERR_MSG("accept");
    65. 		return -1;
    66. 	}
    67. 	puts("accept");
    68.  
    69. 	//5.接受发送消息recv；send
    70. 	char buf[128];
    71. 	while(1){
    72. 		bzero(buf,sizeof(buf));
    73. 		int recv_res=recv(cfd,buf,sizeof(buf),0);
    74.  
    75. 		if(recv_res<0){
    76. 			ERR_MSG("recv");
    77. 			return -1;
    78. 		}else if(recv_res==0){
    79. 			printf("socket peer has shutdown\n");
    80. 			break;
    81. 		}
    82. 		puts("recv success");
    83. 		printf("[%s:%d]:%s\n",inet_ntoa(cli_addr.sin_addr),ntohs(cli_addr.sin_port),buf);
    84. 		if(strcmp(buf,"quit")==0)
    85. 			break;
    86.  
    87. 		strcat(buf,"-----i has received");
    88. 		int send_res=send(cfd,buf,sizeof(buf),0);
    89. 		if(send_res<0){
    90. 			ERR_MSG("send");
    91. 			return -1;
    92. 		}
    93. 		puts("send success");
    94. 	}
    95. 	
    96. 	//6.关闭
    97. 	close(cfd);
    98. 	close(sfd);
    99. 	
    100. 	return 0;
    101. }

    客户端

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8.  
    9. //自定义报错提示
    10. #define ERR_MSG(msg) do{\
    11. 		fprintf(stderr,"__%d__",__LINE__);\
    12. 		perror(msg);\
    13. }while(0)
    14. #define SER_PORT 8888
    15. #define SER_IP "192.168.125.2"
    16. /*
    17.  * function:    TCP客户端
    18.  * @param [ in] 
    19.  * @param [out] 
    20.  * @return      
    21.  */
    22. int main(int argc, const char *argv[])
    23. {
    24. 	//1.创建socket套接字，
    25. 	int cfd=socket(AF_INET,SOCK_STREAM,0);
    26. 	if(cfd<0){
    27. 		ERR_MSG("socket");
    28. 		return -1;
    29. 	}
    30. 	puts("socket create");
    31.  
    32. 	//允许端口快速复用
    33. 	int reuse = 1;
    34.     if(setsockopt(cfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0)
    35.     {
    36.         ERR_MSG("setsockopt");
    37.         return -1;
    38.     }
    39.     printf("允许端口快速复用成功\n");
    40.  
    41. 	//2.连接服务端connect
    42. 	struct sockaddr_in addr;
    43. 	addr.sin_family=AF_INET;
    44. 	addr.sin_port=htons(SER_PORT);
    45. 	addr.sin_addr.s_addr=inet_addr(SER_IP);
    46. 	if(connect(cfd,(struct sockaddr*)&addr,sizeof(addr))<0){
    47. 		ERR_MSG("connect");
    48. 		return -1;
    49. 	}
    50. 	puts("connect success");
    51. 	//5.接受发送消息recv；send
    52. 	char buf[128];
    53. 	while(1){
    54. 		bzero(buf,sizeof(buf));
    55. 		printf("请输入>>>");
    56. 		fgets(buf,sizeof(buf),stdin);
    57. 		buf[strlen(buf)-1]='\0';
    58.  
    59. 		if(strcmp(buf,"quit")==0)
    60. 			break;
    61.  
    62. 		int send_res=send(cfd,buf,sizeof(buf),0);
    63. 		if(send_res<0){
    64. 			ERR_MSG("send");
    65. 			return -1;
    66. 		}
    67. 		puts("send success");
    68.  
    69. 		bzero(buf,sizeof(buf));
    70. 		int recv_res=recv(cfd,buf,sizeof(buf),0);
    71.  
    72. 		if(recv_res<0){
    73. 			ERR_MSG("recv");
    74. 			return -1;
    75. 		}else if(recv_res==0){
    76. 			printf("socket peer has shutdown\n");
    77. 			break;
    78. 		}
    79. 		puts("recv success");
    80. 		printf("[%s:%d]:%s\n",SER_IP,SER_PORT,buf);
    81.  
    82. 		}
    83. 	
    84. 	//6.关闭
    85. 	close(cfd);
    86. 	
    87. 	return 0;
    88. }

    运行结果：

    UDP：代码

    服务端：

    1. #include 
    2. #include 
    3. #include 
    4. #include           /* See NOTES */
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9.  
    10. //自定义报错提示
    11. #define ERR_MSG(msg) do{\
    12. 		fprintf(stderr,"__%d__",__LINE__);\
    13. 		perror(msg);\
    14. }while(0)
    15.  
    16. #define SER_PORT 8888
    17. #define SER_IP "192.168.125.2"
    18.  
    19.  
    20. int main(int argc, const char *argv[])
    21. {
    22. 	//1.创建socket套接字
    23. 	int sfd=socket(AF_INET,SOCK_DGRAM,0);
    24. 	if(sfd<0){
    25. 		ERR_MSG("socket");
    26. 		return -1;
    27. 	}
    28. 	puts("socket success");
    29. 	
    30. 	//2.绑定IP和端口号
    31. 	struct sockaddr_in addr;
    32. 	addr.sin_family=AF_INET;
    33. 	addr.sin_port=htons(SER_PORT);
    34. 	addr.sin_addr.s_addr=inet_addr(SER_IP);
    35. 	if(bind(sfd,(struct sockaddr*)&addr,sizeof(addr))<0){
    36. 		ERR_MSG("bind");
    37. 		return -1;
    38. 	}
    39. 	puts("bind success");
    40.  
    41.  
    42. 	//3.接受和发送消息
    43. 	//
    44. 	struct sockaddr_in src_addr;
    45. 	socklen_t addrlen=sizeof(src_addr);
    46. 	char buf[128];
    47. 	while(1){
    48.  
    49. 		bzero(buf,sizeof(buf));
    50. 		int recv_res=recvfrom(sfd,buf,sizeof(buf),0,(struct sockaddr*)&src_addr,&addrlen);
    51. 		if(recv_res<0){
    52. 			ERR_MSG("recvfrom");
    53. 			return -1;
    54. 		}
    55. 		puts("recvfrom success");
    56. 		printf("[%s:%d]:%s\n",inet_ntoa(src_addr.sin_addr),ntohs(src_addr.sin_port),buf);
    57.  
    58. 		
    59. 		if(strcmp(buf,"quit")==0)
    60. 			break;
    61. 		
    62. 		strcat(buf,"-----i has received");
    63. 		int send_res=sendto(sfd,buf,sizeof(buf),0,(struct sockaddr*)&src_addr,addrlen);
    64. 		if(send_res<0){
    65. 			ERR_MSG("sendto");
    66. 			return -1;
    67. 		}
    68. 		puts("sendto success");
    69.  
    70.  
    71. 		}
    72. 	//4.关闭
    73. 	close(sfd);
    74. 	return 0;
    75. }

    客户端

    1. #include 
    2. #include 
    3. #include 
    4. #include           /* See NOTES */
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9.  
    10. //自定义报错提示
    11. #define ERR_MSG(msg) do{\
    12. 		fprintf(stderr,"__%d__",__LINE__);\
    13. 		perror(msg);\
    14. }while(0)
    15.  
    16. #define SER_PORT 8888
    17. #define SER_IP "192.168.125.2"
    18.  
    19.  
    20. int main(int argc, const char *argv[])
    21. {
    22. 	//1.创建socket套接字
    23. 	int cfd=socket(AF_INET,SOCK_DGRAM,0);
    24. 	if(cfd<0){
    25. 		ERR_MSG("socket");
    26. 		return -1;
    27. 	}
    28. 	puts("socket success");
    29. 	
    30. 	
    31. 	//3.接受和发送消息
    32. 	//目标地址信息
    33. 	struct sockaddr_in addr;
    34. 	addr.sin_family=AF_INET;
    35. 	addr.sin_port=htons(SER_PORT);
    36. 	addr.sin_addr.s_addr=inet_addr(SER_IP);
    37. 	socklen_t addrlen=sizeof(addr);
    38.  
    39. 	//记录接受信息的目标地址信息
    40. 	struct sockaddr_in recv_addr;
    41. 	socklen_t recv_addrlen=sizeof(recv_addr);
    42. 	char buf[128];
    43. 	while(1){
    44. 		
    45. 		printf("请输入>>>");
    46. 		fgets(buf,sizeof(buf),stdin);
    47. 		buf[strlen(buf)-1]='\0';
    48. 		
    49.  
    50. 	
    51. 		int send_res=sendto(cfd,buf,sizeof(buf),0,(struct sockaddr*)&addr,addrlen);
    52. 		if(send_res<0){
    53. 			ERR_MSG("sendto");
    54. 			return -1;
    55. 		}
    56. 		puts("sendto success");
    57. 		if(strcmp(buf,"quit")==0)
    58. 			break;
    59.  
    60. 		bzero(buf,sizeof(buf));
    61. 		int recv_res=recvfrom(cfd,buf,sizeof(buf),0,(struct sockaddr*)&recv_addr,&recv_addrlen);
    62. 		if(recv_res<0){
    63. 			ERR_MSG("recvfrom");
    64. 			return -1;
    65. 		}
    66. 		puts("recvfrom success");
    67. 		printf("[%s:%d]:%s\n",inet_ntoa(recv_addr.sin_addr),ntohs(recv_addr.sin_port),buf);	
    68.  
    69. 		}
    70. 	//4.关闭
    71. 	close(cfd);
    72. 	return 0;
    73. }

    运行结果：

    今日思维导图：

    somthing error：UDP的客户端处

    一开始addrlen只有定义没有赋值，白天的时候有报错给他加了一个初始值；晚上突然一下可以一下不可以，找了找错误改了医改，应该也是这个；

  • 相关阅读:
    代码随想录二刷 Day 44
    产成品差异科目有余额物料分类账帐以后没有结转完
    Sqlserver Try Catch时Catch捕获到错误则重试一次的写法
    骨传导麦克风+耳塞模式，打开飞利浦A7607的“隐藏功能”
    STM32实战总结：HAL之DAC
    Vue-配置代理（解决跨域问题）
    CListCtrl设置只显示单列
    Python学习笔记之分支结构与循环结构
    计算机视觉的应用12-卷积神经网络中图像特征提取的可视化研究，让大家理解特征提取的全过程
    基于Python+Flask+MySQL+HTML的B站数据可视化分析系统
  • 原文地址：https://blog.csdn.net/weixin_53762703/article/details/133047919