消息队列1-RabbitMQ与原生客户端介绍
文章目录
一. MQ的应用场景
1. 异步解耦
2. 流量削峰
3. 消息订阅分发
4. 延迟通知
二. RabbitMQ的结构分析与工作流程
1. AMQP协议
2. 客户端与服务器
3. Connection
4. Channel
5. Virtual host
6. Exchange
7. Queue
8. 工作流程
(1) 创建连接
(2) 声明交换机和队列
(3) 发送消
最近更新
Dubbo- 注册中心实战：Zookeeper 部署与 Dubbo 集成配置
👋 大家好，欢迎来到我的技术博客！ 📚 在这里，我会分享学习笔记、实战经验与技术思考，力求用简单的方式讲清楚复杂的问题。 🎯 本文将围绕Dubbo这个话题展开，希望能为你带来一些启发或实用的参考。 🌱 无论你是刚入门的新手，还是正在进阶的开发者&
标签计算引擎（Flink/Spark）选型
海量标签计算在实际业务落地中面临多重核心难点，直接决定了分布式计算引擎的选型方向。其一，数据规模与并发压力大，标签计算需处理TB/PB级海量用户、商品、设备数据，且包含高并发实时流数据（如峰值时段用户行为日志）与海量静态历史数据，对引擎的吞吐量和并发处理能力提出极高要求。其二，延迟与准确
zookeeper 客户端命令 & 集成SpringBoot笔记
概述Zookeeper是一个开源的 分布式 协调 服务，项目属于Apache Hadoop，树形目录服务。
常用功能
配置管理：充当配置中心，集中管理分布式系统的配置文件，确保各个节点使用一致的配置。
分布式锁：实现跨JVM的锁机制，确保资源的互斥访问。
集群管理：作为注册中心&
AI 大模型的本质：基于大数据的拟合，而非创造
AI 大模型的本质：基于大数据的拟合，而非创造过去几年，“人工智能”“大模型”“AGI”成为最耀眼的技术名词。资本、媒体和产业叙事不断强化一种暗示：
AI 正在接近真正的智能，甚至可能成为文明的发动机。但如果剥离叙事，只从数学、工程与物理约束出发，大模型的本质其实非常清晰——
AI 大模型ÿ
大数据领域Kafka的生产者批量发送优化
大数据领域Kafka的生产者批量发送优化
关键词：大数据、Kafka、生产者、批量发送、优化
摘要：在大数据领域，Kafka作为一款高性能的分布式消息队列，被广泛应用于数据的实时处理和传输。Kafka生产者的批量发送机制对于提高系统的吞吐量和性能至关重要。本文将深入探讨Kafka生产者批量发送的原理、核心算法，通过数学模型和公式进行详细分析，并结合项目实战给出具体的代码案例。同时，介
nginx埋点，按天输出日志，filebeat收集日志到elasticsearch
一、Nginx 按天生成日志
定义时间变量指定格式
map $time_iso8601 $logdate {
'~^(?<ymd>\d{4}-\d{2}-\d{2})' $ymd;
default 'date-not-found';
}
自定义日志json格式
log_format json_log '{"time":"$log
Kafka Streams 实时流处理：构建高效数据管道
Kafka Streams 实时流处理：构建高效数据管道
别叫我大神，叫我 Alex 就好。流处理是现代数据架构的核心，Kafka Streams 让这一切变得简单优雅。
一、Kafka Streams 基础1.1 核心概念// 创建 Kafka Streams 应用
@Configuration
public class KafkaStre
Flutter 三方库 flutter_chat_ui 的鸿蒙化适配指南 - 掌握标准化的即时通讯 UI 构建技术、助力鸿蒙社交应用实现极致流畅且高度专业的对话交互体系
欢迎加入开源鸿蒙跨平台社区：#Flutter 三方库 flutter_chat_ui 的鸿蒙化适配指南 - 掌握标准化的即时通讯 UI 构建技术、助力鸿蒙社交应用实现极致流畅且高度专业的对话交互体系前言在 OpenHarmony 鸿蒙应用全场景覆盖、特别是适配“即时通讯（IM）、在线客服系统、社区互动平台”等高频交互场景中，聊天界面的质感直接
