首页 > 其他分享 >【kafka 消息队列&基础命令】

【kafka 消息队列&基础命令】

时间:2023-02-03 14:46:00浏览次数:39  
标签:订阅 消费 队列 模式 kafka 命令 消息

一、kafka的定义

传统定义:kafka是一个分布式的基于发布/订阅模式的消息队列

发布订阅:消息的发布者不会将消息直接发送给特定的订阅者,而是将发布的消息分为不同的类别,订阅者只接收感兴趣的消息

1、消息队列

目前常见的消息队列产品主要有:Kafka、ActiveMQ、RabbitMQ,大数据常用kafka

1)传统消息队列的应用场景

主要应用的场景包括:缓存/消峰、解耦和异步通信

  • 缓存/消峰:有助于控制和优化数据流经过系统的速度,解决生产消息和消费消息的处理速度不一致的情况
  • 解耦:允许你独立的扩展或修改两边的处理过程,只要确保他们遵守同样的接口约束
  • 异步通信:允许用于把一个消息放入队列,但并不立即处理它,然后在需要的时候再去处理 (先处理重要的消息,不重要的消息后续在慢慢的处理)

2)消息队列的两种模式

  • 点对点模式:消费者主动拉取数据,消息收到后清除消息
  • 发布/订阅模式
    • 可以有多个topic主题(浏览、点赞、收藏、评论)
    • 消费者消费数据后,不删除数据  (a消费完以后b仍然可以消费)
    • 买个消费者相互独立,都可以消费到数据

 

 2、

 

标签:订阅,消费,队列,模式,kafka,命令,消息
From: https://www.cnblogs.com/frankruby/p/17089227.html

相关文章

  • 高性能内存队列Disruptor
    1背景Disruptor是英国外汇交易公司LMAX开发的一个高性能队列,研发的初衷是解决内存队列的延迟问题(在性能测试中发现竟然与I/O操作处于同样的数量级)。基于Disruptor开发的系......
  • MATLAB-常见命令使用
    ✅作者简介:热爱科研的算法开发者,Python、Matlab项目可交流、沟通、学习。......
  • C#使用命令行打开diskpart修改盘符
    参考链接:https://www.cnblogs.com/k98091518/p/6019296.html https://learn.microsoft.com/zh-cn/windows-server/administration/windows-commands/diskpartdiskpart......
  • 双端队列
    题目描述:达达现在碰到了一个棘手的问题,有N个整数需要排序。达达手头能用的工具就是若干个双端队列。她从1到N需要依次处理这N个数,对于每个数,达达能做以下两件事:1.新建一个双......
  • docker 命令
    查询dockersearch    |过滤 --filter=下载拉去dockerpull   |制定版本 dockerpullmysql:5.7删除dockerrmi-f  新建容器并启动dockerru......
  • docker 安装kafka(单机版本)
    网上大多数是这个镜像zookeeper镜像dockerpullwurstmeister/zookeeperkafka镜像dockerpullwurstmeister/kafka  dockerrun-d-p2181:2181--namezookeepe......
  • springcloud:安装rabbitmq并配置延迟队列插件
    0.引言本期主要讲解如何利用docker快速安装rabbitmq并且配置延迟队列插件1.docker安装1.1安装rabbitmq1、下载镜像dockerpullrabbitmq2、安装镜像dockerrun-d--host......
  • 栈和队列
    栈和队列都是通过动态集合来存储数据,在栈和队列中添加和删除数据都是预先设定的。在栈(Stack)中,被删除的元素是最近添加的元素,所以栈的实现方式是后进先出(Last-in,First-out......
  • 在Java中出现运行命令过长如何解决
    在启动程序时出现如下代码:  只需在.idea中找到workspace.xml文件,在如下位置加上代码  "dynamic.classpath":"true",  ......
  • CMD 基本的Dos命令
    CMD基本的Dos命令打开CMD的方式开始+系统+命令提示符Win键+R输入cmd打开控制台(推荐使用)在桌面任意位置按住shift键+鼠标右键,点击打开powershell窗口在资源......