java實現訊息佇列的兩種方式
阿新 • • 發佈:2019-01-10
實現訊息佇列的兩種方式
Apache ActiveMQ官方例項傳送訊息
直接在Apache官網http://activemq.apache.org/download-archives.html下載ActiveMQ原始碼
下載解壓後拿到java程式碼例項
然後倒入IDE
如下:
請認真閱讀readme.md檔案,大致意思就是把專案打成兩個jar包,然後啟動服務,然後同時執行打的兩個jar包,然後就能看到具體的呼叫資訊。打jar包時直接利用maven打就行了,不用修改程式碼。
啟動服務:
利用Spring訊息模板傳送訊息
Spirng對Apache ActiveMQ提供了很好的支援
生成者程式碼:
package com.jms.service.impl;
import com.jms.service.ProducerService;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import javax.jms.Destination;
/**
* 傳送訊息
*/
@Service
public class ProducerServiceImpl implements ProducerService {
@Resource
private JmsTemplate jmsTemplate;
public void sendMessage(Destination destination, String msg) {
System.out.println("向佇列"+destination+"傳送訊息");
jmsTemplate.convertAndSend(destination,msg);
}
public void sendMessage(String msg) {
System.out.println("向佇列" +jmsTemplate.getDefaultDestination().toString()+"傳送訊息");
jmsTemplate.convertAndSend(msg);
}
}
消費者程式碼:
package com.jms.service.impl;
import com.jms.service.CustomerService;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.TextMessage;
@Service
public class CustomerServiceImpl implements CustomerService {
@Resource
private JmsTemplate jmsTemplate;
/**
* 接收訊息
* @param destination
*/
public void receive(Destination destination) {
TextMessage textMessage = (TextMessage) jmsTemplate.receive(destination);
try {
System.out.println("從佇列》"+destination.toString()+"成功獲取訊息》"+textMessage.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
}
Spring配置程式碼
<?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"
xmlns:mvc="http://www.springframework.org/schema/mvc"
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
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc.xsd
">
<!-- 啟動包掃描功能,以便註冊帶有@Controller、@Service、@repository、@Component等註解的類成為spring的bean -->
<context:component-scan base-package="com.jms.service"> </context:component-scan>
<!-- 配置根檢視 -->
<!--<mvc:view-controller path="/" view-name="index"/>-->
<!--啟用註解-->
<mvc:annotation-driven />
<!-- 檢視層配置 -->
<!--<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">-->
<!--<property name="prefix" value="/WEB-INF/view/"/>-->
<!--<property name="suffix" value=".jsp"/>-->
<!--</bean>-->
<!-- 配置JMS連線工廠 -->
<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616" />
</bean>
<!-- 定義訊息佇列(Queue) -->
<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
<!-- 設定訊息佇列的名字 -->
<constructor-arg>
<value>queue1</value>
</constructor-arg>
</bean>
<!-- 配置JMS模板(Queue),Spring提供的JMS工具類,它傳送、接收訊息。 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory" />
<property name="defaultDestination" ref="queueDestination" />
<property name="receiveTimeout" value="10000" />
</bean>
</beans>
測試程式碼
package com.jsm.test;
import com.jms.service.CustomerService;
import com.jms.service.ProducerService;
import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import javax.jms.Destination;
/**
* 訊息佇列測試類
*/
public class JmsTest {
@Test
public void producerTest(){
ClassPathXmlApplicationContext springContext = new ClassPathXmlApplicationContext(new String[]{"classpath:spring-core.xml"});
ProducerService producerService = (ProducerService)springContext.getBean("producerServiceImpl");
CustomerService customerService = (CustomerService)springContext.getBean("customerServiceImpl");
Destination destination = (Destination)springContext.getBean("queueDestination");
producerService.sendMessage("測試訊息佇列");
customerService.receive(destination);
}
}
測試結果