OpenCloudOS 8 安装rabbitMQ 和Docker
买了一个新服务器，安装Docker和RabbitMQ。RabbitMq的安装完全参考了官方文档，不想踩坑的可以参考本篇博客。同时也列出了一些RabbitMQ常用的命令
2023年再不会Redis，就要被淘汰了
Redis实战系列，打造精品专栏。
微服务介绍(史上最全)
1、微服务简介简而言之，微服务架构风格是一种将单个应用程序开发为“一套小型服务”的方法，每个服务“运行在自己的进程中”，并通过轻量级机制(通常是HTTP资源API)进行通信。这些服务“围绕业务功能构建”，并通过全自动部署机制“独立部署”。“这些服务只有最低限度的集中管理”，可能是用不同的编程语言编写
三、Kafka消费者
消费者（Consumer）负责订阅Kafka主题，并从订阅的主题上拉取消息。与其它消息中间件不同的是：Kafka消费理念中还有一层消费者组（Consumer Group）的概念，一个消费者组包含多个消费者，消息发布到主题后，会投递给每个消费者组中的其中一个消费者。如上图，一个主题有四个分区，P0、P
分布式互联网——Web3.0
分布式互联网——Web3.0
九种分布式ID解决方案
背景：在复杂的分布式系统中，往往需要对大量的数据进行唯一标识，比如在对一个订单表进行了分库分表操作，这时候数据库的自增ID显然不能作为某个订单的唯一标识1、UUID2、数据库自增ID2.1、主键表2.2、ID自增步长设置3、号段模式4、Redis INCR5、雪花算法6、美团(Leaf)7、百度(U
『赠书活动 | 第三期』《分布式中间件核心原理与RocketMQ最佳实践》
『赠书活动 | 第三期』《分布式中间件核心原理与RocketMQ最佳实践》
『赠书活动 | 第一期』《分布式中间件核心原理与RocketMQ最佳实践》
『赠书活动 | 第一期』《分布式中间件核心原理与RocketMQ最佳实践》
SpringCloud Alibaba详解
Springcloud，Java,SpringcloudAlibaba
海豚调度器分布式部署
dolphinscheduler，海豚调度器分布式部署及问题记录
PySpark任务提交spark-submit参数设置一文详解
之前我们已经进行了pyspark环境的搭建以及经过jupyter notebook进行过开发以及实现了一系列的函数功能.但是一般我们跑spark都是在集群上面跑，只有测试一般在本地上测试，而且每个公司配置的spark集群的端口和设置的参数都有很大出入，故每种情况都有可能发生。所以一般任务提交的参数最
【kafka】三、kafka命令行操作
kafka命令行操作kafka的相关操作命令脚本文件在bin目录下。
如何查看kafka的topic的消费者组有没有积压
如何查看kafka的topic的消费者组有没有积压
Kafka入门使用
Kafka是一个分布式消息队列，因其可水平扩展和高吞吐率而被广泛使用！kafka的安装与使用（Windows）1、运行zookeeper，下载与安装可见：https://blog.csdn.net/z1790424577/article/details/1066607642、下载kafka，地址为：
Kafka消息中间件（Kafka与MQTT区别）
数据模型不同：Kafka以分布式的方式存储数据，数据按照主题分区存储，每个分区都有多个副本，可以通过分区键选择分区，消费者可以根据分区键并行消费数据。总的来说，Kafka更加适合处理大规模的实时数据，具有高吞吐量、低延迟和高可靠性的特点，而MQTT适用于轻量级的实时数据传输，具有简单易用和广泛支持的
gitlab服务器端hook最全详解
第一步，找到要配置仓库在 gitlab 中存储的路径，但因 gitlab 的仓库自某个版本开始采用 hash 存储，我们想要知道仓库对应的物理路径，可以通过管理员账号拿到对应的物理路径。对于全局的hook，配置脚本后gitlab系统上所有仓库都受影响，开关在配置文件gitlab.rb中（默认安装路径
【Kafka】MM2同步Kafka集群时如何自定义复制策略(ReplicationPolicy)
使用MM2同步集群数据，默认的复制策略为：DefaultReplicationPolicy，这个策略会把同步至目标集群的topic都加上一个源集群别名的前缀，比如源集群别名为A，topic为：bi-log，该topic同步到目标集群后会变成：A.bi-log，为啥这么做呢，就是为了避免双向同步的场景
Kafka 入门篇（二）
生产者分区机制分区策略顺序轮询随机轮询按照 key 进行消息保存生产者压缩机制Kafka 压缩是什么Kafka 重要参数配置key.serializervalue.serializeracksbuffer.memorycompression.typeretriesbatch.sizeclient.i
kafka操作3
粘性分区是kafka从0.11.x版本开始引入这种分配策略，首先会尽量均衡的放置分区到消费者上面，在出现同一消费者组内消费者出现问题的时候，会尽量保持原有分配的分区不变化。虽然自动提交offset十分简单便利，但由于其是基于时间提交的，开发人员难以把握offset提交的时机，因此kafka还提供了手
zookeeper未授权漏洞实战+复现
测试授权目标时，通过工具扫描出了zookeeper未授权（CVE-2014-085）之后就是进行漏洞利用由于目标系统较敏感，没有执行其它操作，所以准备本地复现Zookeeper安装部署之后默认情况下不需要任何身份验证，造成攻击者可以远程利用Zookeeper，安装zookeeper后 默认端口为21
