如何在JSF中实现细粒度WebSocket推送？解决多控制器/组消息过滤问题

Jakarta EE本身不支持运行时动态创建OmniFaces @Push通道（通道是部署阶段静态注册的），但你可以通过以下两种更高效的方式实现精准推送，替代前端过滤的低效方案：

方案一：利用OmniFaces订阅参数实现目标推送（推荐） #

OmniFaces的PushContext支持基于参数的定向推送，无需创建大量静态通道：

1. 后端调整 #

保留一个通用的推送通道，注入方式简化为：

@Inject
@Push(channel = "generalEventChannel")
private PushContext generalEventChannel;

当从ActiveMQ收到消息时，根据消息中的控制器/组ID，指定参数推送：

// 假设消息包含controllerId字段
String targetControllerId = event.getControllerId();
generalEventChannel.send(event.getMessage(), "targetId", targetControllerId);

2. 前端调整 #

在特定视图（如控制器详情页）中，初始化socket时携带当前目标ID作为订阅参数：

<o:socket channel="generalEventChannel" onmessage="onMessage" />

<script>
function onMessage(message) {
    // 此时只有订阅了对应targetId的客户端会收到该消息，直接处理即可
    console.log('收到目标消息:', message);
    // 调用后端回调或更新视图
    backingBean.controllerChannelCallback(message);
}

// 页面加载时订阅指定目标
document.addEventListener('DOMContentLoaded', function() {
    OmniFaces.Push.subscribe('generalEventChannel', onMessage, {
        params: { targetId: '#{currentController.id}' }
    });
});
</script>

<h:commandScript name="controllerChannelCallback" actionListener="#{backingBean.handleControllerEvent}" process="@this" />

OmniFaces会自动维护订阅关系，仅将消息推送给匹配targetId参数的客户端，完全省去前端过滤步骤。

方案二：维护订阅映射实现定向推送 #

如果需要更细粒度的控制，可以在@ApplicationScoped监听器中维护目标与客户端的映射：

1. 后端维护订阅映射 #

@ApplicationScoped
public class ActiveMQListener {

    private final ConcurrentHashMap<String, Set<PushContext>> targetSubscriptions = new ConcurrentHashMap<>();

    @Inject
    @Push(channel = "dynamicEventChannel")
    private PushContext dynamicEventChannel;

    // 供前端调用的注册方法（比如通过REST或JSF ajax）
    public void subscribe(String targetId) {
        // 获取当前客户端的PushContext（OmniFaces会自动关联会话）
        PushContext clientContext = dynamicEventChannel.withSession();
        targetSubscriptions.computeIfAbsent(targetId, k -> ConcurrentHashMap.newKeySet()).add(clientContext);
    }

    // 取消订阅方法
    public void unsubscribe(String targetId) {
        Set<PushContext> contexts = targetSubscriptions.get(targetId);
        if (contexts != null) {
            contexts.remove(dynamicEventChannel.withSession());
            if (contexts.isEmpty()) {
                targetSubscriptions.remove(targetId);
            }
        }
    }

    // ActiveMQ消息监听方法
    public void onMessage(Event event) {
        String targetId = event.getTargetId(); // 控制器/组ID
        Set<PushContext> contexts = targetSubscriptions.get(targetId);
        if (contexts != null) {
            contexts.forEach(context -> context.send(event.getMessage()));
        }
    }
}

2. 前端注册/取消订阅 #

<o:socket channel="dynamicEventChannel" onmessage="onMessage" />

<script>
const targetId = '#{currentController.id}';

// 页面加载时注册
document.addEventListener('DOMContentLoaded', function() {
    backingBean.subscribe(targetId);
});

// 页面关闭时取消订阅
window.addEventListener('beforeunload', function() {
    backingBean.unsubscribe(targetId);
});

function onMessage(message) {
    // 直接处理消息，无需过滤
    backingBean.handleControllerEvent(message);
}
</script>

<h:commandScript name="subscribe" actionListener="#{activeMQListener.subscribe(targetId)}" process="@this" />
<h:commandScript name="unsubscribe" actionListener="#{activeMQListener.unsubscribe(targetId)}" process="@this" />
<h:commandScript name="handleControllerEvent" actionListener="#{backingBean.handleControllerEvent}" process="@this" />

关键注意事项 #

• 避免内存泄漏：务必在会话结束或页面关闭时取消订阅，移除映射中的无效PushContext。
• 线程安全：使用ConcurrentHashMap等线程安全集合维护订阅映射，适配多线程环境。
• 安全性：如果目标ID涉及敏感数据，需验证客户端的订阅权限，防止非法订阅。

内容的提问来源于stack exchange，提问作者Mats