zoukankan      html  css  js  c++  java
  • ActiveMQ讯息传送机制以及ACK机制详解

    【http://www.ylzx8.cn/ruanjiangongcheng/software-architecture-design/11922.html】

    AcitveMQ:消息存储和分发组件,涉及到client与broker端数据交互的方方面面,它不仅要担保消息的存储安全性,还要提供额外的手段来确保消息的分发是可靠的。

    【ActiveMQ消息传送机制】
    Producer客户端用来发送消息的, Consumer客户端用来消费消息;它们的协同中心就是ActiveMQ broker,broker也是让producer和consumer调用过程解耦的工具,最终实现了异步RPC/数据交换的功能。随着ActiveMQ的不断发展,支持了越来越多的特性,也解决开发者在各种场景下使用ActiveMQ的需求。比如producer支持异步调用;使用flow control机制让broker协同consumer的消费速率;consumer端可以使用prefetchACK来最大化消息消费的速率;提供"重发策略"等来提高消息的安全性等。

    图片中简单的描述了一条消息的生命周期,不过在不同的架构环境中,message的流动行可能更加复杂.将在稍后有关broker的架构中详解..一条消息从producer端发出之后,一旦被broker正确保存,那么它将会被consumer消费,然后ACK,broker端才会删除;不过当消息过期或者存储设备溢出时,也会终结它。

  • 相关阅读:
    PHP 中的 cURL 爬虫实战基础
    PHP的输出缓冲区
    Web网站高并发量的解决方案
    PHP Socket 简单使用
    php无极限分类函数
    PHP单链表的基本操作
    PHP中的10个实用函数
    你真的了解现在的PHP吗?
    国人骄傲,layer.js 搞定所有弹窗
    字典排序
  • 原文地址:https://www.cnblogs.com/lsx1993/p/4626485.html
Copyright © 2011-2022 走看看