Kafka从上手到实践 - 初步认知:MQ系统 | 凌云时刻
凌云时刻 · 技术
导读:Kafka 是广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析不可或缺的工具。本篇为 Kafka 系列的第一篇文章,之后将会每天持续更新,让你从上手到实践。
作者 | 计缘
来源 | 凌云时刻(微信号:linuxpk)
什么是MQ
首先我们来认知什么是MQ系统既消息队列(Message Queue)系统。举个不恰当的例子,消息(Message)就相当于自来水,队列(Queue)就相当于自来水管道,错综复杂的管道将自来水送给千家万户。在计算机领域,消息其实就是数据,各种格式的数据,队列就是运输数据的管道,通过各种运输策略将数据送达使用它们的地方。
消息生产者(Producer)
任何MQ系统都离不开消息生产者(后文中统一使用Producer),否则MQ系统也就没有了存在的意义。好比没有了水源,自来水管道也就没有意义了一样。MQ系统中的Producer既消息(数据)生产者,主要的作用就是生成数据,然后发送给MQ系统中的队列,通常情况下,消息生产者将生产出的消息丢给MQ系统的队列后通常就不再关心消息的去向了,所以它的职责主要就是生成数据,以及数据是否成功被队列接收。然后丢进队列。每个MQ系统都有自己的消息格式,以字节数组的形式在队列中传输。
消息主题(Topic)
消息主题指的是一类消息,相当于数据库中的表,或文件系统中的一个文件夹,是MQ系统中一切的基础。我们来引用《Kafka:The Definitive Guide》一书中的例图来举例:
图例展示的是一个独立的队列系统,图中的Metrics Pub/Sub,Logging Pub/Sub,Tracking Pub/Sub其实就是充当了Topic的作用,相当于对消息做了分类。
消息(Message)
MQ系统的内部数据单元一般称为消息(Message),消息类似数据库中的一行或一条记录。不同的MQ系统有不同的消息协议,这个消息协议的作用是为了让消息生产者和消息消费者都能够明白消息所承载的信息,既消息生产者需要知道如何构造消息,消息消费者需要知道如何解析消息,所以就需要有一种统一的格式来描述消息,这个描述消息的格式就是消息协议。
数据持久化(Data Persistent)
在使用MQ系统时,数据的健壮性和一致性是至关重要的。试想一下,如果消息生产者生产了消息并且发送走了,但是在同时消息消费者掉线了,那么这条消息就很有可能丢失了,再或者消息生产者生产了一个很大的文件,需要将其序列化后送入队列,那么在消息被消费的时候,应该将序列化后的数据反序列化,如果序列化后的数据有个别丢失,那么就会导致反序列后的信息是不一致的。
所以在MQ系统中,数据持久化就是用来避免上述情况发生的。通常数据持久化的方式有文件存储,数据库存储两大类,其中还有一些参杂各种缓存机制。对数据持久化的时机也不尽相同,有些是在消息生产者端持久化,有些是在队列中持久化,也有在消息消费者端做持久化。同时对应的重新消费消息的机制和策略也会不相同,比如有消息生产者重发,也有消息消费者重新拉取等。
消息消费者(Consumer)
消息消费者(后文中统一使用Consumer)顾名思义就是消息的使用者,通过订阅一个或多个不同的消息主题,获取到不同类别的消息进行使用。是整个MQ系统的最后一个环节。
小结
这一章节概括了什么是MQ系统,它应该具备哪些基本的功能,这些功能能做什么事情。让大家在脑海里对MQ系统有初步的认知。后续章节在介绍Kafka时其实都是对这几个模块的庖丁解牛。希望能给小伙伴们带来帮助。
END
往期精彩文章回顾
进阶之路:深入解读 Java 堆外内存
干货:一文看懂Apache Ranger
吴翰清:有变革的需求,才有技术的诞生
云原生时代,消息中间件的演进路线
如何提升微服务的幸福感
OceanBase 连破纪录的背后,是技术人的砥砺前行
重磅!解读国内唯一入选全球顶会SIGCOMM论文
一文读懂数据湖
长按扫描二维码关注凌云时刻
每日收获前沿技术与科技洞见
Kafka从上手到实践 - 初步认知:MQ系统 | 凌云时刻相关推荐
- 《深入理解Kafka:核心设计与实践原理》笔误及改进记录
2019年2月下旬笔者的有一本新书--<深入理解Kafka:核心设计与实践原理>上架,延续上一本<RabbitMQ实战指南>的惯例,本篇博文用来记录现在发现的一些笔误,一是给购 ...
- 如何成为一名数据分析师:数据的初步认知
作者 | 钟家福 杏仁医生数据工程师,关注数据分析与挖掘. 对所有从事数据相关工作的人而言,都有一个老生常谈的问题:数据认知!毕竟在真正开始分析.BI 报表开发或者建模前,对数据进行一定的审查和认知是 ...
- Kafka复习计划 - 客户端实践及原理(消费者组/位移/请求处理过程)
Kafka复习计划 - 客户端实践及原理(消费者组/位移/请求处理过程) 前言 一. 消费组 1.1 Rebalance 重平衡 1.2 Coordinator 协调者 1.3 如何尽量避免消费者组重 ...
- Python的初步认知与安装步骤 (小白必备)
Python的初步认知与安装步骤 Python初步认知 安装步骤 基础代码测试(变量.数据类型) 运算符.条件结构.循环结构 思维导图 Python初步认知 Python简介 Python是一种跨平台 ...
- 深入理解Kafka核心设计与实践原理_01
深入理解Kafka核心设计与实践原理_01 01_初识Kafka 1.1 基本概念 1.2 安装与配置 1.3 生产与消费 1.4 服务端参数配置 01_初识Kafka 1.1 基本概念 一个典型的 ...
- 类和对象(面向对象的初步认知)
面向对象的初步认知 什么是面向对象 Java是一门纯面向对象的语言(Object Oriented Program,简称OOP),在面向对象的世界里,一切皆为对象.面向对象是解决问题的一种思想,主要依 ...
- 关于浏览器运行原理的初步认知
在对浏览器运行原理的认知过程中我们首先需要精细的了解一些"概念" 这些"概念"也许理解起来很容易,但没有精细理解的时候很容易忽视 而在没有精细了解这些" ...
- 7 大版块 | 全面解读与认知支付系统
大家好,Ping++ 支付学院真的来了.我是支付学院的教导主任,接下来由我为大家带来一些支付的知识,希望大家快乐学习,有所收获. 说好的「干货」,绝不掺水 最硬干货将会是「全面解读与认知支付系统」,来 ...
- JAVA开发者大会:拍拍贷MQ系统原理与应用
JAVA开发者大会:拍拍贷MQ系统原理与应用 --喜欢记得关注我哟[shoshana]-- 前记: 5月12号参加了JAVA开发者大会,就<拍拍贷消息系统原理及应用> 作者:李乘胜老师 关 ...
- Python与人工智能入门实践——简易人脸识别系统
Python与人工智能入门实践--简易人脸识别系统 写在前面: 笔者在寒假期间进行了一些简短的实训,主要内容包括简单的爬虫和简单的人脸识别算法,由于时间有限,对于python也是第一次详细学习,功能较 ...
最新文章
- smbpasswd 和 pdbedit 的区别
- hdu 1085 Holding Bin-Laden Captive!
- 如何给女朋友解释什么是“元宇宙”?
- 《JS设计模式笔记》 5,适配器模式
- 系统什么时候会用到swap分区?
- Dnn's Event Logging API
- Printf函数中%p代表什么数据类型
- FFT算法(Java实现)
- Ardunio开发实例-ADS1115模数转换器
- android测试基站,Android iPhone 手机查看基站信息
- mybatis系列-03-入门程序
- python案例3:货币转换---初级
- Win8 配置局域网可以访问IIS网站
- // #ifdef MP-WEIXIN微信小程序无效,不执行
- JZOJ 3518. 【NOIP2013模拟11.6A组】进化序列(evolve)
- mx3 android 5.1,魅蓝note3 稳定版Flyme 5.1.11.1[A]
- JAVA学习6-集合工具类、流
- win7系统设置电脑自动开机的操作方法
- 使用Dash快速构建你的数据可视化前端
- dz论坛 修改用户名