lesson6 基于多线程的tcp并发服务器
2017-02-15 21:44
441 查看
1. 每条新连接的client都会抛出一个新线程处理事件
/*DATA: 2015-4-20
*AUTHOR: WJ
*DESCRIPTION: 多线程TCP服务器
* 1、int socket(int domain, int type, int protocol);
* 2、int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
* 3、int listen(int sockfd, int backlog);
* 4、int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
* 5、read、write
*/
#include "apue.h"
#define MAX_LISTEN 10
char buf[100];
int ad[10];
struct sockaddr_in server_ip, remote_ip;
void *thread_fun(void *arg)
{
while(1)
{
printf("read data from client ; %s\n", inet_ntoa(remote_ip.sin_addr.s_addr));
read(ad[(int)arg], buf, 100);
printf("buf is %s\n", buf);
}
return NULL;
}
int main()
{
int server_len, remote_len;
pthread_t tid[10];
int err, sd;
int i=0;
sd = socket(AF_INET, SOCK_STREAM, 0);
if(sd == -1)
{
printf("create socket failed, errno is %d\n", errno);
return;
}
server_ip.sin_family = AF_INET;
server_ip.sin_port = htons(5678);
server_ip.sin_addr.s_addr = htonl(INADDR_ANY);
memset(server_ip.sin_zero, 0, 8);
err = bind(sd, (struct sockaddr *)(&server_ip), sizeof(struct sockaddr));
if(err == -1)
{
printf("bind error, errno is %d\n", errno);
close(sd);
return;
}
err = listen(sd, MAX_LISTEN);
if(err == -1)
{
printf("listen error , errno is %d\n", errno);
close(sd);
return;
}
remote_len = sizeof(struct sockaddr);
while(1)
{
ad[i] = accept(sd, (struct sockaddr *)(&remote_ip), &remote_len);
if(ad[i] == -1)
{
printf("accept error, errno is %d \n", errno);
close(sd);
return;
}
err = pthread_create(&tid[i], NULL, thread_fun, (void *)i);
if(err != 0)
{
printf("create new thread failed\n");
close(ad[i]);
}
i++;
}
close(sd);
return 0;
}
/*DATA: 2015-4-20
*AUTHOR: WJ
*DESCRIPTION: 多线程TCP服务器
* 1、int socket(int domain, int type, int protocol);
* 2、int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
* 3、int listen(int sockfd, int backlog);
* 4、int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);
* 5、read、write
*/
#include "apue.h"
#define MAX_LISTEN 10
char buf[100];
int ad[10];
struct sockaddr_in server_ip, remote_ip;
void *thread_fun(void *arg)
{
while(1)
{
printf("read data from client ; %s\n", inet_ntoa(remote_ip.sin_addr.s_addr));
read(ad[(int)arg], buf, 100);
printf("buf is %s\n", buf);
}
return NULL;
}
int main()
{
int server_len, remote_len;
pthread_t tid[10];
int err, sd;
int i=0;
sd = socket(AF_INET, SOCK_STREAM, 0);
if(sd == -1)
{
printf("create socket failed, errno is %d\n", errno);
return;
}
server_ip.sin_family = AF_INET;
server_ip.sin_port = htons(5678);
server_ip.sin_addr.s_addr = htonl(INADDR_ANY);
memset(server_ip.sin_zero, 0, 8);
err = bind(sd, (struct sockaddr *)(&server_ip), sizeof(struct sockaddr));
if(err == -1)
{
printf("bind error, errno is %d\n", errno);
close(sd);
return;
}
err = listen(sd, MAX_LISTEN);
if(err == -1)
{
printf("listen error , errno is %d\n", errno);
close(sd);
return;
}
remote_len = sizeof(struct sockaddr);
while(1)
{
ad[i] = accept(sd, (struct sockaddr *)(&remote_ip), &remote_len);
if(ad[i] == -1)
{
printf("accept error, errno is %d \n", errno);
close(sd);
return;
}
err = pthread_create(&tid[i], NULL, thread_fun, (void *)i);
if(err != 0)
{
printf("create new thread failed\n");
close(ad[i]);
}
i++;
}
close(sd);
return 0;
}
相关文章推荐
- 高性能、高并发TCP服务器(多线程调用libevent)
- Linux TCP 服务器编程(六):基于线程的并发服务器
- 流式(TCP)套接字客户端/服务器编程 (多线程并发服务器)
- tcp多线程并发服务器
- Linux下套接字详解(六)----基于pthread的多线程的TCP套接字(阻塞/同步/并发)
- TCP并发服务器实例--多线程
- 高性能、高并发TCP服务器(多线程调用libevent)
- 高性能、高并发TCP服务器(多线程调用libevent)
- 高性能、高并发TCP服务器(多线程调用libevent)
- 高性能、高并发TCP服务器(多线程调用libevent)
- TCP多线程并发服务器+线程池+echo
- Linux下面基于TCP多线程聊天室(服务器)
- 高性能、高并发TCP服务器(多线程调用libevent)
- java--通过socket和多线程进行多个客服端与服务器的简单通讯--基于tcp
- 黑马程序员-TCP上传图片-多线程并发上传图片-客户端并发登陆-自定义服务器
- 高性能、高并发TCP服务器(多线程调用libevent)
- TCP并发服务器(六)——创建线程池,每个线程accept,accept使用互斥锁保护——基于UNP代码
- 基于多线程的TCP服务器项目【开源】
- linux下搭建能同时接收UDP和TCP连接的socket并发多线程服务器
- 高性能、高并发TCP服务器(多线程调用libevent)