• 大小: 11.18MB
    文件类型: .zip
    金币: 1
    下载: 0 次
    发布日期: 2023-07-12
  • 语言: Java
  • 标签: activemq  

资源简介

activemq整合spring的实例代码,tomcat下亲测可正常运行,选择其它服务器的直接移植即可。内涵运行的所有jar包,无需再次下载

资源截图

代码片段和文件信息

package com.tgb.SpringActivemq.controller;

import javax.annotation.Resource;

import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import com.tgb.SpringActivemq.mq.producer.queue.QueueSender;
import com.tgb.SpringActivemq.mq.producer.topic.TopicSender;

/**
 * 
 * @author liang
 * @description controller测试
 */
@Controller
@RequestMapping(“/activemq“)
public class ActivemqController {

@Resource 
QueueSender queueSender;
@Resource 
TopicSender topicSender;

/**
 * 发送消息到队列
 * Queue队列:仅有一个订阅者会收到消息,消息一旦被处理就不会存在队列中
 * @param message
 * @return String
 */
@ResponseBody
@RequestMapping(“queueSender“)
public String queueSender(@RequestParam(“message“)String message){
String opt=““;
try {
queueSender.send(“test.queue“ message);
opt = “suc“;
} catch (Exception e) {
opt = e.getCause().toString();
}
return opt;
}

/**
 * 发送消息到主题
 * Topic主题 :放入一个消息,所有订阅者都会收到 
 * 这个是主题目的地是一对多的
 * @param message
 * @return String
 */
@ResponseBody
@RequestMapping(“topicSender“)
public String topicSender(@RequestParam(“message“)String message){
String opt = ““;
try {
topicSender.send(“test.topic“ message);
opt = “suc“;
} catch (Exception e) {
opt = e.getCause().toString();
}
return opt;
}

}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2017-12-20 22:28  SpringActivemq\
     目录           0  2017-12-20 22:28  SpringActivemq\ActiveMQSpringDemo\
     文件        2285  2015-09-24 22:26  SpringActivemq\ActiveMQSpringDemo\.classpath
     文件        1051  2015-09-24 21:39  SpringActivemq\ActiveMQSpringDemo\.project
     目录           0  2017-12-20 22:28  SpringActivemq\ActiveMQSpringDemo\.settings\
     文件         503  2015-09-24 21:39  SpringActivemq\ActiveMQSpringDemo\.settings\.jsdtscope
     文件          57  2015-09-24 21:45  SpringActivemq\ActiveMQSpringDemo\.settings\org.eclipse.core.resources.prefs
     文件         364  2015-09-24 21:39  SpringActivemq\ActiveMQSpringDemo\.settings\org.eclipse.jdt.core.prefs
     文件         506  2015-09-24 21:39  SpringActivemq\ActiveMQSpringDemo\.settings\org.eclipse.wst.common.component
     文件         345  2015-09-24 21:39  SpringActivemq\ActiveMQSpringDemo\.settings\org.eclipse.wst.common.project.facet.core.xml
     文件          49  2015-09-24 21:39  SpringActivemq\ActiveMQSpringDemo\.settings\org.eclipse.wst.jsdt.ui.superType.container
     文件           6  2015-09-24 21:39  SpringActivemq\ActiveMQSpringDemo\.settings\org.eclipse.wst.jsdt.ui.superType.name
     目录           0  2017-12-20 22:28  SpringActivemq\ActiveMQSpringDemo\WebContent\
     目录           0  2017-12-20 22:28  SpringActivemq\ActiveMQSpringDemo\WebContent\meta-INF\
     文件          39  2015-09-24 21:39  SpringActivemq\ActiveMQSpringDemo\WebContent\meta-INF\MANIFEST.MF
     目录           0  2017-12-20 22:28  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\
     目录           0  2017-12-20 22:28  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\
     文件     6590659  2015-06-03 14:55  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\activemq-all-5.11.1.jar
     文件       52915  2015-06-03 15:26  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\commons-logging.jar
     文件      489884  2015-06-03 14:56  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\log4j-1.2.17.jar
     文件      359025  2015-09-24 22:23  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\spring-aop-4.1.0.RELEASE.jar
     文件       56512  2015-09-24 22:23  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\spring-aspects-4.1.0.RELEASE.jar
     文件      701334  2015-09-24 21:51  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\spring-beans-4.1.0.RELEASE.jar
     文件     1023191  2015-09-24 21:51  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\spring-context-4.1.0.RELEASE.jar
     文件      177248  2015-09-24 21:51  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\spring-context-support-4.1.0.RELEASE.jar
     文件     1005039  2015-09-24 21:51  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\spring-core-4.1.0.RELEASE.jar
     文件      249627  2015-09-24 21:51  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\spring-expression-4.1.0.RELEASE.jar
     文件      266160  2015-09-24 21:51  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\spring-jms-4.1.0.RELEASE.jar
     文件      284692  2015-09-24 22:26  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\spring-messaging-4.1.0.RELEASE.jar
     文件      251102  2015-09-24 22:25  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\spring-tx-4.1.0.RELEASE.jar
     文件      697454  2015-09-24 21:51  SpringActivemq\ActiveMQSpringDemo\WebContent\WEB-INF\lib\spring-web-4.1.0.RELEASE.jar
............此处省略56个文件信息

评论

共有 条评论