冰河技术
导读
♻学习路线
  • 面试必问系列

    • 面试必问
  • 架构与模式

    • Java极简设计模式
    • 实战高并发设计模式
  • Java核心技术

    • Java8新特性
    • IOC核心技术
    • JVM调优技术
  • 容器化核心技术

    • Dockek核心技术
  • 分布式存储

    • Mycat核心技术
  • 数据库核心技术

    • MySQL基础篇
  • 服务器核心技术

    • Nginx核心技术
  • 渗透核心技术

    • 渗透实战技术
  • 底层技术
  • 源码分析
  • 基础案例
  • 实战案例
  • 面试
  • 系统架构
  • Spring6核心技术
  • 分布式事务

    • 分布式事务系列视频
  • SpringBoot
  • SpringCloudAlibaba
  • 🔥AI大模型项目

    • 一站式AI智能平台
    • AI智能客服系统
    • AI智能问答系统
    • 实战AI大模型
  • 中间件项目

    • 手写高性能Redis组件
    • 手写高性能脱敏组件
    • 手写线程池项目
    • 手写高性能SQL引擎
    • 手写高性能Polaris网关
    • 手写高性能RPC项目
  • 高并发项目

    • 分布式IM即时通讯系统(新)
    • 分布式Seckill秒杀系统
    • 实战高并发设计模式
  • 微服务项目

    • 简易电商脚手架项目
  • 手撕源码

    • 手撕Spring6源码
🌍知识星球
  • 总览

    • 《书籍汇总》
  • 出版图书

    • 《深入理解高并发编程:核心原理与案例实战》
    • 《深入理解高并发编程:JDK核心技术》
    • 《深入高平行開發:深度原理&專案實戰》
    • 《深入理解分布式事务:原理与实战》
    • 《MySQL技术大全:开发、优化与运维实战》
    • 《海量数据处理与大数据技术实战》
  • 电子书籍

    • 《实战高并发设计模式》
    • 《深入理解高并发编程(第2版)》
    • 《深入理解高并发编程(第1版)》
    • 《从零开始手写RPC框架(基础篇)》
    • 《SpringCloud Alibaba实战》
    • 《冰河的渗透实战笔记》
    • 《MySQL核心知识手册》
    • 《Spring IOC核心技术》
  • 关于自己
  • 关于学习
  • 关于职场
B站
Github
导读
♻学习路线
  • 面试必问系列

    • 面试必问
  • 架构与模式

    • Java极简设计模式
    • 实战高并发设计模式
  • Java核心技术

    • Java8新特性
    • IOC核心技术
    • JVM调优技术
  • 容器化核心技术

    • Dockek核心技术
  • 分布式存储

    • Mycat核心技术
  • 数据库核心技术

    • MySQL基础篇
  • 服务器核心技术

    • Nginx核心技术
  • 渗透核心技术

    • 渗透实战技术
  • 底层技术
  • 源码分析
  • 基础案例
  • 实战案例
  • 面试
  • 系统架构
  • Spring6核心技术
  • 分布式事务

    • 分布式事务系列视频
  • SpringBoot
  • SpringCloudAlibaba
  • 🔥AI大模型项目

    • 一站式AI智能平台
    • AI智能客服系统
    • AI智能问答系统
    • 实战AI大模型
  • 中间件项目

    • 手写高性能Redis组件
    • 手写高性能脱敏组件
    • 手写线程池项目
    • 手写高性能SQL引擎
    • 手写高性能Polaris网关
    • 手写高性能RPC项目
  • 高并发项目

    • 分布式IM即时通讯系统(新)
    • 分布式Seckill秒杀系统
    • 实战高并发设计模式
  • 微服务项目

    • 简易电商脚手架项目
  • 手撕源码

    • 手撕Spring6源码
🌍知识星球
  • 总览

    • 《书籍汇总》
  • 出版图书

    • 《深入理解高并发编程:核心原理与案例实战》
    • 《深入理解高并发编程:JDK核心技术》
    • 《深入高平行開發:深度原理&專案實戰》
    • 《深入理解分布式事务:原理与实战》
    • 《MySQL技术大全:开发、优化与运维实战》
    • 《海量数据处理与大数据技术实战》
  • 电子书籍

    • 《实战高并发设计模式》
    • 《深入理解高并发编程(第2版)》
    • 《深入理解高并发编程(第1版)》
    • 《从零开始手写RPC框架(基础篇)》
    • 《SpringCloud Alibaba实战》
    • 《冰河的渗透实战笔记》
    • 《MySQL核心知识手册》
    • 《Spring IOC核心技术》
  • 关于自己
  • 关于学习
  • 关于职场
B站
Github
  • 专栏开篇

    • 开篇:用讲故事的形式带你彻底吃透并发设计模式
  • 第一篇:不可变模式

    • 第01章:这特么到底是哪里不对
    • 第02章:原来问题出在这里
    • 第03章:有哪些方法能够解决并发问题
    • 第04章:可变类的线程安全问题
    • 第05章:实现不可变类解决线程安全问题
    • 第06章:实现消息聚合发送系统
    • 第07章:JDK中的等效不可变类
  • 第二篇:保护性暂挂模式

    • 第08章:线程的流转状态
    • 第09章:解决交易过程加锁的安全性问题
    • 第10章:解决交易过程性能与死锁问题
    • 第11章:使用保护性暂挂模式优化交易系统性能
    • 第12章:基于护性暂挂模式实现监控报警系统
    • 第13章:保护性暂挂模式在JDK中的应用
  • 第三篇:两阶段终止模式

    • 第14章:线程还没执行完任务怎么就退出了
    • 第15章:到底什么是两阶段终止模式
    • 第16章:实现监控报警系统线程优雅退出
    • 第17章:两阶段终止模式在线程池中的应用
  • 第四篇:承诺模式

    • 第18章:这代码性能怎么这么差
    • 第19章:到底什么是承诺模式
    • 第20章:基于承诺模式优化社区电商项目
    • 第21章:文件同步助手项目性能太差原因分析
    • 第22章:基于承诺模式优化文件同步助手项目
    • 第23章:承诺模式在FutureTask类中的应用
  • 第五篇:生产者消费者模式

    • 第24章:面向C端的个人文库系统崩了
    • 第25章:个人文库系统资源耗尽问题分析
    • 第26章:优化面向C端的个人文库系统
    • 第27章:消息堆积问题场景分析
    • 第28章:消息堆积问题解决方案
    • 第29章:生产者消费者模式在线程池中的应用
  • 第六篇:主动对象模式

    • 第30章:重大事故访问商品链接404
    • 第31章:访问商品链接404原因分析
    • 第32章:到底什么是主动对象模式
    • 第33章:基于主动对象模式优化社区电商系统
    • 第34章:主动对象模式在线程池中的应用
  • 第七篇:线程池模式

    • 第35章:服务器内存爆了
    • 第36章:无法创建新的本地线程
    • 第37章:优化社区电商系统优惠券服务
    • 第38章:线程池核心参数解析
    • 第39章:线程池执行任务源码深度解析
    • 第40章:实现手写线程池
  • 第八篇:线程特有存储模式

    • 第41章:用户信息怎么错乱了
    • 第42章:到底什么是线程特有存储
    • 第43章:解决格式化时间的线程安全问题
    • 第44章:线程特有存储模式在JDK中的应用
    • 第45章:ThreadLocal内存泄露分析
  • 第九篇:串行线程封闭模式

    • 第46章:导出报表数据错乱了
    • 第47章:到底什么是串行线程封闭模式
    • 第48章:优化报表系统导出数据功能
  • 第十篇:主仆模式

    • 第49章:统计个数据性能太差了
    • 第50章:到底什么是主仆模式
    • 第51章:基于主仆模式优化统计热点商品功能
    • 第52章:主仆模式在JDK中的应用
  • 第十一篇:流水线模式

    • 第53章:统计个交易额也能这么慢
    • 第54章:到底什么是流水线模式
    • 第55章:基于流水线模式优化实时统计交易额功能
    • 第56章:流水线模式在Netty中的应用
  • 第十二篇:半同步半异步模式

    • 第57章:支付系统性能太差了
    • 第58章:到底什么是半同步半异步模式
    • 第59章:使用半同步半异步模式优化支付系统
    • 第60章:如何处理消息堆积问题
  • 专栏总结

    • 结尾:并发设计模式整体专栏总结

《并发设计模式》第24章-生产者消费者模式-面向C端的个人文库系统崩了

作者:冰河
星球:http://m6z.cn/6aeFbs
博客:https://binghe.site
文章汇总:https://binghe.site/md/all/all.html
源码获取地址:https://t.zsxq.com/0dhvFs5oR

沉淀,成长,突破,帮助他人,成就自我。

  • 本章难度:★★☆☆☆
  • 本章重点:了解生产者消费者模式的使用场景,重点掌握生产者消费者模式在实际项目场景中的应用,并能够结合自身项目实际场景思考如何将生产者消费者模式灵活应用到自身实际项目中。

大家好,我是冰河~~

其实大家对生产者消费者模式并不陌生了,生产者和消费者模式中有三个重要角色,生产者、任务队列、消费者。生产者提交任务到队列,消费者从队列中取出任务进行处理。市面上比较成熟的消息中间件,像RocketMQ、RabbitMQ、Kafka以及ActiveMQ等,都是基于生产者和消费者模式进行设计的,也在大量的项目中得到的广泛的应用。

一、故事背景

公司生产环境平时平稳运行的个人文库系统,这天晚上突然崩了。此时的小菜正在梦中与周公交流着什么,突然一阵急促的手机铃声打断了他跟周公的交谈。此时的小菜艰难的睁开眼,拿起手机放到耳边:“喂,。。。”,还没等小菜说完,电话那头就传来了急促的声音:“喂,小菜啊,公司线上的个人文库系统崩了,需要马上排查和恢复问题,很紧急,你看看,我这里重启服务都不行,现在使用的人数还比较多”。原来是运维的打来电话,说是公司线上的个人文库系统崩了。

“嗯,我看看”,说着小菜便揉了揉眼睛,艰难的从床上起来,打开自己的电脑便排查起问题。过了10多分钟,电话又响了,“喂,小菜,怎么样,找到问题了吗?修复了吗?”。

其实此时的小菜根本没有定位的问题所在,回应到:“别急,我正在看,目前还没定位到问题”。

“算了,我重新构建、部署和发布下项目试试”,运维急促的说到。

“好,你先这样处理下吧”,小菜回应到。

不一会,电话又响了:“喂,小菜啊,我重新构建、部署和发布了项目,目前暂时可以了,但是就是有点慢,勉强能用,你再排查下是啥问题,我这边先应对下”。

“好的”。

于是,小菜继续排查代码问题,可排查来、排查去也没定位到问题所在,眼看天都快亮了,小菜决定先不排查问题了,先睡觉,不然到公司根本无法正常工作了,于是小菜便再次躺在床上睡着了。。。

二、求助老王

第二天,气喘吁吁的跑到公司,“还好没迟到”,小菜心里想着。于是,来到自己的工位,将电脑放到工位上,继续排查昨晚运维反馈的问题。但无论小菜怎么分析问题,怎么定位问题,但还是不知问题所在,眼看马上就中午了,小菜的心情也越来越急躁,“哎,这到底是啥问题啊”。仍旧是搞不定,

此时,小菜听到了老王正在与产品经理沟通着什么需求。于是,小菜觉得还是求助老王吧。等老王与产品经理沟通完毕,小菜走到老王的工位对老王说:“老大,昨晚运维打电话跟我说,生产环境的个人文库系统崩了,开始让我排查和修复问题,我没定位到问题,运维重新构建项目、部署和发布了,勉强可以使用,说是人比较多的时候,使用起来比较慢,我昨天没找出问题,今天到公司还是没找到问题,可以帮我分析下吗?”。

“好,我看看”,老王回应到。

于是老王便跟着小菜来到了小菜的工位,老王坐下看起了个人文库项目的代码。要不说老王是真牛逼呢?没一会儿,便对小菜说:“这个个人文库系统代码写的确实有点问题,人数多了性能问题就暴露出来了”。

“啊,老大,你是怎么看出来的呢?”。

“我也是分析出来的,走,去会议室,我给你讲讲”。

“好的”。

于是小菜便拿着电脑跟老王一起走进了会议室。。。

三、个人文库核心需求

“为了便于你理解,我还是写几个接口和类来模拟个人文库系统,实现流程与个人文库系统相似”。

“好的”,小菜回应到。

对于个人文库系统来说,用户可以将自己的文档上传到文库中进行管理,个人文库系统会存储这些文档,并且会存储用户的业务数据。另外,个人文库系统后续根据用户的需要,可以根据文档的名称、文档里的关键词进行检索,以便快速定位和搜索用户上传过的文档,这就需要为上传的文档简历索引。所以,对于个人文库项目来说,核心业务有三个,分别是:存储文档、存储业务数据、建立文档索引,如图24-1所示。


而这三个核心功能的数据,要分别存储到不同的服务器上,比如存储文档时,要将文档存储到文件服务器。存储业务数据时,要将业务数据存储到数据库服务器。建立文档索引时,需要将索引文档存储到搜索引擎服务器,如图24-2所示。

查看全文

加入冰河技术知识星球,解锁完整技术文章与完整代码

在 GitHub 上编辑此页
上次更新: 2026/4/29 16:18
Contributors: binghe001
Next
第25章:个人文库系统资源耗尽问题分析
阅读全文
×

扫码或搜索:冰河技术
发送:290992
即可立即永久解锁本站全部文章

星球会员
跳转链接