CometD:广播前处理广播消息

Question

我在码头里运行了一个彗星应用程序。我想从客户端获取传入的广播，然后进行一些处理(涉及与db的交互)，然后在没有遇到错误的情况下向所有订阅者广播。

我最初的想法是用一个扩展来完成这个任务，但是有没有更合适的方法呢？

以下是基于@sbordet回答的修改尝试：

@Inject
private BayeuxServer bayeux;
@Session
private ServerSession serverSession;

    @Listener("/service/*")
    public void handle(ServerSession remote, ServerMessage message) {
        System.out.println("Message received on service: " + message);

        String broadcastChannel = message.getChannel().replace("/service", "");
        System.out.println("bayeux: " + bayeux + " - sending: " + broadcastChannel + " - " + message.getData());
        System.out.println("bayeux.getChannel(broadcastChannel): " + bayeux.getChannel(broadcastChannel));
        bayeux.getChannel(broadcastChannel).publish(serverSession, message.getData());
    }

本质上，我希望侦听所有服务频道，并进行一些处理，然后发布到相同的广播频道，减去/service。因此，/service/test变成了/test。

此当前值返回bayeux.getChannel(broadcastChannel)的null

Answer 1

因为您所描述的是CometD内部的正常消息处理，所以不要使用扩展，而是使用服务。

在需要修改处于CometD核心的Bayeux协议的行为时，应该使用扩展。

另一方面，服务是处理应用程序交换的业务消息的一种方便的方式，因此适合您的情况。