一、JMS基本概念
JMS(Java Message Service,Java消息服务)是Java EE的一种技术。
JMS定义了Java 中访问消息中间件的接口,并没有给予实现,实现JMS 接口的消息中间件称为JMS Provider,例如ActiveMQ
JMS provider:实现JMS接口和规范的消息中间件
JMS message:JMS的消息,JMS消息由以下三部分组成:
1:消息头:每个消息头字段都有相应的getter和setter方法
2:消息属性:如果需要除消息头字段以外的值,那么可以使用消息属性
3:消息体:封装具体的消息数据
JMS producer:消息生产者,创建和发送JMS消息的客户端应用
JMS consumer:消息消费者,接收和处理JMS消息的客户端应用
消息的消费可以采用以下两种方法之一:
1:同步消费:通过调用消费者的receive方法从目的地中显式提取消息,receive 方法可
以一直阻塞到消息到达。
2:异步消费:客户可以为消费者注册一个消息监听器,以定义在消息到达时所采取的动作
二、JMS基本概念2
JMS domains:消息传递域,JMS规范中定义了两种消息传递域:点对点 (point-topoint,简写成PTP)消息传递域和发布/订阅消息传递域(publish/subscribe,简写
成pub/sub)
1:点对点消息传递域的特点如下:
(1)每个消息只能有一个消费者
(2)消息的生产者和消费者之间没有时间上的相关性。无论消费者在生产者发送消息的时候是否处 于运行状态,它都可以提取消息。
2.发布/订阅消息传递域的特点如下:
(1)每个消息可以有多个消费者
(2)生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自它订阅之后发布的 消息。JMS 规范允许客户创建持久订阅,这在一定程度上放松了时间上的相关性要求。持久订 阅允许消费者消费它在未处于激活状态时发送的消息。
3:在点对点消息传递域中,目的地被称为队列(queue);在发布/订阅消息传递域中,目的地被称为 主题(topic)
三、JMS开发中常用的对象
Connection factory:连接工厂,用来创建连接对象,以连接到JMS的provider
JMS Connection:封装了客户与JMS 提供者之间的一个虚拟的连接
JMS Session:是生产和消费消息的一个单线程上下文会话用于创建消息生产者(producer)、消息消 费者(consumer)和消息(message)等。会话提供了一个事务性的上下文,在这个 上下文中,一组发送和接收被组合到了一个原子操作中。
Destination:消息发送到的目的地
Acknowledge:签收
Transaction:事务
JMS client:用来收发消息的Java应用
Non-JMS client:使用JMS provider本地API写的应用,用来替换JMS API实现收
发消息的功能,通常会提供其他的一些特性,比如:CORBA、RMI等。
Administered objects:预定义的JMS对象,通常在provider规范中有定义,提供给JMS客户端来访 问,比如: ConnectionFactory和Destination
相关推荐
总之,ActiveMQ-CPP Library 3.9.5为C++开发者提供了与ActiveMQ交互的便捷方式,结合Visual Studio 2015和2017的支持,能够在Windows平台上高效地构建消息驱动的应用程序。通过理解其核心组件和使用方法,开发者可以...
2. **ActiveMQ-CPP库核心功能** - **连接管理**:ActiveMQ-CPP库提供了连接工厂,用于创建到ActiveMQ服务器的连接。这些连接可以是持久化的,即使服务器断开也能恢复。 - **会话与消费者**:库中的会话接口负责...
tar -zxvf apache-activemq-5.15.12-bin.tar.gz 2.进入bin目录 cd /apache-activemq-5.15.12/bin 3.运行,没有配置环境变量只能在bin目录下使用命令 ./activemq 4.配置环境变量,配置完环境变量之后...
自己编译的activemq-cpp的2.X的最后版本,在windows + vs2010下测试通过。压缩包中包含了include\lib\dll文件。 由于尝试了N个3.X的版本都不同过,于是退到2.X版本,通过了,另外在vs2005下编译出来的也没有问题。...
这个“apache-activemq-5.9.0-bin”压缩包包含了Apache ActiveMQ 5.9.0版本的完整二进制文件,用于在本地或网络环境中安装和运行。 Apache ActiveMQ的核心功能包括: 1. **消息队列**:ActiveMQ支持多种消息模式,...
赠送jar包:activemq-protobuf-1.1.jar; 赠送原API文档:activemq-protobuf-1.1-javadoc.jar; 赠送源代码:activemq-protobuf-1.1-sources.jar; 包含翻译后的API文档:activemq-protobuf-1.1-javadoc-API文档-...
activemqBroker插件:activemqBroker-2.14-SNAPSHOT.war
赠送jar包:activemq-core-5.7.0.jar; 赠送原API文档:activemq-core-5.7.0-javadoc.jar; 赠送源代码:activemq-core-5.7.0-sources.jar; 包含翻译后的API文档:activemq-core-5.7.0-javadoc-API文档-中文...
这个压缩包"apache-activemq-5.8.0-bin.zip"包含了ActiveMQ 5.8.0版本的二进制发行版,供用户在本地计算机上安装和运行。 1. **Apache ActiveMQ简介** - Apache ActiveMQ是业界广泛使用的消息代理,提供可靠的消息...
activemq-parent-5.10.0-source-release.zip activemq-parent-5.10.2-source-release.zip activemq-parent-5.12.3-source-release.zip apache-activemq-5.10.2-bin.tar.gz apache-activemq-5.11.4-bin.zip apache-...
activemq-web-console的默认使用方式是通过在activemq.xml中导入jetty.xml配置一个jetty server来实现的。其实activemq-web-console完全可以和activemq-broker分开来部署。 activemq-web-console包含3个apps, 1.一...
这个"apache-activemq-5.15.8-bin.zip"文件包含了ActiveMQ的可执行版本,用于在本地计算机上安装和运行ActiveMQ服务。 首先,我们需要了解ActiveMQ的核心概念。它是一个消息代理,扮演着消息生产者与消费者之间的...
在“apache-activemq-5.12.0-bin”这个压缩包中,包含了运行Apache ActiveMQ所需的所有文件,适用于Windows操作系统。 Apache ActiveMQ作为消息队列的实现,主要功能包括: 1. **消息传输**:ActiveMQ允许应用程序...
activemq/5.9.0/apache-activemq-5.9.0-bin.tar;activemq/5.9.0/apache-activemq-5.9.0-bin.tar
activemq-all-5.2.0.JAR包,欢迎下载。编写java中间件的时候会用到。这是activemq实现的jms中间件。希望能帮助到你。
mv /usr/local/apache-activemq-5.13.4 /usr/local/apache-activemq ``` - **测试启动和停止ActiveMQ**: 进入`/usr/local/apache-activemq/bin/`目录,尝试启动和停止ActiveMQ: ```bash ./activemq start ....
MQ是消息中间件,是一种在分布式系统中应用程序借以传递消息的媒介,常用的有ActiveMQ,RabbitMQ,kafka。ActiveMQ是Apache下的开源项目,完全支持JMS1.1和J2EE1.4规范的JMS Provider实现。 特点: 1、支持多种...
apache-activemq-5.8.0,包解压后可以直接使用,用于系统间的消息的发布与消费。 pom添加: <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <version>5.11.1</version> </...
这个压缩包"apache-activemq-5.14.4-bin.tar.gz"包含了安装和运行ActiveMQ所需的所有文件。 **ActiveMQ简介** ActiveMQ是一个高性能、灵活且易于使用的消息代理,它允许应用程序通过消息传递进行通信,以解耦生产者...
配置文件位于`/opt/apache-activemq-5.x.x/conf`目录下,主要关注`activemq.xml`。这个文件定义了ActiveMQ的核心配置,包括消息存储、网络连接等。根据需求,你可以调整这些设置以优化性能或安全性。 3. **启动和...