CUBA 平台从后端推送消息到 UI

Question

我想知道是否可以从后端发送消息（例如从外部系统接收信息的运行任务）到 UI。在我的例子中，它需要是一个特定的会话（没有广播）并且只在一个特定的屏幕上

计划 B 会频繁轮询后端，但我希望获得更“实时”的东西

我正试图解决这样的问题，但我一直收到 NotSerializableException。

@Push
class StorageAccess : Screen(), MessageListener {
    @Inject
    private lateinit var stationWSService: StationWebSocketService
    @Inject
    private lateinit var notifications: Notifications

    @Subscribe
    private fun onInit(event: InitEvent) {
    }

    @Subscribe("stationPicker")
    private fun onStationPickerValueChange(event: HasValue.ValueChangeEvent<StorageUnit>) {
        val current = AppUI.getCurrent()
        current.userSession.id ?: return

        val prevValue = event.prevValue
        if (prevValue != null) {
            stationWSService.remove(current.userSession.id)
        }
        val value = event.value ?: return

        stationWSService.listen(current.userSession.id, value, this)
    }

    override fun messageReceived(message: String) {
        val current = AppUI.getCurrent()
        current.access {
            notifications.create().withCaption(message).show()
        }

    }

    @Subscribe
    private fun onAfterDetach(event: AfterDetachEvent) {
        val current = AppUI.getCurrent()
        current.userSession.id ?: return
        stationWSService.remove(current.userSession.id)
    }

}

-- 回调接口

interface MessageListener : Serializable {
    fun messageReceived(message: String);
}

-- 我后台服务的listen方法

private val listeners: MutableMap<String, MutableMap<UUID, MessageListener>> = HashMap()
override fun listen(id: UUID, storageUnit: StorageUnit, callback: MessageListener) {
    val unitStationIP: String = storageUnit.unitStationIP ?: return

    if (!listeners.containsKey(unitStationIP))
        listeners[unitStationIP] = HashMap()

    listeners[unitStationIP]?.set(id, callback)
}

我得到的异常是 NotSerializableException: com.haulmont.cuba.web.sys.WebNotifications，它在将侦听器添加到后端期间发生：stationWSService.listen(current.userSession.id, value, this)

据我所知，这是 UI 将信息发送到后端的地方 - 以及 class StorageAccess 的整个状态，包括它的所有成员。

有没有优雅的解决方案？

问候

Answer 1

有一个插件可以解决这个问题：https://github.com/cuba-platform/global-events-addon

CUBA 平台从后端推送消息到 UI

CUBA Platform push messages from backend to UI

kotlin

server-push

cuba-platform