chengxy-nds / springboot-notebook

Springboot-Notebook 一个以 springboot 为基础开发框架， 整合 Redis 、Mysql 、 Rabbitmq 、ES 、MongoDB、sharding-jdbc 分库分表、zookeeper 、web人脸识别 、实时消息推送 、SQL优化、注册中心 、数据脱敏 等互联网主流技术， 文章图解理论配合实战案例，实现开发中常见功能点的综合项目。 本着拿来即用的原则，助力于减少开发者在工作中的学习成本。

Springboot-Notebook

说在前边

本项目全部案例详细教程，同步在 个人公众号：程序员小富 , 欢迎关注交流指正，加群学习！

作者小富，目前就职某大厂，点击一起来了解下

项目介绍

Springboot-Notebook 一个以 springboot 为基础开发框架， 整合 Redis 、Mysql 、 Rabbitmq 、ES 、MongoDB、sharding-jdbc 分库分表、zookeeper 、web人脸识别 、实时消息推送 、SQL优化、注册中心 、数据脱敏 等互联网主流技术， 文章图解理论配合实战案例，实现开发中常见功能点的综合项目。 本着拿来即用的原则，助力于减少开发者在工作中的学习成本。

中间件	已整合的功能
分库分表	sharding-jdbc
缓存	Redis
数据库	Mysql
消息队列	Rabbitmq 、kafka
搜索引擎	ES
非关系数据库	MongoDB
注册中心	zookeeper、nacos
虹软SDK	web人脸识别
消息推送	7种实时消息推送
更多	......

🤝 关于作者

大家好，我是本站作者小富～ 从事编程工作十余年，在大厂狗东做过架构相关工作.

写作分享很多年，将工作中的所遇到的问题、用到技术梳理成文章分享出来和小伙伴们共勉，希望对大家有用！

目前在持续的更新三个系列的专题《Springboot开发实战100例》、《ShardingSphere5.x分库分表原理与实战》、《面试八股》

🔥技术群 & 资料

如果遇到了问题，可以通过以下方式联系我。也欢迎加入我们的技术交流群，群里都是热心的Javaer，会讨论技术问题，互相帮助，相信能让您获得更多收获。

在我的公众号：程序员小富，内提供了一些资料：

• 技术书籍公众号内回复[ pdf ] Get。

• 面试笔记、springcloud进阶实战PDF，公众号内回复[ 1222 ] Get。

• 原创《ShardingSphere5.x分库分表原理与实战》PDF，公众号内回复[ 分库分表 ] Get。

关注公众号：程序员小富	接搜微信号：xiaofucode

系列专题

《ShardingSphere5.x分库分表原理与实战》

内容同步在小富的个人网站：xiaofucode.com，现有章节已经生成了 PDF，欢迎下载！

获取方式：《ShardingSphere5.x分库分表原理与实战》PDF，公众号：程序员小富内回复[ 分库分表 ] Get。

系列往期精选：

• 好好的系统，为什么要分库分表？
• 分库分表的 21 条法则，hold 住！
• 2 种方式快速实现分库分表，轻松拿捏！
• 分库分表如何管理不同实例中几万张分片表？
• 一口气搞懂分库分表 12 种分片算法，大厂都在用
• DIY 3 种分库分表分片算法，自己写的轮子才吊！
• 持续更新中...

《Springboot 开发场景 100 例》

Springboot101 上百个 Springboot 开发实战案例分享，开发工作拿来即用，省下的时间就是生活。内容同步在小富的个人网站：xiaofucode.com!

系列往期精选：

• springboot一行代码实现文件上传20个平台
• springboot + rabbitmq + MQTT 实现智能家居
• springboot + redis 分布式限流器
• springboot注解实现动态数据源切换
• springboot + Knife4j 集成API文档
• springboot + oauth2.0实战
• springboot + canal实现 mysql+binlog 监控
• springboot + jsoup 实现爬虫
• 更多文章...

面试八股

内容同步在小富的个人网站：xiaofucode.com。

• 《spring cloud alibaba 微服务全家桶》
• 《面试笔记》
• 《LeetCode算法笔记》

获取方式：公众号：程序员小富 , 回复[ 1222 ]

电子书

2000本电子书 下载

优质文章精选

Java 开发技巧

• 3种 Springboot 全局时间格式化方式，别再写重复代码了 (springboot-global-formatting)
• 真是没想到，Springboot + Flowable 开发工作流会这么简单！ (springboot-work-flowable)
• 3 分钟生成一个单元测试报告，这个样式爱了 (springboot-testng-report)
• 实用！一键生成数据库文档，堪称数据库界的Swagger (springboot-database-doc)
• 又被逼着优化代码，这次我干掉了出入参 Log日志 (springboot-aop-unifiedlog)
• OAuth2.0 的四种授权方式
• Github 做授权登录就是这么简单！（OAuth2.0实战`)
• PC人脸识别登录，出乎意料的简单
• 被迫重构代码，这次我干掉了 if-else
• 过滤器 和 拦截器 6个区别，别再傻傻分不清了
• 6种 @Transactional 注解失效场景
• 为了不复制粘贴，我被逼着学会了JAVA爬虫
• 奇淫巧技，CompletableFuture 异步多线程是真的优雅
• 6000 字 | 16 图，吃透 Spring Cloud Gateway 原理
• 奇淫巧技，CompletableFuture 异步多线程是真的优雅
• 我有 7种 实现web实时消息推送的方案，7种！ (springboot-realtime-data)
• 如何防止订单重复支付？
• 我有 10种 保证接口数据安全的方案
• 为什么线程崩溃崩溃不会导致 JVM 崩溃
• 40 个 SpringBoot 高频使用注解，开发效率利器
• 一次内存泄漏问题排查和分析，小坑
• 我有 10 种实现延迟任务的方法，10种！（附代码）
• Spring Boot 接口参数加密、解密？这样实现更优雅
• Springboot 统一参数校验、异常处理、返回值，拿捏了！
• 45个 GIT 经典操作场景，专治不会合代码
• 20 个高频实用 Java 8 Stream 案例，玩转集合的筛选、归约、分组、聚合。。。
• 开工面试必备：Spring 面试 63 连问
• 不会一致性hash算法，劝你简历别写搞过负载均衡
• 千呼万唤，web人脸识别登录完整版来了，这样式我爱了
• 面试官问：订单30分钟未支付，自动取消，该怎么实现？
• 啪！啪！@Transactional 注解的12种失效场景，这坑我踩个遍
• 高并发下玩秒杀，你必须知道的9个细节
• Springboot 配置文件、隐私数据脱敏的最佳实践（原理+源码）
• 发现了 ConcurrentHashMap 源码中的两个BUG
• 我也没想到，Java开发 API接口可以不用写 Controller了
• 干掉前端！3分钟纯 Java 注解搭个管理系统，我直接好家伙

性能优化

• 1000w+ 数据，查询速度提升60倍，SQL 优化就是这么神奇
• 设计 API 的 22 条最佳实践，实用！
• 线上又 OOM 了 ，就这样那样搞定了
• 碰到了一位狠人，这脑洞太秀了！
• 明明还有空间，硬盘却写不进去了！
• 6 个 Java 工具，轻松分析定位 JVM 问题！

分库分表(Sharding-JDBC)

• 一文快速入门分库分表（必修课） (springboot-sharding-jdbc)
• 一文快速入门分库分表中间件 Sharding-JDBC （必修课`)
• 分库分表中间件 Sharding-JDBC 4种分片策略
• 分库分表的 9种分布式主键ID 生成方案

注册中心

• 一文快速入门 zookeeper
• 真的，千万不要给女朋友解释 什么是 “羊群效应”
• 16 图总结 Nacos 一个服务注册请求会经历什么？
• 55 张图吃透 Nacos，微服务的灵魂摆渡者强大在哪
• 阿里面试这样问：Nacos配置中心交互模型是 push 还是 pull ？（原理+源码分析）

redis

• Redis 分布式限流器，可以说是非常厉害了！
• 一口气说出 Redis 16 个使用场景，好家伙！
• 阿里面试这样问：redis 为什么把简单的字符串设计成 SDS？
• redis 分布式锁的 5个坑，真是又大又深
• Redis 内存优化妙招，小内存撬动大数据
• 硬核 | Redis 布隆（Bloom Filter）过滤器原理与实战

消息队列

• 4万字硬核剖析，Kafka 面试 30问( 高级篇)
• 未读消息（小红点），前端 与 RabbitMQ 实时消息推送实践，贼简单~ (springboot-mqtt-messagepush)
• springboot + rabbitmq 用了消息确认机制，感觉掉坑里了 (springboot-rabbitmq-confirm)
• 我也没想到 springboot + rabbitmq 做智能家居，会这么简单 (springboot-rabbitmq-mqtt)

分布式

• 分布式事务（2PC、3PC、TCC`)，这样解释没毛病！
• 分布式事务中间件 Seata （原理+实践`)
• 滴滴的分布式ID生成器（Tinyid`)，好用的一批
• 美团（Leaf`)分布式ID生成器，好用的一批！
• 6种 延时队列的实现方法，面试官也得服
• 4种 “附近的人” 实现方式，面试官笑了
• 9种 分布式ID生成方式，面试官有点懵了
• 阿里开源工具 canal 实时同步 MySQL binlog数据

数据脱敏

• 大厂也在用的 6种 数据脱敏方案，别做泄密内鬼

MySQL

• 面试官：不会看 Explain执行计划，简历敢写 SQL 优化？
• MySQL不会丢失数据的秘密，就藏在它的 7种日志里
• 一次 MySQL 线上事故，被教育了
• 10个经典案例，聊聊如何优化慢 SQL
• 京东一面：MySQL 主备延迟有哪些坑？
• 索引失效的 10 种场景
• 什么是 MySQL 的“回表”？
• 9 张图总结一下 MySQL 架构

干货、工具

• 手写一个抖音视频去水印工具，千万别刚一个程序员 (springboot-douyin-watermark)
• 基于 Java 实现的人脸识别功能（附源码`)
• 实用！8个 chrome插件玩转GitHub，单个文件下载小意思
• 10个 我经常逛的国外技术社区，真的受益匪浅！
• 程序员搭个人博客，一个 GitHub 账号足矣！
• 10个 解放双手的 IDEA 插件，少些冤枉代码
• 程序员必备的13个 免费技术电子书网站
• 10个解放双手实用在线工具，有些代码真的不用手写
• 干掉 powerdesigner，设计数据库表用它就够了
• 一个让学 Git 命令变的好玩又有趣的神奇网站
• 灰度发布、蓝绿发布、滚动发布，有什么区别？这下明白了
• 这些年我用过的 6个API 接口文档平台，真的好用
• 我试了试用 SQL查 Linux日志，好用到飞起
• 拉仇恨！webhook + 企业微信 给同事做了个代码提交监听工具
• 10个解放双手的 IDEA 插件，这些代码真不用手写（第二弹）

求职

• 看了 100多份简历后，想给找工作的程序员几点建议

springboot-notebook's Issues

springboot-sharding-jdbc 启动不了 报错

git 直接拉你的代码 启动报错 Error:(13, 43) java: 程序包com.xiaoju.uemc.tinyid.client.utils不存在

RabbitMQ 消息重试+手动确认

我觉得那个踩坑可能不对，比如：channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
为什么不这样设置 channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false);，让其不要重新入队，而是给这个队列配置一个死信交换机和死信队列，一旦拒绝了，就让其发送到死信队列中，这样就省略进行人工补偿等。

当然，SpringBoot 也支持消费者重试机制，坑爹的是，不能使用 try..catch 处理异常，一旦使用了，重试机制就失效了，不过我提供了支持重试+重试失败之后消息自动到死信队列中的方案。

① application.yaml

spring:
  rabbitmq:
    host: 127.0.0.1
    port: 5672
    username: guest
    password: guest
    virtual-host: /
    publisher-confirm-type: correlated # 消息发送到交换机会触发回调方法
    publisher-returns: true # 是否开启生产者消息回退功能，队列中的消息不可路由回退到生产者
    listener:
      simple:
        retry:
          enabled: true # 开启消费者重试
          max-attempts: 5 # 最大重试次数，默认为 3 次
          initial-interval: 2000 # 消息的间隔时间 默认为 1 秒
        acknowledge-mode: manual # 手动确认
        default-requeue-rejected: false # 重试次数超过上面的设置之后是否丢失

② 配置类：配置普通交换机、普通队列、死信交换机和死信队列

package com.github.config;

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author 许大仙
 * @version 1.0
 * @since 2022-05-27 10:49:11
 */
@Configuration
public class ConfirmConfig {

    /**
     * 交换机名称
     */
    public static final String CONFIRM_EXCHANGE_NAME = "confirm.exchange";

    /**
     * 死信交换机名称
     */
    public static final String DEAD_EXCHANGE_NAME = "dead.exchange";

    /**
     * 队列的名称
     */
    public static final String CONFIRM_QUEUE_NAME = "confirm.queue";

    /**
     * 死信队列
     */
    public static final String DEAD_QUEUE_NAME = "dead.queue";

    /**
     * routing_key
     */
    public static final String CONFIRM_ROUTING_KEY = "confirm";

    /**
     * dead routing key
     */
    public static final String DEAD_ROUTING_KEY = "dead";

    /**
     * 配置交换机
     */
    @Bean
    public DirectExchange confirmExchange() {
        return new DirectExchange(CONFIRM_EXCHANGE_NAME);
    }

    /**
     * 配置交换机
     */
    @Bean
    public DirectExchange deadExchange() {
        return new DirectExchange(DEAD_EXCHANGE_NAME);
    }

    /**
     * 配置队列
     */
    @Bean
    public Queue confirmQueue() {
        return QueueBuilder.durable(CONFIRM_QUEUE_NAME)
                .deadLetterExchange(DEAD_EXCHANGE_NAME)
                .deadLetterRoutingKey(DEAD_ROUTING_KEY)
                .build();
    }

    /**
     * 配置队列
     */
    @Bean
    public Queue deadQueue() {
        return QueueBuilder.durable(DEAD_QUEUE_NAME)
                .build();
    }

    /**
     * 配置绑定关系
     */
    @Bean
    public Binding confirmBinding() {
        return BindingBuilder.bind(confirmQueue()).to(confirmExchange()).with(CONFIRM_ROUTING_KEY);
    }

    /**
     * 配置绑定关系
     */
    @Bean
    public Binding deadBinding() {
        return BindingBuilder.bind(deadQueue()).to(deadExchange()).with(DEAD_ROUTING_KEY);
    }


}

③ 生产者的代码

package com.github.web;

import com.github.config.ConfirmConfig;
import lombok.RequiredArgsConstructor;
import lombok.Value;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.nio.charset.StandardCharsets;

/**
 * @author 许大仙
 * @version 1.0
 * @since 2022-05-27 13:37:39
 */
@Slf4j
@Value
@RestController
@RequiredArgsConstructor
@RequestMapping(value = "/confirm")
public class ConfirmController {

    RabbitTemplate rabbitTemplate;

    @GetMapping(value = "/sendMsg/{msg}")
    public String sendMsg(@PathVariable String msg) {
        log.info("发送的消息是：{}", msg);
        String id = "1";
        CorrelationData correlationData = new CorrelationData(id);
        // 发送消息
        rabbitTemplate.convertAndSend(ConfirmConfig.CONFIRM_EXCHANGE_NAME, ConfirmConfig.CONFIRM_ROUTING_KEY, msg.getBytes(StandardCharsets.UTF_8), correlationData);
        return "发送消息";
    }

}

④ 消费者的代码

package com.github.listener;

import com.github.config.ConfirmConfig;
import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.nio.charset.StandardCharsets;

/**
 * @author 许大仙
 * @version 1.0
 * @since 2022-05-25 14:20:14
 */
@Slf4j
@Component
public class RabbitmqListener {


    // 重试次数
    private int retryCount = 0;

    /**
     * 如果是重试机制，就不能使用 try-catch 捕获，否则重试机制将失效。
     * 如果是自动 ack ，多次重试还是失败，消息就会自动确认，消息就会丢失；
     * 如果是手动 ack ，多次重试还是失败，也无法 nack ，就会一直处于 unacked 状态，导致消息积压。
     *
     * @param message
     * @param channel
     * @param tag
     * @throws IOException
     */
    @RabbitListener(queues = ConfirmConfig.CONFIRM_QUEUE_NAME)
    public void receive(Message message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws IOException {
        String msg = new String(message.getBody(), StandardCharsets.UTF_8);
        try {
            // 处理主要业务
            log.info("接收到的消息是：{}", msg);
            int i = 10 / 0;
            // 确认消息
            channel.basicAck(tag, false);
        } catch (Exception e) {
            retryCount++;
            log.info("重试次数：{}", retryCount);
            // 处理业务失败，还要进行其他操作，比如记录失败原因
            log.info("记录失败原因 ====>");
            // 抛出异常，触发重试机制
            throw e;
        } finally {
            // 重试次数达到限制
            if (retryCount == 5) {
                log.info("消息异常，nack 消息到死信队列");
                channel.basicNack(tag, false, false);
            }
        }
    }

    @RabbitListener(queues = ConfirmConfig.DEAD_QUEUE_NAME)
    public void receiveDead(Message message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long tag) throws IOException {
        String msg = new String(message.getBody(), StandardCharsets.UTF_8);
        log.info("死信队列接收到的消息是：{}", msg);
        channel.basicAck(tag, false);
    }

}

⑤ 测试

• 发送请求

curl 'http://127.0.0.1:8080/confirm/sendMsg/哈哈' -X GET 

• 结果输出：自己看控制台。

优化本仓库大小的建议

本仓库使用 git 拉取半天才拉取下来，仓库大小为 700MB +
建议 Repo 主优化仓库大小：

• 【 600+MB】优化历史提交记录(.git文件夹) Ref: https://blog.csdn.net/Y0W1as5eg37urFdS/article/details/123539994
• 【40+MB】删除 eureka-server jar 包 /springboot-seata-transaction/eureka-server/target

Thx~

推荐一个数据库文档工具

https://github.com/Cocowwy/ShowDB
SpringBoot多数据源自动生成文档（当前仅支持MySQL）

springboot-work-flowable的sql文件在哪

springboot-work-flowable的sql文件在哪

想问一下JDK及MAVEN用哪个版本比较合适？

如题， 本地部署的时候用哪个版本比较好呢？