Spring Boot 中使用 RabbitMQ
通过本文的介绍，你已经学习了如何在 Spring Boot 中使用 RabbitMQ 实现异步消息的发送和接收。你了解了如何配置 RabbitMQ 连接信息，并使用 Spring Boot 提供的和注解进行消息的发送和接收。通过实际的案例，我们展示了如何使用 RabbitMQ 实现任务队列，以邮件发
RabbitMQ分享
RabbitMQ遵循AMQP协议，自身采用Erlang生产者发消息，启动多个消费者实例来消费消息，每个消费者仅消费部分信息，可达到负载均衡的效果。
flink反压
flink反压过程介绍
微服务---Eureka注册中心
引入eureka-server依赖添加@EnableEurekaServer注解在application.yml中配置eureka地址。
【实验2】在Hadoop平台上部署WordCount程序
在Hadoop平台上部署WordCount程序5. 分布式文件系统HDFS上的操作5.1 利用Shell命令与HDFS进行交互5.2 利用Web界面管理HDFS6. 分布式文件系统HDFS上的编程实践6.1 安装Eclipse6.2 创建Eclipse工程6.3 编写一个Java应用程序检测HDFS
RabbitMQ的幂等性、优先级队列和惰性队列
一、幂等性1、概念2、消息重复消费3、解决思路4、消费端的幂等性保障5、唯一 ID+指纹码机制6、Redis 原子性二、优先级队列1、使用场景2、如何添加3、实战三、惰性队列1、使用场景2、两种模式3、内存开销对比以上就是RabbitMQ的幂等性、优先级队列和惰性队列的相关知识点，希望对你有所帮助。
RabbitMQ（三）：AMQP协议
因为RabbitMQ是一种遵循AMQP协议的分布式消息中间件，RabbitMQ实现的AMQP版本是0.9.1，所以在此处简单了解一下AMQP-0-9-1 协议。
RabbitMq
1、每个消费者监听自己的队列。2、生产者将消息发给broker，由交换机将消息转发到绑定此交换机的每个队列，每个绑定交换机的队列都将接收到消息publish/subscribe与work queues有什么区别。1）work queues不用定义交换机，而publish/subscribe需要定义交
如何高效接入 Flink： Connecter / Catalog API 核心设计与社区进展
本文整理自阿里云实时计算团队 Apache Flink Committer 和 PMC Member 任庆盛在 FFA 2023 核心技术专场（二）中的分享。
kafka排除zookeeper使用kraft的最新部署方案
kafka已经推出了kraft来管理集群了，在新的部署方案中可以省去zookeeper服务的安装部署
.NET CORE消息队列RabbitMQ
RabbitMQ是一个开源的消息代理和队列服务器，用于在分布式系统中传递消息。它支持多种消息协议，提供可靠的消息传递、灵活的路由、集群和高可用性功能。
大数据组件之Flink：实时流处理的王者
Apache Flink是一个用于无界和有界数据流的开源流处理框架。它提供了一个统一的API来处理批量和流数据，使得开发者可以轻松地构建高效的实时数据处理应用。Flink的核心优势在于其低延迟、高吞吐量和容错性强的特点，适用于多种实时数据分析场景。Apache Flink作为一款革新的大数据处理引擎
什么！你要学spark！
hadoop是什么 mapreduce概述 spark概述
科普|大数据信用高风险形成原因，怎么查询?
联系人风险是指借款人的联系人(如家庭成员、朋友、同事等)在借款人面临信用风险时，可能受到牵连的风险。在大数据时代，基于大数据技术的大数据信用风险在很多时候是很多机构比较重视的问题，大数据信用风险主要包括多头借贷风险、履约行为风险、联系人风险、司法风险等。市面上做大数据信用查询的比较多，信息比较全服务
Kubernetes kafka系列 | k8s部署kafka+zookeepe集群
Kafka简介： Apache Kafka 是一个开源的分布式流处理平台和消息队列系统。它最初由LinkedIn开发，并于2011年成为Apache软件基金会的顶级项目。特点：高吞吐量： Kafka 能够处理大规模的消息流，并具有很高的吞吐量。持久性： 它将消息持久化到磁盘上，因此即使消费者不在线，
Hadoop必会面试题
分布式: 多台机器做不同的事情, 然后组成1个整体.集群: 多台机器做相同的事情多台机器既可以组成 中心化模式(主从模式), 也可以组成 去中心化模式(主备模式)A.员工1和A.员工2的关系是集群，A.员工1和B.员工1的关系是分布式分布式存储解决了单机存储容量有限的问题, 且带来了比较高的性能提升
flink的分组聚合、over聚合、窗口聚合对比
对比flink的分组聚合group_agg/over聚合over_agg/窗口聚合window_agg
python高校舆情分析系统+可视化+snownlp情感分析 舆情分析+Flask框架 大数据 毕业设计（源码）✅
python高校舆情分析系统+可视化+snownlp情感分析 舆情分析+Flask框架 大数据 毕业设计（源码）✅
Rabbitmq---topics模型之动态路由
一条消息会被所有订阅的队列都消费，但是在某种场景下，我们希望不同的消息被不同的队列消费。这时候就要用到direct的类型的交换机。，它的核心作用就是不同的消息可以被不同消费者消费，同时我们也可以让所有的消费者去消费这一个消息,fanout广播模型，只要生产者一发送，交换机会把所有的消息发给所有的广播
深入浅出RabbitMQ：顺序消费、死信队列和延时队列
通过//关键参数，支持发送延迟消息// 声明交换机"delay.queue", // 交换机名字"fanout", // 交换机类型true, // 是否持久化false,false,false,props, // 设置属性。
