激情久久久_欧美视频区_成人av免费_不卡视频一二三区_欧美精品在欧美一区二区少妇_欧美一区二区三区的

服務器之家:專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|Java教程|ASP教程|編程技術|正則表達式|C/C++|IOS|C#|Swift|Android|VB|R語言|JavaScript|易語言|vb.net|

服務器之家 - 編程語言 - Java教程 - java實現消息隊列的兩種方式(小結)

java實現消息隊列的兩種方式(小結)

2021-06-21 13:54朽木要自雕 Java教程

本文主要介紹了兩種java實現消息隊列的方式,利用Spring消息模板發送消息和Apache ActiveMQ官方實例發送消息,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧

實現消息隊列的兩種方式

apache activemq官方實例發送消息

直接在apache官網http://activemq.apache.org/download-archives.html下載ActiveMQ源碼 

下載解壓后拿到java代碼實例

java實現消息隊列的兩種方式(小結)

然后倒入ide

如下:

java實現消息隊列的兩種方式(小結)

請認真閱讀readme.md文件,大致意思就是把項目打成兩個jar包,然后啟動服務,然后同時運行打的兩個jar包,然后就能看到具體的調用信息。打jar包時直接利用maven打就行了,不用修改代碼。

啟動服務:

java實現消息隊列的兩種方式(小結)

java實現消息隊列的兩種方式(小結)

利用spring消息模板發送消息

spirng對apache activemq提供了很好的支持

java實現消息隊列的兩種方式(小結)

生成者代碼:

?
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;
 
/**
 * 發送消息
 */
@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);
 }
}

消費者代碼:

?
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;
 
@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配置代碼

?
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);
 }
}

測試結果

java實現消息隊列的兩種方式(小結)

代碼地址

https://github.com/wahnn/springjms
https://gitee.com/wahnn/springjms

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持服務器之家。

原文鏈接:https://blog.csdn.net/fenfenguai/article/details/79257928

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板: 欧美一级美国一级 | 色综合精品 | 免费在线观看国产 | 欧美一a一片一级一片 | 黄色7777 | 黄色片网站免费在线观看 | 99www| 精品国产一区二区三区久久久 | 久久91亚洲精品久久91综合 | 国产精品久久av | 成人午夜免费福利 | 欧美亚洲啪啪 | 欧美日韩精品中文字幕 | 97超碰资源站 | 日韩在线激情 | 72pao成人国产永久免费视频 | 狠狠撸电影| 日韩黄在线观看 | 中文在线观看视频 | 热99在线视频 | 性生大片免费观看一片黄动漫 | 法国性xxx精品hd专区 | 日本xxxx色视频在线观看免费, | 夜班护士在线观看 | 91av在线免费播放 | 久久精品首页 | 亚洲情在线 | 成人毛片在线免费看 | 狠狠操操| 日韩电影视频 | 一级成人黄色片 | 亚洲av毛片成人精品 | 成人在线视频免费 | 亚洲精久| 久久福利在线 | 媚药按摩痉挛w中文字幕 | 国产v综合v亚洲欧美久久 | 亚洲福利在线视频 | 泰剧19禁啪啪无遮挡大尺度 | 欧美日性 | 久久国产成人午夜av浪潮 |