Πρώτα Βήματα - Γλώσσες προγραμματισμού

Απ: UDP Socket Exception

Παναγιώτης Καναβός — Thu, 16 Oct 2008 01:24:07 GMT

Ο Άγγελος έχει δίκιο. Αντί για το while (true) θα πρέπει να καλείς μέσα στην EndReceive ξανά την BeginReceive. Έτσι αρχίζεις να ξανακούς αμέσως μόλις λάβεις κάτι. Το while (true) έχει ως αποτέλεσμα να δημιουργούνται συνέχεια listeners με αποτέλεσμα να φτάσεις σχεδόν αμέσως στο όριο των πόσων listeners μπορείς να σηκώσεις. Πέρα από αυτό, ακόμα και αν δεν έσκαγε το πρόγραμμα μέχρι να λάβεις κάτι, θα προσπαθούσαν όλοι οι listeners μαζί να το επεξεργαστούν. Χάος.

Την τεχνική του BeginReceive μέσα στο EndReceive την περιγράφει κάποιο άρθρο στο MSDN, απλά όχι αυτό που σου είχα πει νωρίτερα. Το άρθρο ήταν λίγο δύστροπο γιατί .... έδειχνε και Begin/EndReceive και Begin/EndRead μέσα στην Receive με αποτέλεσμα να είναι ... ελαφρώς περίπλοκο.

Όσον αφορά το IP*Works που πρότεινε ο oldgeorge, είναι όντως μία πολύ καλή σουίτα ... αν θέλεις μία σουίτα από networking components. Θα σε γλυτώσει από τη φασαρία να μάθεις να δουλεύεις με ασύγχρονες κλήσεις και σου δίνει πολύ περισσότερα από απλά ένα εύκολο τρόπο να μιλήσεις με UDP. Από την άλλη, κάποια στιγμή θα πρέπει να μάθεις να δουλεύεις και με τον ασύγχρονο τρόπο ενώ τα $300 του IP*Works είναι πολλά αν το μόνο που σε ενδιαφέρει είναι να φτιάξεις ένα utilitάκι.

Re: Απ: UDP Socket Exception

Oldgeorge — Tue, 14 Oct 2008 22:43:31 GMT

Κάποια στιγμή που είχα μπλέξει σε ένα σχετικό εγχείρημα, είχα δει φως με αυτό, το οποίο δουλεύει αποδεδειγμένα πολύ ωραία σε non blocking mode επικοινωνία. Δυστυχώς δεν το χρησιμοποιήσαμε στην τελική λύση (για άσχετους λόγους) οπότε δεν μπορώ να πω 100% ότι δουλεύει χωρίς σφάλματα σε πραγματικό περιβάλλον, αλλά αν είναι τόσο σημαντικό να κερδίσεις performance overhead αξίζει να του ρίξεις μια ματιά.

Απ: UDP Socket Exception

dtakis — Tue, 14 Oct 2008 04:12:29 GMT

Και εγώ αυτο έχω καταλάβει φίλε μου αλλά θέλω να ακούω συνεχώς για incoming messages από UDP (syslog) οπότε το γυρίζω σε σύγχρονη λήψη και βλέπουμε (τι χάνουμε κτλ).

Πάντως δεν μπορεί να μην υπάρχει ένας τρόπος να ακούει συνεχώς ασύγχρονα μηνύματα...

Απ: UDP Socket Exception

anjelinio — Tue, 14 Oct 2008 02:45:17 GMT

Χωρίς να είμαι απόλυτα σίγουρος για αυτό που λέω - δεν είμαι μπροστά σε dev. μηχάνημα - νομίζω ότι η χρήση του ασύγχρονου API, σε συνδιασμό με το while (true) είναι που γεμίζει τους buffers σου; Η υπόθεσή μου είναι ότι το .BeginReceive στο συγκεκριμένο loop καλείται απλώς συνέχεια, γιατί δεν περιμένει να κάνει όντως ένα receive, βγαίνει κατευθείαν απο την κλήση και λόγω του while .. την ξανακάνει άπειρες φορές;

Γιατί θες να χρησιμοποιήσεις το ασύγχρονο API ( καλά ... ανατριχιάζω κι ο ίδιος με αυτό που λέω τώρα, την εποχή που θέλουμε να γυρνάμε σε ασύγχρονη επεξεργασία όσο μπορούμε ... ) ντε και καλά;

UDP Socket Exception

dtakis — Tue, 14 Oct 2008 00:43:07 GMT

Με while loop του παρακάτω κώδικα (while (processWorking == true)...)

private const int listenPort = 514;

class UdpState
{
public UdpClient u;
public IPEndPoint e;
}

public static void ReceiveCallback(IAsyncResult ar)
{
UdpClient u = (UdpClient)((UdpState)(ar.AsyncState)).u;
IPEndPoint e = (IPEndPoint)((UdpState)(ar.AsyncState)).e;

Byte[] receiveBytes = u.EndReceive(ar, ref e);
string receiveString = Encoding.ASCII.GetString(receiveBytes);
LogMessageToFile(receiveString);
Console.WriteLine("Received:" + receiveString);
ProcessSocketData(receiveString);

//Console.WriteLine("Received: {0}", receiveString);
messageReceived = true;

}

private static void StartListener()
{

bool processWorking = true;

IPEndPoint e = new IPEndPoint(IPAddress.Any, listenPort);
UdpClient u = new UdpClient(e);
UdpState s = new UdpState();

s.e = e;

s.u = u;

while (processWorking == true)
{
try
{
u.BeginReceive(new AsyncCallback(ReceiveCallback), s);
}
catch (Exception ex)
{
Console.WriteLine("Exception:" + ex);
}

Console.Write(".");

Thread.Sleep(100);
}

}

void main(){

StartListener();

}

έχουμε exception:

an operation on a socket could not be performed because the system lacked sufficient buffer space or because a queue was full.

Πως μπορούμε να αποφύγουμε να γεμίσει το buffer;