4. Parallele Verbindungen

Parallele Verbindungen

  • D

    wie kommsten du da drauf Felix? Vergessen wir die Physik und machen einfach 456734876378267693 Threads und schon können wir terrabyteweise daten in ein paar ms um die Welt schicken? NeeNee ... was du vorhast ist realisierbar, aber unsinnig (bringt nix).

    0
  • F

    Und was ist, wenn man 2 odere mehrere Datenpakete auf einmal schicken will, wie z.B. beim Windows Remote Desktop Programm. Da werden die Mausdaten, das Bildschirmbild und die Tastaturdaten alle auf einmal geschickt, oder mein ich das nur?

    0
  • F

    Jetzt bin ich verwirrt:

    Von folgender Website: http://www.cappoodoo.de/?id=download&s=ak&action=showall&category=f7f2e0d076&lang=de

    Fresh Download - Version 7.98

    Fresh Download ist ein einfach zu benutzender, kostenloser Download-Manager, der durch mehrere parallele Verbindungen zur selben Datei die Download-Geschwindigkeit erheblich erhöhen kann. Die Software kommt vollkommen ohne Bannerwerbung (welche auch Traffic verursacht), oder Spyware aus.

    Features:
    Sehr schnelle Downloads aller Arten von Dateien über FTP, HTTP und HTTPS mittels Ihrer aktuellen Internetverbindung (Modem, Kabel, DSL/ADSL, Satellit, T1, etc.)
    Pausieren und fortsetzen abgebrochener Downloads, Wiederherstellung nach einer unterbrochenen Internetverbindung.
    Mehrere parallele Verbindungen (Standard 4, bis zu 8 Verbindungen) zur selben Datei, um die größtmögliche Download-Geschwindigkeit zu erreichen. Laut Benutzerberichten kann dies Methode Ihre Downloads bis zu 400% beschleunigen.
    Einfache Integrierung in alle derzeit gängigen Browser und lauffähig auf jedem Windows-System ab Windows 95 - Vista.
    Taskplaner: Planen der Downloads für Perioden mit geringem Datenverkehr.
    Zwischenablage-Überwachung und Drag'n'Drop Funktion. Erfassssung aller URLs aus jeder beliebigen Anwendung.
    Antivirus-Unterstützung: Prüft heruntergeladene Dateien auf Schädlinge mittels Ihrer derzeit installierten Antiviren-Software.
    Downloadmöglichkeit von Passwortgeschützen Seiten des HTTP-, oder FTP-Protokolls.
    Proxyserver-Unterstützung via HTTP-, oder FTP-Protokoll.
    Vorschau des Inhaltes gepackter (ZIP) Dateien.

    0
  • T

    Trau keiner Statistik die du nicht selbst gefälscht hast 🤡

    Edit: Rest entfernt, zu vorschnell geschrieben.

    0
  • H

    Das Teil nützt wahrscheinlich die Tatsache aus, dass viele Download-Server die Bandbreite pro Verbindung künstlich reduzieren. Wenn man jetzt mehrere Socket-Verbindungen einsetzt kann man das umgehen. Du musst dafür mehrere Sockets erstellen. Threads sind nicht notwendig.

    0
  • F

    Wie funktionieren die parallelen Verbindungen sonst, wenn es keine Threads sind?

    Und da steht:

    Mehrere parallele Verbindungen (Standard 4, bis zu 8 Verbindungen) zur selben Datei, um die größtmögliche Download-Geschwindigkeit zu erreichen. Laut Benutzerberichten kann dies Methode Ihre Downloads bis zu 400% beschleunigen.

    0
  • F

    @hajoe: Danke für Antwort. Aber ich will die Sockets ja gleichzeitig verwenden, also brauch ich doch die Threads, oder?

    0
  • F

    Wie ist so ein Server mit Threads aufgebaut?

    0
  • F

    Ich hab jetzt mal selber einen Server geschrieben. Allerdings funktioniert der noch nicht so richtig:

    #include <stdio.h>
#include <stdlib.h>
#include <windows.h>
#define BUF_SIZE 255

int Port = 12345;

long rc;
SOCKET acceptSocket;
SOCKET connectedSocket;
SOCKADDR_IN addr;

int Clientenanzahl;

int Verbindung;

char Zahl1[900];
char Zahl2[900];

FD_SET fdSet;
SOCKET clients[100];
int i;

int antwortlaenge1;
int antwortlaenge2;
int Laenge1;
int Laenge2; 
char buffer1[100];
char buffer2[100];
char juhu[900];

typedef struct MyData {
    int data;
} MYDATA, *PMYDATA;

PMYDATA pDataArray[100];

int startWinsock(void)
{
  WSADATA wsa;
  return WSAStartup(MAKEWORD(2,0),&wsa);
}

DWORD WINAPI NeuerClient(LPVOID lpParam) 
{ 
    HANDLE hStdout;
    PMYDATA pDataArray;
    int nummer;

    TCHAR msgBuf[BUF_SIZE];
    size_t cchStringSize;
    DWORD dwChars;

    hStdout = GetStdHandle(STD_OUTPUT_HANDLE);
    if( hStdout == INVALID_HANDLE_VALUE )
        return 1;

    pDataArray = (PMYDATA)lpParam;

    nummer=pDataArray->data;

    printf("%d.Client\n",nummer);
    while(1) 
    { 
             antwortlaenge1 = recv(clients[nummer], buffer1, 1, 0);
             buffer1[antwortlaenge1] = '\0';
             Laenge1 = atoi(buffer1);

             antwortlaenge2 = recv(clients[nummer], buffer2, Laenge1, 0);
             buffer2[antwortlaenge2] = '\0';
             Laenge2 = atoi(buffer2);

             Verbindung=recv(clients[nummer],juhu,Laenge2,0); 
             if(Verbindung==SOCKET_ERROR) 
             { 
                              break;
             }
             juhu[Verbindung]='\0';
    }
return 0; 
}

int main(int argc, char *argv[])
{

  rc=startWinsock();
  if(rc!=0)
  {
         printf("\r\nWinsock konnte nicht gestartet werden!\r\n");
         return 0;
  }
  else
  {
          printf("\r\nWinsock gestartet!\r\n");
  }

  acceptSocket=socket(AF_INET,SOCK_STREAM,0);
  if(acceptSocket==INVALID_SOCKET)
  {
                printf("Fehler: Der Socket konnte nicht erstellt werden!\r\n");
                return 0;
  }
  else
  {
                printf("Socket erstellt!\r\n");
  }

  memset(&addr,0,sizeof(SOCKADDR_IN));
  addr.sin_family=AF_INET;
  addr.sin_port=htons(Port);
  addr.sin_addr.s_addr=ADDR_ANY;

  rc=bind(acceptSocket,(SOCKADDR*)&addr,sizeof(SOCKADDR_IN));
  if(rc==SOCKET_ERROR)
  {
             printf("Socket konnte nicht an den Port 12345 gebunden werden!\r\n");
             return 0;
  }
  else
  {
             printf("Socket an Port 12345 gebunden\r\n");
  }

  rc=listen(acceptSocket,100);
  if(rc==SOCKET_ERROR)
  {
                      printf("acceptSocket ist nicht im listen Modus!\r\n");
                      return 0;
  }
  else
  {
                      printf("acceptSocket ist im listen Modus...\r\n"); 
  }
  while(1) 
  { 
            sleep(10);
            FD_ZERO(&fdSet); // Inhalt leeren
            FD_SET(acceptSocket,&fdSet); // Den Socket der verbindungen annimmt hinzufügen

    // alle gültigen client sockets hinzufügen (nur die die nicht INVALID_SOCKET sind)
            for(i=0;i<100;i++) 
            {
                        if(clients[i]!=INVALID_SOCKET)
                        {
                                       FD_SET(clients[i],&fdSet);
                        }
            }

            rc=select(0,&fdSet,NULL,NULL,NULL); // nicht vergessen den ersten parameter bei anderen betriebssystem anzugeben
            if(rc==SOCKET_ERROR) 
            {
              //return 0;
            }

            // acceptSocket is im fd_set? => verbindung annehmen (sofern es platz hat)
            if(FD_ISSET(acceptSocket,&fdSet)) 
            {
                      // einen freien platz für den neuen client suchen, und die verbingung annehmen
                      for(i=0;i<100;i++)
                      {
                                   if(clients[i]==INVALID_SOCKET) 
                                   {
                                              clients[i]=accept(acceptSocket,NULL,NULL);//akzeptieren
                                              printf("Neuer Client\n");

                                              pDataArray[i] = (PMYDATA) HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY,sizeof(MYDATA));
                                              pDataArray[i]->data = i;

                                              CreateThread(NULL, 0, NeuerClient, pDataArray[i], 0, NULL);
                                              break;
                                   }
                      }
            }

            // prüfen welcher client sockets im fd_set sind
            for(i=0;i<100;i++) 
            {
                        if(clients[i]==INVALID_SOCKET)
                        {
                                          continue; // ungültiger socket, d.h. kein verbunder client an dieser position im array
                        }
                        if(FD_ISSET(clients[i],&fdSet))
                        {
                                      //Client will was schicken                                                                                 
                        }
            }

  } 

  return 0;
}

    Was ist da falsch?

    0
  • H

    Nein, Threads sind nicht notwendig. Ich wäre mit Threads überhaupt sparsam. Das Zauberwort heißt "Asynchron". Du musst die FD_XXX Funktionen ersetzen durch WSA_XXX, also WSAWaitForMultipleEvents usw. Dann kannst Du in einem Thread (dem Hauptthread der Anwendung) beliebig viele Sockets bedienen. Dieses ganze FD_XXX Zeug funktioniert unter Windows nicht richtig!

    0
  • ?

    Dieses ganze FD_XXX Zeug funktioniert unter Windows nicht richtig!

    rofl. klar funktioniert das.

    0
  • ?

    hajoe schrieb:

    Dieses ganze FD_XXX Zeug funktioniert unter Windows nicht richtig!

    olo 👍

    0
  • D

    Schon mal was von "Editieren" gehört? Das gibts in jedem noch so verschissenen Forum, und bestimmt nicht, damit es nicht benutzt wird ... nur so btw.

    0
  • F

    @ hajoe: Das Problem ist jetzt nur, dass ich mit Dev-C++ arbeite und da funktioniert getaddrinfo und freeaddrinfo irgendwie nicht. Ich hab alle möglichen .a eingebunden und die richtigen Bibliotheken, aber es geht nicht. Geht das auch ohne die Funktionen oder muss ich doch auf VC++ umsteigen?

    0
  • H

    Ich verstehe das Problem nicht, Du musst doch nur die Funktionen der WinSocket-API einbinden. Übrigens, wenn hier jemand meint die FD_XXX Funktionen tun genau das, was sie sollen, kann er sie ja verwenden, ich tu's nicht (aus Erfahrung).

    0
  • F

    Wenn ich das Beispielprogramm auf MSDN zu WSARecv kompilieren will. Kommen folgende Fehler nachdem ich libws2_32.a und libwsock32.a eingebunden habe:

    wsa neu recv.o(.text+0x145):wsa neu recv.c: undefined reference to `getaddrinfo'
wsa neu recv.o(.text+0x200):wsa neu recv.c: undefined reference to `freeaddrinfo'
wsa neu recv.o(.text+0x2a7):wsa neu recv.c: undefined reference to `freeaddrinfo'
wsa neu recv.o(.text+0x300):wsa neu recv.c: undefined reference to `freeaddrinfo'
wsa neu recv.o(.text+0x354):wsa neu recv.c: undefined reference to `freeaddrinfo'
wsa neu recv.o(.text+0x556):wsa neu recv.c: undefined reference to `freeaddrinfo'

    Den Quellcode könnt ihr bei MSDN hier finden: http://msdn2.microsoft.com/en-us/library/ms741688(VS.85).aspx

    0
  • H

    Verwende doch einfach dynamisches Linking, also z.B. so:

    typedef void (WINAPI *FunctionProc) (Parameterliste);

    FunctionProc IrgendeineFunktion;

    HANDLE h = LoadLibrary ("Ws2_32.dll");

    IrgendeineFunktion = (FunctionProc) GetProcAddress (h,"NameDerFunktion");

    0
  • ?

    lol oder verwendte ne anständige Entwicklungsumgebung und nicht so einen SCHROTT

    0
  • F

    Welche Entwicklungsumgebung kannst du mir außer VC++ empfehlen?

    0
  • ?

    http://www.c-plusplus.net/forum/viewtopic-var-t-is-143003.html

    0
Anmelden zum Antworten