Grails Atmosphere Plugin廣播給不同的客戶端

我試圖擴展Groovy Mag氣氛示例（https://github.com/rbramley/GroovyMagJMS）以廣播到不同的客戶端。（如Broadcasting to a subset of subscribers in Atmosphere）Grails Atmosphere Plugin廣播給不同的客戶端

客戶端連接網址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() 
     } 
    } 
}

}

來源

2012-01-11 user1117605

薩呂。

這應該基於該代碼段工作。廣播時是否調用onStateChange（）方法？由於您正在恢復，第一個廣播將起作用，但在此之後，AtmosphereResource將從其關聯的Broadcaster中刪除，因此不會再進行更新。

感謝

- Jeanfrancois

來源

2012-01-13 20:56:32 jfarcand

Grails Atmosphere Plugin廣播給不同的客戶端

回答

相關問題