Beispiele von zeromq pub/sub mit C# winform

Ich versuche ein C# - Winform-Anwendung, die verwendet ZeroMQ (clrzmq .net-Bindungen (x86) via nuget) in einem pub/sub-Modell.

Nach viel suchen habe ich nur finden können standalone C# Beispiele, wo der code verwendet eine while-Anweisung zu verarbeiten, neue Nachrichten auf unbestimmte Zeit. Wenn ich versuche, um diese Beispiele zu verwenden, ich weiß nicht wohin mit dem code, und es blockiert die gui und alles andere.

Ich weiß nicht, ob es ist unmöglich zu tun, ohne einem anderen thread, aber ich hatte den Eindruck, dass ZeroMQ ist eine asynchrone Verhalten arbeiten könnte, ohne Codierung extra threads. Vielleicht habe ich einfach nicht weiß, wo der zeromq-code, oder vielleicht ich muss wirklich einen anderen thread.

Wenn jemand könnte ein einfaches pub/sub-Beispiel mit den Richtungen, wo Sie tatsächlich fügen Sie den code in ein Standard-C# - winform-Anwendung wäre es sehr geschätzt.

InformationsquelleAutor uberdanzik | 2013-02-10

.net c#winforms zeromq

7

Ich gehe davon aus, dass Sie die clrzmq ZeroMq-wrapper in Ihrem Projekt. Soweit ich weiß ist es nicht möglich, eine Nachricht erhalten, non-blocking in einer einfachen Schleife mit clrzmq, es wird blockiert, entweder auf unbestimmte Zeit, für eine bestimmte Zeit (durch Angabe eines timeout an die receive-Methode) oder bis Sie eine Nachricht erhalten.

Jedoch, es ist ziemlich trivial einzurichten, dass ein thread eine Umfrage der Steckdose regelmäßig und push werden eingehende Nachrichten auf eine Queue. Sie können dann zum Beispiel ein einfaches WinForms Timer regelmäßig dequeue ausstehende Nachrichten aus, die (gemeinsam) Queue. Hier ist ein Beispiel für eine Singlethread-Abonnenten:
```
public class ZeroMqSubscriber
{
    private readonly ZmqContext _zmqContext;
    private readonly ZmqSocket _zmqSocket;
    private readonly Thread _workerThread;
    private readonly ManualResetEvent _stopEvent = new ManualResetEvent(false);
    private readonly object _locker = new object();
    private readonly Queue<string> _queue = new Queue<string>();

    public ZeroMqSubscriber(string endPoint)
    {
        _zmqContext = ZmqContext.Create();
        _zmqSocket = _zmqContext.CreateSocket(SocketType.SUB);
        _zmqSocket.Connect(endPoint);
        _zmqSocket.SubscribeAll();

        _workerThread = new Thread(ReceiveData);
        _workerThread.Start();
    }

    public string[] GetMessages()
    {
        lock (_locker)
        {
            var messages = _queue.ToArray();
            _queue.Clear();
            return messages;
        }
    }

    public void Stop()
    {
        _stopEvent.Set();
        _workerThread.Join();
    }

    private void ReceiveData()
    {
         try
         {
             while (!_stopEvent.WaitOne(0))
             {
                 var message = _zmqSocket.Receive(Encoding.UTF8, 
                               new TimeSpan(0, 0, 0, 1));
                 if (string.IsNullOrEmpty(message))
                     continue;

                 lock (_locker)
                     _queue.Enqueue(message);
             }
         }
         finally
         {
             _zmqSocket.Dispose();
             _zmqContext.Dispose();
         }
    }
}
```
Aus der Form Sie einfach eine Umfrage der Warteschlange periodisch (in diesem Beispiel verwendet eine Forms Timer und einfach fügt der message-Daten zu einem Textbox):
```
private readonly ZeroMqSubscriber _zeroMqSubscriber = 
        new ZeroMqSubscriber("tcp://127.0.0.1:5000");

void ReceiveTimerTick(object sender, EventArgs e)
{
    var messages = _zeroMqSubscriber.GetMessages();
    foreach (var message in messages)
        _textbox.AppendText(message + Environment.NewLine);
}
```
- Wenn ich versuche, mit Ihr ZeroMqSubscriber Klasse über, Visual Studio sagt, es kann nicht finden, den namespace oder den Namen für "ZmqContext" und einige andere Klassen-Instanzen, die Sie verwenden. Ja, ich habe "mit ZMQ". Irgendwelche Ideen?
- Verwenden Sie die clrzmq ZeroMq .NET verbindlich? Ich habe using ZeroMQ, nicht ZMQ. Das Beispiel enthält einen link auf die clrzmq Projekt (Anfang des Beitrags). Ich bin nicht sicher, warum die Beispiele auf der Hauptseite sagt, ZMQ, ich denke, das ist die alte namespace-Namen. ZeroMq .NET-Beispiele verwenden using ZeroMQ.
- Yep, die neueste clrzmq Quelle benutzen, ZeroMQ wie der namespace.
- Ich bin mit dem clrzmq .net-Bindungen package (x86) per nuget...angeblich war dies die empfohlene Methode, um "get started". Ich denke, es gibt einige Unterschiede.
- Ok-Also Visual Studio nuget-Paket-manager zeigt Ihnen nur version 2.0, es sei denn, Sie ändern Sie die dropdown-von "stable only" in den "include" pre-release", dann version 3.0 erscheint für das update, und voila die namespace-Schalter zu ZeroMQ und BAM! nicht mehr namespace-Fehler.
- Bestätigt, dein code funktioniert Super-Coole version 3.0 - vielen Dank für Ihre Hilfe auf diesem.
- Toll zu hören! Nur ein kleiner Hinweis; entweder stellen Sie sicher, Sie können dequeue eingehenden Daten schneller, als es empfangen wird (durch abrufen der Warteschlange ständig) oder hinzufügen, um zu verhindern, dass die queue wächst auf unbestimmte Zeit, d.h. erstellen Sie Ihre eigenen "high-water-mark". Sonst wird die Warteschlange füllen, bis der Absturz mit einer OutOfMemoryException. Viel Glück!
- Irgendeiner Weise zu vermeiden, mit "lock"? Einer der Gründe für die Verwendung von zeromq ist die Vermeidung von lock-code.
- In diesem Fall sehe ich nicht viel Sinn. Die Frage ist, über die Integration von ZeroMq in einer WinForm-Anwendung und als solche sollte es nicht viel Aufwand die lock-Anweisung in Bezug auf was auch immer getan werden muss, um in der Gui, wenn Nachrichten empfangen werden. Aktualisierung von Gui-controls (z.B. das hinzufügen von eingehenden Nachrichten an eine Liste) ist viel langsamer als die lock-Anweisung. Irgendwann werden die Daten muss integriert werden in den Gui-thread. Eine option könnte die Verwendung einer ConcurrentQueue (.NET 4). Nicht sicher, ob das schneller ist obwohl. Sie können eine Sperre hinter den kulissen.
- Ich bin nicht so sehr besorgt über die Geschwindigkeit, wie die Sauberkeit des Codes. Aus dem Reiseführer: "Sie verarbeitet die I/O asynchron in hintergrund-threads. Diese kommunizieren mit der Anwendung Gewinde mit lock-freien Datenstrukturen, also die gleichzeitige ØMQ-Anwendungen benötigen keine locks, Semaphoren oder anderen wait-states)." und von multithreading-Abschnitt, der in Fett: "Um der absolut perfekte MT-Programme (und das meine ich wörtlich), die wir nicht brauchen, Mutexe, sperren, oder jede andere form der inter-thread-Kommunikation außer Nachrichten über ØMQ-sockets." Daher meine Reaktion zu sehen, die "lock" - Wort in deinem Beispiel.
- Ja, das ist richtig. Und normalerweise ist das nur der Fall ist, übergeben Sie Nachrichten über ZeroMq (zwischen den Fäden), nicht über die lock-geschützt producer/consumer-queues wie in meinem Beispiel. Jedoch, da die Frage über eine Gui-Anwendung mit einem Gui-thread dienen die Gui, etwas zu geben hat. Sie können nicht beide haben ein flüssiges Gui und eine gesperrte Leser in dem gleichen thread. Sie können zwar eine Umfrage der ZeroMq-Buchse regelmäßig, mit einem kurzen timeout (aus dem Gui-thread), aber ich weiß noch nicht, ob das die beste Lösung. Normalerweise wird die Gui wäre nur die Behandlung von Ereignissen aus dem thread Umgang mit dem IO.
- verstanden.. hoffe andere tun das auch.
InformationsquelleAutor Jakob Möllås

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.