Threads/Sockets: Performance mit Sockets (Netzwerkprogrammierung und Netzwerke mit Perl)

[thread]4301[/thread]

Threads/Sockets: Performance mit Sockets

Leser: 2

esskar

2005-06-20 23:31

User since
2003-08-04
7321 Artikel
ModeratorIn

user image

[quote=weismat,20.06.2005, 21:20]Ich kann ca. 4 mal 4092 Bytes lesen und dann ist Schluss.[/quote]
bist du sicher, dass mehr gesendet wird?
gib mal den return-wert von read aus...
wenn dieser <= 0 ist, musst du aufhören zulesen (sonst blockt read den prozess) bzw. mit IO::Select entscheiden, ob es noch was zu lesen gibt.

HTH
esskar

weismat

2005-06-29 20:18

User since
2003-08-18
142 Artikel
BenutzerIn
[default_avatar]

Ich habe zu sehr in C gedacht ;-)
Es funktioniert nur mit skalaren Werten. Scheint eine Beschränkung des Moduls zu sein.\n\n

weismat

2005-06-20 23:20

User since
2003-08-18
142 Artikel
BenutzerIn
[default_avatar]

Ich schreibe eine Anwendung die von einem Socket Daten liest und an einen anderen Socket die gelesen Daten umformatiert schreibt. Die Anzahl der Nachrichten liegen bei 400-500 pro Sekunde. Dazu habe ich folgende Fragen:
Gibt es bei einem Socket die Möglichkeit eine die Empfangsseite nach /dev/null oder so umzulenken, da mich die Antworten auf meine Writes ignorieren kann ohne Probleme mit dem Überlauf zu haben.
Nach 2000-3000 Reads bricht die Leseseite zusammen und mein Programm hängt, welche Möglichkeiten gibt es dazu zum Abfangen. Wie kann ich einen größeren Puffer erstellen. Ich kann ca. 4 mal 4092 Bytes lesen und dann ist Schluss. Gibt es sonst etwas mit dem ich die Performance beeinflussen kann? Ich kann gerne auch Code posten, aber ich denke, daß mir etwas konzeptionelles mehr bringt.
Bisher vereinbare ich den Socket wie folgt:

Code: (dl )

  my $remote = IO::Socket::INET->new(
               
      Proto       => "tcp",
               
      PeerAddr => $_[1],
               
      PeerPort  => $_[2],
               
     ) or die "Can not create port";

\n\n

weismat

2005-06-22 18:12

User since
2003-08-18
142 Artikel
BenutzerIn
[default_avatar]

Ich benutze zur Zeit recv, ist das schlechter als read?
Als ich den Code so umwandeln wollte, daß ich Threads bekomme, habe ich folgenden Fehler bekommen:
Invalid value for shared scalar at C:/Perl/lib/Thread/Queue.pm line 90.
Die relevanten Zeilen bei mir sind im Main-Programm:

Code: (dl )

1
2
3

my %message=$api->receive();
my $result=\%message;
$queue->enqueue($result);

und im Working Thread

Code: (dl )

1
2

  while (my $pitem=$queue->dequeue) {
    my %result=\$pitem;

Hat jemand eine Idee, was ich falsch mache?

View all threads created 2005-06-20 23:31.