个人中心
gpt4 book ai didi

java实现消息队列的两种方式(小结)

转载 作者：qq735679552 更新时间：2022-09-28 22:32:09 33 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章java实现消息队列的两种方式(小结)由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

实现消息队列的两种方式 。

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 。

最后此篇关于java实现消息队列的两种方式(小结)的文章就讲到这里了,如果你想了解更多关于java实现消息队列的两种方式(小结)的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

33 4 0
文章推荐： C语言基于哈希表实现通讯录
文章推荐： C语言通讯录管理系统课程设计
文章推荐： 在Windows系统下安装Thrift的方法与使用讲解
文章推荐： 如何在IDEA Maven项目中导入本地jar包的步骤
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com