如何在Tomcat中的多个Spring Boot应用程序之间传递Camel VM消息

Question

当我启动应用程序堆栈时，有三个spring boot应用程序使用了camel，我在日志中看到camel正确启动。但是，当其中一个应用程序向vmendpoint发送消息时，从该endpoint使用并将消息路由到jms主题的路由似乎不会获得该消息。我已经将camel-corejar放在tomcat lib目录中。在spring boot maven插件配置中，我指定了camel-core jar的排除。奇怪的是，这个jar是在战争的WEB-INF/lib中！因此，我已经停止了Tomcat，从爆发的战争中删除了那个jar，并重新启动了Tomcat，但这并没有改变消息传递的行为。

以下是我们正在使用的版本：

• Spring Boot 2.3.1
• 骆驼3.4.2
• Tomcat 8.5.5

from("vm:task")
    .log(LoggingLevel.WARN, "********** Received task message");
    .to("jms:topic:local.private.task")
    .routeId("taskToJms");

o.a.c.impl.engine.DefaultProducerCache (169) - >>>> vm://task Exchange[]

Answer 1

我会贴出答案，或者至少是“一个”答案，给任何可能发现自己处于我发现自己所处的令人困惑的境地的人。

简而言之，答案是最好避免尝试在一个大的JVM（如Tomcat）中跨不同的上下文发送VM消息。相反，使用JMS之类的东西。我使用了Artemis，并在Tomcat的一个spring boot应用程序中设置了一个嵌入式代理。在其他应用程序（即客户端）中，我需要连接到嵌入式artemis服务器，这要求您添加一个@configuration类（在支持嵌入式代理的模块中），该类实现ArtemisConfigurationCustomizer:

@Configuration
public class ArtemisConfig implements ArtemisConfigurationCustomizer {
    @Override
    public void customize(final org.apache.activemq.artemis.core.config.Configuration configuration) {
        configuration.addConnectorConfiguration("nettyConnector", new TransportConnfiguration(NettyConnectorFactory.class.getName()));
        configuration.addAcceptorConfigurathtml" target="_blank">ion(new TransportConfiguration(NettyAcceptorFactory.class.getName()));
    }
}

这样，您的其他东西就可以连接到嵌入的Artemis代理。此外，当您将camel升级到其他版本时，您不必担心在tomcat共享的lib文件夹中升级camel核心JAR。为了维护目的，保持事情简单是很好的！