embedded ActiveMQ Broker，在别的项目中无法连接到broker。

0 0

embedded ActiveMQ Broker，在别的项目中无法连接到broker。30

我使用嵌入式启动ActiveMQ Broker的方式启动Broker，服务端的配置文件如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:amq="http://activemq.apache.org/schema/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd 
  http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

	<!-- embedded ActiveMQ Broker -->
	<amq:broker useJmx="true" persistent="true" brokerId="myBroker" brokerName="myBroker" start="true">
		<amq:persistenceAdapter>   
		    <amq:amqPersistenceAdapter directory="f:/amq"/> 
		</amq:persistenceAdapter>
		<amq:transportConnectors>
		    <amq:transportConnector uri="tcp://192.168.0.239:61616"/>
		</amq:transportConnectors>
		<amq:managementContext>
            <amq:managementContext connectorPort="2011" jmxDomainName="my-broker" connectorPath="/jmxrmi"/>
        </amq:managementContext>
	</amq:broker>

	<!-- ActiveMQ connectionFactory -->
	<amq:connectionFactory id="jmsConnectionFactory" brokerURL="tcp://192.168.0.239:61616"/>

	<!-- ActiveMQ destinations 使用Queue方式 -->
	<amq:queue name="destination" physicalName="JMS-TEST-QUEUE" />
	<!-- 使用topic方式 -->
	<!-- <amq:topic name="TOPIC" physicalName="JMS-TEST-TOPIC" /> -->

	<!--  Spring JmsTemplate config -->
	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory">
			<!--  lets wrap in a pool to avoid creating a connection per send -->
			<bean class="org.springframework.jms.connection.SingleConnectionFactory">
				<property name="targetConnectionFactory" ref="jmsConnectionFactory" />
			</bean>
		</property>
		<!-- custom MessageConverter -->
		<property name="messageConverter" ref="defaultMessageConverter" />
	</bean>
	
	<!-- converter  -->
	<bean id="defaultMessageConverter" class="com.pde.pdp.jms.service.DefaultMessageConverter" />
	
	<bean id="queueMessageProducer" class="com.pde.pdp.jms.service.QueueMessageProducer">
		<property name="template" ref="jmsTemplate" />
		<property name="destination" ref="destination" />
	</bean>
</beans>

另一台机器上运行的客户端的配置文件如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:amq="http://activemq.apache.org/schema/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd 
  http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

	<!-- ActiveMQ connectionFactory -->
	<!-- tcp://192.168.0.239:61616 -->
	<amq:connectionFactory id="jmsConnectionFactory" brokerURL="tcp://192.168.0.239:61616" />
	
	<!-- ActiveMQ destinations 使用Queue方式 -->
	<amq:queue name="destination" physicalName="JMS-TEST-QUEUE"/>
	<!-- 使用topic方式 -->
	<!-- <amq:topic name="TOPIC" physicalName="JMS-TEST-TOPIC" /> -->

	<!--  Spring JmsTemplate config -->
	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<property name="connectionFactory">
			<!--  lets wrap in a pool to avoid creating a connection per send -->
			<bean class="org.springframework.jms.connection.SingleConnectionFactory">
				<property name="targetConnectionFactory" ref="jmsConnectionFactory" />
			</bean>
		</property>
		<!-- custom MessageConverter -->
		<property name="messageConverter" ref="defaultMessageConverter" />
	</bean>
	
	<!-- converter  -->
	<bean id="defaultMessageConverter" class="com.activeMQ.service.DefaultMessageConverter" />
	
	<!-- consumer for queue -->
    <bean id="queueConsumer" class="com.activeMQ.service.QueueConsumer" />
	
    <bean id="queueListener" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
		<constructor-arg ref="queueConsumer" />
		<!--  may be other method -->
		<property name="defaultListenerMethod" value="receive" />
		<!-- custom MessageConverter define -->
		<property name="messageConverter" ref="defaultMessageConverter" />
	</bean>
	
	<bean id="someHandler" class="com.activeMQ.service.SomeHandler" />
	
	<bean id="queueListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
		<!-- <property name="pubSubNoLocal" value="true" />
		<property name="pubSubDomain" value="false" /> -->
		<property name="errorHandler" ref="someHandler"/>
		<property name="connectionFactory" ref="jmsConnectionFactory" />
		<property name="destination" ref="destination" />
		<property name="messageListener" ref="queueListener" />
		<property name="concurrentConsumers" value="1" /> <!-- 控制同时启几个监听的线程,这里设置几个咋控制台那边就可以监控到有几个消费者 -->
	</bean>
	
</beans>

现在客户端那边报错，说无法创建连接 Could not connect to broker URL : tcp://192.168.0.239:61616 ,但是我用jmx监控的时候，看到的所有消息都是已经被消费掉了。我该怎么解决这个错误？

问题补充：客户端那边无法创建连接这个错误已经解决了，是因为我的客户端先启动了的问题。但是我用来接收消息的QueueConsumer类中的receive()方法接收不到消息，不知道是什么原因。我发送的消息是自定义的实体，可序列化。

问题补充：问题已解决，是我的DefaultMessageConverter代码写错了。