1     背景 最近在新项目开发中遇到一个有趣的问题，如何在 SpringBoot 项目中控制 RocketMQ 消费线程数量。如何设置单个 topic 消费线程的最小数量和最大数量，用来区分不同 topic 吞吐量不同。 我们先介绍一下 RocketMQ 消息监听再来说明 RocketMQ 消费线程。 2     RocketMQ 消息监听 设置消费者组为 my_consumer_group，监听 TopicTest 队列，并使用并发消息监听器MessageList

应用场景 多线程对同一资源的竞争，需要用到锁，例如Java自带的Synchronized、ReentrantLock。 但只能用于单机系统中，如果涉及到分布式环境（多机器）的资源竞争，则需要分布式锁。 分布式锁的主要作用： 保证数据的正确性： 比如：秒杀的时候防止商品超卖，表单重复提交，接口幂等性。 避免重复处理数据： 比如：调度任务在多台机器重复执行，缓存过期所有请求都去加载数据库。 分布式锁的主要特性： 互斥：同一时刻只能有一个线程获得锁。 可重入：当一个线程获取锁后，还可以

1. 概述 MQ(Message Quene) : 翻译为消息队列,通过典型的生产者和消费者模型,生产者不断向消息队列中生产消息，消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的，而且只关心消息的发送和接收，没有业务逻辑的侵入,轻松的实现系统间解耦。别名为消息中间件` 通过利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。 1.1 AMQP 协议 AMQP（advanced message queuing protocol）`在2003

这篇文章主要介绍了linux 系统安装zookeeper 服务的方法，非常不错，具有一定的参考借鉴价值,需要的朋友可以参考下

一、前言 最近正好面试，发现各大公司对于spring cloud的越来越重视，已经是微服务时代的基础技能了，于是特别针对spring cloud的常用组件做阐述，并且完整搭建一个spring cloud架构的项目，供需要的人参考 二、组件介绍 （针对以下概念了解的可直接跳过看后面的搭建过程） 要理解spring cloud架构的组件，首先要理解微服务架构，什么是微服务？粗略的讲就是随着单机架构包含的service层越来越多，越来越大，大家开始把同功能属性的service层单独抽离出来做

前言 最近的 chatGPT 很火爆，听说取代程序员指日可待。 于是和 TA 聊了一会儿分布式锁，我的感受是，超过大部分程序员的水平。 Q1: 谈一谈 java 通过 redis 实现分布式 锁 chatGPT: Java通过Redis实现分布式锁，是在多个Java应用程序之间实现同步的一种方式。通过Redis的原子性和高性能，实现了分布式锁的可靠性和高效性。 具体实现步骤如下： 获取Redis连接：在Java应用程序中，使用Java Redis客户端连接到Redis数据库

环境要求docker、docker-compose。 可参考链接：https://blog.csdn.net/pan5633/article/details/128663684https://blog.csdn.net/pan5633/article/details/128663684 1、下载zookeeper、kafka、efak镜像 docker pull confluentinc/cp-zookeeper:6.1.1 docker pull confluentinc/cp-kafk

程序包下载 官网下载地址 下载解压后如下！ 注意，zookeeper需要java环境，如果配置了JAVA_HOME那最好，如果没配置就会出现点击bin下的zkServer.cmd后CMD窗口一闪而过 修改配置 如果本地端口没有特别要求可以直接复制conf下的zoo_sample.cfg跟名为zoo.cfg zookeeper端口！ 启动zookeeper 如果双击\bin\zkServer.cmd一闪而过，那么打开zkServer.cmd文件，末尾添加pause 可见cmd报错如

1、直接在创建表时添加该列并声明默认值，如下： CREATE TABLE `table1` ( `id` int(11) NOT NULL, `createtime` timestamp NULL default CURRENT_TIMESTAMP, `updatetime` timestamp NULL default CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

发布到测试环境 测试环境发布完成后，测试通过，可以直接导出到生产环境，因此生产环境的部署和测试环境的部署大同小异。 略~ 发布到胜场环境 BI报表开发完成后，要把测试环境的URL，和需要的参数，一起发给OA。 OA测试通过后，就可以上线了。 这些操作都是在堡垒机上完成的。 ETL数据准备 ETL是将业务系统的数据经过抽取、清洗转换之后加载到数据仓库的过程。 目的是将企业中的分散、零乱、标准不统一的数据整合到一起，为企业的决策提供分析依据 BIAPP---->BI-

哈喽！大家好，我是小奇，一位不靠谱的程序员 小奇打算以轻松幽默的对话方式来分享一些技术，如果你觉得通过小奇的文章学到了东西，那就给小奇一个赞吧 文章持续更新，可以微信搜索【小奇JAVA面试】第一时间阅读，回复【资料】更有我为大家准备的福利哟！ 一、前言 今天清明假期，赶上北京玉渊潭公园樱花盛开，女朋友非要拉着我去看樱花，我头一天晚上干文章到三点半，我很想睡觉，但是没办法，军令难违呀。 来到这里犹如来到了花的海洋，让我浑身的艺术细菌开始躁动，我忍不住吟

文章部分知识来源千峰教育讲解的zookeeper当中！ 1.什么是ZAB协议 zookeeper作为⾮常重要的分布式协调组件，需要进⾏集群部署，集群中会以⼀主多从的形式进⾏部署。zookeeper为了保证数据的⼀致性，使⽤了ZAB（Zookeeper Atomic Broadcast）协议，这个协议解决了Zookeeper的崩溃恢复和主从数据同步的问题。 下图就是zk集群的结构，主节点主要负责节点的写，也能负责读，其他从节点只有读的权限。虽然从节点不负责写数据，但是他永远会