A C++ hálózatban a select használatával először meg kell figyelnem () és elfogadnom ()?

A TCP-kapcsolatokat a kapcsolat két végének IP-címe és portszáma azonosítja. Ezért jó, ha sok kliens (amelyek általában véletlenszerűen hozzárendelt portszámokkal rendelkeznek) egyetlen szerverporthoz csatlakoznak.

Létrehozol egy socketet, bind() egy portra, amelyen listen(), majd megvárod, amíg az ügyfelek kopogtatnak rajta. Ha nem bánja, ha blokkolja, akkor csak közvetlenül hívhatja a accept() számot, de nem fog tudni időtúllépési ciklust vagy ilyesmit csinálni. Ellenkező esetben select() a lehallgató aljzaton, amely olvashatóvá válik, amikor egy kliens megpróbál csatlakozni, majd hívja a accept() számot.

A accept() egy újonnan létrehozott socketet ad vissza, amely az a socket, amelyen az ügyféllel beszélni kell. Az eredeti lehallgató aljzat tovább hallgat, és több csatlakozás is fogadható rajta.

Jellemző, hogy egy select() hurkot használnak az olvashatóság keresésére a hallgatási aljzaton és a csatlakoztatott aljzatok bármelyikén. Aztán amikor a select() visszatér, egyszerűen ellenőrizze, hogy a lehallgató aljzat olvasható volt-e, és ha igen, akkor accept(); egyébként keress egy olvasható csatlakoztatott aljzatot és kezeld.

fd_set fds;
int max = 0, reuse = 1;
struct timeval tv;
int server;
std::vector<int> connected;

// create server listening socket
server = socket(PF_INET, SOCK_STREAM, getprotobyname("tcp")->p_proto);
setsockopt(server, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(int)); // optional, but recommended
if (bind(server, (struct sockaddr *)&addr, sizeof(struct sockaddr_in)) < 0) {
    // error, could not bind server socket
}
if (listen(server, 8) < 0) {
    // error, could not listen on server port
}

// loop looking for connections / data to handle
while (running) {
    FD_ZERO(&fds);
    FD_SET(server, &fds);
    if (server >= max) max = server + 1;

    for (std::vector<int>::iterator it = connected.begin(); it != connected.end(); ++it) {
        FD_SET(*it, &fds);
        if (*it >= max) max = *it + 1;
    }

    tv.tv_sec = 2; tv.tv_usec = 0;
    if (select(max, &fds, NULL, NULL, &tv) > 0) {
        // something is readable
        if (FD_ISSET(server, &fds)) {
            // it's the listener
            connected.push_back(accept(server, (struct sockaddr *)&addr));
        }
        for (std::vector<int>::iterator it = connected.begin(); it != connected.end(); ++it) {
            if (FD_ISSET(*it, &fds)) {
                // handle data on this connection
            }
        }
    }
}

sok kliens csatlakozhat ugyanahhoz a porthoz

először meg kell hallgatnia, majd kiválasztania

amikor a kiválasztás azt jelzi, hogy új kapcsolat van, akkor fogadja el. Azt mondja, hogy a kliens csatlakozott az fd socket olvasási jelzésével.

Meg kell jelölnie a szerver socketet (listen(2)), de csak akkor hívja meg a accept(2)-t, amikor visszatér a select(2)-ból, amikor az olvashatóvá válik - ez azt jelenti, hogy új csatlakozási kérelem függőben van.

Kérjük, vegye figyelembe, hogy ha nem nem blokkoló socketekkel dolgozik, lehetséges, hogy versenyez select(2) visszatérés és accept(2) - a csatlakozó kliens - hívása között. ezalatt megszakíthatja a kísérletet – így továbbra is blokkolhat.