實現消息隊列的兩種方式
apache activemq官方實例發送消息
直接在apache官網http://activemq.apache.org/download-archives.html下載ActiveMQ源碼
下載解壓后拿到java代碼實例
然后倒入ide
如下：
請認真閱讀readme.md文件，大致意思就是把項目打成兩個jar包，然后啟動服務，然后同時運行打的兩個jar包，然后就能看到具體的調用信息。打jar包時直接利用maven打就行了，不用修改代碼。
啟動服務：
利用spring消息模板發送消息
spirng對apache activemq提供了很好的支持
生成者代碼：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
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;/** * 發送消息 */@servicepublic 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); }} |
消費者代碼：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
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;@servicepublic 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配置代碼
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
|
<?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> |
測試代碼
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
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); }} |
測試結果
代碼地址
https://github.com/wahnn/springjms
https://gitee.com/wahnn/springjms
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持服務器之家。
原文鏈接：https://blog.csdn.net/fenfenguai/article/details/79257928
