Beispielcode für die gemeinsame Nutzung einer Nachrichtenwarteschlange in Java

Dieser Artikel stellt hauptsächlich den einfachen Implementierungscode der Java-Nachrichtenwarteschlange vor. Jetzt werde ich ihn mit Ihnen teilen und als Referenz geben. Folgen wir dem Herausgeber, um einen Blick darauf zu werfen

Heute habe ich gesehen, dass unsere Rekrutierungsinformationen Anforderungen an Nachrichtenwarteschlangen stellen, und dann habe ich darüber nachgedacht und viel online gesucht.

Ich kann zunächst ein kleines Beispiel geben, um das Anwendungsszenario zu veranschaulichen

Angenommen, Ihr Server hat eine Verarbeitungskapazität von 200 pro Minute Wenn der Client jedoch wieder seinen Höhepunkt erreicht, sendet er möglicherweise 1.000 Nachrichten pro Minute. Zu diesem Zeitpunkt können Sie sie in eine Warteschlange stellen und sie dann in der normalen Reihenfolge „First in last out“ (First in last out) verarbeiten out (FIFO) Sie können eine Entscheidung basierend auf Ihrer eigenen Situation treffen

Stack First In Last Out (LIFO)--------Javas entsprechende Klasse Stack

Warteschlange First In First Out (LIFO) FIFO)--------Java entsprechende Klasse Warteschlange

Beide können von Linkedlist gekapselt und implementiert werden. Das Folgende ist ein Beispiel dafür ein Stapel, den ich selbst geschrieben habe

/** 
 * @author 刘伊凡 
 * --------->>>>>>队列的实现-------------- 
 */ 
public class MyStack<T> { 
  private LinkedList<T> storage = new LinkedList<T>(); 
 
  public synchronized void push(T e) {//需要加上同步 
    storage.addFirst(e); 
  } 
 
  public T peek() { 
    return storage.getFirst(); 
  } 
 
  public void pop() { 
    storage.removeFirst(); 
  } 
 
  public boolean empty() { 
    return storage.isEmpty(); 
  } 
 
  @Override 
  public String toString() { 
    return storage.toString(); 
  } 
 
}

Das Folgende ist eine Testklasse

/** 
 * @author 刘伊凡 
 * 
 */ 
public class StackTest { 
  public static void main(String[] args) { 
    MyStack<String> stack = new MyStack<String>(); 
    for(String s : "the prefect code".split(" ")){//LIFO 
      stack.push(s); 
    } 
    while(!stack.empty()){ 
      System.out.print(stack.peek()+" "); 
      stack.pop(); 
    } 

    System.out.println(); 
    for(char s : "写了个一句话倒起来说的程序".toCharArray()){//用例：正话反说 
      stack.push(String.valueOf(s)); 
    } 
    while(!stack.empty()){ 
      System.out.print(stack.peek()); 
      stack.pop(); 
    } 
  } 
}

Es ist ziemlich interessant , es erinnert mich an die Abendparty in der Schule zuvor. Wenn der Moderator im Internet interagiert, kommen Leute auf die Bühne, um Fragen zu beantworten und Preise zu gewinnen. Eine der Fragen besteht darin, dass der Moderator einen Satz sagt und dann die Teilnehmer dazu auffordert Stehen Sie auf und sagen Sie, unser Programm erfüllt die Anforderungen, haha, wir können Java dafür verwenden. Betrügen, anwenden, was Sie gelernt haben

Anwendungsszenarien der Nachrichtenwarteschlange, ergänzend (aus dem Internet)

Ich persönlich denke, dass das Hauptmerkmal der Nachrichtenwarteschlange die asynchrone Verarbeitung ist und ihr Hauptzweck darin besteht, die Antwortzeit der Anfrage zu verkürzen und zu entkoppeln. Daher besteht das Hauptverwendungsszenario darin, Vorgänge, die zeitaufwändig sind und keine sofortigen (synchronen) Rückgabeergebnisse erfordern, als Nachrichten in die Nachrichtenwarteschlange zu stellen. Gleichzeitig müssen Absender und Empfänger der Nachricht aufgrund der Verwendung von Nachrichtenwarteschlangen nicht miteinander in Kontakt treten oder voneinander beeinflusst werden, d. h. Entkopplung und Zusammenfassung, solange das Nachrichtenformat unverändert bleibt.

Nutzungsszenarien, zum Beispiel:

Angenommen, der Benutzer registriert sich in Ihrer Software und nachdem der Server die Registrierungsanfrage des Benutzers erhalten hat, führt er die folgenden Vorgänge aus:

Überprüfen Sie den Benutzernamen und andere Informationen. Wenn kein Problem vorliegt, wird ein Benutzerdatensatz zur Datenbank hinzugefügt.

Wenn Sie sich per E-Mail registrieren, erhalten Sie eine E-Mail Zeigt an, dass die Registrierung erfolgreich war, und sendet eine SMS

, um die persönlichen Daten des Benutzers zu analysieren, um ihm in Zukunft einige Gleichgesinnte zu empfehlen oder ihn diesen zu empfehlen Personen

an den Benutzer Eine Systembenachrichtigung mit Betriebsrichtlinien

und so weiter...

Aber für den Benutzer die Registrierung Die Funktion erfordert eigentlich nur den ersten Schritt, solange der Server seine Daten sendet. Nachdem die Kontoinformationen in der Datenbank gespeichert sind, kann er sich anmelden und tun, was er tun möchte. Müssen andere Dinge in dieser Anfrage ausgefüllt werden? Lohnt es sich, dass der Benutzer darauf wartet, dass Sie sich mit etwas befassen, das ihm egal ist? Nachdem der erste Schritt abgeschlossen ist, kann der Server also tatsächlich andere Vorgänge in die entsprechende Nachrichtenwarteschlange stellen und sofort die Benutzerergebnisse zurückgeben, und die Nachrichtenwarteschlange führt diese Vorgänge asynchron aus.

Oder es gibt eine andere Situation, in der sich eine große Anzahl von Benutzern gleichzeitig für Ihre Software registriert. Unter Bedingungen hoher Parallelität treten bei den Registrierungsanfragen einige Probleme auf, z. B. wenn die E-Mail-Schnittstelle dies nicht aushält Die große Menge an Berechnungen bei der Analyse der Informationen erschöpft die CPU. Bei voller Auslastung kann es vorkommen, dass Benutzerdatensätze zwar schnell zur Datenbank hinzugefügt werden, beim Senden von E-Mails oder bei der Analyse von Informationen jedoch hängen bleiben, was zu einem erheblichen Anstieg führt die Antwortzeit der Anfrage oder sogar ein Timeout, was etwas unwirtschaftlich ist. In dieser Situation werden diese Vorgänge im Allgemeinen in die Nachrichtenwarteschlange gestellt (Produzenten-Konsumenten-Modell). Die Nachrichtenwarteschlange verarbeitet sie langsam und kann gleichzeitig die Registrierungsanforderung schnell abschließen, ohne die Nutzung anderer Funktionen durch den Benutzer zu beeinträchtigen.

Bei der normalen Funktionsentwicklung der Software muss also nicht gezielt nach Nutzungsszenarien von Nachrichtenwarteschlangen gesucht werden. Stattdessen wird bei Auftreten eines Leistungsengpasses überprüft, ob in der Geschäftslogik zeitaufwändige Vorgänge vorliegen die asynchron verarbeitet werden kann, kann eine Nachrichtenwarteschlange eingeführt werden, um das Problem zu lösen. Andernfalls kann die blinde Verwendung von Nachrichtenwarteschlangen zwar die Wartungs- und Entwicklungskosten erhöhen, jedoch keine nennenswerten Leistungsverbesserungen erzielen, was den Gewinn nicht wert ist.

Das obige ist der detaillierte Inhalt vonBeispielcode für die gemeinsame Nutzung einer Nachrichtenwarteschlange in Java. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!