jjzjj

即使积压队列已满,客户端仍连接到 TCP 迭代服务器

coder 2023-09-18 原文

这是我创建的一个迭代服务器,用于处理基本的客户端-服务器聊天应用程序。

我正在尝试在终端窗口上运行 TCPserver 并在多个终端窗口上运行 TCPclient

尽管我设置了 backlog 值(listen 系统调用)在服务器套接字中为 5。

我预计最多可以连接 5 个客户端(一次只能接受 1 个)。

我对 listen 系统调用中设置的 backlog 值的理解有误吗? 请澄清。

int listen(int sockfd, int backlog);

The backlog argument defines the maximum length to which the queue of pending connections for sockfd may grow.

这里是实际的程序供引用。

TCP服务器.c

#include<stdio.h>
#include<stdlib.h>

#include<sys/types.h>
#include<sys/socket.h>

#include<netinet/in.h>
#include<unistd.h>
#define BACKLOG 5

#include <netinet/in.h>
#include <arpa/inet.h>

#include<string.h>

int main()
{
    //create the server socket
    int sd;
    sd=socket(AF_INET,SOCK_STREAM,0);
    if(sd==-1)
    {
        perror("Some error occured in creating the socket: ");   
        //Interprets the value of errno as an error message, and prints it to stderr 
        exit(EXIT_FAILURE);
    }
    else
        printf("Socket created!\n");

    //define the server address
    struct sockaddr_in server_address;
    
    server_address.sin_family = AF_INET;
    server_address.sin_port = htons(9002);
    server_address.sin_addr.s_addr = INADDR_ANY; 
    //inet_addr("192.168.137.163");//INADDR_ANY;

    //bind the socket to our specified IP and port
    int bind_status = bind(sd, (struct sockaddr *) &server_address, sizeof(server_address));
    if(bind_status == -1)
    {
        perror("An error occurred in binding the socket: " );
        exit(EXIT_FAILURE);
    }
    else
        printf("Bind Successful!\n");


    //listen for connections
    int listen_status = listen(sd, BACKLOG);    
    if(listen_status == -1)
    {
        perror("Error occured in listening: ");
        exit(EXIT_FAILURE);
    } 
    else
        printf("Server is listening!\n");

    while(1)
    {
        //Accept a connection and create a new socket for this connection
        int new_sd;
        struct sockaddr_in client_address;
        int client_address_size = sizeof(client_address);

        new_sd= accept(sd, (struct sockaddr*) &client_address, &client_address_size);
        if(new_sd==-1)
        {
            perror("Can't accept connection: ");
            exit(EXIT_FAILURE);
        }
        else
            printf("Accept successful!\nA new client has connected. He'll soon send you a message.\n (You can chat or say \"exit\" to stop chatting)\n\n");
    

        //send a message to the client
        char buffer[256] = "Welcome to the server, lets chat! \n (You can chat or say \"exit\" to stop chatting)\n";
        send(new_sd,buffer,sizeof(buffer),0);

        //start chat
        while(1)
        {
            memset(buffer,0,256);
            int n = recv(new_sd, buffer, sizeof(buffer),0);
            if(n==-1 || strcmp(buffer,"exit\n")==0 || strcmp(buffer,"exit")==0)
                break;
            printf("\nclient said: %s\n",buffer);

            memset(buffer,0,256);
            printf("Say something: ");
            fgets(buffer,256,stdin);
            n = send(new_sd, buffer, sizeof(buffer), 0);
            if(n==-1 || strcmp(buffer,"exit\n")==0)
                break;
        }

        //close the sockets
        close(new_sd);
        printf("\nConnection ended. waiting for new connection now . . .\n");
    }

    close(sd);

    return 0;
}

这是客户

TCP客户端.c

#include<stdio.h>
#include<stdlib.h>

#include<sys/types.h>
#include<sys/socket.h>

#include<netinet/in.h>

#include<unistd.h>

#include <netinet/in.h>
#include <arpa/inet.h>
#include<string.h>
int main()
{
    //create the socket
    int sd = socket(AF_INET,SOCK_STREAM,0);

    if(sd==-1)
    {
        perror("Some error occurred in creating the socket: ");
        exit(EXIT_FAILURE);
    }
    else
        printf("Socket created!\n");

    //specify an address for the socket
    struct sockaddr_in server_address;
    
    server_address.sin_family = AF_INET;
    server_address.sin_port = htons(9002);
    server_address.sin_addr.s_addr = inet_addr("127.0.0.1");//INADDR_ANY;

    //Connect to the server
    int connection_status = connect(sd,(struct sockaddr *) &server_address, sizeof(server_address));

    if(connection_status == -1)
    {
        perror("There was an error connecting to the remote socket: ");
        exit(EXIT_FAILURE);
    }
    else
        printf("Connected to the server! Waiting in the queue for the server to accept the connection...\n");
        
    char buffer[256];
    //get the connection message from the server
    recv(sd, &buffer, sizeof(buffer), 0);
    printf("Server Said: %s\n", buffer);

    //start chat
    while(1)
    {
        memset(buffer,0,256);
        printf("Say something: ");
        fgets(buffer,256,stdin);
        int n = send(sd,buffer,sizeof(buffer),0);
        if(n==-1 || strcmp(buffer,"exit\n")==0)
            break;       

        memset(buffer,0,256);
        n = recv(sd,buffer,sizeof(buffer),0);
        if(n==-1 || strcmp(buffer,"exit\n")==0)
            break;

        printf("\nServer said: %s\n",buffer);
    }

    //close the socket
    close(sd);

    return 0;
}

有人建议我检查我的系统是否启用了 syncookies。当我执行 cat/proc/sys/net/ipv4/tcp_syncookies 时,我得到 1

最佳答案

积压是“待处理 连接队列”——一旦您接受连接,它就不再是待处理的,并从队列中移除,为另外 5 个待处理连接留出空间。

如果您想限制为 5 个连接,那么您需要计算您已接受(且未关闭)的数量。任何更多的连接尝试都会在队列中等待。

关于即使积压队列已满,客户端仍连接到 TCP 迭代服务器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39497530/

有关即使积压队列已满,客户端仍连接到 TCP 迭代服务器的更多相关文章

  1. ruby - 使用 ruby​​ 和 savon 的 SOAP 服务 - 2

    我正在尝试使用ruby​​和Savon来使用网络服务。测试服务为http://www.webservicex.net/WS/WSDetails.aspx?WSID=9&CATID=2require'rubygems'require'savon'client=Savon::Client.new"http://www.webservicex.net/stockquote.asmx?WSDL"client.get_quotedo|soap|soap.body={:symbol=>"AAPL"}end返回SOAP异常。检查soap信封,在我看来soap请求没有正确的命名空间。任何人都可以建议我

  2. ruby - 具有身份验证的私有(private) Ruby Gem 服务器 - 2

    我想安装一个带有一些身份验证的私有(private)Rubygem服务器。我希望能够使用公共(public)Ubuntu服务器托管内部gem。我读到了http://docs.rubygems.org/read/chapter/18.但是那个没有身份验证-如我所见。然后我读到了https://github.com/cwninja/geminabox.但是当我使用基本身份验证(他们在他们的Wiki中有)时,它会提示从我的服务器获取源。所以。如何制作带有身份验证的私有(private)Rubygem服务器?这是不可能的吗?谢谢。编辑:Geminabox问题。我尝试“捆绑”以安装新的gem..

  3. ruby-on-rails - 启动 Rails 服务器时 ImageMagick 的警告 - 2

    最近,当我启动我的Rails服务器时,我收到了一长串警告。虽然它不影响我的应用程序,但我想知道如何解决这些警告。我的估计是imagemagick以某种方式被调用了两次?当我在警告前后检查我的git日志时。我想知道如何解决这个问题。-bcrypt-ruby(3.1.2)-better_errors(1.0.1)+bcrypt(3.1.7)+bcrypt-ruby(3.1.5)-bcrypt(>=3.1.3)+better_errors(1.1.0)bcrypt和imagemagick有关系吗?/Users/rbchris/.rbenv/versions/2.0.0-p247/lib/ru

  4. ruby-on-rails - s3_direct_upload 在生产服务器中不工作 - 2

    在Rails4.0.2中,我使用s3_direct_upload和aws-sdkgems直接为s3存储桶上传文件。在开发环境中它工作正常,但在生产环境中它会抛出如下错误,ActionView::Template::Error(noimplicitconversionofnilintoString)在View中,create_cv_url,:id=>"s3_uploader",:key=>"cv_uploads/{unique_id}/${filename}",:key_starts_with=>"cv_uploads/",:callback_param=>"cv[direct_uplo

  5. ruby - 即使失败也继续进行多主机测试 - 2

    我已经构建了一些serverspec代码来在多个主机上运行一组测试。问题是当任何测试失败时,测试会在当前主机停止。即使测试失败,我也希望它继续在所有主机上运行。Rakefile:namespace:specdotask:all=>hosts.map{|h|'spec:'+h.split('.')[0]}hosts.eachdo|host|begindesc"Runserverspecto#{host}"RSpec::Core::RakeTask.new(host)do|t|ENV['TARGET_HOST']=hostt.pattern="spec/cfengine3/*_spec.r

  6. ruby - 用 Ruby 编写一个简单的网络服务器 - 2

    我想在Ruby中创建一个用于开发目的的极其简单的Web服务器(不,不想使用现成的解决方案)。代码如下:#!/usr/bin/rubyrequire'socket'server=TCPServer.new('127.0.0.1',8080)whileconnection=server.acceptheaders=[]length=0whileline=connection.getsheaders想法是从命令行运行这个脚本,提供另一个脚本,它将在其标准输入上获取请求,并在其标准输出上返回完整的响应。到目前为止一切顺利,但事实证明这真的很脆弱,因为它在第二个请求上中断并出现错误:/usr/b

  7. ruby-on-rails - 在 Rails 中调试生产服务器 - 2

    您如何在Rails中的实时服务器上进行有效调试,无论是在测试版/生产服务器上?我试过直接在服务器上修改文件,然后重启应用,但是修改好像没有生效,或者需要很长时间(缓存?)我也试过在本地做“脚本/服务器生产”,但是那很慢另一种选择是编码和部署,但效率很低。有人对他们如何有效地做到这一点有任何见解吗? 最佳答案 我会回答你的问题,即使我不同意这种热修补服务器代码的方式:)首先,你真的确定你已经重启了服务器吗?您可以通过跟踪日志文件来检查它。您更改的代码显示的View可能会被缓存。缓存页面位于tmp/cache文件夹下。您可以尝试手动删除

  8. ruby - 我的 Ruby IRC 机器人没有连接到 IRC 服务器。我究竟做错了什么? - 2

    require"socket"server="irc.rizon.net"port="6667"nick="RubyIRCBot"channel="#0x40"s=TCPSocket.open(server,port)s.print("USERTesting",0)s.print("NICK#{nick}",0)s.print("JOIN#{channel}",0)这个IRC机器人没有连接到IRC服务器,我做错了什么? 最佳答案 失败并显示此消息::irc.shakeababy.net461*USER:Notenoughparame

  9. 即使安装了 gem,Ruby 也找不到所需的库 - 2

    我花了几天时间尝试安装ruby​​1.9.2并让它与gems一起工作:-/我最终放弃了我的MacOSX10.6机器,下面是我的Ubuntu机器上的当前状态。任何建议将不胜感激!#rubytest.rb:29:in`require':nosuchfiletoload--mongo(LoadError)from:29:in`require'fromtest.rb:1:in`'#cattest.rbrequire'mongo'db=Mongo::Connection.new.db("mydb")#gemwhichmongo/usr/local/rvm/gems/ruby-1.9.2-p0/g

  10. ruby - Rails 开发服务器、PDFKit 和多线程 - 2

    我有一个使用PDFKit呈现网页的pdf版本的Rails应用程序。我使用Thin作为开发服务器。问题是当我处于开发模式时。当我使用“bundleexecrailss”启动我的服务器并尝试呈现任何PDF时,整个过程会陷入僵局,因为当您呈现PDF时,会向服务器请求一些额外的资源,如图像和css,看起来只有一个线程.如何配置Rails开发服务器以运行多个工作线程?非常感谢。 最佳答案 我找到的最简单的解决方案是unicorn.geminstallunicorn创建一个unicorn.conf:worker_processes3然后使用它:

随机推荐