Mit Atmosphere-Laufzeit

Question

kann ich keine Verbindung zu einer einzelnen Verbindung herstellen. Ich verwende Atmosphere Runtime 0.6 Snapshot. Tomcat 7 protokolliert korrekt, dass ich den Http11 Nio Connector verwende und es gibt keine Warnung, dass BlockingIO verwendet wird.

Ich versuche, Nachrichten an drei Arten von Kanälen zu senden.

1. Global Broadcaster - Übertragung an alle suspendierten Ressourcen. (Alle)
2. Übertragung auf eine bestimmte Ressource (sagen wir, Partner)
3. Broadcast aktuelle Ressource (Self)

Wenn ein Login Aktion auftritt, was alle tun, ich in der Sitzung speichern, um müssen diese Art von Rundfunk zu erreichen?

Einige Details meines Codes sind wie folgt:

1. Mein Handler implementiert AtmosphereHandler
im Konstruktor

2. ich die globalBroadcaster instanziiert wie folgt:

   globalBroadcaster = new DefaultBroadcaster();

3. Auf Login ,

   resource.getAtmosphereConfig().getServletContext().setAttribute(name, selfBroadcaster); Dabei ist name der Benutzername aus Anfrageparameter und selfBroadcaster ist eine neue Instanz von DefaultBroadcaster. Hier

4. ist der Code für sendMessageToPartner,

private synchronized void sendMessageToPartner(Broadcaster selfBroadcaster, AtmosphereResource<HttpServletRequest, HttpServletResponse> resource,String name, String message) {
// this gives the partner's name
String partner= (String) resource.getAtmosphereConfig().getServletContext().getAttribute(name + PARTNER_NAME_TOKEN);
// get partner's broadcaster
Broadcaster outsiderBroadcaster = (Broadcaster) resource
.getAtmosphereConfig().getServletContext()
.getAttribute(partner);
if (outsiderBroadcaster == null) {
sendMessage(selfBroadcaster, "Invalid user " + partner);
return;
}
// broadcast to partner
outsiderBroadcaster.broadcast(" **" + message);

Ich hoffe, dass ich gegeben habe, alle erforderlichen Informationen. Ich kann bei Bedarf weitere Informationen bereitstellen.

Das Problem ist, die globale Nachricht wird gesendet. Wenn die Nachricht an den Partner gesendet wird, wird sie manchmal blockiert, die Nachricht wird überhaupt nicht im Client empfangen. Dies geschieht konsistent nach 3-4 Nachrichten.

Gibt es ein Gewindeproblem? Was mache ich falsch?

Ich hoffe, dass mir jemand dabei hilft.

Answer 1

Ok, ich habe herausgefunden, wie dies mit Atmosphere Laufzeit erreicht werden kann. Zuerst habe ich auf 0,7 SNAPSHOT aufgerüstet, aber ich denke, die gleiche Logik würde auch mit 0,6 funktionieren.

So ein Broadcaster für einen einzelnen Benutzer erstellen:

In GET-Anfrage,

// Use one Broadcaster per AtmosphereResource    
try {  
atmoResource.setBroadcaster(BroadcasterFactory.getDefault().get());  

} catch (Throwable t) { 
       throw new IOException(t); 
      } 

      // Create a Broadcaster based on this session id. 
      selfBroadcaster = atmoResource.getBroadcaster(); 
      // add to the selfBroadcaster 
      selfBroadcaster.addAtmosphereResource(atmoResource); 

      atmoResource.suspend(); 

Wenn Login Aktion aufgerufen wird,

//Get this broadcaster from session and add it to BroadcasterFactory. 

Broadcaster selfBroadcaster = (Broadcaster) session.getAttribute(sessionId); 

BroadcasterFactory.getDefault().add(selfBroadcaster, name); 

Now the global broadcaster. The logic here is, you create a broadcaster from the first resource and then add each resource as they log in. 

Broadcaster globalBroadcaster; 

globalBroadcaster = BroadcasterFactory.getDefault().lookup(DefaultBroadcaster.class, GLOBAL_TOKEN, false); 
       if (globalBroadcaster == null) { 
        globalBroadcaster = selfBroadcaster; 

        } else { 
         BroadcasterFactory.getDefault().remove(
           globalBroadcaster, GLOBAL_TOKEN); 
         AtmosphereResource r = (AtmosphereResource) session 
           .getAttribute("atmoResource"); 
         globalBroadcaster.addAtmosphereResource(r); 

        } 
        BroadcasterFactory.getDefault().add(globalBroadcaster, 
          GLOBAL_TOKEN); 

Schließlich können Sie auf Einzel ausgestrahlt Verbindung oder global zu allen Verbindungen wie folgt:

// Single Connection/Session 
Broadcaster singleBroadcaster= BroadcasterFactory.getDefault().lookup(
          DefaultBroadcaster.class, name); 
singleBroadcaster.broadcast("Only for you"); 

// Global 
Broadcaster globalBroadcaster = BroadcasterFactory.getDefault().lookup(DefaultBroadcaster.class,GLOBAL_TOKEN, false); 
globalBroadcaster.broadcast("Global message to all"); 

Um eine Nachricht an den Partner zu senden, suchen Sie einfach den Sender für den Partner und machen Sie dasselbe wie oben für eine einzelne Verbindung.

Hoffe das hilft jemandem, der versucht, das gleiche zu erreichen. Es gibt möglicherweise bessere Möglichkeiten, dies zu tun. Ich denke, ich muss diesen Ansatz verwenden, bis jemand eine bessere Lösung vorschlägt.