Springboot集成Kafka原理
看过源码的应该都知道,springboot项目启动过程其实核心是在ApplicationContext中完成的,主要流程如下:其中bean的创建和初始化都是在finishBeanFactoryInitialization这一步完成的,spring bean初始化前后都会有相应的处理,见源码:如果bean的方法中有使用注解@KafkaListener,则会在KafkaListenerAnnotationBeanPostProcessor#postProcessAfterInitialization 方法中做相应的处理。
Spring Boot从入门到精通:Kafka微服务分布式事务+消息积压处理
在上一篇中,我们完成了Kafka高级特性的学习与企业级实战,掌握了幂等性处理、消息回溯、分区策略等核心技能,落地了用户行为日志收集和订单消息幂等性处理两个实战案例,实现了从“会用Kafka”到“用好Kafka”的跨越。
SpringBoot 配置热更新实战:不重启服务,限流阈值
大促前一小时,运营跑来说秒杀接口的限流阈值要从 200 提到 800。改配置,打包,重启,三台机器滚动发布一轮下来,二十分钟没了,重启窗口里的下单请求全部失败。这种事碰到几次之后,多数团队会想到两个办法:要么上配置中心,要么忍着。
SpringBoot 消息重试机制:失败消息自动重试
在分布式系统中,网络抖动、服务超时、资源繁忙等问题时有发生。想象一下:用户下单后,订单消息发送失败,导致库存没有扣减...支付成功后,通知消息丢失,导致订单状态没有更新...这些问题如果处理不当,很容易造成数据不一致!
河南考生444分报殡葬专业,偏见与高就业率错位在哪?
从一个数字看起——444。河南考生魏斌杰2026年高考444分,出生日期4月4日,被三门峡社会管理职业学院现代殡葬技术与管理专业录取。
Spring 最重要的方法refresh方法
标记的类就是 Environment 环境信息的加载过程调用的类,最终会调用到 System#getProperties 和 System#getenv 方法,然后完成环境信息的加载,主要加载的信息就是系统的环境变量,比如在 Windows 配置的环境变量或者启动类中使用 -D 参数配置的启动参数都会进行加载到 StandardEnvironment 这个类中,类似于使用- Dxxx.name=123 这种参数会加载到 systemProperties 中,配置的 windows 环境变量会加载 systemEnvironment 中。
Kafka和Spring Boot使用@KafkaListener实现单条或批量接收消息
前面一章,我们实现了通过spring-kafka 发送消息。接着,我们将演示如何从kafka中topic监听消息,Receiver类将消费kafka topic的消息。
20-SpringBoot部分-静态资源处理与前后端交互
教学目标维度目标描述知识目标理解Spring Boot静态资源目录的配置及访问规则;掌握WebMvcConfigurer自定义配置;了解Thymeleaf模板引擎的基本用法;理解前后端分离架构的核心思想技能目标能够配置静态资源目录;能够使用Vue3 + Axios调用后端API;
面向状态机编程:复杂业务逻辑应对之道
作者:京东零售 樊思国一、背景在研发项目中,经常能遇到复杂的状态流转类的业务场景,比如游戏编程中NPC的跳跃、前进、转向等状态变化,电商领域订单的状态变化等。这类情况其实可以有一种优雅的实现方法:状态机。
从 refresh() 开始,揭开 Spring 启动流程的全貌
写在前面每天写下 SpringApplication.run(MyApp.class, args); 这行代码时,你有没有想过:从这一行代码到所有 Bean 就绪、服务对外可用,Spring 究竟在背后做了哪些事?