六、多绑定器配置 1，单绑定器配置 （1）我们知道 Spring Cloud Stream 中默认实现了对 RabbitMQ、Kafka 的绑定器，从而实现了将应用程序逻辑上的输入输出通道连接到物理上的消息中间件。 （2）而引入绑定器的方法比较简单，只需在 pom.xml 中增加对应消息中间件的绑定器依赖即可......
我们知道 Spring Cloud Stream 是基于 Spring Integration 构建起来的，所以 Spring Cloud Stream 完全可以使用 Spring Integration 的原生注解来实现各种业务需求。 Spring Integration 的原生的 @ServiceActivator 是用来实现对输入消息通道的监听......
十一月头条：Python 势如破竹，超越 Java 自有 TIOBE 榜单以来，近二十年的榜单前两名都是由 C 和 Java 牢牢占据，从未发生过变化。本月榜单虽然 C 依然位列第一，但 Java 已被 Python 超越跌至第三。这也是Java 自今年 5 月被 C 超越后，本月又再次下跌一位，首次跌出前二......
四、消费组和消息分区 1，未设置消费组和消息分区的情况 通常来说生产环境中的每个服务都不会以单节点的方式运行，而是都会部署多个实例来实现高可以用和负载均衡。当同一个服务启动多个实例的时候，这些实例会绑定到同一个消息通道的目标主题上......
在前文中我们使用 Spring Cloud Stream 自带的 Sink 和 Source 通道接口来进行消息的接收和发送。但如果业务复杂，即一个应用中需有多个输入通道，或者多个输出通道（对应不同主题），那么就需要我们自定义接口来实现。 三、自定义消息通道接口......
本文通过一个简单的样例演示如何通过 Spring Cloud Stream 实现消息的发送和接收。Spring Cloud Stream 默认提供了三个通道接口：Sink、Source 和 Processor，如果当前应用最多只需一个输入通道、一个输出通道，那么直接使用默认通道接口即可，无需再自定义通道接口......
一、基本介绍 1，什么是 Spring Cloud Stream? Spring Cloud Stream 是一个用来为微服务应用构建消息驱动能力的框架。它为一些供应商的消息中间件产品提供了个性化的自动化配置实现，并且引入了发布-订阅、消费组以及分区这三个核心概念......
1，需求描述 在使用 K8s 集群的时候可能会遇到这种情况：发现其中一台 Node 节点出了问题，想将其删除再换一个节点。 2，操作步骤 （1）假设我们需要删除 k8s-node1 这个节点，首先在 master 节点上依次执行以下两个命令： kubectl drain k8s-node1......
在前文中我介绍了如何使用 RabbitMQ 实现消息总线（点击查看），本文接着演示如何使用 Kafka 实现消息总线。所以首次要安装好 Kafka 和 ZooKeeper 环境......
一、整合 RabbitMQ 实现消息总线 1，消息总线介绍 在微服务架构的系统中，我们通常会使用轻量级的消息代理来构建一个共用的消息主题让系统中所有微服务实例都连接上来，由于该主题中产生的消息会被所有实例监听和消费所以我们称它为消息总线......