071-如何避免消息堆积与消费延迟

好，那我们下面来看一下，经过前面这些呃，深入的分析，那我们看如何避免消息堆积和消息延迟。同时，为了避免在业务使用时出现非预期的消息堆积和消息延迟问题。要在前期设计阶段对整个业务逻辑进行完善的排查和梳理。其中最重要的就是。什么两点？一个是梳理消息的消费耗时。对吧。另外一个就是什么设置消息消费的变化度。啊，设置消息消费的。并发度是吧，这两点来我们分别再来看一下啊，其实前面我们都说过类似的了啊，我们再看一下，总结一下。

首先啊，梳理消息的消费耗时，那么通过压测获取消息的消费耗时，然后呢，并对耗时较高的操作的代码逻辑进行分析。处理消息的消费号时，需要关注以下信息啊，第一个。呃，消息消费逻辑的计算复杂度是否过高？你不能太后的。是吧，呃，你这里边儿啊，看看代码里边是否存在无限循环或者是递归。对吧，这是有问题的。然后呢，我们消息消费逻辑里边的IO操作是不是必须的。因为你要远程访问的，那你是不是必须的，能否用本地缓存等方案给它规避掉。那第三呃，消费逻辑里边的呃，复杂耗时操作是否可以做一步化处理。因为同步太慢了呀。

是不是？啊，如果可以。那可以的话，是否会造成逻辑混乱，那你你你给他做成异步的了，乱套了。那肯定也不行啊，因为异步的执行啊，那那那可能我这边。我这边啊消息，呃，比如说我一步啊，我就把消息读过来了，那边还没处理完呢，我说给你响应了，有没有这种可能性，会出现逻辑上的混乱，对不对。然后我们再来看啊，设置消费变化度的时候啊。需要注意什么？那对于消息消费变化度的计算，可以通过以下两个步骤实施，第一，逐步调大单个考节点的线收数。啊，并观测节点的系统指标啊，得到单个节点最优的。这个消费新成数和这个消息的吞吐量。对吧。然后第二个。根据呃，上下游链路的流量峰值啊，这样一个流量峰值，然后计算出需要设置的节点数，这个流量峰值啊。

来计算设置的，这这个这个计算我相信大家很清楚啊，这个很很简单对吧，怎么算。你有峰值。有单个经典的吞吐量，你怎么算一除不就行了吗？对不对啊，这样吧，给大家还是写写出来吧。呃。这个。节点数对吧，等于什么。就等于这个流量峰值。除以。And。节点。这个消息。坑。吞吐。对吧。啊，这是，呃，我们这个如何避免障碍，我们需要怎么做。

嗯，OK，嗯，那么这样的话啊，可以说我们就十分的深入的把消息的堆积与消息延迟问题啊，我们给他这个分析，呃。产生的原因如何，如何解决是吧？啊，能详细的就说过了。