- 浏览: 130818 次
- 性别:
- 来自: 深圳
文章分类
最新评论
package mq; import javax.jms.Connection; import javax.jms.MessageProducer; import javax.jms.Queue; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnectionFactory; public class Main { public static void main(String[] args) throws Exception { ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(); Connection conn = factory.createConnection(); conn.start(); Session session = conn.createSession(true, Session.AUTO_ACKNOWLEDGE); Queue query = session.createQueue("my-query"); MessageProducer producer = session.createProducer(query); for (int i = 0; i < 11; i++) { TextMessage messgae = session.createTextMessage("Hello World!--"+i); producer.send(messgae); System.out.println(messgae.getText()); } session.commit(); session.close(); conn.close(); } }
package mq; import javax.jms.Connection; import javax.jms.MessageConsumer; import javax.jms.Queue; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.activemq.ActiveMQConnectionFactory; public class MainClient { public static void main(String[] args) throws Exception { ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(); Connection conn = factory.createConnection(); conn.start(); Session session = conn.createSession(true, Session.AUTO_ACKNOWLEDGE); Queue query = session.createQueue("my-query"); MessageConsumer consumer = session.createConsumer(query); int i = 0; do { TextMessage msg = (TextMessage) consumer.receive(1000); if(null==msg||5==i) break; System.out.println("收到消息:"+msg.getText()); session.commit(); i++; } while (true); session.close(); conn.close(); } }
发表评论
-
note
2013-11-20 15:38 1016groupadd hadoop useradd hadoo ... -
阻塞队列
2013-10-17 10:15 761import java.io.*; impor ... -
生产者和消费者
2013-10-14 15:58 1import java.util.Stack; ... -
排序代码
2013-10-08 14:17 795import java.util.Arrays; ... -
Spring中的事务传播属性详解
2013-06-07 17:10 976文章不错,转载于:htt ... -
java中byte和int的那些事
2013-05-30 17:50 681java基本数据类型转换,看似简单,可很多人在工作编程中却 ... -
单例?
2013-05-24 22:15 764老是有人喜欢装X的问单例,话说下面是一种最靠谱的答案 ... -
cfx 调用webservice方式
2013-05-24 15:30 6683方式一:通过ClientProxyFactoryBean 调 ... -
Tomcat 配置访问权限
2013-04-08 12:03 1474tomcat貌似有个比较好玩的东西,有时候我们的应用 ... -
ibatis 修改sql文件不用重启服务器
2013-04-07 14:45 0ibatis在开发的时候每次修改都需要重启应用服务器,所以 ... -
apache cxf Client (soupUI)
2013-03-28 11:56 1147public class CxfClientT ... -
xfire
2013-03-27 12:40 0applicationContext.xml ... -
apche cxf
2013-03-27 11:52 0web.xml <servlet> ... -
structs2 漏洞代码
2013-02-01 17:52 0structs2 漏洞 ?('\u0023_ ... -
netty版telnet Server端
2013-02-01 09:13 0package netty; import ja ... -
spring mvc 2.5
2013-01-09 11:05 1231spring mvc使用笔记(基于xml配置文件) 需要三个 ... -
递归求组合?
2012-12-14 14:38 745比如【1,2,3】 获得其全部的排列组合,包括1个数字的 ... -
小试JFreeChart柱状图和饼状图
2012-07-11 20:44 2655闲来无事,就学学报表技术,目前找到一款开源JFreeC ... -
netty小试Telnet
2012-07-07 15:57 4058使用netty小时telnet一把,引入netty ... -
java原生RMI测试
2012-07-07 13:42 3062package rmi; import java.rmi.R ...
相关推荐
在这个Java项目中,包含了使用Java操作ActiveMQ的代码示例和所需的jar包,可以方便地运行队列和订阅模式。 在ActiveMQ中,有两种主要的消息传递模型:队列(Queue)和主题(Topic)。队列遵循“一对一”通信模式,...
ActiveMQ是Apache软件基金会开发的一款开源消息中间件,它基于Java平台并支持多种协议,如OpenWire、AMQP、STOMP、XMPP等。ActiveMQ 5是其一个重要的版本,提供了高度可扩展性和可靠性,广泛应用于分布式系统中的...
而ActiveMQ则是Apache软件基金会的一个开源项目,是Java消息服务(JMS)的实现,用于在分布式系统中可靠地传递消息。 当我们谈论Spring与ActiveMQ的整合时,主要涉及的是Spring的JMS模块。这个模块允许我们轻松地与...
总结来说,Java操作ActiveMQ涉及到以下几个核心概念: 1. **连接工厂(ConnectionFactory)**:创建JMS连接的入口点,允许配置与ActiveMQ服务器的连接参数。 2. **连接(Connection)**:代表与消息代理的会话,...
ActiveMQ是中国最流行的开源消息中间件之一,它基于Java Message Service (JMS) 规范,为分布式系统提供了可靠的异步通信能力。本实例将深入探讨如何使用ActiveMQ实现点对点的消息通信以及不同系统之间的互操作性。 ...
ActiveMQ是中国最流行的开源消息中间件之一,它基于Java Message Service (JMS) 规范,为分布式系统提供高效、可靠的消息传递。本教程将详细阐述如何搭建ActiveMQ环境,并通过实例来解析其工作原理。 首先,让我们...
标题中的“在Java与C++间应用Activemq”指的是使用Apache ActiveMQ这一开源消息代理在Java和C++编程语言之间构建通信桥梁。ActiveMQ是Java Message Service (JMS) 的实现,允许分布式系统中的组件通过消息传递进行...
在本项目中,我们将讨论如何将Spring框架与ActiveMQ消息队列进行整合,以及如何使用Java单独操作ActiveMQ。 首先,让我们理解Spring和ActiveMQ的基本概念。Spring是一个开源的应用框架,提供了AOP(面向切面编程)...
Java中间件领域的ActiveMQ是一款由Apache开发的开源消息中间件,它为企业级应用提供高效、可扩展、稳定且安全的消息通信服务。ActiveMQ的核心目标是实现标准的、面向消息的集成,支持多语言环境,确保不同平台之间的...
在"java消息通信activemq"的示例中,我们主要关注以下几个核心知识点: 1. **JMS接口**:JMS定义了生产者(Message Producers)、消费者(Message Consumers)以及消息队列(Queues)和主题(Topics)的概念。生产...
总结来说,"activemq + spring"的主题涵盖了使用Java原生API连接ActiveMQ以及通过Spring框架实现更高级别的整合,包括利用Spring的JMS支持简化消息发送和接收。这些知识对于构建基于消息驱动的分布式系统,实现解耦...
这个"ActiveMQ接受和发送工具.rar"压缩包包含了用于与ActiveMQ交互的实用工具,方便用户进行消息的接收和发送操作。 在使用ActiveMQ时,了解以下几个关键知识点是至关重要的: 1. **Java Message Service (JMS)**...
手册会详细解释如何创建、发送和接收消息,这对于初学者来说是了解ActiveMQ功能和操作的重要参考资料。 "ActiveMQ集群:网络连接模式(network connector)详解"这部分内容,将深入探讨ActiveMQ的集群特性。在高可用...
Apache ActiveMQ是开源的、基于Java消息服务(JMS)的应用服务器,它是Apache软件基金会的一部分。这个名为"apache-activemq-5.17.3"的压缩包包含了ActiveMQ的5.17.3版本,这是一个稳定且功能丰富的发布版本。在深入...
`JmsTemplate`提供了一种简单且灵活的方式来执行发送和接收消息的操作,同时处理了底层的JMS API细节。 另一方面,`DefaultMessageListenerContainer`用于监听特定的队列或主题,当有新消息到达时,它会自动调用...
5. **异步处理**:ActiveMQ的异步特性使得文件上传操作可以在不影响用户界面的情况下进行,提高了系统的响应速度。即使文件上传过程中出现错误,由于消息的持久化特性,可以确保消息不会丢失,待问题解决后重新尝试...
标题"memcached和activeMQ的JAVA示例代码"表明这是一个关于使用Java编程语言实现的,针对memcached缓存系统和activeMQ消息中间件的示例项目。这通常是为了帮助开发者理解如何在实际应用中整合这两种技术。 描述中的...
ActiveMQ路由配置方式 ActiveMQ路由配置是Apache ActiveMQ项目中的一种重要配置方式,它依赖另一个Apache项目Camel。ActiveMQ集成了Camel,启动时同时会启动Camel。通过Camel Web Console可以进行Routing配置。 ...
### Java消息中间件教程——ActiveMQ #### 一、课程安排与消息中间件的重要性 - **1-1 课程安排**:本课程旨在系统性地介绍ActiveMQ的各个方面,包括安装、使用、集群搭建等内容。 - **1-2 为什么使用消息中间件**...
Apache ActiveMQ是Apache软件基金会开发的一个开源消息中间件,它基于Java Message Service(JMS)规范,用于在分布式系统中高效地传输数据。ActiveMQ在企业级应用中扮演着重要的角色,因为它允许应用程序通过异步...