Active Mq JMS

Jan 2, 2009Download as ppt, pdf

2 likes533 views

hzchenkj

该文档介绍了础肠迟颈惫别惭蚕及其与闯惭厂的关系，重点介绍了其架构、特征和功能。础肠迟颈惫别惭蚕支持多种协议、持久化选项和安全特性，并提供了简单的使用示例。该文档还包含了有关高级主题和更多资料的链接。

ActiveMQ
作者： honno
时间： 2008.8
Email: honnom@163.com
目前研究和应用推广的开源项目：

JMS 介绍
? （ 1 ） destination
? （ 2 ） product
? （ 3 ） consumer
? （ 4 ） broker
? （ 5 ） P2P,Pub/Sub

ActiveMQ 与 JMS
? JMS 是一种规范。
? ActiveMQ 是 JMS 规范的一种实
现， MOM 。

ActiveMQ 主要特征
特征 :
? (1)JMS1.1,J2EE1.4
? (2)J2EE servers(Tomcat,JBoss4,GlassFish,WebLogic…)
? (3) 多语言客户端（ Java,C,C++,C#,Ruby,PhP ）
? (4) 多种协议 (VM,TCP,SSL,UDP,multicast,JGroups…)
? (5)Spring
? (6)Ajax
? (7)CXF,Axis
? (8)REST
? (9)Message Groups,Virtual Destinations,Wildcards,Composite
Destinations
? (10) 持久化 (journal,JDBC)
? (11) 性能 (client-server,cluster,peer…)

ActiveMQ 功能介绍
? 多种协议
? 持久化
? 安全
? 群集
? 监控
? 其他

多种协议
URI: scheme:scheme-specific-part
? （ 1 ） VM vm://brokername
? （ 2 ） TCP tcp://host:port
? （ 3 ） SSL ssl://host:port
? （ 4 ） HTTP http://host:port
? （ 5 ） UDP udp://host:port

多种协议
? （ 6 ） peer peer://group/brokername
? （ 7 ） multicast multicast://IPAddress
? （ 8 ） static static(list uris)
? （ 9 ） failover failvoer(list uris)
? （ 10 ） discovery discovery://host:port

持久化
? 日志
<journaledJDBC journalLogFiles="5"dataDirectory="../mq-data" />
? 数据库
包括：
Derby,HSQL,MySQL,SQLServer,
Sybase,DB2,Oracle…
<journaledJDBC dataSource="#mysql-ds"/>

安全
? 认证
simpleAuthenticationPlugin
jaasAuthenticationPlugin
? 授权
authorizationPlugin

ActiveMQ 高级话题
? Wildcards
* 和 >
? Composite Destinations
<compositeQueue >
<forwardTo>
<queue … />
<topic … />
</forwardTo>
</compositeQueue>
? Message Groups

ActiveMQ 入门实例
? 实例说明：
? ActiveMQ 发送和异步接受文本类型消息的
简单功能

broker
? 启动
? BrokerService broker = new BrokerService();
try {
broker.addConnector("tcp://localhost:61616");
broker.start();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}

producer
? 发送 : 生产 10 个文本消息，并发送 .
? MessageProducer producer =
? session.createProducer(destination);
TextMessage message
? =session.createTextMessage();
for (int i = 0; i < 10; i++) {
message.setText("This is message " +
? (i + 1));
producer.send(message);
}

consumer
? 接收
? MessageConsumer consumer =
session.createConsumer(destination);
PrintlnUtil.println("Consumering
Messages");
consumer.setMessageListener(this);

运行效果图
详细： http://www.opensourceforce.org/thread-249-1-1.html

本文档介绍了奥别产厂辫丑别谤别的培训目标和基础知识，包括闯2贰贰应用服务器的原理、奥别产厂辫丑别谤别管理技能以及集群的配置方法。内容涵盖了奥别产应用的创建、贰闯叠的实现及部署、闯顿叠颁的连接管理、闯惭厂的基本概念和服务集成总线的构建等多方面。通过学习，读者将掌握奥别产厂辫丑别谤别的基本服务及其在公司级应用中的应用技巧。

ASP.net MVCGuider Lee

Mq light in microservicesSteve Upton

The document discusses using AMQP/MQ Light as a microservices transport. It compares using MQ Light to using REST for communication between microservices. MQ Light uses a publish-subscribe model where services subscribe to topics to receive messages, rather than services calling each other directly. This allows for looser coupling between services and avoids services needing to know about changes to other services.

Active mq Installation and Master Slave setupRamakrishna Narkedamilli

Apache ActiveMQ is an open-source messaging and integration pattern server that allows for message throttling, redelivery, and delay. This document discusses how to install and configure ActiveMQ, including setting up dead letter queues and clustering multiple ActiveMQ instances. The key steps are: 1) Installing ActiveMQ on each node, 2) Configuring dead letter queues by setting redelivery policies in activemq.xml, and 3) Configuring clustering by giving each broker a unique name, connecting them to a shared SQL database, and starting one as the master node.

ActiveMQ In ActionBruce Snyder

This document summarizes common problems and solutions when using ActiveMQ. It addresses questions about creating JMS clients from scratch, efficiently managing connections, consuming only certain messages, reasons for locking/freezing, when a network of brokers is needed, and using a master/slave configuration. Spring JMS and selectors are recommended over building clients from scratch. Connection pooling and caching are advised for efficiency. Selectors and proper design can filter messages. Memory, prefetch limits, and cursors impact performance and need configuration. Networked brokers improve availability while master/slave configurations provide high availability.

Messaging With ActiveMQBruce Snyder

This document provides an overview and summary of ActiveMQ features for message-oriented middleware including messaging domains, durability vs persistence, message acknowledgement vs transactions, synchronous vs asynchronous message consumption, broker clustering, master/slave configurations, security options, wire formats for non-Java clients, handling disconnected producers/consumers, consumer options, slow consumer strategies, monitoring broker statistics, and an introduction to Apache Camel for integration.

Messaging for IoTVirtual JBoss User Group

The document discusses the complexities and solutions related to messaging in the Internet of Things (IoT), focusing on the roles of protocols like JMS, MQTT, and AMQP, as well as messaging brokers such as Apache ActiveMQ and Artemis. It explores the challenges in IoT environments, including interoperability, scalability, and reliability, while outlining the advantages and limitations of various communication patterns and technologies. Additionally, it emphasizes innovative tools like the Qpid Dispatch Router that facilitate scalable deployments in IoT messaging infrastructure.

Messaging for Web and Mobile with Apache ActiveMQdejanb

Advanced messaging with Apache ActiveMQdejanb

This document provides an overview of Apache ActiveMQ, an open source messaging system. It discusses what ActiveMQ is, its basics like topics and queues, techniques for scaling such as vertical, horizontal and hybrid approaches, ensuring high availability, and its future direction with ActiveMQ Apollo. The presentation aims to explain how ActiveMQ works and how to configure it for different deployment needs.

Active Mq JMS

1. ActiveMQ 作者： honno 时间： 2008.8 Email: honnom@163.com 目前研究和应用推广的开源项目：

2. 概要 ActiveMQ -JMS - 特征 - 功能 - 实例

4. JMS 介绍 ? （ 1 ） destination ? （ 2 ） product ? （ 3 ） consumer ? （ 4 ） broker ? （ 5 ） P2P,Pub/Sub

5. ActiveMQ 与 JMS ? JMS 是一种规范。 ? ActiveMQ 是 JMS 规范的一种实现， MOM 。

6. ActiveMQ 架构图架构图

7. ActiveMQ 主要特征特征 : ? (1)JMS1.1,J2EE1.4 ? (2)J2EE servers(Tomcat,JBoss4,GlassFish,WebLogic…) ? (3) 多语言客户端（ Java,C,C++,C#,Ruby,PhP ） ? (4) 多种协议 (VM,TCP,SSL,UDP,multicast,JGroups…) ? (5)Spring ? (6)Ajax ? (7)CXF,Axis ? (8)REST ? (9)Message Groups,Virtual Destinations,Wildcards,Composite Destinations ? (10) 持久化 (journal,JDBC) ? (11) 性能 (client-server,cluster,peer…)

8. ActiveMQ 功能介绍 ? 多种协议 ? 持久化 ? 安全 ? 群集 ? 监控 ? 其他

9. 多种协议 URI: scheme:scheme-specific-part ? （ 1 ） VM vm://brokername ? （ 2 ） TCP tcp://host:port ? （ 3 ） SSL ssl://host:port ? （ 4 ） HTTP http://host:port ? （ 5 ） UDP udp://host:port

10. 多种协议 ? （ 6 ） peer peer://group/brokername ? （ 7 ） multicast multicast://IPAddress ? （ 8 ） static static(list uris) ? （ 9 ） failover failvoer(list uris) ? （ 10 ） discovery discovery://host:port

11. 持久化 ? 日志 <journaledJDBC journalLogFiles="5"dataDirectory="../mq-data" /> ? 数据库包括： Derby,HSQL,MySQL,SQLServer, Sybase,DB2,Oracle… <journaledJDBC dataSource="#mysql-ds"/>

12. 安全 ? 认证 simpleAuthenticationPlugin jaasAuthenticationPlugin ? 授权 authorizationPlugin

13. 集群 ? Master/Slave ? Network of Brokers

14. 监控 ? JMX ? Advisory Message

15. ActiveMQ 高级话题 ? Wildcards * 和 > ? Composite Destinations <compositeQueue > <forwardTo> <queue … /> <topic … /> </forwardTo> </compositeQueue> ? Message Groups

16. ActiveMQ 入门实例 ? 实例说明： ? ActiveMQ 发送和异步接受文本类型消息的简单功能

17. broker ? 启动 ? BrokerService broker = new BrokerService(); try { broker.addConnector("tcp://localhost:61616"); broker.start(); } catch (InterruptedException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); }

18. producer ? 发送 : 生产 10 个文本消息，并发送 . ? MessageProducer producer = ? session.createProducer(destination); TextMessage message ? =session.createTextMessage(); for (int i = 0; i < 10; i++) { message.setText("This is message " + ? (i + 1)); producer.send(message); }

19. consumer ? 接收 ? MessageConsumer consumer = session.createConsumer(destination); PrintlnUtil.println("Consumering Messages"); consumer.setMessageListener(this);

20. 运行效果图详细： http://www.opensourceforce.org/thread-249-1-1.html

21. 更多资料 ? 更多对于 SOA,ESB,MQ 的相关资料见： ? 开源力量

22. 谢谢

狠狠撸

Active Mq JMS

Recommended

More Related Content

Viewers also liked (6)

Active Mq JMS