我有两个服务应该通过ActiveMQ相互通信。当我将接收者和发送者放在一个服务中时,一切工作都很好,但是当我将它们分开时,我得到了一个奇怪的activemq异常。
这是服务A的配置:
@EnableScheduling @SpringBootApplication @EnableJms public class App extends SpringBootServletInitializer { private static final Logger log = LoggerFactory.getLogger(App.class); @Autowired private static JmsTemplate jms; public static void main(String[] args) { SpringApplication.run(App.class, args); } }
发送消息:
@Autowired private JmsTemplate jms; public void sendTicket(Reservation reservation) { log.debug("---------------sending message----------------"); // Send a message jms.send("mailbox-destination", new MessageCreator() { public ObjectMessage createMessage(Session session) throws JMSException { ObjectMessage message = session.createObjectMessage(); message.setObject(reservation); return message; } }); }
JMS被配置为内存队列:
spring.activemq.in-memory=true spring.activemq.pooled=false
服务B是类似的,但id并未定义JmsContainerFactory。它只有接收者:
@Component public class Receiver { private static final Logger log = LoggerFactory.getLogger(Receiver.class); /** * Receive a message with reservation and print it out as a e-ticket. * * @param reservation */ @JmsListener(destination = "mailbox-destination") public void receiveMessage(Reservation reservation) { log.info("Received <" + reservation.getId() + ">"); } }
服务A具有JMS和ActiveMQ代理作为maven依赖项:
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> </dependency> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-broker</artifactId> </dependency>
服务B仅具有JMS依赖性。
您能否给我一个提示,如何在两个服务之间共享bean并在它们之间发送消息?我是这个话题的新手。
收到消息时出现以下异常
org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Could not create Transport. Reason: javax.management.InstanceAlreadyExistsException: org.apache.activemq:type=Broker,brokerName=localhost
编辑:如果我从服务之一中删除代理依赖项,则Tomcat甚至无法启动:
java.util.concurrent.ExecutionException: org.apache.catalina.LifecycleException: Failed to start component [StandardEngine[Catalina].StandardHost[localhost]] at java.util.concurrent.FutureTask.report(FutureTask.java:122) at java.util.concurrent.FutureTask.get(FutureTask.java:192) at org.apache.catalina.core.ContainerBase.startInternal(ContainerBase.java:917) at org.apache.catalina.core.StandardEngine.startInternal(StandardEngine.java:262) at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150) at org.apache.catalina.core.StandardService.startInternal(StandardService.java:439) at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150) at org.apache.catalina.core.StandardServer.startInternal(StandardServer.java:769) at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150) at org.apache.catalina.startup.Catalina.start(Catalina.java:625) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:497) at org.apache.catalina.startup.Bootstrap.start(Bootstrap.java:351) at org.apache.catalina.startup.Bootstrap.main(Bootstrap.java:485) Caused by: org.apache.catalina.LifecycleException: Failed to start component [StandardEngine[Catalina].StandardHost[localhost]] at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:154) at org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1409) at org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1399) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: org.apache.catalina.LifecycleException: A child container failed during start at org.apache.catalina.core.ContainerBase.startInternal(ContainerBase.java:925) at org.apache.catalina.core.StandardHost.startInternal(StandardHost.java:871) at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150) ... 6 common frames omitted
过去,JMS服务器是独立部署的独立应用程序,使用者以及消息的侦听器都与此服务器进行通信。因此,JMS方程中通常有三个单独的应用程序。
现在,Spring Boot允许将Active MQ JMS代理(JMS服务器)嵌入到Spring Boot应用程序中。但是,如果您分别使用自己的嵌入式JMS代理配置Spring Boot服务,则这两个JMS代理是完全独立的,彼此之间并不了解,也没有任何连接。
如果要在生产中使用JMS,避免使用Spring Boot嵌入式JMS代理并将其单独托管会更明智。 因此,对于PROD,首选3节点设置。
编辑 :
我怀疑以前使用共享嵌入式JMS代理的方式时错了。查看Spring Docs,ActiveMQ似乎无法实现:
spring.activemq.broker-url =#ActiveMQ代理的URL。默认情况下自动生成。例如tcp://localhost:61616 spring.activemq.in-memory = true#指定默认代理URL是否应在内存中。忽略是否已指定显式代理。
spring.activemq.broker-url =#ActiveMQ代理的URL。默认情况下自动生成。例如tcp://localhost:61616
tcp://localhost:61616
spring.activemq.in-memory = true#指定默认代理URL是否应在内存中。忽略是否已指定显式代理。
在处理这些Spring Enterprise示例时,我曾在HornetQ上进行过尝试,但现在找不到这样的配置。所以我敢打赌,我遇到了问题,最终使用了单独的第三个节点。
如果您想进一步尝试 ,我会
spring.hornetq.mode=embedded
spring.hornetq.port=5445
但是正如我提到的,我之前没有做过这个,也不知道是否可行。 在Spring Boot docs中没有找到显式消息,这种组合不起作用。
我怀疑嵌入式Spring Boot JMS代理背后的想法是仅允许本地内存集成测试,而不是将嵌入式JMS代理暴露给外界。