Linux TCP协议使用进程实现并发服务器
2016-11-07 21:34
417 查看
直接放代码:
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <string.h>
#include <arpa/inet.h>
#define PORTNUM 3333
int main()
{
int sock_fd;
int sock_fd_new;
struct sockaddr_in my_addr;
int addrlen = sizeof(struct sockaddr);
struct sockaddr_in addr_client;
char buf[1024];
//1.socket
sock_fd = socket(AF_INET,SOCK_STREAM,0);
if(sock_fd < 0)
{
printf("socket error\n");
exit(1);
}
//2.bind
bzero(&my_addr,sizeof(struct sockaddr_in));
my_addr.sin_family = AF_INET;
my_addr.sin_port = htons(PORTNUM);
//my_addr.sin_addr.s_addr = htonl(INADDR_ANY);
my_addr.sin_addr.s_addr = inet_addr("192.168.1.11");
if(bind(sock_fd,(struct sockaddr *)(&my_addr),addrlen) < 0)
{
printf("bind error\n");
close(sock_fd);
exit(1);
}
//3.listen
if(listen(sock_fd,10) < 0)
{
printf("listen error\n");
}
while(1)
{
bzero(buf,sizeof(buf));
//4.accept
bzero(&addr_client,sizeof(struct sockaddr_in));
sock_fd_new = accept(sock_fd,(struct sockaddr *)(&addr_client),&addrlen);
if(sock_fd_new < 0)
{
printf("accept error\n");
}
if(fork() == 0)//有客户链接成功,就新建一个进程。
{
//5.recv
while(1)
{
if(recv(sock_fd_new,(void *)buf,1024,0) > 0)
{
printf("buf = %s\n",buf);
}
if(strncmp(buf,"quit",4) == 0)
{
close(sock_fd_new);
break;
}
}
}
}
//6.close
close(sock_fd);
return 0;
}
一个在努力中的未来程序员,如果有更好的算法,欢迎评论。
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <string.h>
#include <arpa/inet.h>
#define PORTNUM 3333
int main()
{
int sock_fd;
int sock_fd_new;
struct sockaddr_in my_addr;
int addrlen = sizeof(struct sockaddr);
struct sockaddr_in addr_client;
char buf[1024];
//1.socket
sock_fd = socket(AF_INET,SOCK_STREAM,0);
if(sock_fd < 0)
{
printf("socket error\n");
exit(1);
}
//2.bind
bzero(&my_addr,sizeof(struct sockaddr_in));
my_addr.sin_family = AF_INET;
my_addr.sin_port = htons(PORTNUM);
//my_addr.sin_addr.s_addr = htonl(INADDR_ANY);
my_addr.sin_addr.s_addr = inet_addr("192.168.1.11");
if(bind(sock_fd,(struct sockaddr *)(&my_addr),addrlen) < 0)
{
printf("bind error\n");
close(sock_fd);
exit(1);
}
//3.listen
if(listen(sock_fd,10) < 0)
{
printf("listen error\n");
}
while(1)
{
bzero(buf,sizeof(buf));
//4.accept
bzero(&addr_client,sizeof(struct sockaddr_in));
sock_fd_new = accept(sock_fd,(struct sockaddr *)(&addr_client),&addrlen);
if(sock_fd_new < 0)
{
printf("accept error\n");
}
if(fork() == 0)//有客户链接成功,就新建一个进程。
{
//5.recv
while(1)
{
if(recv(sock_fd_new,(void *)buf,1024,0) > 0)
{
printf("buf = %s\n",buf);
}
if(strncmp(buf,"quit",4) == 0)
{
close(sock_fd_new);
break;
}
}
}
}
//6.close
close(sock_fd);
return 0;
}
一个在努力中的未来程序员,如果有更好的算法,欢迎评论。
相关文章推荐
- Linux TCP协议使用线程实现并发服务器
- Linux网络编程使用多进程实现服务器并发访问
- 并发服务器的实现(进程与线程)
- 第十三篇:并发回射服务器的具体实现及其中僵尸子进程的清理( 下 )
- 使用Python WSGI编写Web服务器前端,并利用Boost.Python在同一进程内连接到C++服务后端实现
- linux下高并发服务器实现(修改用户进程可打开文件数限制ulimit -n)
- linux(一)------多进程并发服务器实现(fork)
- linux下一个单进程并发服务器的实例 使用select
- Unix网络编程(七)使用select来实现服务器的并发
- 第十九篇:不为客户连接创建子进程的并发回射服务器(select实现)
- Linux网络编程:TCP服务器(单进程多用户),使用select方法实现
- 不为客户连接创建子进程的并发回射服务器( select实现 )
- 单进程多线程并发服务器实现
- 第二十篇:不为客户连接创建子进程的并发回射服务器(poll实现)
- 使用Select I/O模型来实现一个并发处理多个客户端的TCP服务器
- 网络编程(6)单进程多线程并发服务器实现
- 并发回射服务器的具体实现及其中僵尸子进程的清理( 下 )
- Linux网络编程:TCP服务器(单进程多用户),使用select方法实现
- Linux下一个单进程并发服务器的实例 使用select
- 使用socket的Linux上的C语言helloworld多进程并发服务器