• hw0921

     多线程发送方

    1. #include 
    2. int main(int argc, const char *argv[])
    3. {
    4. 		//创建流式套接字
    5. 	int cfd=socket(AF_INET,SOCK_STREAM,0);
    6. 	printf("socket success\n");
    7. 	//填充服务器地址
    8. 	struct sockaddr_in sin;
    9. 	sin.sin_family=AF_INET;
    10. 	sin.sin_port=htons(4444);
    11. 	sin.sin_addr.s_addr=inet_addr("192.168.125.230");
    12.  
    13. 	//连接服务器
    14. 	if(connect(cfd,(struct sockaddr*)&sin,sizeof(sin))<0)
    15. 	{
    16. 		perror("connect");
    17. 		return -1;
    18. 	}
    19. 	printf("connect success\n");
    20. 	
    21.  
    22. 	char buf[128]="";
    23. 	ssize_t res=0;
    24. 	while(1)
    25. 	{
    26. 		bzero(buf,sizeof(buf));
    27. 		printf("输入：");
    28. 		scanf(" %s",buf);
    29. 	//	buf[strlen(buf)-1]='\0';
    30.  
    31. 		write(cfd,buf,sizeof(buf));
    32.  
    33. 	/*	res=recv(cfd,buf,sizeof(buf),0); 
    34. 		if(res<0)
    35. 		{
    36. 			perror("recv");
    37. 		}
    38. 		else if(0==res)
    39. 		{
    40. 			printf("服务器链接失败\n");
    41. 			break;
    42. 		}
    43. 	*/	printf("[192.168.122.84,4444]:%s\n",buf);
    44. 	}
    45. 	close(cfd);
    46.  
    47. 	return 0;
    48. }

    多线程接收方

    1. #include 
    2. int main(int argc, const char *argv[])
    3. {
    4. 		//创建流式套接字
    5. 	int cfd=socket(AF_INET,SOCK_STREAM,0);
    6. 	printf("socket success\n");
    7. 	//填充服务器地址
    8. 	struct sockaddr_in sin;
    9. 	sin.sin_family=AF_INET;
    10. 	sin.sin_port=htons(4444);
    11. 	sin.sin_addr.s_addr=inet_addr("192.168.125.230");
    12.  
    13. 	//连接服务器
    14. 	if(connect(cfd,(struct sockaddr*)&sin,sizeof(sin))<0)
    15. 	{
    16. 		perror("connect");
    17. 		return -1;
    18. 	}
    19. 	printf("connect success\n");
    20. 	
    21.  
    22. 	char buf[128]="";
    23. 	ssize_t res=0;
    24. 	while(1)
    25. 	{
    26. 		bzero(buf,sizeof(buf));
    27. 		printf("输入：");
    28. 		scanf(" %s",buf);
    29. 	//	buf[strlen(buf)-1]='\0';
    30.  
    31. 		write(cfd,buf,sizeof(buf));
    32.  
    33. 	/*	res=recv(cfd,buf,sizeof(buf),0); 
    34. 		if(res<0)
    35. 		{
    36. 			perror("recv");
    37. 		}
    38. 		else if(0==res)
    39. 		{
    40. 			printf("服务器链接失败\n");
    41. 			break;
    42. 		}
    43. 	*/	printf("[192.168.122.84,4444]:%s\n",buf);
    44. 	}
    45. 	close(cfd);
    46.  
    47. 	return 0;
    48. }
    49. ubuntu@ubuntu:TCP$ cat pth_ser.c
    50. #include 
    51. #define PORT 4444
    52. #define IP "192.168.125.230"
    53. struct Climsg{
    54. 	int newfd;
    55. 	struct sockaddr_in cin;
    56. };
    57. int main(int argc, const char *argv[])
    58. {
    59. 	//创建流式套接字
    60. 	int sfd=socket(AF_INET,SOCK_STREAM,0);
    61. 	printf("socket success\n");
    62. 	//允许端口被重复使用
    63. 	int reuse=1;
    64. 	setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))<0;
    65. 	printf("允许端口被重复使用\n");
    66. 	//bind
    67. 	struct sockaddr_in sin;
    68. 	sin.sin_family=AF_INET;
    69. 	sin.sin_port=htons(PORT);
    70. 	sin.sin_addr.s_addr=inet_addr(IP);
    71. 	bind(sfd,(struct sockaddr*)&sin,sizeof(sin));
    72. 	printf("bind success\n");
    73. 	//listen
    74. 	listen(sfd,128);
    75. 	//存储客户端信息0
    76. 	struct sockaddr_in cin;
    77. 	socklen_t addrlen=sizeof(cin);
    78.  
    79. 	int newfd;
    80. 	pthread_t tid;
    81. 	struct Climsg info;
    82. 	while(1)
    83. 	{
    84. 		newfd=accept(sfd,(struct sockaddr*)&cin,&addrlen);
    85. 		if(newfd<0)
    86. 		{
    87. 			perror("accept");
    88. 			return -1;
    89. 		}
    90. 		printf("connect success\n");
    91. 		printf("[%s:%d]\n",\
    92. 			inet_ntoa(cin.sin_addr),ntohs(cin.sin_port));
    93. 		info.newfd=newfd;
    94. 		info.cin=cin;
    95. 		pthread_create(&tid,NULL,deal_cli_msg,(void*)&info);
    96. 		pthread_detach(tid);//分离线程
    97. 	}
    98. 	close(sfd);
    99. 	return 0;
    100. }
    101. void* deal_cli_msg(void *info)
    102. {
    103. 	int newfd=((struct Climsg*)info)->newfd;
    104. 	struct sockaddr_in cin=((struct Climsg*)info);
    105. 	char buf[128];
    106. 	ssize_t res=0;
    107. 	while(1)
    108. 	{
    109. 		bzero(buf,sizeof(buf));
    110. 		//接收数据
    111. 		res=recv(newfd,buf,sizeof(buf),0);
    112. 		if(res<0)
    113. 		{
    114. 			perror("recv");
    115. 			break;
    116. 		}
    117. 		else if(0==res)
    118. 		{
    119. 			printf("[%s:%d]客户端下线\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port));
    120. 			break;
    121. 		}
    122. 		printf("[%s:%d]:%s\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),buf);
    123. 		if(strcmp(buf,"quit")==0)
    124. 		{
    125. 			break;
    126. 		}
    127. 		//发送数据
    128. 		strcat(buf,"-_-_--");
    129. 		if(send(newfd,buf,sizeof(buf),0)<0)
    130. 		{
    131. 			perror("send");
    132. 			break;
    133. 		}printf("发送成功\n");
    134. 	}
    135. 	close(newfd);
    136. }

    多进程发送方

    1. #include 
    2. int main(int argc, const char *argv[])
    3. {
    4. 		//创建流式套接字
    5. 	int cfd=socket(AF_INET,SOCK_STREAM,0);
    6. 	printf("socket success\n");
    7. 	//填充服务器地址
    8. 	struct sockaddr_in sin;
    9. 	sin.sin_family=AF_INET;
    10. 	sin.sin_port=htons(4444);
    11. 	sin.sin_addr.s_addr=inet_addr("192.168.125.230");
    12.  
    13. 	//连接服务器
    14. 	if(connect(cfd,(struct sockaddr*)&sin,sizeof(sin))<0)
    15. 	{
    16. 		perror("connect");
    17. 		return -1;
    18. 	}
    19. 	printf("connect success\n");
    20. 	
    21.  
    22. 	char buf[128]="";
    23. 	ssize_t res=0;
    24. 	while(1)
    25. 	{
    26. 		bzero(buf,sizeof(buf));
    27. 		printf("输入：");
    28. 		scanf(" %s",buf);
    29. 	//	buf[strlen(buf)-1]='\0';
    30.  
    31. 		write(cfd,buf,sizeof(buf));
    32.  
    33. 	/*	res=recv(cfd,buf,sizeof(buf),0); 
    34. 		if(res<0)
    35. 		{
    36. 			perror("recv");
    37. 		}
    38. 		else if(0==res)
    39. 		{
    40. 			printf("服务器链接失败\n");
    41. 			break;
    42. 		}
    43. 	*/	printf("[192.168.122.84,4444]:%s\n",buf);
    44. 	}
    45. 	close(cfd);
    46.  
    47. 	return 0;
    48. }

    多线程接收方

    1. ubuntu@ubuntu:TCP$ cat tcp_ser.c
    2. #include 
    3. #define PORT 4444
    4. #define IP "192.168.125.230"
    5. void handler(int sig)
    6. {
    7. 	while(waitpid(-1,NULL,WNOHANG)>0);
    8. 	return;
    9. }
    10. int main(int argc, const char *argv[])
    11. {
    12. 	//17信号
    13. 	if(signal(SIGCHLD,handler)==SIG_ERR)
    14. 	{
    15. 		ERR_MSG("signal");
    16. 		return -1;
    17. 	}
    18. 	//创建流式套接字
    19. 	int sfd=socket(AF_INET,SOCK_STREAM,0);
    20. 	printf("socket success\n");
    21. 	//允许端口被重复使用
    22. 	int reuse=1;
    23. 	setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))<0;
    24. 	printf("允许端口被重复使用\n");
    25. 	//bind
    26. 	struct sockaddr_in sin;
    27. 	sin.sin_family=AF_INET;
    28. 	sin.sin_port=htons(PORT);
    29. 	sin.sin_addr.s_addr=inet_addr(IP);
    30. 	bind(sfd,(struct sockaddr*)&sin,sizeof(sin));
    31. 	printf("bind success\n");
    32. 	//listen
    33. 	listen(sfd,128);
    34. 	//存储客户端信息0
    35. 	struct sockaddr_in cin;
    36. 	socklen_t addrlen=sizeof(cin);
    37.  
    38. 	int newfd;
    39. 	pid_t p;
    40. 	while(1)
    41. 	{
    42. 		newfd=accept(sfd,(struct sockaddr*)&cin,&addrlen);
    43. 		printf("1\n");
    44. 		if(newfd<0)
    45. 		{
    46. 			perror("accept");
    47. 			return -1;
    48. 		}
    49. 		printf("connect success\n");
    50. 		printf("[%s:%d]\n",\
    51. 			inet_ntoa(cin.sin_addr),ntohs(cin.sin_port));
    52. 		p=fork();
    53. 		if(p==0)
    54. 		{
    55.  
    56. 			//接收
    57. 			char buf[128]="";
    58. 			size_t res=0;
    59. 			while(1)
    60. 			{
    61. 				bzero(buf,sizeof(buf));
    62. 				res=recv(newfd,buf,sizeof(buf),0); 
    63. 				if(res<0)
    64. 				{
    65. 					perror("recv");
    66. 				}
    67. 				else if(0==res)
    68. 				{
    69. 					printf("客户端链接失败，客戶端IP：%s\n，客戶端端口：%d\n",\
    70. 						inet_ntoa(cin.sin_addr),ntohs(cin.sin_port));
    71. 					break;
    72. 				}
    73. 				printf("[%s:%d]:%s\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),buf);
    74. 			}
    75. 			close(newfd);
    76. 			exit(0);
    77. 		}
    78. 	close(newfd);
    79. 	}
    80. 	return 0;
    81. }

    广播发送方

    1. #include 
    2. #define PORT 4444
    3. #define IP "192.168.125.255"
    4. int main(int argc, const char *argv[])
    5. {
    6. 	//创建流式套接字
    7. 	int cfd=socket(AF_INET,SOCK_DGRAM,0);
    8. 	printf("socket success\n");
    9. 	//允许端口被重复使用
    10. 	int reuse=1;
    11. 	setsockopt(cfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))<0;
    12. 	printf("允许端口被重复使用\n");
    13. 	int a=1;
    14. 	if(setsockopt(cfd,SOL_SOCKET,SO_BROADCAST,&a,sizeof(a))<0)
    15. 	{
    16. 		printf("setsockopt broadcast");
    17. 	}
    18. 	printf("a=%d\n",a);
    19. 	printf("设置广播成功\n");
    20.  
    21. 	//服务器地址
    22. 	struct sockaddr_in sin;
    23. 	sin.sin_family=AF_INET;
    24. 	sin.sin_port=htons(PORT);
    25. 	sin.sin_addr.s_addr=inet_addr(IP);
    26. 	
    27. 	char buf[128]="";
    28. 	ssize_t res=0;
    29. 	socklen_t addrlen=sizeof(sin);
    30. 	while(1)
    31. 	{
    32. 		//发送
    33. 		bzero(buf,sizeof(buf));
    34. 		printf("输入:");
    35. 		scanf("%s",buf);
    36. 		sendto(cfd,buf,sizeof(buf),0,(struct sockaddr*)&sin,addrlen);
    37. 		printf("发送成功\n");
    38. 		//接收
    39. 	/*	bzero(buf,sizeof(buf));
    40. 		res=recvfrom(cfd,buf,sizeof(buf),0,(struct sockaddr*)&sin,&addrlen); 
    41. 		if(res<0)
    42. 		{
    43. 			perror("recv");
    44. 		}
    45. 		printf(":%s\n",buf);
    46. */
    47. 	}
    48. 	close(cfd);
    49. 	return 0;
    50. }

    广播接收方

    1. #include 
    2. #define PORT 4444
    3. #define IP "192.168.125.255"
    4. int main(int argc, const char *argv[])
    5. {
    6. 	//创建流式套接字
    7. 	int sfd=socket(AF_INET,SOCK_DGRAM,0);
    8. 	printf("socket success\n");
    9. 	//允许端口被重复使用
    10. 	int reuse=1;
    11. 	setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))<0;
    12. 	printf("允许端口被重复使用\n");
    13. /*	int size1=0;
    14. 	socklen_t len=sizeof(size1);
    15. 	getsockopt(sfd,SOL_SOCKET,SO_RCVBUF,&size1,&len);
    16. 	printf("size1=%d\n",size1);
    17. */	//bind
    18. 	struct sockaddr_in sin;
    19. 	sin.sin_family=AF_INET;
    20. 	sin.sin_port=htons(PORT);
    21. 	sin.sin_addr.s_addr=inet_addr(IP);
    22. 	bind(sfd,(struct sockaddr*)&sin,sizeof(sin));
    23. 	printf("bind success\n");
    24. 	//客户端地址
    25. 	struct sockaddr_in cin;
    26. 	char buf[128]="";
    27. 	ssize_t res=0;
    28. 	socklen_t addrlen=sizeof(cin);
    29. 	while(1)
    30. 	{
    31. 		//接收
    32. 		bzero(buf,sizeof(buf));
    33. 		res=recvfrom(sfd,buf,sizeof(buf),0,(struct sockaddr*)&cin,&addrlen); 
    34. 		if(res<0)
    35. 		{
    36. 			perror("recv");
    37. 		}
    38. 		printf(":%s\n",buf);
    39. 		//与发送信息的客户端绑定
    40. /*		connect(sfd,(struct sockaddr*)&cin,addrlen);
    41. 		if(strcmp(buf,"quit")==0)
    42. 		{
    43. 			sin.sin_family=AF_UNSPEC;
    44. 			printf("断开连接\n");
    45. 		}
    46. 		//发送
    47. 		bzero(buf,sizeof(buf));
    48. 		printf("输入:");
    49. 		scanf("%s",buf);
    50. 		sendto(sfd,buf,sizeof(buf),0,(struct sockaddr*)&cin,addrlen);
    51. 		printf("发送成功\n");
    52. 		*/
    53. 	}
    54. 	close(sfd);
    55. 	return 0;
    56. }

    组播接收方

    1. #include 
    2. #define PORT 4444
    3. #define GIP "224.5.5.5"
    4. #define LIP "192.168.125.230"
    5. int main(int argc, const char *argv[])
    6. {
    7. 	//创建流式套接字
    8. 	int sfd=socket(AF_INET,SOCK_DGRAM,0);
    9. 	printf("socket success\n");
    10. 	//允许端口被重复使用
    11. 	int reuse=1;
    12. 	setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))<0;
    13. 	printf("允许端口被重复使用\n");
    14. 	//加入多播组
    15. 	struct ip_mreqn mq;
    16. 	mq.imr_multiaddr.s_addr=inet_addr(GIP);//组播ip
    17. 	mq.imr_address.s_addr=inet_addr(LIP);//本地ip
    18. 	mq.imr_ifindex=2;//网络设备索引号
    19. 	if(setsockopt(sfd,IPPROTO_IP,IP_ADD_MEMBERSHIP,&mq,sizeof(mq))<0)
    20. 	{
    21. 		perror("setsockopt(group)");
    22. 		return -1;
    23. 	}
    24. 	printf("加入多播组[%s]成功\n",GIP);
    25. 	//服务器地址
    26. 	struct sockaddr_in sin;
    27. 	sin.sin_family=AF_INET;
    28. 	sin.sin_port=htons(PORT);
    29. 	sin.sin_addr.s_addr=inet_addr(LIP);
    30. 	bind(sfd,(struct sockaddr*)&sin,sizeof(sin));
    31. 	printf("绑定地址信息成功\n");
    32.  
    33. 	struct sockaddr_in cin;
    34. 	char buf[128]="";
    35. 	ssize_t res=0;
    36. 	socklen_t addrlen=sizeof(cin);
    37. 	while(1)
    38. 	{
    39. 		//接收
    40. 		bzero(buf,sizeof(buf));
    41. 		res=recvfrom(sfd,buf,sizeof(buf),0,(struct sockaddr*)&cin,&addrlen);
    42. 		if(res<0)
    43. 		{
    44. 			perror("recv");
    45. 		}
    46. 		printf(":%s\n",buf);
    47. 	}
    48. 	close(sfd);
    49. 	return 0;
    50. }
    51.

    组播发送方

    1. #include 
    2. #define PORT 4444
    3. #define GIP "224.5.5.5"
    4. int main(int argc, const char *argv[])
    5. {
    6. 	//创建报式套接字
    7. 	int cfd=socket(AF_INET,SOCK_DGRAM,0);
    8. 	printf("socket success\n");
    9. 	//允许端口被重复使用
    10. 	int reuse=1;
    11. 	setsockopt(cfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))<0;
    12. 	printf("允许端口被重复使用\n");
    13.  
    14. 	//服务器地址
    15. 	struct sockaddr_in sin;
    16. 	sin.sin_family=AF_INET;
    17. 	sin.sin_port=htons(PORT);
    18. 	sin.sin_addr.s_addr=inet_addr(GIP);
    19. 	
    20. 	char buf[128]="";
    21. 	ssize_t res=0;
    22. 	socklen_t addrlen=sizeof(sin);
    23. 	while(1)
    24. 	{
    25. 		//发送
    26. 		bzero(buf,sizeof(buf));
    27. 		printf("输入:");
    28. 		scanf("%s",buf);
    29. 		sendto(cfd,buf,sizeof(buf),0,(struct sockaddr*)&sin,addrlen);
    30. 		printf("发送成功\n");
    31. 		//接收
    32. 	/*	bzero(buf,sizeof(buf));
    33. 		res=recvfrom(cfd,buf,sizeof(buf),0,(struct sockaddr*)&sin,&addrlen); 
    34. 		if(res<0)
    35. 		{
    36. 			perror("recv");
    37. 		}
    38. 		printf(":%s\n",buf);
    39. */
    40. 	}
    41. 	close(cfd);
    42. 	return 0;
    43. }
    44.

  • 相关阅读:
    关于electron中使用ffi-napi窗口遍历的过程及问题
    搬砖日记：vue2 用require引入图片项目编译失败
    Java基于B/S架构，包括PC后台管理端、APP移动端、可视化数据大屏的智慧工地源码
    人大金仓数据库创建与还原--九五小庞
    基于C#的Windows控制台的吃豆豆小游戏
    Win11拖拽文件偶现卡顿死机情况解决
    实现内网穿透的最佳解决方案（无实名认证，完全免费）
    进阶——旋转数组
    排序学习总结
    烽火传递——单调队列优化dp问题
  • 原文地址：https://blog.csdn.net/qiujunhang/article/details/133148231