Comment obtenir un existant websocket exemple

Le conteneur crée une instance distincte du point de terminaison pour chaque connexion client, de sorte que vous ne pouvez pas faire ce que vous essayez de faire. Mais je pense que ce que vous essayez de faire est d'envoyer un message à toutes les connexions client lorsqu'un événement se produit, ce qui est assez simple.

La javax.websocket.Session la classe a l' getBasicRemote méthode pour récupérer un RemoteEndpoint.Basic instance qui représente le point de terminaison associé à cette session.

Vous pouvez récupérer toutes les sessions ouvertes en appelant Session.getOpenSessions(), puis itérer à travers eux. La boucle sera envoyer à chaque client de connexion un message. Voici un exemple simple:

@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) { ... }
  } 
} 

Mais dans votre cas, vous voudrez probablement utiliser CDI événements pour déclencher la mise à jour à tous les clients. Dans ce cas, vous devez créer un CDI événement qu'une méthode dans votre point de terminaison Websocket classe observe:

@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) { ... }
        }
      }
    }
  }
}

L'EJB dans l'exemple ci-dessus serait de faire quelque chose comme:

...
@Inject
Event<ArticleEvent> newArticleEvent;

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

Voir la Java EE 7 Tutoriel chapitres sur Les WebSockets et CDI Événements.

Edit: Modifié le @Observer de la méthode à utiliser un événement en tant que paramètre.

Edit 2: enveloppé de la boucle broadcastArticle dans synchronisé, par @gcvt.

Edit 3: liens mis à Jour vers Java EE 7 Tutoriel. Beau travail, Oracle. Sheesh.