3

我们在集群环境中有多个 JBoss-Server 实例。对于后台任务，有一个可用的全局队列，用于管理在其中注册的所有作业。对于这个队列，每个节点上都有一个简单的侦听器 (MDB)，用于管理传入的消息。此侦听器对单例 bean 进行手动查找（无注入）并启动预定义的方法。到目前为止一切正常，但是单例 bean 中的方法使用了在某些情况下不可用的其他一些（无单例服务）。例如，如果一个节点将被重新启动并且队列中有剩余的消息（尚未处理），则消息将被侦听器拾取并且所有进一步的 bean 都为空，因此该作业会产生 NPE。是否可以在接收消息后在 JMS-Listener 中定义延迟时间，或者是否可以定义“

一种可能是将 MDB 属性“DeliveryActive”设置为 false 并在完全部署后启动 bean。是否有一种简单的工作方式以编程方式执行此操作（不在 jmx-console 中）？我找到的任何手册都会将我重定向到手动 jndi 查找。我认为必须可以为每个注释注入 Bean 并调用 startDelivery()？在应用程序中是否有这样做的好地方？

另一个提示将我带到 application.xml 中的 order 属性的初始化，因为问题可能与 JBoss 部署顺序有关（某些 EJB 将比侦听器更晚可用），但JBoss 6.0 中似乎存在错误并升级到6.1。不是一种选择。也许有一个演练？

我希望问题得到充分解释，否则请询问更多信息。

在此先感谢，丹尼

附加信息：

  • JBoss 6.0.0 最终版
  • HornetQ 2.2.5 Final（已经更新，因为 JBoss 的默认版本有问题）

聆听者：

@MessageDriven(activationConfig =
    {
            @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
            @ActivationConfigProperty(propertyName = "destination", propertyValue = "/queue/SchedulerQueue")
    })
public class SchedulerQueueListener implements MessageListener {
...
@Override
public void onMessage(Message message) {
   ...
   service = (IScheduledWorkerService) new InitialContext().lookup(jndiName);
   EJobResult eJobResult = service.executeJob(message);
   ...
}

样本工人：

@Singleton
@LocalBinding(jndiBinding = SampleJobWorkerService.JNDI_NAME)
public class SampleJobWorkerService implements IScheduledWorkerService {

...
    @EJB(name = "SampleEJB/local")
    private ISampleEJB sampleEjb;
...
    @Override
    public EJobResult executeJob(Message message) {
    int state = sampleEjb.doSomething(message.getLongProperty(A_PROPERTY));
    }

在这种情况下，sampleEjb - 成员有时会为空

4

2 回答 2

1

  1. 作为一种解决方法，您可以创建一个带有超时的计时器，而不是直接从 MDB 调用 EJB。因此，执行会有一些延迟。

    在 Timer 的 timeout 方法中，您可以调用单例 EJB，以防调用其他非单例 EJB。

  2. JBoss 特定：可以在发送前尝试在消息对象中设置属性。

    msg.setLongProperty("JMS_JBOSS_SCHEDULED_DELIVERY", (current + delay));

    其他选择是_JBM_SCHED_DELIVERY.

编辑 ：

对于第一部分，您可以拥有 JTA 事务，它可能跨越 JMS 和 EJB。因此可以相应地处理故障转移和其他事情。

您还可以增加消息对象的重新传递延迟。

<address-setting match="jms.queue.someQueue">
        <redelivery-delay>5000</redelivery-delay>
</address-setting>
于 2012-02-13T19:54:44.820 回答
0

我现在也有同样的麻烦。

我建议您在单例 bean 上使用EJB 3 启动 bean 注释 @Startup来调用startDelivery消息侦听器上的方法。

于 2012-05-23T13:27:27.110 回答