kafka查看topic的偏移量
1. 列举消费者2. 查看偏移量3. 移动至最新。
Zookeeper基础命令操作
为什么我不完全主张自学？①平台上的大牛基本上都有很多年的工作经验了，你有没有想过之前行业的门槛是什么样的，现在行业门槛是什么样的？以前企业对于程序员能力要求没有这么高，甚至十多年前你只要会写个“Hello World”，你都可以入门这个行业，所以以前要入门是完全可以入门的。②现在也有一些优秀的年轻大
【RabbitMQ】初识 RabbitMQ
本期内容主要介绍 MQ 是什么，以及它在不同场景下的作用，同时对比了三种目前主流的 MQ，介绍 RabbitMQ 是什么。
掌握Kafka事务，看这篇就够了
先赞后看，南哥助你Java进阶一大半Kafka事务实际上引入了原子多分区写入的概念，播客画了以下流程图，展示了事务在分区级别如何工作。我是南哥，一个Java学习与进阶的领路人，相信对你通关面试、拿下Offer进入心心念念的公司有所帮助。
zookeeper之分布式队列
JVM，JAVA集合，JAVA多线程并发，JAVA基础，Spring原理，微服务，Netty与RPC，网络，日志，Zookeeper，Kafka，RabbitMQ，Hbase，MongoDB，Cassandra，设计模式，负载均衡，数据库，一致性哈希，JAVA算法，数据结构，加密算法，分布式缓存，H
RabbitMQ-高级
3.1.2或者也可以直接引入MQ，解耦调用过程。
RabbitMQ--死信队列
以上的内容就是说明死信队列是为了解决死信的问题，什么是死信呢：就是消息在发送之后可能因为种种原因没有被消费的消息就变成了死信。我们为了不将死信直接删除，就设置了死信队列。1.消息被消费者拒绝2.发送的消息带有时间，时间到了还是没有被消费3.队列有生存时间，队列生存时间到了，它里面未来得及被消费的消息
环境搭建--Hadoop完全分布式
Hadoop的完全分布式安装
OJ在线评测系统 微服务 用分布式消息队列 RabbitMQ 解耦判题服务和题目服务 手搓交换机和队列 实现项目异步化
分布式消息队列是一种用于异步通信的系统，它允许不同的应用程序或服务之间传递消息。消息队列的核心理念是将消息存储在一个队列中，发送方可以将消息发送到队列，而接收方则可以在适当的时候从队列中读取消息。这种机制有助于解耦应用程序，提高系统的可扩展性和可靠性。：发送方和接收方可以在不同的时间工作，不必直接交
hadoop全分布式搭建（三台虚拟机，一个主节点，两个从节点）
出现的信息即为压缩包所在地址，如果没有出现可能在桌面/home目录下，或者上传不成功。在windowns系统的浏览器中输入hadoop101的IP:9870，可以看到文件管理。在windowns系统的浏览器中输入hadoop102的IP:8088，可以看到资源管理。进入/opt/module/had
RabbitMQ概述
RabbitMQ是一个基于AMQP（高级消息队列协议）的开源信息代理软件（简称消息中间件），它使用Erlang语言编写，由于Erlang语言的高并发特性，RabbitMQ在性能上表现优异。RabbitMQ支持集群部署，以提高系统的可靠性和扩展性。在集群部署中，可以将多个RabbitMQ节点组合在一起
【RabbitMq源码阅读】分析RabbitMq发送消息源码
1、通过Channel往Rabbit服务端发送消息。2、通过PRC申明交换机，队列，绑定等信息。3、通过AMQP协议发送消息。
rabbitmq消费者应答模式
RabbitMQ 中的消息应答模式主要包括两种：自动应答（Automatic Acknowledgement）和手动应答（Manual Acknowledgement）。不在乎消费者对消息处理是否成功，都会告诉队列删除消息。如果处理消息失败，实现自动补偿（队列投递过去 重新处理）。在手动应答模式下，
kafka在windows上的启动
kafka在window上的启动
仿RabbitMQ实现消息队列客户端
在RabbitMQ中，提供服务的是信道，因此在客⼾端的实现中，弱化了Client客⼾端的概念，也就是说在RabbitMQ中并不会向⽤⼾展⽰⽹络通信的概念出来，⽽是以⼀种提供服务的形式来体现。同样的，客⼾端也有信道，其功能与服务端⼏乎⼀致，或者说不管是客⼾端的channel还是服务端的channel都
安装JAVA环境和Hadoop3.1.3完全分布式
修改主机名称：hostnamectl set-hostname master(slave1或slave2)查看主机名称：cat /etc/hostname切换用户：su root查看ip:ip addr在master添加三台虚拟机ip地址：vi/etc/hosts三台虚拟机都生成密钥：ssh-key
分布式数据库——HBase基本操作
以下图片则是hbase启动成功~接下来就可以开始建表啦~count '表名'
RabbitMQ进阶--保证消息的可靠性
在我们使用消息队列时，是否考虑过一个问题，如果在发送消息的时候存在网络波动，会引发哪些问题？举个例子，我们在购物的时候，已经支付完成，但是消息没有正确的被消费，前端发送请求查询支付状态时，肯定是查询交易服务状态，会发现业务订单未支付，而用户自己知道已经支付成功，这就导致用户体验不一致。因此，这里我们
使用rabbitmq发送消息和caffeineCache保存本地
- 导入mq依赖-->-- 本地缓存依赖-->
RabbitMQ的各类工作模式介绍
P:, 也就是要发送消息的程序C:,消息的接收者Queue:, 图中⻩⾊背景部分. 类似⼀个邮箱, 可以缓存消息;⽣产者向其中投递消息, 消费者从其中取出消息.: ⼀个⽣产者P，⼀个消费者C, 消息只能被消费⼀次. 也称为点对点(Point-to-Point)模式.: 消息只能被单个消费者处理。
