java - 带有 Akka actor 的 UI 中的 Vaadin 通知

标签 java akka actor vaadin7

我正在致力于将基于 akka actor 的后端集成到 vaadin 应用程序中。 我面临的问题是我敢说简单(请原谅我,我是 vaadin 初学者 :P)。

项目结构(简化)
2 个模块前端和后端。

  • 我的后端有一个管理所有后端参与者的参与者系统。
    -> 和一个服务类,该类具有用于必要计算的所有相关方法。

  • 我的前端包含一个带有一堆 View 的 UI。
    -> 和管理一个 UIActor 的第二个 actor 系统(因为后端 actor 无法访问 UI)
    不用说后端是前端依赖的一部分。

问题
在我的一个 View 中,我有一个点击事件处理程序,它通过 UIActor 将消息发送到后端参与者之一,一旦计算完成,后端参与者就会回复。
这是 UIActor 中的“onReceive”方法

public void onReceive(Object message) throws Exception {

    if (message  == "test") {
        System.out.println("showing notification by "+currentUI);
        currentUI.testMethod();

    } else if (message instanceof MyUI) {
        System.out.println("this is the ui actor test request forwarded");
        currentUI = (MyUI) message;
        backEndAgent.tell("check",getSelf());
    } else {
        unhandled(message);
    }
}

currentUI 包含 (MyUI) getCurrent() 的返回值,由处理程序作为消息发送,以备您疑惑。

至于 testMethod,它非常基础。

public void testMethod() {
        Notification.show("Success", Notification.Type.HUMANIZED_MESSAGE);
    }

不幸的是,由于 Page.getCurrent() 返回 null,此调用在 Show 方法中生成了一个空指针。

所以我的问题是为什么我在这里得到一个空指针?
同样在我的 Actor 中,我将 currentUI 引用作为消息发送,否则调用 UIActor 内的 getCurrent 将返回 null。知道为什么吗?
编辑
这是新的测试方法 page 参数是 currentUI.getPage()

    public void testMethod(final Page page) {
            this.access(new Runnable() {
                @Override
                public void run() {
                    new Notification("Success",Notification.Type.HUMANIZED_MESSAGE).show(page);

                }
            });
        }

这以某种方式解决了问题,但仅在我第二次单击按钮而不是第一次单击按钮后才显示通知。
这让我发疯。

最佳答案

Notification.show() 使用 Page.getCurrent() 获取当前页面。 Page.getCurrent() 是一个 ThreadLocal,它在传统的 HTTP 请求-响应周期中设置,这意味着 Notification.show() 有效(不在 HTTP 请求-响应线程期间不返回 null)。

在您的情况下,Notification.show() 是在 HTTP 请求-响应线程之外调用的,这就是它返回 null 的原因。如果我从您的代码中理解正确,currentUI 是对您当前 UI 的引用,它不是 null。在这种情况下,您可以从

public void testMethod() {
    Notification.show("Success", Notification.Type.HUMANIZED_MESSAGE);
}

public void testMethod() {
    new Notification("Success", Notification.Type.HUMANIZED_MESSAGE).show(getPage());
}

修改后的版本不再使用 Page.getCurrent(),而是从 UI 实例的 getPage() 方法获取当前页面。

编辑。忘记添加与访问 Vaadin 代码的参与者/外部线程相关的重要信息:

从 Vaadin 的角度来看,调用方法来显示通知的 actor 是一个外部线程。 Vaadin 假定对 Vaadin 组件和 Vaadin 相关其他对象的访问已正确锁定/同步。当使用传统的 HTTP 请求-响应线程时,适当的锁定/同步就位,但当外部线程(例如 actor)访问这些线程时,开发人员必须确保锁定。确保锁定的一种方法是使用 UI.access:

getUI().access(new Runnable() {
    @Override
    public void run() {
        // insert your code accessing Vaadin related objects here
    }
});

您在单击按钮后看到通知的原因是浏览器不知道当 Actor 调用 Notification.show 时有内容要显示。由单击按钮引起的请求将更改从服务器拉到浏览器,然后显示通知。要在没有用户交互(例如单击按钮)的情况下查看参与者/外部线程的更改,应用程序必须使用轮询或推送。要启用轮询,请为您的用户界面设置 PollInterval。

关于java - 带有 Akka actor 的 UI 中的 Vaadin 通知,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30666816/

相关文章:

java - 考虑速度的特定路径算法

java - Flex AMF Remoting 请求到 Java 服务器的排队策略

java - 反引号准备好的语句 Java

playframework - Reload后在WebSocket Iteratee中 Play Morphia MappingException

scala - 如何最大限度地减少 akka 流中的内存使用

java - 循环遍历 2 个不同的数组来评估 Java 中的条件

events - 等待akka actor系统可用

multithreading - 为什么在一个应用程序中可以有数百万个 actor,但只有 10,000 个线程就太多了?

java - 当 Actor 调整大小时是否有监听器?

java - 在 AKKA 中,调用 supervisor 的 shutdown 会停止它所监督的所有 actor 吗?