`

java操作ActiveMQ

    博客分类:
  • java
 
阅读更多

 

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();
	}
}
 
分享到:
评论

相关推荐

    java操作activeMQ(java项目代码及jar包可运行,队列和订阅模式)

    在这个Java项目中,包含了使用Java操作ActiveMQ的代码示例和所需的jar包,可以方便地运行队列和订阅模式。 在ActiveMQ中,有两种主要的消息传递模型:队列(Queue)和主题(Topic)。队列遵循“一对一”通信模式,...

    ActiveMQ 5 java 源码

    ActiveMQ是Apache软件基金会开发的一款开源消息中间件,它基于Java平台并支持多种协议,如OpenWire、AMQP、STOMP、XMPP等。ActiveMQ 5是其一个重要的版本,提供了高度可扩展性和可靠性,广泛应用于分布式系统中的...

    Spring和ActiveMQ的整合实例源码

    而ActiveMQ则是Apache软件基金会的一个开源项目,是Java消息服务(JMS)的实现,用于在分布式系统中可靠地传递消息。 当我们谈论Spring与ActiveMQ的整合时,主要涉及的是Spring的JMS模块。这个模块允许我们轻松地与...

    工具使用篇——java操作activemq

    总结来说,Java操作ActiveMQ涉及到以下几个核心概念: 1. **连接工厂(ConnectionFactory)**:创建JMS连接的入口点,允许配置与ActiveMQ服务器的连接参数。 2. **连接(Connection)**:代表与消息代理的会话,...

    activemq实例

    ActiveMQ是中国最流行的开源消息中间件之一,它基于Java Message Service (JMS) 规范,为分布式系统提供了可靠的异步通信能力。本实例将深入探讨如何使用ActiveMQ实现点对点的消息通信以及不同系统之间的互操作性。 ...

    ActiveMQ环境搭建及实例详解的源码

    ActiveMQ是中国最流行的开源消息中间件之一,它基于Java Message Service (JMS) 规范,为分布式系统提供高效、可靠的消息传递。本教程将详细阐述如何搭建ActiveMQ环境,并通过实例来解析其工作原理。 首先,让我们...

    在Java与C++间应用Activemq

    标题中的“在Java与C++间应用Activemq”指的是使用Apache ActiveMQ这一开源消息代理在Java和C++编程语言之间构建通信桥梁。ActiveMQ是Java Message Service (JMS) 的实现,允许分布式系统中的组件通过消息传递进行...

    spring-activemq整合工程,java单独操作activemq

    在本项目中,我们将讨论如何将Spring框架与ActiveMQ消息队列进行整合,以及如何使用Java单独操作ActiveMQ。 首先,让我们理解Spring和ActiveMQ的基本概念。Spring是一个开源的应用框架,提供了AOP(面向切面编程)...

    java中间件之activemq

    Java中间件领域的ActiveMQ是一款由Apache开发的开源消息中间件,它为企业级应用提供高效、可扩展、稳定且安全的消息通信服务。ActiveMQ的核心目标是实现标准的、面向消息的集成,支持多语言环境,确保不同平台之间的...

    java消息通信activemq

    在"java消息通信activemq"的示例中,我们主要关注以下几个核心知识点: 1. **JMS接口**:JMS定义了生产者(Message Producers)、消费者(Message Consumers)以及消息队列(Queues)和主题(Topics)的概念。生产...

    activemq + spring

    总结来说,"activemq + spring"的主题涵盖了使用Java原生API连接ActiveMQ以及通过Spring框架实现更高级别的整合,包括利用Spring的JMS支持简化消息发送和接收。这些知识对于构建基于消息驱动的分布式系统,实现解耦...

    ActiveMQ接受和发送工具.rar

    这个"ActiveMQ接受和发送工具.rar"压缩包包含了用于与ActiveMQ交互的实用工具,方便用户进行消息的接收和发送操作。 在使用ActiveMQ时,了解以下几个关键知识点是至关重要的: 1. **Java Message Service (JMS)**...

    Java消息中间件ActiveMQ学习资料

    手册会详细解释如何创建、发送和接收消息,这对于初学者来说是了解ActiveMQ功能和操作的重要参考资料。 "ActiveMQ集群:网络连接模式(network connector)详解"这部分内容,将深入探讨ActiveMQ的集群特性。在高可用...

    apache-activemq-5.17.3

    Apache ActiveMQ是开源的、基于Java消息服务(JMS)的应用服务器,它是Apache软件基金会的一部分。这个名为"apache-activemq-5.17.3"的压缩包包含了ActiveMQ的5.17.3版本,这是一个稳定且功能丰富的发布版本。在深入...

    activemq-demo

    `JmsTemplate`提供了一种简单且灵活的方式来执行发送和接收消息的操作,同时处理了底层的JMS API细节。 另一方面,`DefaultMessageListenerContainer`用于监听特定的队列或主题,当有新消息到达时,它会自动调用...

    activeMQ在文件上传的应用

    5. **异步处理**:ActiveMQ的异步特性使得文件上传操作可以在不影响用户界面的情况下进行,提高了系统的响应速度。即使文件上传过程中出现错误,由于消息的持久化特性,可以确保消息不会丢失,待问题解决后重新尝试...

    memcached和activeMQ的JAVA示例代码

    标题"memcached和activeMQ的JAVA示例代码"表明这是一个关于使用Java编程语言实现的,针对memcached缓存系统和activeMQ消息中间件的示例项目。这通常是为了帮助开发者理解如何在实际应用中整合这两种技术。 描述中的...

    ActiveMQ路由配置方式

    ActiveMQ路由配置方式 ActiveMQ路由配置是Apache ActiveMQ项目中的一种重要配置方式,它依赖另一个Apache项目Camel。ActiveMQ集成了Camel,启动时同时会启动Camel。通过Camel Web Console可以进行Routing配置。 ...

    java消息中间件教程-activemq

    ### Java消息中间件教程——ActiveMQ #### 一、课程安排与消息中间件的重要性 - **1-1 课程安排**:本课程旨在系统性地介绍ActiveMQ的各个方面,包括安装、使用、集群搭建等内容。 - **1-2 为什么使用消息中间件**...

    apache-activemq-5.15.6

    Apache ActiveMQ是Apache软件基金会开发的一个开源消息中间件,它基于Java Message Service(JMS)规范,用于在分布式系统中高效地传输数据。ActiveMQ在企业级应用中扮演着重要的角色,因为它允许应用程序通过异步...

Global site tag (gtag.js) - Google Analytics