3

我遇到的问题似乎表明 Java 对象不是在我预期的堆上创建的。简短的版本是我有一个 JMS onMessage() 方法，它调用另一个方法来实例化基于 TextMessage 的 JSon 有效负载的正确对象 (routingCommand)。

    public void onMessage(Message message) throws RuntimeException {

IRoutingCommand routingCommand = null;
routingCommand = instantiateRoutingCommand(message);
...
process(routingCommand);
}

private IRoutingCommand instantiateRoutingCommand(Message message)  {

    IRoutingCommand routingCommand = null;

    ... lots of code to build the correct type of RoutingCommand

    routingCommand = new IeRoutingCommand(ieNotification);
    return routingCommand;
}

问题是，在我的负载测试期间，在极其罕见的情况下，同一条 JMS 消息被多次“处理（）”。当我设置 maxConcurrentConsumers=1 时，这不会发生。

我在互联网上发现了这个我从来不知道的智慧宝石，但假设它是正确的，它可以解释我的问题：

对对象的本地引用有点不同。引用本身不共享。然而，引用的对象并不存储在每个线程的本地堆栈中。所有对象都存储在共享堆中。

instantiateRoutingCommand 方法大约有 50 行长——这就是我一开始就把它分解的原因。我可以充分检查 JMS 消息以确定它代表什么类型的对象，并在 onMessage() 方法中对其进行实例化，并将 instantiateRoutingCommand 转换为仅在传递的对象上使用设置器。即满足上述规定。但即使这样也不是微不足道的，而且会弄乱 onMessage() 方法。

我没有尝试使对象变得易失或使任何东西同步，因为如果上述情况属实，那么我看不到任何帮助。那么在多线程对象中处理传递对象的最佳方法是什么？

4

2 回答 2

1

您必须同步对多个线程引用的对象的访问，或者为每个线程提供自己的副本。虽然后者可能是唯一有效的解决方案，但应注意复制的对象不包含也包含在被复制对象中的引用。

于 2013-09-18T19:46:11.757 回答
0

我最终为我的 RoutingCommand 的所有子类创建了克隆方法。

然后在类上同步的块中使用它。由于实例化正确子类的方法只是一个解析器（没有 I/O），因此阻塞所有线程并不是特别繁重。

synchronized(FlowController.class) {
routingCommand = instantiateRoutingCommand(message).clone();  
}

这解决了我的线程安全问题。所以上面返回的对象在共享堆上的观点实际上是正确的。

于 2013-09-19T17:44:22.350 回答