java activeMQ消息的發送與接收
activemq是我們經常用到的消息隊列之一，比如說速度快，對spring的很好的支持，支持多種協議等等，今天我們就來看一下activeMQ消息的發送與接收的源代碼。
我這里使用了兩個配置文件，其實在一個配置文件里面就可以完成發送與接收功能，但是為了方便觀察日志，我就使用了兩個配置文件。在使用代碼之前需要搭建好activeMQ消息隊列環境。
一、代碼目錄結構
所建立的工程是maven工程，代碼結構如圖所示：
一、maven配置pom.xml
4.0.0
Test
Test
0.0.1-SNAPSHOT
<dependencies><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.16</version></dependency><dependency><groupId>org.json</groupId><artifactId>org.json</artifactId><version>chargebee-1.0</version>
</dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version><scope>test</scope></dependency><dependency><groupId>com.cloudhopper.proxool</groupId><artifactId>proxool</artifactId><version>0.9.1</version><exclusions><exclusion><artifactId>log4j</artifactId><groupId>log4j</groupId></exclusion></exclusions></dependency><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.11.0</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jms</artifactId><version>4.1.4.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>4.1.4.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-core</artifactId><version>4.1.4.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-beans</artifactId><version>4.1.4.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>4.1.4.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context-support</artifactId><version>4.1.4.RELEASE</version></dependency><dependency><groupId>org.apache.cxf</groupId><artifactId>cxf-rt-frontend-jaxws</artifactId><version>2.7.3</version></dependency><dependency><groupId>org.apache.cxf</groupId><artifactId>cxf-rt-transports-http</artifactId><version>2.7.3</version></dependency><dependency><groupId>org.apache.cxf</groupId><artifactId>cxf-rt-transports-http-jetty</artifactId><version>2.4.5</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><version>1.7.5</version></dependency><dependency><groupId>com.h2database</groupId><artifactId>h2</artifactId><version>1.3.152</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId><version>4.1.1</version></dependency><dependency><groupId>dom4j</groupId><artifactId>dom4j</artifactId><version>1.6.1</version></dependency><dependency><groupId>commons-dbutils</groupId><artifactId>commons-dbutils</artifactId><version>1.3</version></dependency><dependency><groupId>org.freemarker</groupId><artifactId>freemarker</artifactId><version>2.3.16</version></dependency><dependency><groupId>jaxen</groupId><artifactId>jaxen</artifactId><version>1.1.1</version></dependency><dependency><groupId>net.sourceforge.saxon</groupId><artifactId>saxon</artifactId><version>9.1.0.8</version></dependency><dependency><groupId>net.sourceforge.saxon</groupId><artifactId>saxon</artifactId><version>9.1.0.8</version><classifier>xqj</classifier></dependency><dependency><groupId>net.sourceforge.saxon</groupId><artifactId>saxon</artifactId><version>9.1.0.8</version><classifier>xpath</classifier></dependency><dependency><groupId>net.sourceforge.saxon</groupId><artifactId>saxon</artifactId><version>9.1.0.8</version><classifier>xom</classifier></dependency><dependency><groupId>net.sourceforge.saxon</groupId><artifactId>saxon</artifactId><version>9.1.0.8</version><classifier>sql</classifier></dependency><dependency><groupId>net.sourceforge.saxon</groupId><artifactId>saxon</artifactId><version>9.1.0.8</version><classifier>s9api</classifier></dependency><dependency><groupId>net.sourceforge.saxon</groupId><artifactId>saxon</artifactId><version>9.1.0.8</version><classifier>jdom</classifier></dependency><dependency><groupId>net.sourceforge.saxon</groupId><artifactId>saxon</artifactId><version>9.1.0.8</version><classifier>dom4j</classifier></dependency><dependency><groupId>net.sourceforge.saxon</groupId><artifactId>saxon</artifactId><version>9.1.0.8</version><classifier>dom</classifier></dependency><dependency><groupId>xom</groupId><artifactId>xom</artifactId><version>1.1</version></dependency><dependency><groupId>stax</groupId><artifactId>stax</artifactId><version>1.2.0</version></dependency><dependency><groupId>org.drools</groupId><artifactId>drools-core</artifactId><version>5.3.0.Final</version></dependency><dependency><groupId>org.drools</groupId><artifactId>drools-compiler</artifactId><version>5.3.0.Final</version></dependency><dependency><groupId>commons-io</groupId><artifactId>commons-io</artifactId><version>2.2</version></dependency><dependency><groupId>javax.xml.bind</groupId><artifactId>jsr173_api</artifactId><version>1.0</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-test</artifactId><version>4.1.4.RELEASE</version></dependency><dependency><groupId>corba</groupId><artifactId>corba-connect</artifactId><version>0.0.2</version></dependency><dependency><groupId>com.ustcinfo.inm.data</groupId><artifactId>inm-data-spi</artifactId><version>0.0.1-SNAPSHOT</version></dependency><dependency><groupId>com.taobao.metamorphosis</groupId><artifactId>metamorphosis-client</artifactId><version>1.4.4</version></dependency><dependency><groupId>com.googlecode.aviator</groupId><artifactId>aviator</artifactId><version>2.2.1</version></dependency><dependency><groupId>com.jcraft</groupId><artifactId>jsch</artifactId><version>0.1.50</version></dependency>
</dependencies>
<build><sourceDirectory>src</sourceDirectory><plugins><plugin><artifactId>maven-compiler-plugin</artifactId><version>3.3</version><configuration><source>1.8</source><target>1.8</target></configuration></plugin></plugins>
</build>
————————————————
二、LoadUtil.java加載類
package aaa.activemq.load;
import javax.jms.Destination;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
/**
- 加載配置文件工具類
- @author Administrator
*/
public class LoadUtil {
ApplicationContext applicationContext;
JmsTemplate template;//jsm對象，可以發送和消費消息
Destination destination;//隊列名稱/*** 加載方法* @param path 文件路徑名稱*/
public void load(String path){applicationContext = new ClassPathXmlApplicationContext(path);template = (JmsTemplate) applicationContext.getBean("jmsTemplate");destination = (Destination) applicationContext.getBean("queueDestination");this.setApplicationContext(applicationContext);this.setDestination(destination);this.setDestination(destination);
}public ApplicationContext getApplicationContext() {return applicationContext;
}public void setApplicationContext(ApplicationContext applicationContext) {this.applicationContext = applicationContext;
}public JmsTemplate getTemplate() {return template;
}public void setTemplate(JmsTemplate template) {this.template = template;
}public Destination getDestination() {return destination;
}public void setDestination(Destination destination) {this.destination = destination;
}
}
三、QueueProducer.java發送消息到activeMQ類
package aaa.avtivemq.sendmessage;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import aaa.activemq.load.LoadUtil;
public class QueueProducer{
/**
* 發送消息到activemq的實現方法
* @param msg //發送消息的內容，為字符串類型
*/
public void sendMessage(String msg) {
LoadUtil lu = new LoadUtil();
lu.load(“activemq-config.xml”);
JmsTemplate template = lu.getTemplate();
String destination = template.getDefaultDestination().toString();
System.out.println(“向隊列” + destination + “發送了消息:” + msg);
template.send(new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage(msg);
}
});
}
/*** 主方法* @param args*/
public static void main(String[] args) {QueueProducer producer = new QueueProducer();producer.sendMessage("zcinfo_test");
}
}
四、activemq-config.xml配置文件
?xml version=“1.0” encoding=“UTF-8”?>
<!--配置連接工廠地址-->
<bean id="activeMQConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.0.81.80:8765"></property><!-- <property name="brokerURL" value="failover:(tcp://tcp://192.0.81.83:8765,tcp://tcp://192.0.81.84:8765,tcp://tcp://192.0.81.85:8765)"></property> -->
</bean>
<!--配置隊列名稱 -->
<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue"><constructor-arg><value>UEAP_TO_GZZC_QUEUE_TEST</value></constructor-arg>
</bean>
<!-- 配置JMS模版，這是spring提供的 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"><property name="connectionFactory" ref="activeMQConnectionFactory"></property><property name="defaultDestination" ref="queueDestination"></property><property name="receiveTimeout" value="10000"></property>
</bean>
五、ActivemqConsumer.java消費類 package www.activemq.receivemessage;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import www.activemq.load.LoadUtil;
public class ActivemqConsumer implements MessageListener{
@Override
public void onMessage(Message message) {TextMessage tm = (TextMessage)message;System.out.println("監聽到MQ中有數據......");try {System.out.println("獲取MQ中數據信息>>>>>>>>>>" + tm.getText());}catch (Exception e) {e.printStackTrace();}
}/*** 加載配置文件之后監聽器會自動調用onMessage方法，并且保持服務一直開啟很實用* @param args*/
public static void main(String[] args) {new LoadUtil().load("activemq-context.xml");
}
}
六、activemq-context.xml配置文件
<?xml version="1.0" encoding="UTF-8"?>
<context:component-scan base-package="com.starit.analyse" /><!-- Spring提供的JMS工具類，它可以進行消息發送、接收等 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"><!-- 這個connectionFactory對應的是我們定義的Spring提供的那個ConnectionFactory對象 --><property name="connectionFactory" ref="connectionFactory"/>
</bean><!-- 真正可以產生Connection的ConnectionFactory，由對應的 JMS服務廠商提供-->
<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"><!-- <property name="brokerURL" value="failover:(tcp://192.0.81.83:8765:8400,tcp://192.0.81.84:8765,tcp://192.0.81.85:8765)"/> --><property name="brokerURL" value="failover:(tcp://192.0.81.80:8765)?jms.prefetchPolicy.all=1"/>
</bean><!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->
<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"><!-- 目標ConnectionFactory對應真實的可以產生JMS Connection的ConnectionFactory --><property name="targetConnectionFactory" ref="targetConnectionFactory"/>
</bean><!--這個是隊列目的地-->
<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue"><constructor-arg><value>UEAP_TO_GZZC_QUEUE_TEST</value></constructor-arg>
</bean><!-- 消息監聽器 加載此處會自動調用監聽方法并且一直保持服務開啟，很實用 -->
<bean id="consumerMessageListener" class="www.activemq.receivemessage.ActivemqConsumer"/>
<!-- 消息監聽容器 -->
<bean id="jmsContainer"class="org.springframework.jms.listener.DefaultMessageListenerContainer"><property name="connectionFactory" ref="connectionFactory" /><property name="destination" ref="queueDestination" /><property name="messageListener" ref="consumerMessageListener" /><property name="concurrentConsumers" value="1"/>
</bean>
七、測試結果 （1）發送消息
（2）activemq顯示收到消息
（3）接收消息，服務一直開啟接收發送者消息
總結
以上是生活随笔為你收集整理的java activeMQ消息的发送与接收的全部內容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。
