Linux C TCP服务器端-select案例

简介: 本文主要介绍了linux下Select的TCP通信流程,实现了客户端和服务器的通信,主要实现了消息的回发,即服务器将消息原封不动的回发给客户端。

前言

本文主要介绍了linux下Select的TCP通信流程,实现了客户端和服务器的通信,主要实现了消息的回发,即服务器将消息原封不动的回发给客户端。

这里主要介绍服务端代码,关于客户端代码请参考客户端代码和socket的基本使用


服务器端代码

#include <errno.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <unistd.h>
#define MAXLNE  4096
int main(int argc, char **argv) 
{
    int listenfd, connfd, n;
    struct sockaddr_in servaddr;
    char buff[MAXLNE];
    if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
        printf("create socket error: %s(errno: %d)\n", strerror(errno), errno);
        return 0;
    }
    memset(&servaddr, 0, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    servaddr.sin_port = htons(9999);
    if (bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) == -1) {
        printf("bind socket error: %s(errno: %d)\n", strerror(errno), errno);
        return 0;
    }
    //listen接口之后会一直监听客户端的连接,每次客户端连接,都会和其创建连接(三次连接时内核完成的,不是由应用程序去控制的)
  //三次握手不发生在任何API中,协议栈本身被动完成的。
    if (listen(listenfd, 10) == -1) {
        printf("listen socket error: %s(errno: %d)\n", strerror(errno), errno);
        return 0;
    }
    //select模型相比于一请求一线程而言
  //一个select最多支持1024 socket,如果开多个线程,那么是能支持大量socket的。
    //select不能做到100w级别的fd,select函数本身有copy全部监控的socket,循环这些
  //全部监控的socket存在一定的效率问题
  // fd_set,每个socket对应一个bit位,bit位为1,代表该socket发生了事件。
  //rfds:是需要监控读的集合(从用户copy到内核)
  //rset:是发生了读事件的socket的集合(从内核copy到用户)
  fd_set rfds, rset, wfds, wset;
  FD_ZERO(&rfds);//清空bit位
  FD_SET(listenfd, &rfds);//设置监听的socket的bit位
  FD_ZERO(&wfds);
    //比如listenfd为100,那么select就需要从第一位bit监控到101位的bit
  int max_fd = listenfd;//select第一个参数为监听socket的最大值+1
  while (1) {
  rset = rfds;
  wset = wfds;
        //一个专门的服务员来给所有的客户端服务,可以知道到底是哪些客户端发生了相应的事件(比如发送了数据给服务器)
  //如果最后一个参数为NULL,那么是阻塞的,一直到有事件发生(nready会大于0)
  int nready = select(max_fd+1, &rset, &wset, NULL, NULL);
  if (FD_ISSET(listenfd, &rset)) { //listenfd监听到了客户端连接
    struct sockaddr_in client;
      socklen_t len = sizeof(client);
      if ((connfd = accept(listenfd, (struct sockaddr *)&client, &len)) == -1) {
          printf("accept socket error: %s(errno: %d)\n", strerror(errno), errno);
          return 0;
      }
    FD_SET(connfd, &rfds);//加入到读的集合中,代表要监听某客户端的读(recv)事件
    //如果客户端没有回收,connfd比max_fd大,但是如果客户端回收了fd,那么数字会变小,因此需要判断当前的connfd是否大于max_fd  
    if (connfd > max_fd) max_fd = connfd;//重新设置最大的fd
    if (--nready == 0) continue;//只有一个客户端的连接
  }
  int i = 0;
  //注意0-标志输入,1-标志输出,2-错误,然后是listenfd,
  //然后每次客户端连接后,connfd会依次增大。回收后connfd会变小,但是无论如何都比listenfd大
  //因此这里检测的是所有客户端是否有客户端与服务器进行了通信
  for (i = listenfd+1;i <= max_fd;i ++) {
    if (FD_ISSET(i, &rset)) { //检测某个客户端是否已经准备好了数据或者关闭(正常关闭也会设置读数据)
    n = recv(i, buff, MAXLNE, 0);//
          if (n > 0) { //收到n个字节的数据
              buff[n] = '\0';
              printf("recv msg from client: %s\n", buff);
      设置可以往该客户端socket发送数据
      //有兴趣的朋友可以去为每个fd封装一个发送缓冲和接收缓冲,设置写标志后
      //然后再下面的else if (FD_ISSET(i, &wset))发送数据给客户端
      FD_SET(i, &wfds);
      send(i, buff, n, 0);//直接将接收到的数据发送给客户端
          } else if (n == 0) { //收到的字节为0,代表该客户端正常关闭了
      FD_CLR(i, &rfds);//清空该客户端的读事件
      //printf("disconnect\n");
              close(i);
          }
    if (--nready == 0) break;//没有客户端的读事件了
    } 
    else if (FD_ISSET(i, &wset)) {//某个客户端写事件已就绪
    // send(i, buff, n, 0);  //将前面接收到数据发送给客户端
    // FD_SET(i, &rfds);//
    }
  }
  } 
    close(listenfd);
    return 0;
}

说明

代码主要说明了select的基本用法,一般服务器使用select来实现多路复用的代码都跟其类似,不过在实际的开发中,一般select是和定时器事件结合起来的,因为在一般的网络中,包括定时器事件和网络I/O事件,在一次消息循环中需要同时处理定时器事件和网络I/O事件。,有兴趣的朋友可以参考live555的消息循环的相关代码。


相关文章
|
15天前
|
存储 Oracle 关系型数据库
服务器数据恢复—EVA存储硬盘读写性能不稳定掉线的数据恢复案例
服务器存储数据恢复环境: 一台EVA某型号控制器+EVA扩展柜+FC磁盘。 服务器存储故障&检测: 磁盘故障导致该EVA存储中LUN不可用,导致上层应用无法正常使用。
80 47
|
14天前
|
数据挖掘 Linux 数据库
服务器数据恢复—reiserfs文件系统数据恢复案例
服务器数据恢复环境: 一台服务器中有一组由4块SAS硬盘组建的RAID5阵列,上层安装linux操作系统统。分区结构:boot分区+LVM卷+swap分区(按照顺序),LVM卷中划分了一个reiserfs文件系统作为根分区。 服务器故障: 服务器操作系统在运行过程中由于未知原因崩溃,管理员重装操作系统后发现分区结构变为:boot分区+swap分区+LVM卷(按照顺序),LVM卷中文件系统位置有个空的reiserfs超级块。 用户方需要恢复reiserfs文件系统中所有数据,包含数据库、网站程序与网页、OA系统中所有办公文档。
服务器数据恢复—reiserfs文件系统数据恢复案例
|
22天前
|
监控 Linux Shell
|
25天前
|
监控 Java Linux
Linux系统之安装Ward服务器监控工具
【10月更文挑战第17天】Linux系统之安装Ward服务器监控工具
49 5
Linux系统之安装Ward服务器监控工具
|
7天前
|
安全 算法 Linux
Linux 服务器还有漏洞?建议使用 OpenVAS 日常检查!
在数字化时代,Linux 服务器的安全至关重要。OpenVAS 是一款优秀的开源漏洞扫描工具,可以帮助及时发现并修复服务器中的安全隐患。本文将介绍 OpenVAS 的主要功能、使用方法及应对漏洞的措施,帮助用户加强服务器安全管理,确保企业数字化安全。
23 7
|
7天前
|
存储 运维 数据挖掘
服务器数据恢复—华为OceanStor存储数据恢复案例
服务器存储数据恢复环境: 华为品牌型号为OceanStor S2600T的存储设备,存储上有一组由24块4T容量的机械硬盘组建的RAID5阵列,作为存储池使用。 图1 服务器存储故障&检测: 存储设备中raid5阵列上多块硬盘出现故障离线,raid5阵列失效,数据无法正常访问。 关机后将存储中所有硬盘标记&取出,硬件工程师对所有硬盘进行硬件故障检测。经过检测,没有发现存在物理故障的磁盘,都可以正常读取。
|
8天前
|
存储 Linux
服务器数据恢复——使用fsck后Ext4文件系统挂载不上的数据恢复案例
关于Ext4文件系统的几个概念: 块组:Ext4文件系统的全部空间被划分为若干个块组,每个块组结构基本上相同。 块组描述符表:每个块组都对应一个块组描述符,这些块组描述符统一放在文件系统的前部,称为块组描述符表。每个块组描述符大小为32字节,主要描述块位图、i-节点位图及i-节点表的地址等信息。 超级块(Superblock):用于存储文件系统的配置参数(块大小、总块数、i-节点数等)和动态信息(当前空闲块数和i-节点数)。Ext4文件系统的超级块始于1024字节处,即2号扇区。 i节点:描述文件的时间、大小、块指针等信息。
|
10天前
|
监控 Ubuntu Linux
使用VSCode通过SSH远程登录阿里云Linux服务器异常崩溃
通过 VSCode 的 Remote - SSH 插件远程连接阿里云 Ubuntu 22 服务器时,会因高 CPU 使用率导致连接断开。经排查发现,VSCode 连接根目录 ".." 时会频繁调用"rg"(ripgrep)进行文件搜索,导致 CPU 负载过高。解决方法是将连接目录改为"root"(或其他具体的路径),避免不必要的文件检索,从而恢复正常连接。
|
13天前
|
缓存 Unix Linux
服务器linux!!!
本文介绍了计算机的演变历史、硬件基础知识及服务器相关知识。从电子管时代的ENIAC到冯-诺伊曼架构,再到现代计算机系统组成,详细讲解了计算机的发展历程。此外,文章还介绍了服务器的分类、品牌、硬件组成以及IDC机房的上架流程,为读者提供了全面的技术背景知识。
32 0
服务器linux!!!
|
15天前
|
人工智能 安全 Linux