1

我正在寻找在网络搜索中找不到的更多信息。我很可能在寻找错误的东西，我希望有人能纠正我。

我已经实现了一个客户端（javascript）-服务器（java）websocket 应用程序。我有为多个客户端工作的连接，现在我想从 main 方法创建的一些初始数据开始。但是，我的 java 应用程序中的主要方法没有链接到 websocket 端点。因此，如果我在运行应用程序时创建对象实例，我希望将该信息发送到会话操作闭环之外的连接客户端。

我所描述的听起来不可能，但我确信我只是没有正确解释它。

结论：

在处理 websockets 时，我怎样才能拥有 OnServerStartup 以便我可以加载保存的数据或创建初始数据？

背景：

我已经使用 javax.websocket.server 实现了一个带注释的服务器端点。由于出现故障可能导致我感到困惑的历史是，我首先从 java 应用程序开始，然后我想要一个客户端 UI 来添加、编辑、删除数据。所以我使用了一个通过 websockets 与我的 java 应用程序通信的 javascript 前端。现在我的应用程序无法与 websocket 连接进行通信，或者至少我还不知道如何。

理想情况下，我想做的是让用户操作通过 websocket 进入，然后我想将操作放入我的应用程序然后处理的队列中。完成后，它将对数据集的结果更改发送到所有活动会话。这里有一个大问题，因为我想在允许 websocket 连接之前初始化保存的数据。此外，如果我有一个定时事件，我希望能够将所有更新发送到连接的会话。

4

1 回答 1

1

这里有三个解决方案。他们可能无法帮助使用 Glassfish 的原始海报；我不知道。但它们是已发布问题的答案，可能会有一些用处。

我为我的服务器使用嵌入式 Jetty。（这意味着服务器是在我的 Java 代码中创建的，所以我可以访问所有内容。）

答案 1：让您的 websocket 服务器端点监听从您的主线程发送的 CDI 事件。我没有这样做，但我认为这是一个非常干净的概念。

答案 2：让您的端点在主线程中“注册”自身。

在核心类中创建一个静态集合成员：

public class Core()
...
    public static List<MyEndpoint> webSockets = new ArrayList<MyEndpoint>();

Endpoint 将 self 添加到集合中：

@ServerEndpoint(value="/path/")
public class MyEndpoint
{
    @OnOpen
    public void onWebSocketConnect(javax.websocket.Session session)
    {
        synchronized(Core.webSockets)
        {
            Core.webSockets.add(this);
        }
        ...
    }

回到 Core，您将遍历webSockets以发送消息。同步迭代，或者更好的是，复制webSockets并迭代整个副本（标准同步收集实践）。您还需要在@OnClose 中处理从列表中的删除，并在迭代期间注意关闭的套接字。

请注意，可以根据需要以其他方式完成同步：Collections.synchronizedList() 或 CopyOnWriteArrayList 在不同情况下很有用。

答案 3：控制构建端点实例。这是我的选择中最强大的，因为您可以使用数据和外部引用来构建它。

我的实现是基于 JSR-356（和 Jetty）的，但其他框架中也有钩子。总是略显复杂。

在服务器创建期间：

context = new ServletContextHandler(ServletContextHandler.SESSIONS);
// ... more server creation

ServerContainer wscontainer = WebSocketServerContainerInitializer.configureContext(context);

wscontainer.addEndpoint(ServerEndpointConfig.Builder.create(MyEndpoint.class, "/path/")
    .configurator(new MyConfigurator(aSocketManagerObject))
    .build());

在哪里：

public class MyConfigurator extends javax.websocket.server.ServerEndpointConfig.Configurator
{
    private final ManagerObject aSocketManagerObject;

    public EventsConfigurator(ManagerObject aSocketManagerObject)
    {
        this.aSocketManagerObject = aSocketManagerObject;
    }

    @Override
    public <T> T getEndpointInstance(Class<T> endpointClass) throws InstantiationException
    {
        return (T) new MyEndpoint(aSocketManagerObject); // This constructor to be added to your MyEndpoint class
    }
}

端点现在有一个引用aSocketManagerObject并且可以自由地与它通信以获取数据、注册为侦听器等。

Bhaskar S. 在Introduction to WebSockets中提供了答案 3 的健壮实现

编辑：

有关 CDI 方法的更多信息是有问题的，如何获取现有的 websocket 实例。

并且从 Web Socket @ServerEndpoint 中的 HttpServletRequest 访问 HttpSession包括关于端点实例的长时间讨论。

于 2017-09-03T13:46:00.013 回答