网页设计的交流网站建外贸网站

网页设计的交流网站,建外贸网站,做得好的网站,免费word在线编辑当成百上千的服务需要相互协作时#xff0c;它们之间的通信模式变得至关重要。如果服务间采用紧密耦合的同步调用#xff0c;一个服务的延迟或故障#xff0c;就可能引发连锁反应#xff0c;导致系统性的“雪崩”。消息中间件正是为了打破这种刚性依赖而生。它在服务之间建…当成百上千的服务需要相互协作时它们之间的通信模式变得至关重要。如果服务间采用紧密耦合的同步调用一个服务的延迟或故障就可能引发连锁反应导致系统性的“雪崩”。消息中间件正是为了打破这种刚性依赖而生。它在服务之间建立了一个异步的通信渠道通常是一个消息队列。生产者服务只需将任务即“消息”投递到队列中便可完成工作而无需等待消费者服务的实时响应。使用场景消息中间件常见的使用场景包括不限于解耦、有序性、异步处理、削峰填谷等。解耦在一个电商系统中用户下单后订单系统通常需要直接调用库存系统来减少库存。但是如果库存系统有问题或延迟订单系统也会受影响导致用户下单失败或延迟。使用消息中间件订单系统在用户下单后只需发送一条消息然后立即回应用户。库存系统会从消息中间件获取消息并处理。这样即使库存系统有问题订单系统也不会受影响。image有序性在一个银行系统中用户的转账操作可以被视为一个消息包含转账金额和目标账户。这些消息的顺序很重要因为需要保证转账的顺序与用户的操作顺序相同。使用消息中间件可以把每次转账操作作为一个消息发送出去。消息中间件能确保消息的顺序也就是先发送的消息先处理后发送的消息后处理。这样用户的转账操作顺序就能得到保证。image异步处理在一个在线服务平台中用户登录后系统需要做一些操作如更新登录时间发送欢迎邮件生成登录日志等。如果这些操作同时进行可能会让用户等待时间变长影响体验。使用消息中间件用户登录成功后系统可以立即回应用户然后把需要做的操作作为消息发送出去。后台服务会从消息中间件获取消息然后异步处理。image削峰填谷在一个电商网站的大促销活动中用户访问和订单量会激增这就是流量峰值。如果系统直接处理这些请求可能会因负载过大而崩溃所以需要削峰即平滑处理这些请求。使用消息中间件用户下单时系统可以将订单作为消息发送出去然后立即回应用户。后台服务会从消息中间件获取消息然后处理订单。这样即使短时间内订单量大也不会直接冲击到订单处理服务实现了削峰。另外在流量低的时候如深夜订单处理服务可能会闲置。这时如果有未处理的订单在消息中间件中订单处理服务可以继续处理订单实现了填谷。架构image无论是Kafka系统架构还是RocketMQ系统架构从图中可以看到它们整体的结构是大同小异的通常由四个主要部分构成。1生产者负责生成并发送消息到Broker集群进行存储。2Broker集群这是消息队列的核心部分它负责存储来自生产者的消息并将这些消息分发给消费者进行处理。3消费者负责接收并处理来自Broker集群的消息。4元数据中心集群例如Kafka中的Zookeeper和RocketMQ中的NameServer它们都扮演着相似的角色主要负责维护集群以及主题相关的元数据。image集群扩展能力Kafka和RocketMQ都具有良好的集群扩展能力但它们的实现方式和特点有所不同。!image在Kafka中数据同步以分区为单位进行。在创建主题时会预设分区数和副本数。Kafka会从每个分区的副本集中选出一个Broker作为Leader其余副本所在的Broker则作为Follower。所有客户端请求包括生产者发送消息和消费者消费消息都由Leader节点处理数据同步也由Leader节点向Follower节点进行。这种设计赋予了Kafka优秀的水平扩展性可以通过增加Broker数量来提升集群的存储和处理能力。在RocketMQ中整个集群由多个子集群组成每个子集群包含一个Master节点和多个Slave节点。RocketMQ会首先按照子集群对主题进行分片然后在每个子集群内部将分片的主题进一步拆分为多个消息队列MessageQueue。每个消息队列是一个逻辑队列。当生产者发送特定主题的消息时通过负载均衡策略默认为轮询策略将消息路由到各个消息队列从而确保集群中每个Broker节点的负载大致均衡。主题在消息中间件中主题Topic是一个关键的逻辑概念。生产者将消息发布到特定的主题而消费者则从这些主题中订阅并接收消息。因此主题实际上是消息的分类标识它使得消费者能够进行有效的消息筛选和选择。主题的存在实现了一条消息可以被多个消费者接收从而形成了一种发布-订阅Pub-Sub的通信模式。例如在一个“天气更新”主题中所有订阅了这个主题的消费者可能包括多个应用或服务都会收到关于天气更新的消息。这种模式的优势在于它实现了生产者和消费者的解耦。生产者只需知道消息应发送到哪个主题而无需关心谁将会是消费者。同样消费者只需订阅他们感兴趣的主题而无需知道谁是消息的生产者。这种解耦的设计使得生产者和消费者可以独立地进行扩展和修改。image未完待续