Grails Atmosphere 插件向不同客户端广播

Question

我正在尝试扩展 Groovy Mag Atmosphere 示例 (https://github.com/rbramley/GroovyMagJMS) 向不同的客户端广播。 （如向 Atmosphere 中的一部分订阅者广播）

客户端使用 url http://localhost:8080/GrailsTest/atmosphere/messages/?id=1。一个 id 将被传递到服务器。新添加的lookupBroadcaster方法使用id创建一个新的Broadcaster对象。当我想广播消息时，客户端没有收到结果。

有人可以帮助我并尝试一下吗？

我将气氛 0.8.2 库添加到 BuildConfig.groovy 以使用“/atmosphere/messages/*”等映射。

dependencies {  
    runtime 'org.atmosphere:atmosphere-runtime:0.8.2'
}


class AtmosphereService {

static transactional = false

static atmosphere = [mapping: '/atmosphere/messages/*']

static exposes = ['jms']

@Subscriber(topic='msgevent')
def onEvent(msg) {
    println 'onevent'
    def payload = msg
    if(msg instanceof Map) {
        // convert map messages to JSON
        payload = msg.encodeAsJSON()
    }

    Broadcaster b = lookupBroadcaster(msg["id"], false);
    b.broadcast(payload)

    return null
}

Broadcaster lookupBroadcaster(String id, Boolean createBroadcast) {
    return BroadcasterFactory.getDefault().lookup(id, createBroadcast)
}

def onRequest = { event ->

    def req = event.request
    def id = req.getParameter("id")

    Broadcaster b = lookupBroadcaster(id, true);
    event.setBroadcaster(b);
    b.addAtmosphereResource(event)

    event.suspend()

}

def onStateChange = { event ->
    if (event.message) {
        log.info "onStateChange, message: ${event.message}"

        if (event.isSuspended()) {
            event.resource.response.writer.with {
                write "<script>parent.callback('${event.message}');</script>"
                flush()
            }
            event.resume()
        }
    }
}

}

Answer 1

这应该基于该代码片段工作。广播时是否会调用 onStateChange() 方法？由于您正在恢复，第一个广播将正常工作，但之后 AtmosphereResource 将从其关联的广播器中删除，因此不再更新。