Wie den Unterschied zwischen Warteschlange und Pub/Sub in einer programmatischen Weise kennen und mein Projekt Warteschlangen-Konzept erfordert. können Sie bitte ein Beispiel Queue-Programm in Java zur Verfügung stellen?Apache kafka: wie programmatisch der Unterschied zwischen Warteschlange und Pub/Sub zu finden ist
Wie ich in den Kommentaren geschrieben habe, implementiert Kafka einen Pub-Sub-Algorithmus. Es ist keine Warteschlange und der Mechanismus ist nicht ereignisbasiert.
Die Datenproduzenten werden die neuen Daten an Kafka veröffentlichen, und die Verbraucher werden Kafka bitten, ihnen Nachrichten nach Id = x zu geben. Nachrichten werden nicht entfernt, nachdem das System bestätigt hat, dass sie empfangen wurden. Kafka ist es einfach egal. Wenn es mit Ihnen in Ordnung ist, können Sie es wie folgt verwenden:
Die Implementierung dieses Dienstes ist fast die gleiche wie Microsoft Ereignis-Hub und Amazon Kinesis.
Wenn Sie eine Warteschlange benötigen, müssen Sie ein System verwenden, die Warteschlange Funktionalitäten wie Microsoft Service Bus -Queue implementieren, java sample oder andere Warteschlangensystem
Ich habe mehrere Verbraucher, 1. Wenn ich mehrere Anfragen von diesen Verbrauchern mit einer eindeutigen ID an einen Broker sende, wie wird der Hersteller Antworten auf diese eindeutigen IDs einzeln erzeugen? 2. Wie wird der Hersteller feststellen, wann diese eindeutigen ID-Anfragen beim Broker eingehen? 3. Was ist die Beziehung zwischen einem Produzenten und einem Verbraucher? – sumanth
Die einzige Beziehung zwischen Produzenten und Konsumenten in Kafka sind die Themen (und Partitionen): Produzenten produzieren nach Themen/Partitionen und Verbraucher abonnieren Themen/Partitionen. Wenn Sie möchten, könnten Sie ein Thema pro Verbraucher haben, aber Themen werden normalerweise für Seitenzugriffe, Benutzerregistrierung usw. verwendet. –
es nicht wichtig ist, wenn Sie einen Code in Java schreiben möchten, C# oder andere Sprachen. Sie können eines der verfügbaren Warteschlangensysteme verwenden. Sie können sogar Microsoft Service Bus-Queue https://azure.microsoft.com/en-us/documentation/articles/service-bus-java-how-to-use-queues/ –
können Sie bitte einen Beispielcode für Apache Kafka Warteschlange mit Java? – sumanth
Wie der Verbraucher Nachrichten aus der Warteschlange erhalten wird. – sumanth