`
SilenceGG
  • 浏览: 109168 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

镜像队列阐述(翻译)

    博客分类:
  • JAVA
阅读更多

http://activemq.apache.org/mirrored-queues.html

 

 

                   Mirrored Queues

----------------------------------------------------------------------

  镜像队列

 

  Queues provide an excellent reliable and high performance load balancing mechanism. Each message placed on a queue can only be successfully processed by a single 

  队列提供杰出可靠和高性能的负载机制。 每一个置于队列的消息都只能被成功的消费一次被唯一的消费者。这是好事! 然而有时候我们需要去监视一个消息从生产者到消费者的流向是咋样的

  consumer。This is a good thing!  sometimes you want to monitor what messages flow between the producers and consumers on a queue.

 

  

 

 

  To do this you can use Virtual Destinations to setup a virtual Queue which forwards the message to multiple physical queues. However enabling this for every 

  你能使用虚拟目的地 设置一个虚拟队列(一个消息发往多个物理队列) ,然而为每一个队列提供这个功能非常繁琐

  single queue in your system can be painful.

  

 

  So to make it easy to monitor queues, we have added a feature we call Mirrored Queues. Mirrored Queues are kinda like a zero-configuration Wire Tap on all of 

  为了让监控队列比较容易,我们添加了镜像队列这个特性。镜像队列有点像是一个为实例上的所有队列都添加了一个零配置的Wire Tap。

  your queues inside your Message Broker.

 

 

  Example

  ----------------------------------------------------------------------

 

      For example imagine we have a number of producers sending to queue Foo.Bar and consumers consuming from queue Foo.Bar and we want to monitor or view activity.

                        想像我们有许多生产者往队列Foo.Bar 发送消息 消费者持续取从Foo.Bar取消息.  我们想监控或者观察内部活动

      

      If you enable Mirrored Queues then by default you can subscribe to the topic VirtualTopic.Mirror.Foo.Bar and receive all the messages that are sent to the 

          如果你开启了镜像队列,默认你能订阅主题VirtualTopic.Mirror.Foo.Bar,然后你能收到所有发往队列Foo.Bar的消息 ,就像一个主题能被许多需要的消费者所订阅.

      queue Foo.Bar. Since its a topic as many consumers can subscribe to this topic as are required. 

      

 

      If you want you can use this feature with Virtual Topics; so that you can define a logical consumer; say called A. Then you can subscribe to the queue 

      如果你愿意你能借助虚拟队列使用它;你能定义一个逻辑消费者,我们叫他A吧。然后你能订阅Consumer.A.VirtualTopic.Mirror.Foo.Bar这个队列去接收所有发往Foo.Bar的消息.

      Consumer.A.VirtualTopic.Mirror.Foo.Bar to receive all the messages sent to queue Foo.Bar for the consumer A. You can then run multiple instances of this 

      你能运行这个消费者的多个实例去接收他以至于彼此均衡

      consumer who can then load balance among each other.

 

      This combination of Mirrored Queues and Virtual Destinations can be extremely useful for monitoring transaction flows; for example with Business Activity 

        镜像队列与虚拟目的的组合能及其有用的监控事务; 如商业活动监控

      Monitoring (BAM).

 

  How Mirrored Queues work

 

  --------------------------------------------------------------------

 

     When enabled, mirrored queues causes every message sent to a queue to also be sent to a topic of a similar name; so that folks who are interested in watching 

     当你开启镜像队列时,镜像队列可以使每个发往一个队列的消息,同时发送到一个类似名字的TOPIC中.  那些对队列传输期间消息交换感兴趣的人可以消费者这个虚拟队列主题

     message exchanges on a queue can consume from the mirrored queue topic.

 

 

     When coupled with Virtual Topics on this topic as described in the above example, you can actually end up creating new queues which are mirrors of a given

     当成对的像上面描述的虚拟主题,你能创建多动态的的镜像队列在运行时作为结束

      queue dynamically at runtime!

 

 

 

  Enabling Mirrored Queues

 

  -------------------------------------------------------------------

 

     By default Mirrored Queues is disabled; as enabling it will cause a virtual topic to be created for each queue you use.

     

     默认情况下,镜像队列是关闭的。如果开启的话,将会为你使用的每一个队列创建一个虚拟主题.

 

     To enable Mirrored Queues, set the useMirroredQueues property on BrokerService or add the following inside the <broker> element in the

 

      Xml Configuration:

        <mirroredQueue copyMessage = "true" postfix=".qmirror" prefix=""/>

        </destinationInterceptors>

 

     This would make a topic named "*.qmirror" for each queue on your Broker.

分享到:
评论

相关推荐

    RabbitMQ实战 高效部署分布式消息队列 PDF下载

    此外,通过镜像队列,可以实现队列级别的数据冗余和高可用。 7. **持久化与可靠性**:RabbitMQ支持消息和队列的持久化,即使服务器重启,也能恢复之前的数据,保证消息不丢失。 8. **Spring整合**:在Java应用中,...

    RabbitMQ安装手册

    3. **高可用性**:通过集群和镜像队列实现RabbitMQ的高可用性,保证服务的稳定性。 4. **安全配置**:设置用户权限、虚拟主机和网络访问控制,保障RabbitMQ的安全运行。 **六、常见问题与解决方案** 在使用...

    尚硅谷RabbitMQ pdf笔记(优质文档)

    此外,笔记还会涵盖RabbitMQ的高可用性方案,如通过镜像队列实现数据冗余,以及集群设置,使得服务能够在多台机器间分布,提高系统的容错性和可扩展性。同时,它也会涉及RabbitMQ的持久化机制,确保即使在服务器重启...

    RabbitMQ面试题(面试题整合)

    - **Mirrored Queues**:镜像队列,队列在集群中的多个节点有副本,保证数据安全性。 - **Sharding**:队列分片,提高处理能力。 6. **RabbitMQ的管理工具** - **RabbitMQ Management Console**:Web界面,用于...

    尚硅谷_消息中间件RabbitMQ_课件.rar

    6. **高可用性**:RabbitMQ可以通过集群和镜像队列等方式提高服务的可用性和数据的可靠性。 7. **延迟队列与死信队列**:RabbitMQ提供了延迟插件,可以设置消息在特定时间后才被消费。死信队列则用于处理无法正常...

    消息中简介Rabbitmq集群搭建

    1. **镜像队列**:为了保证高可用,可以设置镜像队列,使消息在多个节点间复制。即使某个节点失败,其他节点仍能提供服务。 2. **自动故障恢复**:RabbitMQ 支持自动故障检测和恢复,当节点故障时,其上的队列会被...

    Java高级架构面试知识点整理.pdf

    Java高级架构面试知识点主要聚焦在消息队列的使用和其在系统设计中的重要性。首先,我们来深入探讨一下消息队列。...在准备面试时,除了掌握基础知识,还要能结合实际工作中的案例进行阐述,展现自己的实战能力。

    Oracle Rac技术原理-RAC进程.docx

    RAC技术的核心在于进程间的协作,以下将详细阐述文档中提到的关键进程: 1. GSD (Global Services Daemon): GSD进程是Oracle RAC管理和控制的关键组件,它与DBCA(Database Configuration Assistant)、SRVCTL...

    openflow.zip

    4. **端口与队列**:文档会详细描述交换机的端口结构,包括物理端口和虚拟端口,以及端口上的数据包队列管理,如队列配置和流量调度策略。 5. **流统计与镜像**:OpenFlow支持收集流量统计信息,用于监控和优化网络...

    DES-3800系列中文手册(命令行).rar

    - 端口镜像:设置端口镜像以进行网络监控和故障排查。 3. VLAN配置 - VLAN创建与删除:了解如何创建VLAN,以隔离不同部门或服务的流量。 - VLAN成员分配:将物理端口分配到不同的VLAN,实现数据隔离。 - VLAN间...

    openstack安装手册

    在实际操作中,用户会了解到如何配置网络、数据库、消息队列等基础设施,以及如何设置OpenStack的各个组件,如Nova控制器、计算节点、Swift存储节点等。此外,手册还会指导用户如何配置Keystone以实现身份验证和授权...

    RTL8367RB_DataSheet&RTL8370N-VB-CG_Draft_DataSheet_0.3数据手册

    此外,还会阐述其内存管理单元(MMU)的工作原理,它是如何调度数据包以确保高效的数据传输。 其次,RTL8370N-VB-CG同样是一款5端口千兆交换机,但可能具有不同的特性和优化。例如,它可能具有更高级的节能功能,如...

    数据中心接入交换机采购要求.doc

    本文档详细阐述了中国国际电子商务中心在数据中心接入交换机的采购要求,主要包括24口和48口接入交换机的技术规格和性能指标。这些交换机需具备万兆接口,支持全路由交换功能,以及二、三层线速转发,同时要求支持堆...

    22分布式系统的技术栈1

    以下将详细阐述相关知识点。 1. **大流量处理**: - **负载均衡系统**:通过将流量分散到多台服务器,实现水平扩展,降低单一节点的压力,例如Nginx、HAProxy等。 - **缓存系统**:如Redis、Memcached,提供快速...

    企业级云原生白皮书项目实战.pdf

    综上所述,《企业级云原生白皮书项目实战》不仅提供了云原生技术的理论基础,还结合实战案例深入浅出地阐述了如何在企业中落地云原生架构,对于希望利用云原生技术进行数字化转型的企业具有很高的参考价值。

    flashfxp

    下面将详细阐述FlashFXP的主要功能、特点以及如何使用。 1. **主要功能:** - 文件传输:FlashFXP支持FTP、FTPS(FTP over SSL/TLS)、SFTP(SSH File Transfer Protocol)等多种协议,能够安全地进行文件的上传、...

    Windows Azure云平台基本操作手册.docx

    无论是Windows Server还是Linux,创建虚拟机的过程都涉及选择合适的镜像、配置硬件规格、设置网络和安全组。对于Windows Server VM,快速创建选项简化了流程,而从镜像库创建则允许用户自定义更多设置。Windows VM的...

    Quidway S5300系列以太网交换机 配置指南-IP业务

    以下将详细阐述这些知识点。 1. VLAN(虚拟局域网):VLAN是一种将物理网络划分为多个逻辑网络的技术,以提高网络管理效率和安全性。在S5300系列交换机上,你可以通过命令行界面(CLI)创建、删除和修改VLAN,配置...

    H3C S1526智能以太网交换机 用户手册

    功能特性中,S1526采用MAC地址自学习和老化机制,并支持QoS服务,包括802.1p优先级、四队列调度和端口限速。端口镜像功能允许用户监控特定端口的数据流量,而端口统计可以追踪报文流量和类型。电缆诊断功能则能检查...

Global site tag (gtag.js) - Google Analytics