Async Verbraucher für Amazon sqs

Ich bin neu bei arbeiten mit Warteschlangen.
Ich bin in der Lage, erfolgreich Nachrichten senden und empfangen synchron
Allerdings bin ich jetzt versucht, async jetzt.

Den Referenz-links zur Verfügung gestellt durch die sqs schlägt vor, jmsclient wrapper.
Und den link auch erwähnt, es zu benutzen, wenn Sie bereits einen code, der integriert ist, um ein jms-client.

http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/jmsclient.html#samples

Aber ich bin Neubeginns
Ich bezog mich in diesem Beispiel für das senden und empfangen von Nachrichten synchron.

https://github.com/aws/aws-sdk-java/blob/master/src/samples/AmazonSimpleQueueService/SimpleQueueServiceSample.java

Kann ich den gleichen code implementieren, aber es mit einem message listener?
Alle code-Beispiele werden geschätzt.

InformationsquelleAutor user5118993 | 2015-08-26
  1. 6

    Gibt es ein code-Beispiel im Abschnitt über Mit JMS mit Amazon SQS der Amazon SQS-Developer-Guide, der zeigt, wie für das asynchrone empfangen von Nachrichten mit JMS.

    Zunächst implementieren Sie die MessageListener-Schnittstelle:

    class MyListener implements MessageListener {

    @Override
    public void onMessage(Message message) {
        try {
            //Cast the received message as TextMessage and print the text to screen.
            if (message != null) {
                System.out.println("Received: " + ((TextMessage) message).getText());
            }
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

    Und dann legen Sie es als MessageListener für eine MessageConsumer:

    //Create a consumer for the 'TestQueue'.
MessageConsumer consumer = session.createConsumer(queue);

//Instantiate and set the message listener for the consumer.
consumer.setMessageListener(new MyListener());

//Start receiving incoming messages.
connection.start();

//Wait for 1 second. The listener onMessage() method will be invoked when a message is received.
Thread.sleep(1000);
    • wo bekomme ich das Objekt queue aus zu passieren, um den .createConsumer Methode? Ich verwenden Sie eine vorhandene Warteschlange, die ich nicht wollen, erstellen Sie eine neue Warteschlange.
    • Tut dies ständig zu hören, um Nachrichten aus der Warteschlange aus oder tut es das shutdown nach 1 minute?
    InformationsquelleAutor rbarni
  2. 2

    Können Sie sqslistener annotation von SpringCloud Rahmen.
    Wenn Sie die Entwicklung von Anwendungen mit Spring und AWS und Sie nicht mit Spring Cloud es ist eine gute Zeit für Sie zu wechseln.

    Hier ist ein Beispiel-code für das asynchrone Nachricht empfangen von SQS mit sqslistener annotation. Eine gute Sache ist, Sie haben zu fast null-Konfiguration für die Nutzung dieser :

    import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.aws.messaging.listener.SqsMessageDeletionPolicy;
import org.springframework.cloud.aws.messaging.listener.annotation.SqsListener;
import org.springframework.stereotype.Component;
import com.example.my.RecoverableException;

@Component
@Slf4j
public class CustomMessageQueue {

    @SqsListener(value = "${build_request_queue.name}", deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS)
    public void receive(String message) {
        try {
            //write message processing here
        } catch (RecoverableException e) {
            //handle errors here for which message from queue should not be deleted
            //throwing an exception will make receive method fail and hence message does not get deleted
            throw e;

        } catch (Exception e) {
            //suppress exceptions for which message should be deleted.
        }
    }
}

    Die große Sache über sqslistener Anmerkung ist seine deletionPolicy. So können Sie entscheiden, Wann eine Nachricht von SQS gelöscht wird.

    InformationsquelleAutor doer_uvc
  3. 0

    SQS steht für "Simple Queue Service". Es soll einfach sein, buchstäblich. Als Ergebnis, es unterstützt einige der Feinheiten von JMS, insbesondere asynchronen Listener.

    Ich geschrieben habe, einen blog-post zu diesem Thema: http://thedulinreport.com/2015/05/09/guaranteeing-delivery-of-messages-with-aws-sqs/

    Im Grunde, was Sie tun müssen, ist schreiben ein poller in einer Endlosschleife, aber Sie wollen sein smart über es-Sie wollen nicht zu halten polling zu viel, denn Sie zahlen pro Anfrage.

    • Danke, ich ll überprüfen Sie Ihre post. Statt uns polling, ich bin auf der Suche an Optionen zu nutzen, messagelisteners. Irgendwelche Hinweise, die sehr nützlich sein würde.
    • Es gibt keine message-listener im gleichen Sinn, wie die JMS-message-Listener in der SQS.
    InformationsquelleAutor Oleg Dulin
Schreibe einen Kommentar