如何获取现有的Websocket实例

容器会为每个客户端连接创建一个单独的终结点实例，因此您无法做您想做的事情。但是我认为您想要做的是在事件发生时向所有活动的客户端连接发送消息，这非常简单。

本

javax.websocket.Session

getBasicRemote

RemoteEndpoint.Basic

您可以通过调用来检索所有打开的会话

Session.getOpenSessions()

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

但是在您的情况下，您可能想使用CDI事件来触发对所有客户端的更新。在这种情况下，您将创建一个CDI事件，您的Websocket端点类中的方法会观察到此事件：

@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将执行以下操作：

...@InjectEvent<ArticleEvent> newArticleEvent;public void publishArticle(Article article) {  ...  newArticleEvent.fire(new ArticleEvent(article));  ...}

请参阅有关WebSocket和CDI事件的Java EE 7教程章节。

编辑：修改了

@Observer

编辑2：按照@gcvt，以同步方式将循环包装在broadcastArticle中。

编辑3：更新了指向Java EE 7教程的链接。干得好，Oracle。嘘。