Zookeeper 安装与部署
Zookeeper 使用的基本时间,服务器之间或客户端与服务器之间维持心跳的时间间隔,也就是每个 tickTime 时间就会发送一个心跳,时间单位为毫秒。注意:如果不是第一次搭建集群,那么就把 Zookeeper 安装目录下的 zkData目录删除,并且把 logs 目录也删除。时能容忍的最多心跳数
RabbitMQ(五)之延迟消息
生产者发送消息时指定一个时间,消费者不会立刻收到消息,而是在才收到消息。:设置在一定时间之后才执行的任务延迟消息的实现有两种:死信交换机,延迟消息插件。
从0开始学人工智能测试节选:Spark -- 结构化数据领域中测试人员的万金油技术(三)
分布式计算的原理总结一句话就是:分而治之。所有的分布式软件都是分而治之的思路, 当数据量大到了单机无法承载的时候, 那么就利用上面的原理 ,把数据分布到不同的机器中。这样的架构也就可以支持横向扩展,也就是当存储软件的性能或者磁盘空间不够用时, 只要加机器就可以了。
kafka进阶核心原理详解:案例解析(第11天)
本文通过案例的方式详解kafka进阶核心原理:副本机制,数据位移,分发策略,负载均衡,数据积压等问题
Redisson分布式Redis锁,tryLock方法详解
在 Java 中,RLock是 Redisson 库中提供的一个分布式锁接口,用于实现基于 Redis 的分布式锁。RLock的tryLock方法用于尝试获取锁,并在特定的时间内等待获取锁。
Zookeeper 面试题(一)
1. ZooKeeper 适合哪些应用场景?2. 简述什么是Zookeeper ?3. 简述Zookeeper 目录结构和作用 ?4. 简述Zookeeper的工作原理 ?5. 简述zoo.cfg 配置项目和对应的作用 ?6. 请列举Zookeeper的常用命令 ?7. 列举Zookeeper服务启
完美解决 RabbitMQ可视化界面Overview不显示折线图和队列不显示Messages
今天使用docker部署了一个RabbitMQ,浏览器打开15672可视化页面发送消息后不显示交换机中的Overview中的折线图,还有队列中的Messages,因为我要看队列中的消息数量。5. 退出容器 exit6. 重启容器。
Jdk17连接zookeeper报错:127.0.0.1/<unresolved>:2181
Jdk17连接zookeeper报错
Kafka SASL认证与ACL配置
SASL/PLAIN,这种方式其实就是一个的认证方式,不过它有很多缺陷,比如用户名密码是存储在文件中,等等!建议大家用SASL/SCRAM的方式 ,这种方式 用户名/密码是存储在zookeeper中,能够。该种认证方式还会使用sha256或sha512对,安全性相对会高一些。本文主要介绍SASL/P
这也许是让你了解和使用RabbitMQ的方式
每个RabbitTemplate只能配置一个ReturnCallback,因此需要在项目加载时配置可以采用配置类去实现ApplicationContextAware的bean完成消息发送,获取到所有bean后去获取RabbitTemplate,这样子就可以保证是唯一的,切忌在函数 发送消息的时候去调
深入了解 RabbitMQ:构建可靠消息传递系统的关键
在现代分布式应用程序开发中,构建可靠的消息传递系统至关重要。RabbitMQ 作为一款强大的消息代理软件,为开发人员提供了丰富的工具和解决方案。本文将深入探讨 RabbitMQ 的核心概念、工作原理以及其在实际应用中的应用场景。
13、Kafka ------ kafka 消费者API用法(消费者消费消息代码演示)
Kafka ------ kafka 消费者API用法(消费者消费消息代码演示)
RabbitMQ面试题
RabbitMQ高频面试题。
大数据基础知识-Hadoop、HBase、Hive一篇搞定
相应的,数据库由于规模较小,因此可以支持的数据规模较小,一般单张表中能存储百万条数据(最新版的MySQL经过优化,单表中可以存储千万条或者上亿条数据,即使是一亿条数据,也就10GB大小,且此时效率会非常低)。HBase数据存储依靠HDFS,HDFS存储数据具有一次写入,多次读取的特点,其不支持对数据
Spark on Yarn安装配置
今天我们讲解Spark的安装配置,spark的部署分为两种,一种是Standalone模式,另一种就是on yarn 模式,我们这一节着重讲解on yarn 模式,因为符合生产活动,但也会提到Standalone模式。
RabbitMQ笔记
比较常用的就是以上三种:直连(DirectExchange),发布订阅(FanoutExchange),通配符(TopicExchange)。熟练运用这三种交换机类型,基本上可以解决大部分的业务场景。实际上稍微思考一下,可以发现通配符(TopicExchange)这种模式其实是可以达到直连(Dire
RabbitMq踩坑记录
检查你的连接配置,很可能是你的yml里面的端口配置的是15672,更改为5672即可;2、连接报错:org.springframework.amqp.AmqpIOException: java.io.IOException。step1:登陆rabbitmq的管理页面(PS:地址为localhost:
基于Hadoop的旅行推荐系统
随着互联网和移动设备的普及,旅游已经成为人们生活中不可或缺的一部分。然而,海量的旅游信息和多样化的旅行需求让旅行计划变得复杂且费时。为了解决这一问题,我们设计并实现了基于HadoopHivePandasFlask和ECharts的零陵古城旅行推荐系统。该系统通过分析大量用户行为数据和旅游资源信息,提
【RabbitMQ】使用SpringAMQP的Publish/Subscribe(发布/订阅)
*发布(Publish)、订阅(Subscribe):**允许将同一个消息发送给多个消费者**注意:**exchange负责消息路由,而不是存储,路由失败则消息丢失。