Comment configurer intégré ActiveMQ URL de Courtier avec Spring Boot
J'ai suivi un exemple simple de mise en place et en cours d'exécution incorporé ActiveMQ avec le Printemps de Démarrage (version 1.4.X). Voici le lien pour l'exemple https://spring.io/guides/gs/messaging-jms/
Ma classe est structuré comme ci-dessous:
@SpringBootApplication
@EnableJms
public class Application {
@Autowired
ConfigurableApplicationContext context;
@Bean
JmsListenerContainerFactory<?> myJmsContainerFactory(ConnectionFactory connectionFactory) {
SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
return factory;
}
@JmsListener(destination = "mailbox-destination", containerFactory = "myJmsContainerFactory")
public void receiveMessage(String message) {
System.out.println("Message received: " + message);
context.close();
}
public static void main(String[] args) throws Exception {
FileSystemUtils.deleteRecursively(new File("active-data"));
ConfigurableApplicationContext context = SpringApplication.run(Application.class, args);
JmsTemplate template = context.getBean(JmsTemplate.class);
MessageCreator messageCreator = new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage("Test");
}
};
template.send("mailbox-destination", messageCreator);
}
}Et de construire.gradle comme ci-dessous:
apply plugin: 'java'
apply plugin: 'maven'
group = 'jms.activemq'
version = '0.0.1-SNAPSHOT'
description = """jms.activemq"""
sourceCompatibility = 1.5
targetCompatibility = 1.5
repositories {
maven { url "http://repo.maven.apache.org/maven2" }
}
dependencies {
compile group: 'org.springframework.boot', name: 'spring-boot-starter-activemq', version:'1.4.0.RELEASE'
testCompile(group: 'org.springframework.boot', name: 'spring-boot-starter-test', version:'1.4.0.RELEASE') {
exclude(module: 'commons-logging')
}
}Tout fonctionne bien pour l'instant (tant que je quitte l'application.propriétés du vide), mais si j'essaie de configurer l'url de courtier (donc à distance les clients peuvent se connecter) par l'ajout suivant l'application.fichier de propriétés:
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=adminJ'obtiens une exception:
2016-08-03 12:46:00.938 WARN 88180 --- [ main] s.c.a.AnnotationConfigApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.context.ApplicationContextException: Failed to start bean 'org.springframework.jms.config.internalJmsListenerEndpointRegistry'; nested exception is org.springframework.jms.UncategorizedJmsException: Uncategorized exception occurred during JMS processing; nested exception is javax.jms.JMSException: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused: connect
2016-08-03 12:46:00.939 INFO 88180 --- [ main] o.s.j.e.a.AnnotationMBeanExporter : Unregistering JMX-exposed beans on shutdown
2016-08-03 12:46:00.945 INFO 88180 --- [ main] utoConfigurationReportLoggingInitializer :
org.springframework.context.ApplicationContextException: Failed to start bean 'org.springframework.jms.config.internalJmsListenerEndpointRegistry'; nested exception is org.springframework.jms.UncategorizedJmsException: Uncategorized exception occurred during JMS processing; nested exception is javax.jms.JMSException: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused: connect
at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:176) ~[spring-context-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:51) ~[spring-context-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:346) ~[spring-context-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:149) ~[spring-context-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:112) ~[spring-context-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:874) ~[spring-context-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:544) ~[spring-context-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:759) [spring-boot-1.4.0.RELEASE.jar:1.4.0.RELEASE]
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:369) [spring-boot-1.4.0.RELEASE.jar:1.4.0.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:313) [spring-boot-1.4.0.RELEASE.jar:1.4.0.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1185) [spring-boot-1.4.0.RELEASE.jar:1.4.0.RELEASE]
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1174) [spring-boot-1.4.0.RELEASE.jar:1.4.0.RELEASE]
at jms.activemq.Application.main(Application.java:37) [main/:na]
Caused by: org.springframework.jms.UncategorizedJmsException: Uncategorized exception occurred during JMS processing; nested exception is javax.jms.JMSException: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused: connect
at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:316) ~[spring-jms-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:169) ~[spring-jms-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.jms.listener.AbstractJmsListeningContainer.start(AbstractJmsListeningContainer.java:273) ~[spring-jms-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.jms.config.JmsListenerEndpointRegistry.startIfNecessary(JmsListenerEndpointRegistry.java:243) ~[spring-jms-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.jms.config.JmsListenerEndpointRegistry.start(JmsListenerEndpointRegistry.java:206) ~[spring-jms-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:173) ~[spring-context-4.3.2.RELEASE.jar:4.3.2.RELEASE]
... 12 common frames omitted
Caused by: javax.jms.JMSException: Could not connect to broker URL: tcp://localhost:61616. Reason: java.net.ConnectException: Connection refused: connect
at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:36) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:373) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:303) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:243) ~[activemq-client-5.13.4.jar:5.13.4]
at org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:180) ~[spring-jms-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.jms.listener.AbstractJmsListeningContainer.createSharedConnection(AbstractJmsListeningContainer.java:413) ~[spring-jms-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.jms.listener.AbstractJmsListeningContainer.establishSharedConnection(AbstractJmsListeningContainer.java:381) ~[spring-jms-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.jms.listener.AbstractJmsListeningContainer.doStart(AbstractJmsListeningContainer.java:285) ~[spring-jms-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.jms.listener.SimpleMessageListenerContainer.doStart(SimpleMessageListenerContainer.java:210) ~[spring-jms-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.jms.listener.AbstractJmsListeningContainer.start(AbstractJmsListeningContainer.java:270) ~[spring-jms-4.3.2.RELEASE.jar:4.3.2.RELEASE]
... 15 common frames omitted
Caused by: java.net.ConnectException: Connection refused: connect
at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method) ~[na:1.8.0_92]
at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85) ~[na:1.8.0_92]
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) ~[na:1.8.0_92]
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[na:1.8.0_92]
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) ~[na:1.8.0_92]
at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172) ~[na:1.8.0_92]
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[na:1.8.0_92]
at java.net.Socket.connect(Socket.java:589) ~[na:1.8.0_92]
at org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:525) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:488) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.transport.AbstractInactivityMonitor.start(AbstractInactivityMonitor.java:168) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.transport.InactivityMonitor.start(InactivityMonitor.java:52) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:58) ~[activemq-client-5.13.4.jar:5.13.4]
at org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:353) ~[activemq-client-5.13.4.jar:5.13.4]
... 23 common frames omitted J'ai regardé quelques liens et pas encore en mesure de déterminer ce qui est à l'origine du problème. Apprécierais vraiment une bonne idée, ou du matériel qui peut vous aider.
Ma première pensée était que le Printemps Démarrage, la lecture de ces valeurs et de les utiliser pour configurer courtier ActiveMQ, mais au lieu dirait qu'il utilise ces valeurs pour se connecter au courtier (broker ayant déjà été configuré avec des paramètres différents). Comment puis-je changer la configuration du broker afin de clients externes (pas en cours d'exécution à partir avec la même JVM que le courtier), vous pouvez accéder au courtier à l'aide de tcp://localhost:61616
Mise à JOUR:
J'ai suivi l'une des façons d'intégrer un courtier répertoriés ici et la possibilité d'intégrer un courtier avec l'url voulue et capable de se connecter à elle. Cependant, il semble que je finis par avoir deux courtiers, car il semble le Printemps de Démarrage va toujours de l'avant et de créer, comme il le faisait avant.
Fondamentalement, je viens d'ajouter ce bout de code et au début de la méthode main avant d'appeler SpringApplication.exécuter(Application.class, args);
BrokerService broker = new BrokerService();
broker.addConnector("tcp://localhost:61617");
broker.setPersistent(false);
broker.start();Ne se sent pas le droit à tout, ayant deux courtier cas(je crois) en cours d'exécution.
1) Est-ce la bonne façon d'incorporer un courtier
2) Si oui, comment puis-je arrêter de Printemps de Démarrage de commencer un autre? (Sans avoir à retirer le printemps-amorçage-starter-activemq de la dépendance).
Merci d'avance.
Ressemble le courtier ActiveMQ n'est pas en cours d'exécution, ou de l'est à l'écoute sur un port différent de celui que vous avez configuré. Veuillez modifier votre message et ajoutez la sortie de
Oui, j'ai vérifié et il n'y a pas de port (Avait utilisé resmon ainsi de surveiller les ports avant). Je suppose que ma question est plus comme, comment puis-je obtenir Printemps de démarrage pour configurer le courtier afin qu'il écoute ce port? J'ai pensé d'ajouter cette information dans l'application.propriétés dites de printemps "c'est l'adresse et le port où je veux configurer mon broker", mais au lieu semble que la raconte ", voici où trouver le courtier". J'ai édité la question d'être un peu plus clair.
ici un exemple complet
netstat -nat|grep LISTEN (sur Windows netstat -nat|findstr LISTEN)Oui, j'ai vérifié et il n'y a pas de port (Avait utilisé resmon ainsi de surveiller les ports avant). Je suppose que ma question est plus comme, comment puis-je obtenir Printemps de démarrage pour configurer le courtier afin qu'il écoute ce port? J'ai pensé d'ajouter cette information dans l'application.propriétés dites de printemps "c'est l'adresse et le port où je veux configurer mon broker", mais au lieu semble que la raconte ", voici où trouver le courtier". J'ai édité la question d'être un peu plus clair.
ici un exemple complet
OriginalL'auteur Aliyu Fonyuy | 2016-08-03
Vous devez vous connecter pour publier un commentaire.
Je crois que j'ai compris cela après avoir joué avec pendant un certain temps. Je pensais que les deux instances étaient en cours d'exécution parce que j'essayais de créer une connexion à la valeur par DÉFAUT intégré courtier (dans une tentative pour voir si il a été créé/existaient) comme ci-dessous:
Mais apparemment Printemps de Démarrage des chiffres de l'un n'existe pas et il crée à cette époque.
De sorte à n'avoir que mon instance créée en cours d'exécution, tout ce que j'avais à faire était de fournir une URL que j'ai ajouté pour le connecteur lorsque j'ai créé l'instance (dans ce cas
tcp://localhost:61616) dans leapplication.propertiesfichier comme ci-dessouset le Printemps de Démarrage va se connecter à cette instance et de ne pas en créer un autre. En l'absence de l'entrée ci-dessus dans le fichier de propriétés (ou si vous faites une tentative de connexion à un intégré à l'instance à l'aide de vm://localhost?... comme je l'ai fait ci-dessus), le Printemps de Démarrage va aller de l'avant et de l'instancier pour vous.
Je n'ai également lu cela dans le la documentation:
Mais à mon avis, c'est pas bien orthographié (mais il ne m'a fait réfléchir dans le bon sens).
S'il vous plaît, faites-le savoir si vous avez eu des résultats différents, ou si ma conclusion n'est pas bonne. Merci!!!
créer un nouveau
application-{profile}.ymlfichier de configuration et de mettre à l'intérieurspring.activemq.broker-url: vm://localhost?broker.persistent=false"tant qu'aucun courtier URL est spécifiée dans la configuration de l'", c'est à dire NE PAS fournir tout le printemps.activemq.courtier url dans votre configuration. Puis le Printemps de Démarrage va faire sa magie.
OriginalL'auteur Aliyu Fonyuy