氛围+球衣:我如何拥有多个广播公司

Question

我有一个工作泽西/大气/Guice应用程序，它有两个大气资源。第一个几乎是示例聊天应用程序的克隆：

@Path("/chat")
@AtmosphereService(broadcaster = JerseyBroadcaster.class, path = "/chat")
public class ChatResource {
    @Suspend(contentType = "application/json")
    @GET
    public String suspend() {
       return "";
    } 
    @Broadcast(writeEntity = false)
    @POST
    @Produces("application/json")
    public Response broadcast(Message message) {
        return new Response(message.author, message.message);
    }
}

第二个是测试通知资源，它将向服务器端发送事件：

@Path("/notifications")
@AtmosphereService(broadcaster = JerseyBroadcaster.class, path = "/notifications")
public class NotificationsResource {
    @Suspend(contentType = "application/json")
    @GET
    public String suspend() {
       return "";
    } 
}

一切都连接正确并且工作正常。但是，为了让我发送服务器端事件，我发出：

MetaBroadcaster.getDefault().broadcastTo("/*", new Response(...));

显然，这会将广播消息发送到两个资源。我想做的是仅将服务器端事件发送到通知资源：

MetaBroadcaster.getDefault().broadcastTo("/notifications", new NotificationResponse(...));

但是，这行不通。我总是收到以下错误：

org.atmosphere.cpr.MetaBroadcaster - No Broadcaster matches /notifications.

那是因为只有一个广播公司注册;/*上的泽西广播公司。

问题是：如何使这两个资源具有具有不同 ID/名称的不同广播公司？

Answer 1

在资源中，使用您想要的通道挂起（如果通道不存在，则 lookup（） 的 'true' 参数强制创建通道）：

@Suspend( contentType = MediaType.APPLICATION_JSON, period = MAX_SUSPEND_MSEC )
@GET
public Broadcastable suspend( @Context final BroadcasterFactory factory )
{
    return new Broadcastable( factory.lookup( MY_CHANNEL, true ) );
}

在另一个代码中，几乎可以在任何地方，广播到该频道：

Broadcaster broadcaster = BroadcasterFactory.getDefault().lookup( MY_CHANNEL );
if( broadcaster != null ) {
    broadcaster.broadcast( message );
}

如果你要从资源方法广播，你可以改为注释它（如ChatResource的broadcast（）方法所示）。

Answer 2

只需使用 @PathParam 注释注入广播器：

private
@PathParam("topic")
Broadcaster topic;

您还可以使用@Context批注。希望有帮助。

- 让弗朗索瓦