#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#define MYPORT 1234 // 侦听端口
#define BACKLOG 5 // 最大可连接客户端数量
#define BUF_SIZE 200
int fd_A[BACKLOG]; // 连接的FD数组
int conn_amount; // 当前连接的数量
void showclient()
{
int i;
printf("client amount: %d\n", conn_amount);
for (i = 0; i < BACKLOG; i++)
{
printf("[%d]:%d ", i, fd_A[i]);
}
printf("\n\n");
}
int main(void)
{
int sock_fd, new_fd; // 侦听sock_fd, 新连接new_fd
struct sockaddr_in server_addr; // server address information
struct sockaddr_in client_addr; // connector's address information
socklen_t sin_size;
int yes = 1;
char buf[BUF_SIZE];
int ret;
int i;
//创建侦听Socket
if ((sock_fd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
{
perror("Create listening socket error!");
exit(1);
}
//配置侦听Socket
//SO_REUSEADDR BOOL 允许套接口和一个已在使用中的地址捆绑。
if (setsockopt(sock_fd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1)
{
perror("setsockopt error!");
exit(1);
}
server_addr.sin_family = AF_INET; // host byte order
server_addr.sin_port = htons(MYPORT); // short, network byte order
server_addr.sin_addr.s_addr = INADDR_ANY; // automatically fill with my IP
memset(server_addr.sin_zero, '\0', sizeof(server_addr.sin_zero));
//绑定新创建的Socket到指定的IP和端口
if (bind(sock_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1)
{
perror("bind error!");
exit(1);
}
//开始侦听,最大连接数为BACKLOG
if (listen(sock_fd, BACKLOG) == -1)
{
perror("listen error!");
exit(1);
}
printf("listen port %d\n", MYPORT);
//监控文件描述符集合
fd_set fdsr;
//监控文件描述符集合中最大的文件号
int maxsock;
//Select超时返回的时间。
struct timeval tv;
conn_amount = 0;
sin_size = sizeof(client_addr);
maxsock = sock_fd;
while (1)
{
// 初始化文件描述符集合 initialize file descriptor set
FD_ZERO(&fdsr);
// 把Sock_fd加入到文件描述符集合
FD_SET(sock_fd, &fdsr);
// 超时设置30秒
tv.tv_sec = 30;
tv.tv_usec = 0;
// 把活动的socket的句柄加入到文件描述符集合中
for (i = 0; i < BACKLOG; i++)
{
if (fd_A[i] != 0)
{
FD_SET(fd_A[i], &fdsr);
}
}
//Select 函数原型
//int select(nfds, readfds, writefds, exceptfds, timeout)
//nfds: select监视的文件句柄数,视进程中打开的文件数而定,一般设为呢要监视各文件中的
//最大文件号加一
//readfds:select监视的可读文件句柄集合
//writefds:select监视的可写文件句柄集合。
//exceptfds:select监视的异常文件句柄集合。
//timeout:本次select的超时结束时间。
ret = select(maxsock + 1, &fdsr, NULL, NULL, &tv);
if (ret < 0)
{
perror("select error!");
break;
}
else if (ret == 0)
{
printf("timeout\n");
continue;
}
// 轮询各个文件描述符(socket)
for (i = 0; i < conn_amount; i++)
{
//FD_ISSET(int fd, fdset *fdset):检查fdset联系的文件句柄fd是否可读写,
// >0表示可读写。
if (FD_ISSET(fd_A[i], &fdsr))
{
//接收数据
ret = recv(fd_A[i], buf, sizeof(buf), 0);
if (ret <= 0) //接收数据出错
{
printf("client[%d] close\n", i);
close(fd_A[i]);
FD_CLR(fd_A[i], &fdsr);
fd_A[i] = 0;
}
else // 数据接收成功
{
//将接收数据的最后一位补0
if (ret < BUF_SIZE)
memset(&buf[ret], '\0', 1);
printf("client[%d] send:%s\n", i, buf);
}
}
}
// 检查是否有新连接进来,如果有新连接进来,接收连接,生成新socket,
//并加入到监控文件描述符集合中。
if (FD_ISSET(sock_fd, &fdsr))
{
//接受连接
new_fd = accept(sock_fd, (struct sockaddr *)&client_addr, &sin_size);
if (new_fd <= 0)
{
perror("accept socket error!");
continue;
}
// 将新的连接加入到监控文件描述符集合
if (conn_amount < BACKLOG)
{
fd_A[conn_amount++] = new_fd;
printf("new connection client[%d] %s:%d\n", conn_amount,inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
if (new_fd > maxsock)
maxsock = new_fd;
}
else
{
printf("max connections arrive, exit\n");
send(new_fd, "bye", 4, 0);
close(new_fd);
break;
}
}
showclient();
}
// 关闭所有连接
for (i = 0; i < BACKLOG; i++)
{
if (fd_A[i] != 0)
{
close(fd_A[i]);
}
}
exit(0);
}
分享到:
相关推荐
在linux下的socket编程服务器模型之多路复用I/O,源码经过本人编译,测试,绝对能正确运行。
建立TCP、UDP单播、组播 创建服务器端与客户端,服务器端使用select机制接收客户端的请求,并交给线程池处理
linux socket的select函数例子
linux-socket-select-异步聊天 linux-socket-select-异步聊天 linux-socket-select-异步聊天
linux socket select test code
Linux下使用select多socket的UDP服务实例
Select在Socket编程中还是比较重要的,可是对于初学Socket的人来说都不太爱用Select写程序,他们只是习惯写诸如connect、accept、recv或recvfrom这样的阻塞程序(所谓阻塞方式block,顾名思义,就是进程或是线程执行...
linux网络编程 pdf # Linux网络编程基础 Linux网络编程是指在Linux操作系统上开发网络应用程序的过程。它主要涉及到TCP/UDP协议以及select/poll/epoll等多路复用技术。 TCP/UDP协议是网络通信的基础,其中TCP协议...
本程序是Linux下基于socket套接字完成的简单网络编程程序,可以接收Tcp、Udp单播、Udp组播消息,并且加入了Select机制和多线程编程,比较简单,适合初学者使用。
linux环境 c++实现的httpserver, 包含tcpserver、tcpclient,其中tcpserver包含单线程、多线程、select模式、线程池、epool等几种实现
linux socket编程server和多client连接c++代码;select非阻塞监听;可直接运行./tcp-server和./tcp-client测试;移植性好;
linux网络编程实例,讲解了一些udp tcp的socket编程,有select的例子
在linux下socket通讯,用select实现一个服务器对多个客户端的相互之间的通讯。用法在资料里有说明。希望对大家有帮助~~如有疑问请留言~~谢谢支持
采用I/O复用技术select实现socket通信,完成Linux下的多客户聊天室!
linux_socket_select_tcp_server_client基础知识.pdf
linux下socket通讯,采用三种不同实现方法 1.fork方式,服务器为每个客户端生成一个子进程用于数据处理 2.select方式,采用轮询每个客户端socket的方式进行通讯 3.pthread方式,服务器建立一个侦听线程和接收线程...
自己实验的时候写的一个用select实现的TCP连接的并发socket代码
简单运用socket和select知识编写,是一个select的精彩例子。 PS:在根目录下直接 qmake make ,就能运行,文件夹里也包含有可运行文件。
该代码在Linux实现了一个类似于windows上的QQ的聊天工具。主要是基于TCP/IP协议的socket通信。包括服务器端和客户端两部分,其中客户端使用了select的IO多路复用技术,服务器端由于要监听多个客户端,因此使用了...
网络聊天室(socket中的select模型) 服务器、客户端 有点像qq群组