DeFiBus 整体架构 服务和Topic的定义 特性列表: DeFiBus        DeFiBus=RPC+MQ，是基于开源消息中间件打造的安全可靠的分布式金融级消息总线。DeFibus不仅提供了RPC同步调用，还提供了MQ的异步事件通知、事件组播和广播等常用服务调用和消息模式，同时增加了应用多中心多活、服务就近、灰度发布等分布式场景下...

3.熔断 Links: 3.熔断       DeFiBus基于队列来做消费端的负载均衡，对同一个消费组，除广播模式外，每个队列只由一个消费者实例消费。当一个实例处理能力下降或者异常出现消息堆积时，为了避免堆积情况继续加剧，DeFiBus会触发队列的熔断，此时生产者实例在感知到队列熔断之后，会优先把消息发送到其他没有熔断的队列上，暂停往熔断队列上写...

5.同城多中心多活 Links: 5.同城多中心多活       同城多中心多活指的是应用的多活，在DeFiBus集群正常运行的情况下，应用部署在多个数据中心，一个数据中心的应用实例全部挂掉后，DeFiBus能够自动将应用流量切换到另一个数据中心的应用实例上，保证应用能够持续稳定地提供服务而不中断。同城多中心多活得益于DeFiBus的服务就近特性，...

2.灰度发布 Links: 2.灰度发布       同一个消费组中的消费者实例通常订阅的Topic是相同的。在有新业务上线时，我们希望仅仅在个别实例上进行灰度，验证通过之后再进行全量。DeFiBus提供了灰度发布的能力，同一个消费组中，允许不同消费者实例订阅不同的Topic，只有订阅了某个具体Topic的实例才能够收到这个Topic的消息，同消费...

9. 单播、多播、广播 单播 多播 广播 9. 单播、多播、广播        DeFiBus支持单播、多播、广播消费模式。 单播 单播模式下，topic只被一个消费组监听；接收消息时，消费组内有且仅有一个实例会收到消息。 多播 多播模式下，topic被多个消费组监听；接收消息时，每个消费组内有且仅有一个...

8.容错机制 隔离机制 1. Producer端的隔离 2. Consumer端的隔离 连接空闲机制 Links: 8.容错机制       在金融场景下，对可用性和稳定性的要求非常高，中间件对机器故障、网络故障、应用故障以及中间件本身的故障等常见故障场景需要有容错能力，降低故障带来的影响。 隔离机制 1. Producer端的隔...

4.服务就近 就近发送 就近监听 Links: 4.服务就近       为了保证高可用，服务的部署通常分布在多个机房、区域。我们希望服务之间能够就近调用，减少跨机房跨区域网络访问的时延问题。对此，DeFiBus在Broker和客户端上都增加了区域的属性来标识实例属于哪个区域。对于Producer，消息会优先发往同区域内的Broker集群上；对...

7. 隔离机制 Links: 7. 隔离机制 Producer在往Topic发送消息时，会按照MessageQueueSelector定义的选择策略，从Topic的所有MessageQueue中选择一个作为目标队列发送消息。 当队列发生熔断，或者Broker故障导致队列发送消息异常时，如果没有对这些队列进行特殊处理，下次再轮到发这个队列的时候仍然可...

1. Request-Reply同步调用 Links: 1. Request-Reply同步调用       Request-Reply同步调用指的是请求方发出一条消息之后，需要响应方在消费完这条消息后回复一个响应结果。 整个调用过程包含了两个消息的产生和消费过程。1.请求方产生请求消息，服务响应方消费这条请求消息       请求方根据服...

6. 自动伸缩Queue Links: 6. 自动伸缩Queue        在同一个消费组内，每个队列只由一个实例消费。当队列数小于消费者实例数时，会有部分消费者实例分不到队列；反之，当队列数大于消费者实例数时，每个消费者需要消费多个队列。队列数不是消费者实例数的整数倍时，则会出现部分实例需要消费比同组内的其他实例更多的队列，出现负载不均衡问题...