RabbitMQ下载与安装
我们在Centos7虚拟机中使用Docker来安装。
整合RabbitMQ实现消息异步发送
消息队列中间件消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削峰等问题。中间件最标准的用法是生产者生产消息传送到队列，消费者从队列中拿取消息并处理，生产者不用关心是谁来消费，消费者不用关心谁在生产消息，从而达到解耦的目的。在分布式的系统中，消息队列也会被用在很多其它的方面，
Zookeeper的数据版本控制与回滚
1.背景介绍Zookeeper是一个开源的分布式协同服务框架，用于构建分布式应用程序。它提供了一种可靠的、高性能的数据存储和同步机制，以及一种分布式协调服务。Zookeeper的数据版本控制和回滚功能是其核心特性之一，可以确保数据的一致性和可靠性。在分布式系统中，数据版本控制和回滚是非常重要的，因为
【分布式锁】06-Zookeeper实现分布式锁：可重入锁源码分析
前言前面已经讲解了Redis的客户端Redission是怎么实现分布式锁的，大多都深入到源码级别。在分布式系统中，常见的分布式锁实现方案还有Zookeeper，接下来会深入研究Zookeeper是如何来实现分布式锁的。Zookeeper初识文件系统Zookeeper维护一个类似文件系统的数据结构im
关于安装Dubbo+zookeeper过程中遇到的许多问题
dubbo安装启动，打包dubbo-admin项目错误，npm run dev 的各种错误，npm install 命令卡住不动，0308010C错误，Nodejs的版本问题
Hadoop 实战 | 词频统计WordCount
该程序基于Hadoop MapReduce框架实现了简单的单词计数功能，适用于大规模文本数据的并行处理。WordCount(词频统计)/* Map函数，处理每一行的文本 */input//Value使用Text类型表示文本行2：从文本中提取文档ID和实际文本内容snippet；3：使用空格、单引号和
RabbitMQ登录控制台显示--你与此网站的连接不是私密连接
RabbitMQ登录控制台显示--你与此网站的连接不是私密连接
RabbitMQ介绍及简单操作
MQ（消息队列），存放消息的队列，异步调用中的Broker，先进先出（FIFO）。Kafka每秒吞吐量达百万级；RockertMQ每秒吞吐量达十万级；RabbitMQ每秒吞吐量达十万级左右，但是它消息延迟仅仅是微秒的，可靠性高；考虑大部分情况下公司是达不到每秒吞吐量百万级的，所以选择RabbitMQ
java面试题：分布式和微服务的区别
分布式架构解决的是如何将一个大的系统划分为多个业务模块这些业务模块会分别部署到不同的机器上，通过接口进行数据交互的问题。微服务是指很小的服务，可以小到只完成一个功能，这个服务可以单独部署运行，不同服务之间通过rpc调用。分布式架构是将一个大的系统划分为多个业务模块，这些业务模块会分别部署到不同的机器
RabbitMQ系列之死信交换机的使用
在我们上一期的RabbitMQ博客系列的分享中我们分享了有关RabbitMQ中交换机的使用，其中讲解到什么是交换机，以及交换机的类型。主要讲述了直连交换机、主题交换机、扇形交换机的示例使用，还有一个死信交换机的示例使用没有讲到，本期博客就针对与死信交互机详细的讲解一下。死信交换机（Dead-Lett
Zookeeper简介
这是我的学习笔记，以便后面翻阅。ZooKeeper是一个分布式的、开放源码的分布式应用程序协调服务，它是Google的Chubby一个开源的实现，是Hadoop和Hbase的重要组件。ZooKeeper的目标是封装好复杂易出错的关键服务，将简单易用的接口和性能高效、功能稳定的系统提供给用户。它以Fa
RabbitMQ的五种消息模型
RabbitMQ提供了多种消息模型，官网上第6种是RPC不属于常规的消息队列。属于消息模型的是前5种：简单的一对一模型工作队列模型 ，一个生产者将消息分发给多个消费者发布/订阅模型 ，生产者发布消息，多个消费者同时收取路由模型 ，生产者通过关键字发送消息给特定消费者主题模型 ，路由模式基础上，在关键
RabbitMQ的基本消息属性与持久化
1.背景介绍RabbitMQ是一款开源的消息中间件，它使用AMQP(Advanced Message Queuing Protocol)协议来提供高性能、可靠的消息传递功能。在分布式系统中，RabbitMQ是一种常用的消息队列技术，可以帮助系统之间的解耦和异步通信。在RabbitMQ中，消息是由消息
Kafka入门及可视化界面推荐
*死信队列（Dead Letter Queue，简称 DLQ）**是消息中间件中的一种特殊队列。它主要用于处理无法被消费者正确处理的消息，通常是因为消息格式错误、处理失败、消费超时等情况导致的消息被"丢弃"或"死亡"的情况。当消息进入队列后，消费者会尝试处理它。如果处理失败，或者超过一定的重试次数仍
Hadoop分布式安装部署
多次初始化会造成数据丢失，也会造成hdfs集群主从角色互不识别，需要通过删除所有机器hadoop.tmp.dir目录（core-site.xml中设置该目录）重新进行format初始化！将主机器的hadoop文件使用scp命令复制到其余两台机器，因hadoop文件太大了，故本文三台机器的hadoop
PySpark（二）RDD基础、RDD常见算子
RDD定义叫做Dataset：一个数据集合，用于存放数据的。Distributed：RDD中的数据是分布式存储的，可用于分布式计算。Resilient：RDD中的数据可以存储在内存中或者磁盘中。RDD分区是RDD存储数据的最小单位，一份RDD数据实际上是被分成了很多分区RDD是逻辑的抽象概念，
RabbitMQ——死信队列介绍和项目应用
RabbitMQ——死信队列介绍和项目应用。如果你不还不了解死信队列，或者不知道其在项目中的应用的话，看完我的文章你一定会有所收获。
zookeeper
分部式系统管理框架，主要来解决分布式应用集群中应用系统的一致性问题：相当于各种分布式应用的 注册中心+文件系统+通知机制用于注册各种分布式应用，存储和管理这些分布式应用的元数据，如果应用或服务本身状态发送变化就会通知客户端。
centos7 安装部署kafka
kafka 在centos7的单机部署，基本操作
Kafka-服务端-GroupMetadataManager
consumer_offsets的某Partition记录某consumerGroup的GroupMotadata消息记录某ConsumerGroup对Partition的offset消息记录某ConsumerGroup对Partition1的offset消费记录某ConsumerGroup的Par
