查看Docker容器中RabbitMQ的密码
要访问管理界面，需要在容器中开放15672端口，并在浏览器中访问`http://:15672`，其中``是RabbitMQ容器的IP地址。在管理界面中，可以使用默认的用户名`guest`和密码`guest`进行登录。需要注意的是，在使用管理界面时，要先确保15672端口在Docker容器中已经开放，
大数据与Hadoop入门理论
Hadoop入门理论
RabbitMQ的五种常见消费模型
在RabbitMQ中，消息的生产和消费是通过一系列的消费模型来管理的。本文将深入介绍RabbitMQ的五种常见消费模型，包括简单队列模型、工作队列模型、发布/订阅模型、路由模型和主题模型，在这种模型中，交换机会将消息路由到与它所绑定的队列匹配的路由键的队列中。如果有消息时，所有的消费者都会在接收到该
【Zookeeper】终端操作常用命令
zookeeper常用的命令
ZooKeeper实现分布式锁
【代码】ZooKeeper实现分布式锁。
hadoop报错——ResourceManager无法启动
本次的遇到的问题为启动Hadoop集群后，jps查看进程中，ResourceManage节点没有启动，导致无法访问http://localhost:8088，通过查看ResourceManage的启动日志，日志中给出的错误为，笔者初步判断为yarn-site.xml文件未填写Zookeeper的端口
centos搭建hadoop伪分布式
centos搭建hadoop伪分布式
SpringBoot结合Redisson实现分布式锁
有关于SpringBoot结合Redisson实现分布式锁到此就结束了。
Kafka详解
Apache Kafka 是一个分布式发布 - 订阅消息系统和一个强大的队列，可以处理大量的数据，并使你能够将消息从一个端点传递到另一个端点。Kafka 适合离线和在线消息消费。Kafka 消息保留在磁盘上，并在群集内复制以防止数据丢失。Kafka 构建在 ZooKeeper 同步服务之上。它与 A
VMware搭建Hadoop集群 for Windows（完整详细，实测可用）
hadoop集群搭建，完整详细。
Kafka的底层“真面目”
kafka是一个分布式消息队列。具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息，消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解耦、削峰、异步处理的作用。kafka对外使用topic的概念，生产者往topic里写消息，消费者从读消息。为了做到水平扩展，一个topic实际是
启动 Hadoop 后没有 dataNode 进程
原因：进行 hadoop 格式化的时候没有事先结束所有进程，或者多次进行了 format 导致的 datanode 的 clusterID 和 namenode 的 clusterID 不匹配，从而在启动后没有 datanode 进程。
大数据之hadoop入门
是一个分布式系统架构，Apache基金会所开发的。主要解决海量数据的存储和海量数据的分析计算问题。Hadoop通常指一个更广泛的概念，Hadoop生态圈（Hadoop, Hive, ）大数据之父：Doug Cutting，开发了Lucene，一个搜索引擎，类似谷歌搜索引擎。为了在对Lucene进行优
RabbitMQ 79b5ad38df29400fa52ef0085a14b02f
消息队列可以看作是一个存放消息的容器，其中，生产者负责生产数据到消息队列中，而消费者负责消费数据。消息队列是分布式系统中重要的组件，目前使用较多的消息队列有ActiveMQ，RabbitMQ，Kafka，RocketMQ。消息队列主要解决了应用耦合、异步处理、流量削锋等问题。
模拟宕机后kafka的重新分区
直接停掉192.168.233.133:9092 (broker.id = 5)恢复192.168.233.133:9092 (broker.id = 5)宕掉的broker已经不在leader和Isr中，Replicas依然还在。Isr中已经恢复看到了，但是leader中还是没有。leader也能
【RabbitMQ 实战】08 集群原理剖析
上一节，我们用docker-compose搭建了一个RabbitMQ集群，这一节我们来分析一下集群的原理。
Kafka是什么，以及如何使用SpringBoot对接Kafka
继上一次教大家手把手安装kafka后，今天我们直接来到入门实操教程，也就是使用SpringBoot该怎么对接和使用kafka。当然，在一开始我们也会比较细致的介绍一下kafka本身。那么话不多说，马上开始今天的学习吧
Kafka核心原理第一弹——更新中
kafka的通信主要发生于生产端和broker之间，broker和消费端之间，broker和broker之间，这些通信都是基于TCP协议进行的，大家自己看看网络课程，底层基于TCP连接和传输数据，应用层的协议，是Kafka自己自定义的所谓自定义协议，就是定好传输数据的格式，请求格式、响应格式，这样大
FlinkSQL kafka完整案例 可直接复制使用
完整案例，可以直接使用。flinksql 消费kafka整体来说是十分简单好用的，使用时门口较低，实时性又高
zookeeper 理论合集
用于管理分布式系统，使一个系统中的节点知道其他节点的状态。实现方式？通过维护和监控存储的数据变化，达到基于数据的集群一致性管理。简单说，zookeeper = 文件系统 + 监控通知机制配置维护、域名维护、分布式同步、服务发现等C：保证「，并不保证强一致性，在十几秒可以Sync到各个节点（如果保证强
