java - 在线程安全类中返回一个对象

Question

我遇到的问题似乎表明 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 消息被“process()ed”多次。当我设置 maxConcurrentConsumers=1 时，这不会发生。

我在 Internet 上发现了这个我从来不知道的智慧 gem ，但假设它是正确的，它就可以解释我的问题:

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

instantiateRoutingCommand 方法大约有 50 行长——这就是为什么我一开始就把它拆开的原因。我可以充分检查 JMS 消息以确定它代表什么类型的对象并在 onMessage() 方法中实例化它并将 instantiateRoutingCommand 转换为仅在传递的对象上使用 setter。这样就满足了上面的规定。但即便如此，这也不是完全微不足道的，并且会使 onMessage() 方法变得困惑。

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

Answer 1

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