学步园

1.使用的是maven的结构，导入activeMQ的包

<dependency><br /> <groupId>org.apache.activemq</groupId><br /> <artifactId>activemq-core</artifactId><br /> <version>5.5.0</version><br /> </dependency> 

2.创建“生产者”

①xml配置文件

<!-- 创建工厂连接 --><br /> <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"><br /> <property name="brokerURL" value="tcp://localhost:61616" /><br /> </bean></p> <p> <!-- activeMQ消息目标 队列 --><br /> <bean id="rantzDestination" class="org.apache.activemq.command.ActiveMQQueue"><br /> <constructor-arg index="0" value="rantz.marketing.queue"></constructor-arg><br /> </bean></p> <p> <!-- activeMQ消息目标 主题--><br /> <!-- <bean id="rantzDestination" class="org.apache.activemq.command.ActiveMQTopic">--><br /> <!-- <constructor-arg index="0" value="rantz.marketing.queue"></constructor-arg>--><br /> <!-- </bean>--><br /> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"><br /> <property name="connectionFactory" ref="connectionFactory" /><br /> </bean></p> <p> <bean id="marketingGateway" class="com.jms.service.RantzMarketingGatewayImpl"><br /> <property name="jmsTemplate" ref="jmsTemplate" /><br /> <property name="destination" ref="rantzDestination" /><br /> </bean><br />  

②java代码

主类SpringMain

public static void main(String[] args) {<br /> /*开始加载spring配置文件*/<br /> ApplicationContext context = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");<br /> IRantzMarketingGateway rantzMarketingGateway= (RantzMarketingGatewayImpl) context.getBean("marketingGateway");<br /> rantzMarketingGateway.sendMotoristInfo();<br /> System.out.println("Start ...");<br /> }

消息发送类RantzMarketingGatewayImpl

import javax.jms.Destination;<br /> import javax.jms.JMSException;<br /> import javax.jms.Message;<br /> import javax.jms.Session;<br /> import org.springframework.jms.core.JmsTemplate;<br /> import org.springframework.jms.core.MessageCreator;<br /> public class RantzMarketingGatewayImpl implements IRantzMarketingGateway {</p> <p> private JmsTemplate jmsTemplate;<br /> private Destination destination;</p> <p> public JmsTemplate getJmsTemplate() {<br /> return jmsTemplate;<br /> }<br /> public void setJmsTemplate(JmsTemplate jmsTemplate) {<br /> this.jmsTemplate = jmsTemplate;<br /> }<br /> public Destination getDestination() {<br /> return destination;<br /> }<br /> public void setDestination(Destination destination) {<br /> this.destination = destination;<br /> }</p> <p> public void sendMotoristInfo(){<br /> jmsTemplate.send(<br /> destination,<br /> new MessageCreator(){<br /> public Message createMessage(Session session) throws JMSException {<br /> return session.createTextMessage("这是一个测试");<br /> }<br /> }<br /> );<br /> }<br /> } 

3.创建“消费者”

①xml配置文件

<!-- 创建工厂连接 --><br /> <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"><br /> <property name="brokerURL" value="tcp://localhost:61616" /><br /> </bean></p> <p> <!-- activeMQ消息目标 队列 --><br /> <bean id="rantzDestination" class="org.apache.activemq.command.ActiveMQQueue"><br /> <constructor-arg index="0" value="rantz.marketing.queue"></constructor-arg><br /> </bean></p> <p> <!-- activeMQ消息目标 主题--><br /> <!-- <bean id="rantzDestination" class="org.apache.activemq.command.ActiveMQTopic">--><br /> <!-- <constructor-arg index="0" value="rantz.marketing.queue"></constructor-arg>--><br /> <!-- </bean>--><br /> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"><br /> <property name="connectionFactory" ref="connectionFactory" /><br /> <property name="defaultDestination" ref="rantzDestination" /><br /> </bean></p> <p> <bean id="marketingGateway" class="com.huateng.jms.service.MarketingReceiverGatewayImpl"><br /> <property name="jmsTemplate" ref="jmsTemplate" /><br /> </bean>

②java代码

主类SpringMain

public static void main(String[] args) {<br /> /*开始加载spring配置文件*/<br /> ApplicationContext context = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");<br /> MarketingReceiverGatewayImpl rantzMarketingGateway= (MarketingReceiverGatewayImpl) context.getBean("marketingGateway");<br /> System.out.println("Receive Start ...");<br /> try {<br /> rantzMarketingGateway.receiveMotorist();<br /> } catch (Exception e) {<br /> e.printStackTrace();<br /> }<br /> }

消息发送类MarketingReceiverGatewayImpl

import javax.jms.TextMessage;<br /> import org.springframework.jms.core.JmsTemplate;<br /> public class MarketingReceiverGatewayImpl {</p> <p> private JmsTemplate jmsTemplate;</p> <p> public JmsTemplate getJmsTemplate() {<br /> return jmsTemplate;<br /> }<br /> public void setJmsTemplate(JmsTemplate jmsTemplate) {<br /> this.jmsTemplate = jmsTemplate;<br /> }</p> <p> public MarketingReceiverGatewayImpl() {<br /> }</p> <p> public void receiveMotorist() throws Exception{<br /> TextMessage message = (TextMessage)jmsTemplate.receive();<br /> System.out.println("reviced msg is:" + message.getText());<br /> }</p> <p>}

4.启动activeQM

在下载的activeQM包中的bin目录中，可以找到一个用于启动activeMQ的脚本。unix用户使用activemq；windows用户使用activemq.bat

5.先运行"生产者"，再运行"消费者"

6.结果