- 浏览: 7328635 次
- 性别:
- 来自: 上海
文章分类
- 全部博客 (1546)
- 企业中间件 (236)
- 企业应用面临的问题 (236)
- 小布Oracle学习笔记汇总 (36)
- Spring 开发应用 (54)
- IBatis开发应用 (16)
- Oracle基础学习 (23)
- struts2.0 (41)
- JVM&ClassLoader&GC (16)
- JQuery的开发应用 (17)
- WebService的开发应用 (21)
- Java&Socket (44)
- 开源组件的应用 (254)
- 常用Javascript的开发应用 (28)
- J2EE开发技术指南 (163)
- EJB3开发应用 (11)
- GIS&Mobile&MAP (36)
- SWT-GEF-RCP (52)
- 算法&数据结构 (6)
- Apache开源组件研究 (62)
- Hibernate 学习应用 (57)
- java并发编程 (59)
- MySQL&Mongodb&MS/SQL (15)
- Oracle数据库实验室 (55)
- 搜索引擎的开发应用 (34)
- 软件工程师笔试经典 (14)
- 其他杂项 (10)
- AndroidPn& MQTT&C2DM&推技术 (29)
- ActiveMQ学习和研究 (38)
- Google技术应用开发和API分析 (11)
- flex的学习总结 (59)
- 项目中一点总结 (20)
- java疑惑 java面向对象编程 (28)
- Android 开发学习 (133)
- linux和UNIX的总结 (37)
- Titanium学习总结 (20)
- JQueryMobile学习总结 (34)
- Phonegap学习总结 (32)
- HTML5学习总结 (41)
- JeeCMS研究和理解分析 (9)
最新评论
-
lgh1992314:
[u][i][b][flash=200,200][url][i ...
看看mybatis 源代码 -
尼古拉斯.fwp:
图片根本就不出来好吧。。。。。。
Android文件图片上传的详细讲解(一)HTTP multipart/form-data 上传报文格式实现手机端上传 -
ln94223:
第一个应该用排它网关吧 怎么是并行网关, 并行网关是所有exe ...
工作流Activiti的学习总结(八)Activiti自动执行的应用 -
ZY199266:
获取不到任何消息信息,请问这是什么原因呢?
ActiveMQ 通过JMX监控Connection,Queue,Topic的信息 -
xiaoyao霄:
DestinationSourceMonitor 报错 应该导 ...
ActiveMQ 通过JMX监控Connection,Queue,Topic的信息
在多个系统中可能考虑到远程访问等的,采用WebService方式和远程系统的JMS消息系统交互。本文采用ActiveMQ和JAXWS实现。客户端通过webservice将消息发送给服务端的消息队列。
package easyway.app.activemq.ws; import javax.jws.WebMethod; import javax.jws.WebParam; import javax.jws.WebService; /** * 服务端接口 * @author longgangbai * */ @WebService public interface HelloWorld { /** * 启动相关的服务方法 * @param name * @return */ @WebMethod String sayHi(@WebParam(name = "name") String name); }
package easyway.app.activemq.ws; import javax.jws.WebService; /** * 服务端实现 * @author longgangbai * */ @WebService public class HelloWorldImpl implements HelloWorld { /* * (non-Javadoc) * @see test.IHello#sayHi(java.lang.String) */ public String sayHi(String name) { return "Hello " + name; } }
服务端通过WebService发布JMS消息的信息:
package easyway.app.activemq.ws.server; import javax.xml.ws.Endpoint; import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.broker.BrokerService; import easyway.app.activemq.ws.HelloWorldImpl; /** * 通过WebService提供本地的JMS服务 * @author longgangbai * */ public class ActiveMQWServer { //设置JMS的URI的格式:jms:queue or topic:destination private static final String JMS_ENDPOINT_URI = "jms:queue:jaxws.jmstransport.queue?timeToLive=1000" + "&jndiConnectionFactoryName=ConnectionFactory" + "&jndiInitialContextFactory" + "=org.apache.activemq.jndi.ActiveMQInitialContextFactory"; private ActiveMQWServer() { } public static void main(String args[]) throws Exception { ActiveMQWServer server=new ActiveMQWServer(); //初始化Broker的方法 server.initBrokerService(); //启动JAXWS相关的 服务 server.launchJaxwsApi(); System.out.println("Server ready... Press any key to exit"); System.in.read(); System.out.println("Server exiting"); System.exit(0); } /** * 启动ActiveMQ的Broker * @throws Exception */ public void initBrokerService() throws Exception{ BrokerService brokerService=new BrokerService(); brokerService.addConnector( ActiveMQConnectionFactory.DEFAULT_BROKER_BIND_URL); brokerService.setDataDirectory("target/activemq-data"); brokerService.start(); } /** * 发布WebService服务 * */ private void launchJaxwsApi() { Endpoint.publish(JMS_ENDPOINT_URI, new HelloWorldImpl()); } }
客户端通过webservice发送消息到服务端的消息队列:
package easyway.app.activemq.ws.client; import javax.xml.namespace.QName; import javax.xml.ws.Service; import org.apache.cxf.transport.jms.spec.JMSSpecConstants; import easyway.app.activemq.ws.HelloWorld; /** * 客户端通过WebService向服务端队列中发送消息 * @author longgangbai * */ public final class ActiveMQWSClient { //WebService请求的url的路径 private static final String JMS_ENDPOINT_URI = "jms:queue:jaxws.jmstransport.queue?timeToLive=1000" + "&jndiConnectionFactoryName=ConnectionFactory" + "&jndiInitialContextFactory" + "=org.apache.activemq.jndi.ActiveMQInitialContextFactory"; private static final QName SERVICE_QNAME = new QName("http://ws.activemq.app.easyway/", "HelloWorldImplService"); private static final QName PORT_QNAME = new QName("http://ws.activemq.app.easyway/", "HelloWorldPort"); private ActiveMQWSClient() { } /** * 客户端调用WS服务 * @return */ private static HelloWorld createClientJaxWs() { //创建相关的 服务 Service service = Service.create(SERVICE_QNAME); // Add a port to the Service service.addPort(PORT_QNAME, JMSSpecConstants.SOAP_JMS_SPECIFICATION_TRANSPORTID, JMS_ENDPOINT_URI); return service.getPort(HelloWorld.class); } public static void main(String[] args) throws Exception { HelloWorld client = createClientJaxWs(); String reply = client.sayHi("HI"); System.out.println(reply); } }
发表评论
-
ActiveMQ的拦截器插件
2011-07-22 09:29 6600ActiveMQ拦截器使用和原 ... -
ActiveMQ的各种表SQL的管理
2011-07-20 20:58 3499在ActiveMQ为了方便的切换数据库,更为了深入 ... -
ActiveMQ中advisory的使用和原理
2011-07-20 18:46 2900在ActiveMQ中的监控和管理也可以通过Advisory实现 ... -
ActiveMQ的异步转发(DispatchAsync)功能
2011-07-20 11:29 47001. 消息者异步转发功能 针对正常情况下,在一个 ... -
ActiveMQ 的独占消费(Exclusive Consumer)
2011-07-20 11:26 4092我们经常希望维持队列中的消息,按一定次序转发给消息者。然而当有 ... -
ActiveMQ5.5在Tomcat6.0中部署
2011-07-19 22:27 2920在ActiveMQ中监控管理Web组件为ActiveMQCon ... -
Window 下ActiveMQ端口冲突,负载均衡,主备配置
2011-07-17 16:03 5525在Java 学习中Window操作系 ... -
ActiveMQ中消息权限策略
2011-07-17 00:31 2665在ActiveMQ发送消息的时候,可以通过MessageAut ... -
ActiveMQ和Jetty整合使用
2011-07-07 22:49 5582在ActiveMQ中的activemq.b ... -
ActiveMQ 和Commons-Daemon整合
2011-07-07 20:13 2938在一般的java项目中,如果在linu ... -
关于ActiveMQ中怎么实现一对多发送消息讨论
2011-07-07 19:50 6065无 ... -
ActiveMQ 中ActiveMQBlobMessage的接收和发送
2011-07-05 10:47 5119在ActiveMQ中对比较大的消息采用一 ... -
ActiveMQ-Camel的使用
2011-07-02 10:27 10220在一个电子系统中可能接受来自不同供应商的 ... -
ActiveMQ模板和Velocity整合使用
2011-07-01 19:50 2304ActiveMQ模板使用 在ActiveMQ中AMQ ... -
ActiveMQ中消息游标
2011-06-30 18:16 2655在 ActiveMQ 5.0的之前版本中,b ... -
ActiveMQ和Tomcat的整合应用
2011-06-30 17:00 11208在ActiveMQ的资源让容器Tomcat管理时 ... -
ActiveMQ关于文件传输需要注意哪些方面?
2011-06-18 22:11 6176最近一直在关注一些文件传输中间件的实现,想用Acti ... -
关于ActiveMQ中Session和Connection资源的管理
2011-06-15 23:43 25096配置完了持久化之后,我们就可以使用代码来发送 ... -
ActiveMQ中关于文件锁的机制的学习
2011-06-14 23:31 3330在ActiveMQ中提供了文件数据库机 ... -
ActiveMQ的JMX监控使用
2011-06-10 17:26 13148package easyway.app.activemq.d ...
相关推荐
以上就是ActiveMQ与Spring整合封装的基本过程,通过这样的方式,我们不仅实现了全注解开发,简化了操作,还提高了系统的性能和可扩展性。在实际应用中,还可以根据需求进行更深入的定制,比如添加事务支持、错误处理...
将Spring与ActiveMQ整合,可以轻松地在Spring应用中实现消息队列的功能,提高系统的可扩展性和可靠性。 首先,让我们了解Spring框架如何支持消息传递。Spring提供了JmsTemplate类,这是一个模板类,用于简化发送和...
整合ActiveMQ和Tomcat的好处在于,它允许Web应用程序利用ActiveMQ的强大功能,如发布/订阅模式和点对点模式的消息传递,以及高可用性和故障恢复能力。同时,由于ActiveMQ是独立于Tomcat运行的,因此可以与其他应用...
通过整合ActiveMQ和Tomcat,可以在Web应用中充分利用消息队列的优势,实现异步处理、提高系统的可扩展性和可靠性。同时,正确配置持久化消息和Tomcat服务器对于保证服务的稳定性和数据的完整性至关重要。在实际项目...
ActiveMQ和Spring的整合是企业级应用中常见的一种技术组合,尤其在分布式系统和微服务架构中,消息队列(Message Broker)如ActiveMQ扮演着至关重要的角色。它能有效地实现系统间的异步通信,提高系统的可扩展性和...
将ActiveMQ与Spring整合,可以充分利用Spring的便捷性来管理和使用消息队列,使得消息的发送和接收更加简单。 首先,要进行ActiveMQ与Spring的整合,你需要在项目中引入相应的依赖。通常,这可以通过在Maven或...
在IT行业中,Apache ActiveMQ和Spring框架的整合是常见的企业级消息传递解决方案。这个"activemq和spring整合发布消息和订阅消息demo"是用于演示如何在Spring环境中配置和使用ActiveMQ来实现实时的数据通信。现在,...
在实际应用中,ActiveMQ与Tomcat的整合可以实现应用程序间的异步通信,提高系统的响应速度和可扩展性。通过Topic和Queue,你可以构建发布/订阅模型或者点对点的消息传递模式,从而解耦不同的服务组件,使得系统更加...
将ActiveMQ与Tomcat整合,可以让Tomcat应用利用消息队列实现更高效的通信,提高系统的可扩展性和可靠性。 **一、ActiveMQ简介** ActiveMQ的主要功能包括: 1. **消息队列**: 提供点对点和发布/订阅两种模式的消息...
在Java世界中,ActiveMQ和Spring的整合是企业级应用中常见的消息中间件解决方案,用于实现JMS(Java Message Service)消息传递。本教程将深入探讨如何将这两个强大的工具结合在一起,以创建一个简单的发送JMS消息的...
在IT行业中,Spring Boot和ActiveMQ的整合是一个常见的任务,特别是在构建分布式系统和微服务架构时。Spring Boot以其简化配置和快速开发的特性受到广泛欢迎,而ActiveMQ作为一款开源的消息中间件,提供了消息队列...
将ActiveMQ与Spring整合可以极大地简化消息队列的使用,提高系统的可维护性和扩展性。 本例子程序的主题是"activeMQ与spring整合开发",这意味着它将展示如何在Spring应用中集成ActiveMQ,以便利用消息队列进行异步...
### Apache ActiveMQ与JMS整合Tomcat:深入解析与实践 #### 一、Apache ActiveMQ:强大而灵活的开源消息中间件 Apache ActiveMQ作为一款成熟的开源消息中间件,不仅遵循了JMS 1.1规范,还兼容J2EE 1.4以上的标准,...
**标题:“ActiveMQ与Spring整合”** 在Java企业级应用中,消息中间件扮演着重要的...提供的activemq_demo示例代码应该包含了整合的完整流程和优化措施,学习和研究这些代码可以帮助我们更好地理解和实践这个过程。
将ActiveMQ与Spring整合,可以方便地在Spring应用中使用消息队列,实现异步处理和分布式通信。 **一、ActiveMQ安装与配置** 在Linux系统中安装ActiveMQ,首先需要下载ActiveMQ的二进制包,解压后将其放置在合适的...
通过以上知识点的讲解,我们可以看到,ActiveMQ与Spring的整合使得在Java应用中使用JMS变得更加简单和高效。无论是消息的生产还是消费,都能通过Spring的抽象和ActiveMQ的稳定性能得到很好的支持。在实际项目中,...
java springboot整合activemq工程 #activemq配置 #默认情况下activemq提供的是queue模式 true是可以使用topic,false是仅使用queue模式 spring.jms.pub-sub-domain: true # 设置连接的activemq服务器 spring....
在构建分布式架构的过程中,SpringBoot 2.0.1、Zookeeper、Dubbo、ActiveMQ 和 Redis 是五款至关重要的技术组件。它们各自扮演着不同的角色,共同为系统的高效运行和扩展性提供支持。 首先,SpringBoot 2.0.1 是...