二、Kafka的集群架构与工作流程

（1）生产者定期向主题发送消息。
（2）Kafka 代理存储该特定主题配置的分区中的所有消息。 确保消息在分区之间平等共享。 如果生产者发送两个消息并且有两个分区，Kafka 将在第一分区中存储一个消息，在第二分区中存储第二消息。
（3）消费者订阅特定主题。一旦消费者订阅主题，Kafka 将向消费者提供主题的当前偏移，并且还将偏移保存在 Zookeeper 系统中。
（4）消费者将定期请求 Kafka 新消息。 Kafka 收到来自生产者的消息后，会将这些消息转发给消费者。
（5）消费者收到消息并进行处理后，便会向 Kafka 代理发送确认。
（6） Kafka 收到确认，将偏移更改为新值，并在 Zookeeper 中更新它。 由于偏移在 Zookeeper 中维护，消费者可以正确地读取下一封邮件，即使在服务器暴力期间。
（7）重复以上流程，直到消费者停止请求。消费者可以随时回退/跳到所需的主题偏移量，并阅读所有后续消息。

在队列消息传递系统，而不是单个消费者中，具有相同 Group ID 的一组消费者将订阅主题。这个消费者组被认为是单个组，并且消息在它们之间共享。

（1）生产者定期向某个主题发送消息。
（2）Kafka 代理存储该特定主题配置的分区中的所有消息。
（3）单个消费者订阅特定主题，假设为 Topic-01，Group ID 为 Group-1。
（4）Kafka 以与发布 - 订阅消息相同的方式与消费者交互，直到新消费者以相同的组 ID 订阅相同主题Topic-01 。
（5）一旦新消费者到达，Kafka 将其 *** 作切换到共享模式，并在两个消费者之间共享数据。 此共享将持续，直到用户数达到为该主题配置的分区数。
（6）一旦消费者的数量超过分区的数量，新消费者将不会接收任何新消息，直到现有的一个消费者取消订阅。 出现这种情况是因为 Kafka 中的每个消费者将被分配至少一个分区，并且一旦所有分区被分配给现有消费者，新消费者将必须等待。

转自 W3Cschool的Kafka基本工作流程

WEB服务器流量超负载问题解决方法

Web应用服务器集群系统，是由一群同时运行同一个web应用的服务器组成的集群系统，在外界看来，就像是一个服务器一样。为了均衡集群服务器的负载，达到优化系统性能的目的，集群服务器将众多的访问请求，分散到系统中的不同节点进行处理。从而实现了更高的有效性和稳定性，而这也正是基于Web的企业应用所必须具备的特性。

一、计算WEB服务器负载量的两种方法

web应用服务器集群系统，是由一群同时运行同一个web应用的服务器组成的集群系统，在外界看来，就像是一个服务器一样。为了均衡集群服务器的负载，达到优化系统性能的目的，集群服务器将众多的访问请求，分散到系统中的不同节点进行处理。从而实现了更高的有效性和稳定性，而这也正是基于Web的企业应用所必须具备的特性。

高可靠性可以看作为系统的一种冗余设定。对于一个特定的请求，如果所申请的服务器不能进行处理的话，那么其他的服务器能不能对之进行有效的处理呢？对于一个高效的系统，如果一个Web服务器失败的话，其他的服务器可以马上取代它的位置，对所申请的请求进行处理，而且这一过程对用户来说，要尽可能的透明，使用户察觉不到！

稳定性决定了应用程序能否支持不断增长的用户请求数量，它是应用程序自身的一种能力。稳定性是影响系统性能的众多因素的一种有效的测量手段，包括机群系统所能支持的同时访问系统的最大用户数目以及处理一个请求所需要的时间。

在现有众多的均衡服务器负载的方法中，广泛研究并使用的是以下两个方法：

DNS负载平衡的方法RR-DNS(Round-Robin Domain Name System)

负载均衡器

以下，我们将就这两种方法进行讨论。

二、DNS轮流排程的优势及缺点

域名服务器（Domain Name Server）中的数据文件将主机名字映射到其IP地址。当你在浏览器中键入一个URL时（例如：解释。基于所读出的这些信息，负载均衡器就可以重写报头并将请求发往集群中合适的节点上，该节点维护着相应客户端请求的会话信息。在>