如何解决MQ的重复消费问题？MQ（消息队列）的重复消费问题是一个需要认真对待的挑战，因为它可能导致业务逻辑的重复执行，进而引发数据不一致或其他问题。以下是一些常见的解决MQ重复消费问题的方法：一、确保消息幂等性消费者幂等设计：设计消费者时，应确保其具有幂等性，...
数栈君 发表于2025-01-14 14:08
311
0
《数据资产管理白皮书》下载地址：https://www.dtstack.com/resources/1073/?src=bbs《行业指标体系白皮书》下载地址：https://www.dtstack.com/resources/1057/?src=bbs《数据治...
数栈君 发表于2025-01-13 16:58
183
0
Kafka 是一款高吞吐量、低延迟的分布式消息系统。本文将详细介绍如何在 Spring Boot 项目中使用 Kafka 进行消息接收与消费，并结合幂等和重试机制，确保消息消费的可靠性和系统的扩展性。我们将以电商交易系统为案例进行深入解析。1. 系统架构概览在...
数栈君 发表于2025-01-10 10:30
342
0
章节内容上节我们完成了如下的内容：·自定义拦截器(续接上节) 编写代码·日志采集小结整体结构ODS层ODS的定义ODS是一种面向操作层的数据存储，专注于支持企业的日常运营。它通常整合了来自不同数据源（如ERP、CRM、销售系统等）的数据，通过清洗、转换后存储，...
数栈君 发表于2025-01-10 10:11
304
0
Kafka 是大数据领域非常流行的一款分布式消息中间件，是实时计算中必不可少的一环，同时一款 OLAP 系统能否对接 Kafka 也算是考量是否具备流批一体的衡量指标之一。ClickHouse 的 Kafka 表引擎能够直接与 Kafka 系统对接，进而订阅 ...
数栈君 发表于2025-01-09 18:08
320
0
一、Publish/Subscribe(发布/订阅)在发布/订阅模型中，多了一个Exchange角色.Exchange 常见有三种类型, 分别代表不同的路由规则a) Fanout:广播，将消息交给所有绑定到交换机的队列 (Publish/Subscribe模式...
数栈君 发表于2025-01-08 17:37
211
0
前言在前面学习了简单模式的写法, 接下来学习另外几种工作模式的写法简单模式快速入门程序就是简单模式.Work Queues (工作队列)简单模式的增强版, 和简单模式的区别就是: 简单模式有一个消费者, 工作队列模式支持多个消费者接收消息, 消费者之间是竞争关...
数栈君 发表于2025-01-08 16:47
206
0
在今天这个喜庆的日子，我们迎来了袋鼠云的第九个生日。自2016年成立以来，袋鼠云始终秉承“让数据产生价值”的理念，坚持客户第一，帮助客户和伙伴构建Data+AI生产力，成为可持续的数智化服务领航者。袋鼠云的每一步成长都离不开客户及伙伴的支持，今天让我们举杯，一...
数栈君 发表于2025-01-08 16:04
310
0
一、RabbitMQ 快速入门1、创建一个空的项目2、引入依赖com.rabbitmqamqp-client5.20.0二、编写生产者代码建立连接需要信息1.ip2.端口号3.账号4.密码5.虚拟主机生产者和消费者创建的 channel 并不是同⼀个//2.开...
数栈君 发表于2025-01-08 14:00
236
0
前言后续使用云服务器上的服务器，来对rabbitmq 进行运行我们需要先把云服务器上的 rabbitmq 服务启动起来一、RabbitMQ 核心概念在安装完RabbitMQ之后, 我们接下来学习如何去使用RabbitMQ在上一个篇幅, 我们讲了RabbitMQ...
数栈君 发表于2025-01-08 12:07
246
0
@Copyrights 2016-2023 杭州玳数科技有限公司 浙ICP备15044486号-1 浙公网安备33011002011932号
