訊息中介軟體與JMS和spring框架的整合使用
阿新 • • 發佈：2018-11-16
整合其實與原生的非常相似,只是將重複的很多步驟都寫在了配置檔案中,將所有能new的都交給了spring進行管理
生產者productor專案
第一步:導包
匯入一個是跟spring框架整合的包, 一個是訊息中介軟體的包,這時候因為有跟spring整合的包,所以spring的所有包都要匯入,我們對pring的版本進行了統一都是使用4.2.4版本
pom.xml 檔案
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>demo</artifactId>
<groupId>cn.itcast.demo</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>springjms_consumer</artifactId>
<properties>
<spring.version>4.2.4.RELEASE</spring.version>
</properties>
<dependencies>
<dependency>
<!--spring-->
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring.version}</version>
</dependency>
<!--訊息中介軟體相關-->
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-all</artifactId>
<version>5.11.2</version>
</dependency>
<!--測試相關-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
</dependencies>
</project>第二步:生產者的spirngxml檔案
解釋:將原生的工廠交給spring與jms結合的工廠,然後建立一個template ,通過template就可以進行所有操作,再造一個目的地就可以了
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
<context:component-scan base-package="cn.itcast.productor"/>
<!--建立工廠例項化物件-->
<bean id="activeMQConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.5.111:61616"/>
</bean>
<!--真正的工廠:spring-jms工廠-->
<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="activeMQConnectionFactory"></property>
</bean>
<!--獲取模板-->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"/>
</bean>
<!--建立佇列的目的地,點對點-->
<bean class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg value="springjms-productor-queue-demo"/>
</bean>
<!--建立廣播的目的地distination,點對面-->
<bean class="org.apache.activemq.command.ActiveMQTopic">
<constructor-arg value="springjms-productor-topic-demo"/>
</bean>
</beans>第三步: 傳送中介軟體訊息方法
package cn.itcast.productor;
import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Component;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;
@Component
public class QueueProductor {
//注入模板
@Autowired
private JmsTemplate jmsTemplate;
//注入目的地
@Autowired
private ActiveMQQueue activeMQQueue;
//傳送訊息
public void sendTextMessage(final String text){
jmsTemplate.send(activeMQQueue, new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
return session.createTextMessage(text);
}
});
}
}第四步:測試傳送
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext-jms-producer.xml")
public class quequeAndTopicTest {
@Autowired
private QueueProductor queueProductor;
@Autowired
private TopicProductor topicProductor;
//queuqe型別生產者測試
@Test
public void queueProductorTest() throws IOException {
queueProductor.sendTextMessage("我是生產者:springjms_productor下面的queue生產者.");
}
消費者consumer專案
第一步:導包,與生產者一樣,srpring包,中介軟體包,結合包
第二步:書寫配置檔案,與生產者非常相似
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
<!--掃描包,將自身交給spring容器進行管理-->
<!--<context:component-scan base-package="cn.itcast.demo"/>-->
<!--例項化工廠類-->
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.5.111:61616"/>
</bean>
<!--真正的工廠類,spring-jms結合起來的,將上面的工廠類作為一個屬性-->
<bean id="SingleconnectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="connectionFactory"/>
</bean>
<!--例項化佇列,目的地-->
<bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg value="springjms-productor-queue-demo"/>
</bean>
<!--監聽類:監聽包下的quequeConsumer-->
<bean id="myMessageListern" class="cn.itcast.demo.QueueConsumer"></bean>
<!--訊息監聽容器-->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="SingleconnectionFactory"/>
<property name="destination" ref="destination"/>
<property name="messageListener" ref="myMessageListern"/>
</bean>
<!--下面是topic相關的========================================-->
<!--這個是主題目的地，釋出訂閱的 文字資訊-->
<bean id="topicdestination" class="org.apache.activemq.command.ActiveMQTopic">
<constructor-arg value="springjms-productor-topic-demo"/>
</bean>
<!-- 我的監聽類 -->
<bean id="topicConsumer" class="cn.itcast.demo.TopicConsumer"></bean>
<!-- 訊息監聽容器 -->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<!--連線工廠-->
<property name="connectionFactory" ref="SingleconnectionFactory"/>
<!--訊息消費的目的地-->
<property name="destination" ref="topicdestination"/>
<!--訊息的監聽類-->
<property name="messageListener" ref="topicConsumer"/>
</bean>
</beans>
第三步: 接收訊息
package cn.itcast.demo;
import org.springframework.stereotype.Component;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
@Component
public class QueueConsumer implements MessageListener {
public void onMessage(Message message) {
//獲取訊息
TextMessage textMessage= (TextMessage) message;
try {
System.out.println("消費者接收到的消失是:"+textMessage.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
}
第四步: 測試:想辦法讓消費者一直活著接收訊息
System.in.read(); 一直等待鍵盤錄入讀取,保證消費者一直生存
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext_jms_consumer-queue.xml")
public class test {
@Test
public void queueConsumerTest(){
try {
System.in.read();
} catch (IOException e) {
e.printStackTrace();
}
}
}