分布式
-
RabbitMQ的几种消息确认机制详细介绍
前言:大家好,我是小威,24届毕业生,在一家满意的公司实习。本篇文章将详细介绍RabbitMQ的几种消息确认机制。 如果文章有什么需要改进的地方还请大佬不吝赐教👏&…
-
Spark与IoT与智能设备
1.背景介绍 随着互联网的普及和技术的不断发展,物联网(IoT)已经成为了我们生活中不可或缺的一部分。智能设备、自动化、大数据等技术已经深入到我们的生活中,为我们提供了更方便、更智…
-
浅析redis setIfAbsent的用法及在分布式锁上的应用及同步锁的缺陷
浅析redis setIfAbsent的用法及在分布式锁上的应用及同步锁的缺陷 一、业务场景:同步锁的问题与分布式锁的应用 1、redis的基本命令 (1)SETNX命令(SET …
-
kafka报错:could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClie
执行kafka命令报错 排查: 命令中的kafka地址和端口是否填写正确 可查看config目录下的server.properties中的listeners=PLAINTEXT:…
-
高可用分布式部署Spark、完整详细部署教程
前言 Spark 是 UC Berkeley AMP Lab 开源的通用分布式并行计算框架。 Spark基于map reduce算法实现的分布式计算,拥有Hadoop MapRed…
-
【Rabbitmq详解】
文章目录 消息中间件 一、何为消息中间件 二、消息队列协议 消息队列持久化 三、持久化 消息的分发策略-高可用高可靠 四、消息分发策略 五、消息分发策略的机制对比 六、消息队列高可…
-
RabbitMQ 部署与配置[CentOS7]
# RabbitMQ,Erlang 版本包对应 https://rabbitmq.com/which-erlang.html#eol-series cd /usr/local/sr…
-
第01讲:大话 Hadoop 生态圈
从故事开始:一个电商平台的用户行为分析需求 最近,就职于一家电商公司的小李遇到了一些麻烦事,因为领导突然给他布置了一个任务,要把他们电商平台里所有的用户在 PC 端和 App 上的…
-
【技术分享】四、RabbitMQ “延时队列”
前言 延时的含义为 等待一段时间,应用到RabbitMQ 消息 发布/订阅 模型中的概念就是,拿到消息后不想立即消费,等待一段时间再执行。 ex: 定时任务:十分钟后执行某种操作。…
-
Rabbitmq的安装与使用(Linux版)
目录 Rabbitmq安装 1.在Ubuntu上安装RabbitMQ: 打开终端,运行以下命令以更新软件包列表: 安装RabbitMQ: 安装完成后,RabbitMQ服务会自动启动…
-
深入Kafka broker
一、协议设计 颗粒度, PRODUCE和FETCH中支持topic,partion等层级的颗粒度; 测试友好, 基于session_id和epoch确定一条拉取链路的fetch s…
-
kafka max.poll.records用法介绍
一、max.poll.records是什么 max.poll.records是Kafka consumer的一个配置参数,表示consumer一次从Kafka broker中拉取的…
-
Kafka的@KafkaListener注解参数详解
@KafkaListener 注解提供了许多可配置的参数,以便更灵活地定制 Kafka 消息监听器的行为。 topics: 描述: 指定监听的 Kafka 主题,可以是一个字符串数…
-
MQ回顾之kafka速通
不定期更新 官网概念自查 官网:Apache Kafka kafka结构 和kafka相关的关键名词有:Producer、Broker、Topic、Partition、Replic…
-
Kafka收发消息核心参数详解
这一部分主要是从客户端使用的角度来理解Kakfa的重要机制。重点依然是要建立自己脑海中的Kafka消费模型。Kafka的HighLevel API使用是非常简单的,所以梳理模型时也…
