在前文中我们使用 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，消息总线介绍 在微服务架构的系统中，我们通常会使用轻量级的消息代理来构建一个共用的消息主题让系统中所有微服务实例都连接上来，由于该主题中产生的消息会被所有实例监听和消费所以我们称它为消息总线......
Spring Zuul 核心组件是过滤器，路由转发都是通过各种过滤器实现。作为网关服务器，它需要不间断的工作。就算是内部逻辑要改变，也最好不要使其停止工作。 对于路由规则的改变，我们之前介绍过可以通过远程配置中心来实现不停止服务的改变规则。但是对于过滤器这种通过编码实现的规则......
十三、禁用过滤器 无论是核心过滤器还是自定义过滤器，只要在 API 网关应用中为它们创建了实例，那么默认情况下，它们都是启用状态。如果有些过滤器我们不想使用了，通常有如下两种方式禁用它们。 1，重写 shouldFilter 逻辑 只要重写某个过滤器的 shouldFilter 逻辑......
十二、异常处理 1，自定义 Error 过滤器 （1）Zuul 过滤器（链）生命周期的任何部分发生异常，都会执行 Error 过滤器。下面我们自定义一个简单的 Error 过滤器......
十月头条：Python 越来越接近第二名的位置 去年，Python 夺得了第三名的位置。虽然 Python 今年仍然排名第三，但它受欢迎程度仍在稳定上升中，本月更是达到历史新高 11.28%。另一方面，随着 Java 达到 2001 年以来历史最低值 11.28%......