跨实例同步对 MDB 方法的访问

发布于 2024-10-03 00:47:42 字数 195 浏览 2 评论 0原文

我有一个消息驱动 Bean，它接收审核消息。这些消息还包含有关正在审核的系统的信息。当收到消息时，MDB 可以创建系统（如果该系统不存在）或重用现有系统。

我的挑战是，当同时接收到来自新系统的大量消息时，会创建多个 MDB 实例，并最终可能会创建重复的系统。向数据库添加约束是解决该问题的一种方法。有没有办法避免应用程序（在本例中为 MDB）中出现这些重复项？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

看透却不说透 2024-10-10 00:47:42

确保只有一个线程处理所有消息。这可以在激活规范、连接池上进行配置。

回复收藏 0 原文

岁月流歌 2024-10-10 00:47:42

MessageDrivenBean 可以通过队列 Destination Options 进行同步。在我的例子中，对于单个消息处理，MessageDriven 注释看起来像这样：

@MessageDriven(name = "ArchiveCounterStJmsListener", activationConfig = {
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "destination", propertyValue = LINK_TO_QUEUE + "?consumer.dispatchAsync=false&consumer.prefetchSize=1"),
    @ActivationConfigProperty(propertyName = "maxSessions", propertyValue = "1")
})

MessageDrivenBean can be synchronized via queue Destination Options. In my case MessageDriven annotation looks like this for single message processing:

@MessageDriven(name = "ArchiveCounterStJmsListener", activationConfig = {
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "destination", propertyValue = LINK_TO_QUEUE + "?consumer.dispatchAsync=false&consumer.prefetchSize=1"),
    @ActivationConfigProperty(propertyName = "maxSessions", propertyValue = "1")
})

回复收藏 0 原文

叹沉浮 2024-10-10 00:47:42

你可以尝试这样的事情：

private Object LOCK;
public void onMessage() {
    code…
    synchronized(LOCK) {
        check if system exists, create if necessary
    }
    more code…
}

You could try something like this:

private Object LOCK;
public void onMessage() {
    code…
    synchronized(LOCK) {
        check if system exists, create if necessary
    }
    more code…
}

回复收藏 0 原文

~没有更多了~