Wie man eine bestehende websocket-Instanz

Den container erstellt eine separate Instanz des Endpunkts für jede client-Verbindung, so dass Sie nicht tun können, was Sie zu tun versuchen. Aber ich denke, was Sie versuchen zu tun, ist senden Sie eine Nachricht an alle aktiven client-verbindungen wenn ein Ereignis Eintritt, das ist ziemlich einfach.

Den javax.websocket.Session Klasse hat die getBasicRemote Methode zum abrufen einer RemoteEndpoint.Basic Instanz, stellt den Endpunkt im Zusammenhang mit der Tagung.

Können Sie abrufen, alle offenen Sitzungen durch den Aufruf Session.getOpenSessions(), dann Durchlaufen Sie. Die Schleife sendet jede client-Verbindung eine Nachricht. Hier ein einfaches Beispiel:

@ServerEndpoint("/myendpoint")
public class MyEndpoint {
  @OnMessage
  public void onMessage(Session session, String message) {
    try {  
      for (Session s : session.getOpenSessions()) {
        if (s.isOpen()) {
          s.getBasicRemote().sendText(message);
        }
    } catch (IOException ex) { ... }
  } 
} 

Aber in Ihrem Fall, werden Sie wahrscheinlich verwenden wollen, CDI-events auslösen, das update auf allen clients. In diesem Fall würden Sie erstellen ein CDI-Fall, dass eine Methode in der Websocket endpoint-Klasse beobachtet:

@ServerEndpoint("/myendpoint")
public class MyEndpoint {
  //EJB that fires an event when a new article appears
  @EJB
  ArticleBean articleBean;
  //a collection containing all the sessions
  private static final Set<Session> sessions = 
          Collections.synchronizedSet(new HashSet<Session>());

  @OnOpen
  public void onOpen(final Session session) {
    //add the new session to the set
    sessions.add(session);
    ...
  }

  @OnClose
  public void onClose(final Session session) {
    //remove the session from the set
    sessions.remove(session);
  }

  public void broadcastArticle(@Observes @NewArticleEvent ArticleEvent articleEvent) {
    synchronized(sessions) {
      for (Session s : sessions) {
        if (s.isOpen()) {
          try {
            //send the article summary to all the connected clients
            s.getBasicRemote().sendText("New article up:" + articleEvent.getArticle().getSummary());
          } catch (IOException ex) { ... }
        }
      }
    }
  }
}

EJB-im obigen Beispiel würde so etwas machen:

...
@Inject
Event<ArticleEvent> newArticleEvent;

public void publishArticle(Article article) {
  ...
  newArticleEvent.fire(new ArticleEvent(article));
  ...
}

Finden Sie unter Java EE 7 Tutorial Kapitel auf WebSockets und CDI-Events.

Bearbeiten: Verändert die @Observer Methode, um ein Ereignis als parameter.

Edit 2: gewickelt, der loop-in-broadcastArticle in synchronisiert, pro @gcvt.

Edit 3: links Aktualisiert, um Java EE 7 Tutorial. Netter job, Oracle. Sheesh.

InformationsquelleAutor Ian Evans