• l8-d8 TCP并发实现

    一、TCP多进程并发

    1.地址快速重用

    先退出服务端，后退出客户端，则服务端会出现以下错误：

    地址仍在使用中

    解决方法：

    /*地址快速重用*/
        int flag=1,len= sizeof (int);
        if ( setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &flag, len) == -1) {
                  perror("setsockopt");
                  exit(1);
        }

     2.多进程并发

    1）fork函数

    1. #include 
    2. #include 
    3. #include 
    4.  
    5. int main(int argc, char *argv[])
    6. {
    7.     pid_t pid = fork();
    8.     if(pid < 0){
    9.         perror("fork");
    10.         exit(0);
    11.     }else if(pid == 0){
    12.         printf("This is child process.\n");
    13.     }else{
    14.         printf("This is father process.\n");
    15.         wait(NULL);
    16.     }
    17.     return 0;
    18. }

    2）多个客户端

    代码演示

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9.  
    10. #define BACKLOG 5
    11. void ClinetHandle(int newfd);
    12. int main(int argc, char *argv[])
    13. {
    14. 	int fd, newfd;
    15. 	struct sockaddr_in addr, clint_addr;
    16. 	socklen_t addrlen = sizeof(clint_addr);
    17. 	
    18. 	pid_t pid;
    19. 	
    20. 	if(argc < 3){
    21. 		fprintf(stderr, "%s\n", argv[0]);
    22. 		exit(0);
    23. 	}
    24.  
    25. 	/*创建套接字*/
    26. 	fd = socket(AF_INET, SOCK_STREAM, 0);
    27. 	if(fd < 0){
    28. 		perror("socket");
    29. 		exit(0);
    30. 	}
    31. 	addr.sin_family = AF_INET;
    32. 	addr.sin_port = htons( atoi(argv[2]) );
    33. 	if ( inet_aton(argv[1], &addr.sin_addr) == 0) {
    34. 		fprintf(stderr, "Invalid address\n");
    35. 		exit(EXIT_FAILURE);
    36. 	}
    37.  
    38. 	/*地址快速重用*/
    39. 	int flag=1,len= sizeof (int); 
    40. 	if ( setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &flag, len) == -1) { 
    41. 		      perror("setsockopt"); 
    42. 			        exit(1); 
    43. 	} 
    44. 	/*绑定通信结构体*/
    45. 	if(bind(fd, (struct sockaddr *)&addr, sizeof(addr) ) == -1){
    46. 		perror("bind");
    47. 		exit(0);
    48. 	}
    49. 	/*设置套接字为监听模式*/
    50. 	if(listen(fd, BACKLOG) == -1){
    51. 		perror("listen");
    52. 		exit(0);
    53. 	}
    54. 	while(1){
    55. 		/*接受客户端的连接请求，生成新的用于和客户端通信的套接字*/
    56. 		newfd = accept(fd, (struct sockaddr *)&clint_addr, &addrlen);
    57. 		if(newfd < 0){
    58. 			perror("accept");
    59. 			exit(0);
    60. 		}
    61. 		printf("addr:%s port:%d\n", inet_ntoa(clint_addr.sin_addr), ntohs(clint_addr.sin_port) );
    62. 		if( (pid = fork() ) < 0){
    63. 			perror("fork");
    64. 			exit(0);
    65. 		}else if(pid == 0){
    66. 			close(fd);
    67. 			ClinetHandle(newfd);
    68. 			exit(0);
    69. 		}
    70. 		else
    71. 			close(newfd);
    72. 	}
    73. 	close(fd);
    74. 	return 0;
    75. }
    76. void ClinetHandle(int newfd){
    77. 	int ret;
    78. 	char buf[BUFSIZ] = {};
    79. 	while(1){
    80. 		//memset(buf, 0, BUFSIZ);
    81. 		bzero(buf, BUFSIZ);        //初始化
    82. 		ret = read(newfd, buf, BUFSIZ);
    83. 		if(ret < 0)
    84. 		{
    85. 			perror("read");
    86. 			exit(0);
    87. 		}
    88. 		else if(ret == 0)
    89. 			break;
    90. 		else
    91. 			printf("buf = %s\n", buf);
    92. 	}
    93. 	close(newfd);
    94. }
    95.

    二、僵尸进程处理

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9. #include 
    10. #include 
    11.  
    12. #define BACKLOG 5
    13. void SigHandle(int sig){
    14. 	if(sig == SIGCHLD){
    15. 		printf("client exited\n");
    16. 		wait(NULL);
    17. 	}
    18. }
    19. void ClinetHandle(int newfd);
    20. int main(int argc, char *argv[])
    21. {
    22. 	int fd, newfd;
    23. 	struct sockaddr_in addr, clint_addr;
    24. 	socklen_t addrlen = sizeof(clint_addr);
    25.  
    26. #if 0
    27. 	struct sigaction act;
    28. 	act.sa_handler = SigHandle;
    29. 	act.sa_flags = SA_RESTART;
    30. 	sigemptyset(&act.sa_mask);
    31. 	sigaction(SIGCHLD, &act, NULL);
    32. #else
    33. 	signal(SIGCHLD, SigHandle);
    34. #endif
    35.  
    36. 	pid_t pid;
    37. 	
    38. 	if(argc < 3){
    39. 		fprintf(stderr, "%s\n", argv[0]);
    40. 		exit(0);
    41. 	}
    42.  
    43. 	/*创建套接字*/
    44. 	fd = socket(AF_INET, SOCK_STREAM, 0);
    45. 	if(fd < 0){
    46. 		perror("socket");
    47. 		exit(0);
    48. 	}
    49. 	addr.sin_family = AF_INET;
    50. 	addr.sin_port = htons( atoi(argv[2]) );
    51. 	if ( inet_aton(argv[1], &addr.sin_addr) == 0) {
    52. 		fprintf(stderr, "Invalid address\n");
    53. 		exit(EXIT_FAILURE);
    54. 	}
    55.  
    56. 	/*地址快速重用*/
    57. 	int flag=1,len= sizeof (int); 
    58. 	if ( setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &flag, len) == -1) { 
    59. 		      perror("setsockopt"); 
    60. 			        exit(1); 
    61. 	} 
    62. 	/*绑定通信结构体*/
    63. 	if(bind(fd, (struct sockaddr *)&addr, sizeof(addr) ) == -1){
    64. 		perror("bind");
    65. 		exit(0);
    66. 	}
    67. 	/*设置套接字为监听模式*/
    68. 	if(listen(fd, BACKLOG) == -1){
    69. 		perror("listen");
    70. 		exit(0);
    71. 	}
    72. 	while(1){
    73. 		/*接受客户端的连接请求，生成新的用于和客户端通信的套接字*/
    74. 		newfd = accept(fd, (struct sockaddr *)&clint_addr, &addrlen);
    75. 		if(newfd < 0){
    76. 			perror("accept");
    77. 			exit(0);
    78. 		}
    79. 		printf("addr:%s port:%d\n", inet_ntoa(clint_addr.sin_addr), ntohs(clint_addr.sin_port) );
    80. 		if( (pid = fork() ) < 0){
    81. 			perror("fork");
    82. 			exit(0);
    83. 		}else if(pid == 0){
    84. 			close(fd);
    85. 			ClinetHandle(newfd);
    86. 			exit(0);
    87. 		}
    88. 		else
    89. 			close(newfd);
    90. 	}
    91. 	close(fd);
    92. 	return 0;
    93. }
    94. void ClinetHandle(int newfd){
    95. 	int ret;
    96. 	char buf[BUFSIZ] = {};
    97. 	while(1){
    98. 		//memset(buf, 0, BUFSIZ);
    99. 		bzero(buf, BUFSIZ);
    100. 		ret = read(newfd, buf, BUFSIZ);
    101. 		if(ret < 0)
    102. 		{
    103. 			perror("read");
    104. 			exit(0);
    105. 		}
    106. 		else if(ret == 0)
    107. 			break;
    108. 		else
    109. 			printf("buf = %s\n", buf);
    110. 	}
    111. 	close(newfd);
    112. }
    113.

    三、TCP并发多线程

     

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. #include 
    7. #include 
    8. #include 
    9. #include 
    10.  
    11. #define BACKLOG 5
    12.  
    13. void *ClinetHandle(void *arg);
    14. int main(int argc, char *argv[])
    15. {
    16. 	int fd, newfd;
    17. 	struct sockaddr_in addr, clint_addr;
    18. 	pthread_t tid;
    19. 	socklen_t addrlen = sizeof(clint_addr);
    20. 	
    21. 	if(argc < 3){
    22. 		fprintf(stderr, "%s\n", argv[0]);
    23. 		exit(0);
    24. 	}
    25.  
    26. 	/*创建套接字*/
    27. 	fd = socket(AF_INET, SOCK_STREAM, 0);
    28. 	if(fd < 0){
    29. 		perror("socket");
    30. 		exit(0);
    31. 	}
    32. 	addr.sin_family = AF_INET;
    33. 	addr.sin_port = htons( atoi(argv[2]) );
    34. 	if ( inet_aton(argv[1], &addr.sin_addr) == 0) {
    35. 		fprintf(stderr, "Invalid address\n");
    36. 		exit(EXIT_FAILURE);
    37. 	}
    38.  
    39. 	/*地址快速重用*/
    40. 	int flag=1,len= sizeof (int); 
    41. 	if ( setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &flag, len) == -1) { 
    42. 		      perror("setsockopt"); 
    43. 			        exit(1); 
    44. 	} 
    45. 	/*绑定通信结构体*/
    46. 	if(bind(fd, (struct sockaddr *)&addr, sizeof(addr) ) == -1){
    47. 		perror("bind");
    48. 		exit(0);
    49. 	}
    50. 	/*设置套接字为监听模式*/
    51. 	if(listen(fd, BACKLOG) == -1){
    52. 		perror("listen");
    53. 		exit(0);
    54. 	}
    55. 	while(1){
    56. 		/*接受客户端的连接请求，生成新的用于和客户端通信的套接字*/
    57. 		newfd = accept(fd, (struct sockaddr *)&clint_addr, &addrlen);
    58. 		if(newfd < 0){
    59. 			perror("accept");
    60. 			exit(0);
    61. 		}
    62. 		printf("addr:%s port:%d\n", inet_ntoa(clint_addr.sin_addr), ntohs(clint_addr.sin_port) );
    63. 		pthread_create(&tid, NULL, ClinetHandle, &newfd);    //创建线程
    64. 		pthread_detach(tid);    //设置为分离属性
    65. 	}
    66. 	close(fd);
    67. 	return 0;
    68. }
    69. void *ClinetHandle(void *arg){
    70. 	int ret;
    71. 	char buf[BUFSIZ] = {};
    72. 	int newfd = *(int *)arg;    //传参，强转
    73. 	while(1){
    74. 		//memset(buf, 0, BUFSIZ);
    75. 		bzero(buf, BUFSIZ);
    76. 		ret = read(newfd, buf, BUFSIZ);
    77. 		if(ret < 0)
    78. 		{
    79. 			perror("read");
    80. 			exit(0);
    81. 		}
    82. 		else if(ret == 0)
    83. 			break;
    84. 		else
    85. 			printf("buf = %s\n", buf);
    86. 	}
    87. 	printf("client exited\n");
    88. 	close(newfd);
    89. 	return NULL;
    90. }
    91.

    Makefile


    CC=gcc
    CFLAGS=-Wall
    all:client server

    server:server.c
        $(CC) $^ -Wall -o $@ -lpthread

    clean:
        rm client server
     

  • 相关阅读:
    MMDetection在ScanNet上训练
    万字长文：一文彻底搞懂Elasticsearch中Geo数据类型查询、聚合、排序
    Navicat 15 下载、安装、重装
    妙啊，Python 管道 Pipe 编写代码如此优雅
    openssl客户端编程：一个不起眼的函数导致的SSL会话失败问题
    超标量处理器设计 姚永斌 第8章 指令发射 摘录
    net-java-php-python-单位办公OA系统计算机毕业设计程序
    第四代智能井盖传感器：万宾科技助力城市安全
    Java中 \n \f \r \t 含义
    some和every
  • 原文地址：https://blog.csdn.net/revengeman/article/details/132744417