为近 80 个或更多客户端使用 select 或多线程?

问题描述 投票:0回答:3

我正在开发一个项目,其中我需要从 80 个或更多客户端读取数据,然后将他们的 O/P 连续写入文件中,然后读取这些新数据以执行另一项任务。我的问题是我应该使用选择还是多线程?

我还尝试使用 read/fgets 和 write/fputs 调用来使用多线程,但由于它们是阻塞调用并且可以一次执行一项操作,因此这是不可行的。任何想法都非常感激。

更新1:我尝试使用条件变量实现相同的功能。我能够实现这一目标,但它一次写入和读取一个。当另一个客户端尝试写入时,除非我从第一个线程退出,否则它无法写入。我不明白。现在应该可以了。我犯了什么错误?

更新2:谢谢大家..我能够成功地使用互斥条件变量实现这个模型。

更新后的代码如下:

        **header file*******
         char    *mailbox ;
    pthread_mutex_t  lock  = PTHREAD_MUTEX_INITIALIZER ;
    pthread_cond_t   writer = PTHREAD_COND_INITIALIZER;

    int main(int argc,char *argv[])
    {
      pthread_t          t1 , t2;
      pthread_attr_t     attr;
      int            fd, sock , *newfd;
      struct sockaddr_in cliaddr;
      socklen_t      clilen;
      void          *read_file();
      void          *update_file();

      //making a server socket
      if((fd=make_server(atoi(argv[1])))==-1)
        oops("Unable to make server",1)


      //detaching threads
      pthread_attr_init(&attr);
      pthread_attr_setdetachstate(&attr,PTHREAD_CREATE_DETACHED);

      ///opening thread for reading
      pthread_create(&t2,&attr,read_file,NULL);

      while(1)
      {
        clilen = sizeof(cliaddr);
        //accepting request
        sock=accept(fd,(struct sockaddr *)&cliaddr,&clilen);

        //error comparison against failire of request and INT
        if(sock==-1 && errno != EINTR)
                oops("accept",2)
        else if ( sock ==-1 && errno == EINTR)
            oops("Pressed INT",3)

        newfd = (int *)malloc(sizeof(int));
        *newfd = sock;
        //creating thread per request
        pthread_create(&t1,&attr,update_file,(void *)newfd);
      } 
     free(newfd);
     return 0;
    }

    void *read_file(void *m)
    {
        pthread_mutex_lock(&lock);
        while(1)
        {
            printf("Waiting for lock.\n");
        pthread_cond_wait(&writer,&lock);
            printf("I am reading here.\n");
            printf("%s",mailbox);
            mailbox = NULL ;
        pthread_cond_signal(&writer);
        }
    }


    void *update_file(int *m)
    {
       int  sock = *m;
       int  fs ; 
       int  nread;
       char buffer[BUFSIZ] ;

       if((fs=open("database.txt",O_RDWR))==-1)
          oops("Unable to open file",4)

       while(1)
       {
        pthread_mutex_lock(&lock);
        write(1,"Waiting to get writer lock.\n",29);

        if(mailbox != NULL)
           pthread_cond_wait(&writer,&lock);

            lseek(fs,0,SEEK_END);
            printf("Reading from socket.\n");
            nread=read(sock,buffer,BUFSIZ);
            printf("Writing in file.\n");
            write(fs,buffer,nread);
            mailbox = buffer ;
          pthread_cond_signal(&writer);
          pthread_mutex_unlock(&lock);
       }
        close(fs);
    }
c multithreading sockets posix-select
3个回答
1
投票

我认为对于网络部分,每个客户端线程或多路复用单线程都可以正常工作。

至于磁盘 I/O,您说得对,磁盘 I/O 操作是阻塞操作,如果您的数据吞吐量足够高(和/或您的硬盘驱动器足够慢),它们可能会减慢您的网络操作,如果磁盘 I/O 是同步完成的。

如果这对您来说是一个实际问题(并且您应该首先测量以验证它确实是一个问题;如果您不需要,则没有必要使事情复杂化),我要尝试改善问题的第一件事是通过调用 setbuffer 使文件的输出缓冲区更大。有了足够大的缓冲区,C 运行时库就有可能隐藏由磁盘访问引起的任何延迟。

如果较大的缓冲区还不够,我要尝试的下一件事是创建一个或多个专用于读取和/或写入数据的线程。也就是说,当您的网络线程想要将数据保存到磁盘时,它不是直接调用 fputs()/write(),而是分配一个包含要写入的数据的缓冲区,并通过 (互斥锁保护或无锁) FIFO 队列。然后,I/O 线程将该缓冲区从队列中弹出,将数据写入磁盘,并释放缓冲区。 I/O 线程可以承受偶尔写入缓慢的情况,因为没有其他线程被阻塞等待写入完成。从磁盘进行线程读取稍微复杂一些,但基本上 IO 读取线程会填充一个或多个内存数据缓冲区,以便网络线程耗尽;每当网络线程从缓冲区中耗尽一些数据时,它就会向 IO 读取线程发出信号,将缓冲区重新填充到顶部。这样(理想情况下)每当网络线程需要向客户端发送一些输入数据时,RAM 中总是存在大量输入数据。

注意,上面的多线程方法有点棘手,因为它涉及线程间同步和通信;所以不要这样做,除非没有任何更简单的替代方案就足够了。


0
投票
如果你的编程能够解决问题,那么选择/轮询或多线程都可以。

我猜随着客户端数量的增加,你的程序将受到 io 限制,因为你经常进行磁盘读/写。因此,多个线程执行 io 操作不会加快速度。那么投票可能是更好的选择


0
投票
您可以将从

accept

 获得的套接字设置为非阻塞。然后很容易使用
select
来查找何时有数据,读取可用的字节数并处理它们。

对于(仅)80 个客户端,我认为没有理由期望使用线程有任何显着差异,除非您从不同的客户端获得非常不同的数据量。

© www.soinside.com 2019 - 2024. All rights reserved.