RabbitMQ之动态创建队列与绑定交换机和监听器
为什么需要动态创建队列与绑定交换机？我在写项目的时候遇到这么个问题，我数据库中存在一个字段messageType指定为消息类型，消息类型存在三种，一种是通知类，一种是验证码类，一种是活动类。并且对应的，要将消息进行不同渠道的分发，还存在一个channelType，而他又存在QQ邮箱，手机短信、服务号
kafka 开启认证授权
kafka Kraft 模式 用户名密码 认证
Kafka官方生产者和消费者脚本简单使用
这就可以见到测试kafka对应topic了.
【kafka】实时数据存储
kafka是一个高吞吐的分布式消息系统分区：分布式副本：容错性。
zookeeper单机版的搭建
4.通过vim修改配置文件夹，将dataDir 修改成刚才所建的data文件夹。./zkServer.sh status # 查看启动状态。./zkServer.sh restart # 重启。./zkServer.sh stop # 停止。./zkCli.sh # 查看zk客户端。2.创建data
ubantu安装kafka
在官网下载所需版本，我这里以kafka_2.12-2.7.0为例。
数据处理生产环境_利用MurmurHash3算法在Spark和Scala中生成随机颜色
生产环境中的前端轨迹是没有颜色的，我这边作为数据工程的应用层，必须支撑给不同的编号 数据一个随机颜色，如果数据中编号一样了，也要支持同一颜色目标是同一种随时颜色。此代码定义了一个函数，使用MurmurHash3算法根据输入的种子生成随机颜色。代码主要功能是使用自定义的函数（UDF）将这个函数应用到D
zookeeper全分布安装
1.zookeeper：一个领导者（leader），多个跟随者（follower）组成的集群2.集群中只要有半数以上节点存活，zookeeper集群就能正常服务3.全局数据一致：每个Server保存一份相同的数据副本，Client无论连接到哪个Server，数据都是一致的4.更新请求顺序进行，来自同
RabbitMQ - 修改日志和数据存放路径
默认情况下，RabbitMQ会将日志和数据存储在预定义的路径下。然而，有时候我们希望修改这些路径，以满足特定的需求。本文将详细介绍如何修改RabbitMQ的日志和数据存放路径，并提供相应的源代码示例。通过修改RabbitMQ的配置文件，我们可以轻松地修改日志和数据存放路径。在修改配置文件后，记得重启
RabbitMQ 安装和使用
AMQP，即 Advanced Message Queuing Protocol（英[ˈprəʊtəkɒl]）（高级消息队列协议），是一个网络协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。
Zookeeper 实战 | Zookeeper 和Spring Cloud相结合解决分布式锁、服务注册与发现、配置管理
Zookeeper 是一个开源的分布式协调服务，它起源于 Google 的 Chubby 项目，并成为 Hadoop 分布式系统的基础组件。Zookeeper 提供了一组简单的原语集，分布式应用程序可以基于这些原语实现同步服务、配置维护和命名服务等。Zookeeper 主要角色是协调器（Contro
解密Kafka主题的分区策略：提升实时数据处理的关键
理解Kafka主题的分区策略对于构建高性能的消息传递系统至关重要。深入探讨Kafka分区策略的重要性以及如何在分布式消息传递中使用它。Kafka是一个分布式消息传递系统，用于实现高吞吐量的数据流。消息传递系统的核心是主题（Topics），而这些主题可以包含多个分区（Partitions）。分区是Ka
分布式锁，分布式锁应该具备哪些条件，分布式锁的实现方式有：基于Zookeeper实现、Redis实现、数据库实现
随着互联网技术的不断发展，用户量的不断增加，越来越多的业务场景需要用到分布式系统。分布式系统有一个著名的理论CAP，指在一个分布式系统中，最多只能同时满足下面三项中的两项一致性）：在分布式系统中的所有数据备份，在同一时刻是否同样的值（等同于所有节点访问同一份最新的数据副本）可用性）：保证每个请求不管
开源框架APM工具--SkyWalking原理与应用
随着业务系统的不断发展、微服务架构的演进，从原来的单体应用架构、垂直应用架构、分布式 SOA 架构到现在的微服务架构，系统逐步走向微服务化以适应用户高并发请求等需求。在微服务架构中，一个业务操作往往需要多个服务间协同操作，而在一个复杂的系统中出现问题的时候，需要我们能够快速的分析并定位到问题的原因，
rabbitMq (2)
本文主要内容：消息应答 , rabbitmq 持久化 ， 发布确认 , 几种分发模式
【Hadoop实战】Hadoop指标系统V2分析
hadoop的指标系统V2
rabbitMQ rascal/amqplib报错 Error: Unexpected close 排查
这意味着客户端的 TCP 连接在 AMQP 0-9-1（该客户端的）连接之前关闭。TCP协议通过KeepAlive机制判断是应用程序掉线了还是确实没有数据传输，当超过一段时间之后，TCP自动发送一个数据为空的报文给对方，如果对方回应了这个报文，说明对方还在线，连接可以继续保持，如果对方没有报文返回，
rabbitmq 集群搭建
RabbitMQ集群是一组RabbitMQ节点（broker）的集合，它们一起工作以提供高可用性和可伸缩性服务。RabbitMQ集群中的节点可以在同一物理服务器或不同的物理服务器上运行。RabbitMQ集群的工作原理是，每个节点在一个虚拟主机中提供服务，并通过网络进行通信和数据同步。当一个节点在集群
微服务面试问题小结（ 微服务、分布式、MQ、网关、zookeeper、nginx）
nginx几种常见的负载均衡策略。根据权重负载均衡：在轮询策略的基础上指定轮询的几率根据ip负载均衡：指定负载均衡器按照基于客户端IP的分配方式，这个方法确保了相同的客户端的请求一直发送到相同的服务器，以保证session会话。这样每个访客都固定访问一个后端服务器，可以解决session不能跨服务器
Spark 基础知识点
Spark 基础知识点
