一个简单的客户单与服务端程序

int select(int nfds, fd_set *readfds, fd_set *writefds, exceptfds, const struct timeval* timeout);

#include <sys/time.h>

#include <unistd.h>

    1.timeout=NULL                 （阻塞：select将一直被阻塞，直到某个文件描述符上发生了事件）

    2.timeout所指向的结构设为非零时间  （等待固定时间：如果在指定的时间段里有事件发生或者时间耗尽，函数均返回）

    3.timeout所指向的结构，时间设为0   （非阻塞：仅检测描述符集合的状态，然后立即返回，并不等待外部事件的发生）

FD_ZERO(*fds)：     将fds设为空集
    
FD_CLR(fd,*fds)：   从集合fds中删除指定的fd

FD_SET(fd,*fds)：   从集合fds中添加指定的fd

FD_ISSET(fd,*fds)： 判断fd是否属于fds的集合

socket s;
.....
fd_set set;
while(1){
FD_ZERO(&set);                    //将你的套节字集合清空
FD_SET(s, &set);                 //加入你感兴趣的套节字到集合,这里是一个读数据的套节字s
select(0,&set,NULL,NULL,NULL);   //检查套节字是否可读,
if(FD_ISSET(s, &set)            //检查s是否在这个集合里面,
{                               //select将更新这个集合,把其中不可读的套节字去掉
                                //只保留符合条件的套节字在这个集合里面
recv(s,...);
}
//do something here
}

   （1）执行fd_set set; FD_ZERO(&set);  则set用位为0000,0000。

   （2）若fd＝5,执行FD_SET(fd,&set);     后set变为 0001,0000(第5位置为1)

   （3）若再加入fd＝2，fd=1               则set变为 0001,0011

   （4）执行select(6,&set,0,0,0)        阻塞等待

   （5）若fd=1,fd=2                    上都发生可读事件，则select返回，此时set变为0000,0011。注意：没有事件发生的fd=5被清空。

#include <time.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/socket.h>
 
#define REMOTE_PORT 6666　　　　　　　　//服务器端口
#define REMOTE_ADDR "127.0.0.1"　　　  //服务器地址
 
int main(){
  int sockfd;
  struct sockaddr_in addr;
  char msgbuffer[256];
   
  //创建套接字
  sockfd = socket(AF_INET,SOCK_STREAM,0);
  if(sockfd>=0)
    printf("open socket: %d\n",sockfd);
 
  //将服务器的地址和端口存储于套接字结构体中
  bzero(&addr,sizeof(addr));
  addr.sin_family=AF_INET;
  addr.sin_port=htons(REMOTE_PORT);
  addr.sin_addr.s_addr = inet_addr(REMOTE_ADDR);
  
  //向服务器发送请求
  if(connect(sockfd,(struct sockaddr*)&addr,sizeof(addr))>=0)
    printf("connect successfully\n");
   
  //接收服务器返回的消息（注意这里程序会被阻塞，也就是说只有服务器回复信息，才会继续往下执行）
  recv(sockfd,msgbuffer,sizeof(msgbuffer),0);
    printf("%s\n",msgbuffer);
  
  while(1){
    //将键盘输入的消息发送给服务器，并且从服务器中取得回复消息
    bzero(msgbuffer,sizeof(msgbuffer));
    read(STDIN_FILENO,msgbuffer,sizeof(msgbuffer));
    if(send(sockfd,msgbuffer,sizeof(msgbuffer),0)<0)
      perror("ERROR");
    
    bzero(msgbuffer,sizeof(msgbuffer));
    recv(sockfd,msgbuffer,sizeof(msgbuffer),0);
    printf("[receive]:%s\n",msgbuffer);
    
    usleep(500000);
  }
}

#include <time.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/types.h>
#include <sys/socket.h>
 
#define LOCAL_PORT 6666　　　　　　//本地服务端口
#define MAX 5　　　　　　　　　　　　//最大连接数量
 
int main(){
  int sockfd,connfd,fd,is_connected[MAX];
  struct sockaddr_in addr;
  int addr_len = sizeof(struct sockaddr_in);
  char msgbuffer[256];
  char msgsend[] = "Welcome To Demon Server";
  fd_set fds;
   
  //创建套接字
  sockfd = socket(AF_INET,SOCK_STREAM,0);
  if(sockfd>=0)
    printf("open socket: %d\n",sockfd);
 
  //将本地端口和监听地址信息保存到套接字结构体中
  bzero(&addr,sizeof(addr));
  addr.sin_family=AF_INET;
  addr.sin_port=htons(LOCAL_PORT);
  addr.sin_addr.s_addr = htonl(INADDR_ANY);   //INADDR_ANY表示任意地址0.0.0.0 0.0.0.0
   
  //将套接字于端口号绑定
  if(bind(sockfd,(struct sockaddr*)&addr,sizeof(addr))>=0)
    printf("bind the port: %d\n",LOCAL_PORT);
 
  //开启端口监听
  if(listen(sockfd,3)>=0)
    printf("begin listenning...\n");
 
  //默认所有fd没有被打开
  for(fd=0;fd<MAX;fd++)
    is_connected[fd]=0;
 
  while(1){
    //将服务端套接字加入集合中
    FD_ZERO(&fds);
    FD_SET(sockfd,&fds);
     
    //将活跃的套接字加入集合中
    for(fd=0;fd<MAX;fd++)
      if(is_connected[fd])
        FD_SET(fd,&fds);
 
    //监视集合中的可读信号，如果某个套接字有信号则继续执行，此时集合中只有存在信号的套接字会被置为1，其他置为0
    if(!select(MAX,&fds,NULL,NULL,NULL))
      continue;
 
    //遍历所有套接字判断是否在属于集合中的活跃套接字
    for(fd=0;fd<MAX;fd++){
      if(FD_ISSET(fd,&fds)){
        if(fd==sockfd){                             //如果套接字是服务端，那么与客户端accept建立连接
          connfd = accept(sockfd,(struct sockaddr*)&addr,&addr_len);
          write(connfd,msgsend,sizeof(msgsend));    //向其输出欢迎语
          is_connected[connfd]=1;                   //对客户端的fd对应下标将其设为活跃状态，方便下次调用
          printf("connected from %s\n",inet_ntoa(addr.sin_addr));
        }else{                                      //如果套接字是客户端，读取其信息并返回，如果读取不到信息，冻结其套接字
          if(read(fd,msgbuffer,sizeof(msgbuffer))>0){ 
            write(fd,msgbuffer,sizeof(msgbuffer));
            printf("[read]: %s\n",msgbuffer);
          }else{
             is_connected[fd]=0;
             close(fd);
             printf("close connected\n");
          }
        }
      }
    }
  }
}