ActiveMQ 消息中间件技术详解
ActiveMQ in Action ActiveMQ是一种基于JMS(Java Message Service)的消息中间件,用于实现异步消息传递。下面对ActiveMQ的知识点进行详细阐述: 1.JMS基本构件 JMS(Java Message Service)是一种Java API,用于在Java程序之间实现异步消息传递。JMS的基本构件包括连接工厂、连接、会话、目的地、消息生产者、消息消费者和消息等。 1.1 连接工厂 连接工厂是客户用来创建连接的对象,例如ActiveMQ提供的ActiveMQConnectionFactory。连接工厂用于创建到JMS提供者的连接。 1.2 连接 JMSConnection封装了客户与JMS提供者之间的一个虚拟的连接。连接用于在客户和JMS提供者之间传递消息。 1.3 会话 JMSSession是生产和消费消息的一个单线程上下文。会话用于创建消息生产者、消息消费者和消息等。会话提供了一个事务性的上下文,在这个上下文中,一组发送和接收被组合到了一个原子操作中。 1.4 目的地 目的地是客户用来指定它生产的消息的目标和它消费的消息的来源的对象。JMS1.0.2规范中定义了两种消息传递域:点对点(PTP)消息传递域和发布/订阅消息传递域。 1.4.1 点对点消息传递域 点对点消息传递域的特点如下: * 每个消息只能有一个消费者。 * 消息的生产者和消费者之间没有时间上的相关性。 * 无论消费者在生产者发送消息的时候是否处于运行状态,它都可以提取消息。 1.4.2 发布/订阅消息传递域 发布/订阅消息传递域的特点如下: * 每个消息可以有多个消费者。 * 生产者和消费者之间有时间上的相关性。 * 订阅一个主题的消费者只能消费自它订阅之后发布的消息。 1.5 消息生产者 消息生产者是由会话创建的一个对象,用于把消息发送到一个目的地。 1.6 消息消费者 消息消费者是由会话创建的一个对象,它用于接收发送到目的地的消息。消息的消费可以采用以下两种方法之一: * 同步消费。通过调用消费者的receive方法从目的地中显式提取消息。receive方法可以一直阻塞到消息到达。 * 异步消费。客户可以为消费者注册一个消息监听器,以定义在消息到达时所采取的动作。 1.7 消息 JMS消息由以下三部分组成: * 消息头。每个消息头字段都有相应的getter和setter方法。 * 消息属性。如果需要除消息头字段以外的值,那么可以使用消息属性。 * 消息体。 ActiveMQ作为一个JMS提供者,提供了一个完整的JMS实现,支持点对点和发布/订阅两种消息传递域,并提供了丰富的消息处理机制,例如事务性、持久订阅等。
剩余44页未读,继续阅读
- 粉丝: 611
- 资源: 48
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- 多模态联合稀疏表示在视频目标跟踪中的应用
- Kubernetes资源管控与Gardener开源软件实践解析
- MPI集群监控与负载平衡策略
- 自动化PHP安全漏洞检测:静态代码分析与数据流方法
- 青苔数据CEO程永:技术生态与阿里云开放创新
- 制造业转型: HyperX引领企业上云策略
- 赵维五分享:航空工业电子采购上云实战与运维策略
- 单片机控制的LED点阵显示屏设计及其实现
- 驻云科技李俊涛:AI驱动的云上服务新趋势与挑战
- 6LoWPAN物联网边界路由器:设计与实现
- 猩便利工程师仲小玉:Terraform云资源管理最佳实践与团队协作
- 类差分度改进的互信息特征选择提升文本分类性能
- VERITAS与阿里云合作的混合云转型与数据保护方案
- 云制造中的生产线仿真模型设计与虚拟化研究
- 汪洋在PostgresChina2018分享:高可用 PostgreSQL 工具与架构设计
- 2018 PostgresChina大会:阿里云时空引擎Ganos在PostgreSQL中的创新应用与多模型存储