最近收到好几个类似的问题：使用Spring Cloud Stream操作RabbitMQ或Kafka的时候，出现消息重复消费的问题。通过沟通与排查下来主要还是用户对消费组的认识不够。其实，在之前的博文以及《Spring Cloud微服务实战》一书中都有提到关于消费组的概念以及作用。
那么什么是消费组呢？为什么要用消费组？它解决什么...
可能看到这个标题，读者会问：要修改日志的级别，不是直接修改log.xxx就好了吗？为何要搞那么复杂呢？所以，先说一下场景，为什么要通过TurboFilter去动态的修改日志级别。我们在使用Java开发各种项目的时候必然的会引入很多框架，这些框架通过堆叠的方式完成所要提供的业务服务（一个服务请求在进入后会在这...
应用场景
之前我们已经通过《Spring Cloud Stream消费失败后的处理策略（一）：自动重试》一文介绍了Spring Cloud Stream默认的消息重试功能。本文将介绍RabbitMQ的binder提供的另外一种重试功能：重新入队。
动手试试
准备一个会消费失败的例子，可以直接沿用前文的工程，也可以新建一个，然后创建如下代码的...
应用场景
前两天我们已经介绍了两种Spring Cloud Stream对消息失败的处理策略：
自动重试：对于一些因环境原因（如：网络抖动等不稳定因素）引发的问题可以起到比较好的作用，提高消息处理的成功率。
自定义错误处理逻辑：如果业务上，消息处理失败之后有明确的降级逻辑可以弥补的，可以采用这种方式，但是2....
应用场景
有的时候，我们对于同一通道中的消息处理，会通过判断头信息或者消息内容来做一些差异化处理，比如：可能在消息头信息中带入消息版本号，然后通过if判断来执行不同的处理逻辑，其代码结构可能是这样的：
@StreamListener(value = TestTopic.INPUT)public void receiveV1(String payload, @Header("ve...
应用场景
我们在使用一些开源调度系统（比如：elastic-job等）的时候，对于任务的执行时间通常都是有规律性的，可能是每隔半小时执行一次，或者每天凌晨一点执行一次。然而实际业务中还存在另外一种定时任务，它可能需要一些触发条件才开始定时，比如：编写博文时候，设置2小时之后发送。对于这些开始时间不确...
前情回顾：
《Spring Cloud Alibaba基础教程：使用Nacos实现服务注册与发现》
《Spring Cloud Alibaba基础教程：支持的几种服务消费方式（RestTemplate、WebClient、Feign）》
《Spring Cloud Alibaba基础教程：使用Nacos作为配置中心》
上一篇，我们学习了如何在Nacos中创建配置，以及如何使用Spring Cloud...
通过《Spring Cloud Alibaba基础教程：使用Nacos实现服务注册与发现》一文的学习，我们已经学会如何使用Nacos来实现服务的注册与发现，同时也介绍如何通过LoadBalancerClient接口来获取某个服务的具体实例，并根据实例信息来发起服务接口消费请求。但是这样的做法需要我们手工的去编写服务选取、链接拼接等繁...
昨晚Nacos社区发布了第一个生产级版本：0.8.0。由于该版本除了Bug修复之外，还提供了几个生产管理非常重要的特性，所以觉得还是有必要写一篇讲讲这次升级，在后续的文章中也都将以0.8.0版本为基础。
升级的理由
如Nacos官方的发布文档中描述的那样，本版本将支持非常重要的三个特性：
第一，用户登录。在过去...
前情回顾：
《Spring Cloud Alibaba基础教程：使用Nacos实现服务注册与发现》
《Spring Cloud Alibaba基础教程：支持的几种服务消费方式》
《Spring Cloud Alibaba基础教程：使用Nacos作为配置中心》
《Spring Cloud Alibaba基础教程：Nacos配置的加载规则详解》
通过之前两篇对Nacos配置管理功能的介绍，已...