某天报警：某台机器部署的一个服务突然无法访问。谨记第一反应登录机器查看日志，因为服务挂掉，很可能因OOM。这个时候在机器的日志中发现了如下的一些信息： nio handle failed java.lang.OutOfMemoryError: Direct buffer memory at org.eclipse.jetty.io.nio.xxxx at org.eclipse.jetty.io.nio.xxxx at org.eclipse.jetty.io.nio.xxxx表明确实为OOM，问题是哪个区导致的呢？可以看到是：Direct buffer memory，还看到一大堆jetty相...

假设知道自己的系统OOM了，咋办？ 解决OOM的初步思路 OOM必然说明系统中某区的对象太多，塞满那个区，而且一定无法回收掉那些对象，最终才导致内存溢出。 就得知道到底是什么对象太多了最终导致OOM，就必须得有一份JVM发生OOM时的dump内存快照。 OOM的时候自动dump 假设JVM发生OOM了，你觉得JVM是完全来不及处理然后突然进程就没了吗？也就是JVM是看起来非常突然的自己无法控制的就挂掉了吗？ 不是的，JVM本身在发生OOM之前都会尽可能的去进行GC腾出来一些内存空间，如果GC后还是没有空间，放不下对象， 才会触发内存溢出。 所以JVM自己对OOM情况的发生是完全有把控权的，他知...

1 个人简介 一位不致命的 Java Coder。双一流双非本科，迄今在百度、携程、华为等各厂都打了刻上我的名字的螺丝。一直专注于Java生态各种中间件原理、框架源码、微服务架构设计及实战，哦对了还有大数据算法！也获得过一些技术社区荣誉：阿里云开发者社区专家博主、腾讯云+社区2019、2020年度最佳作者、慕课网认证作者、CSDN百万阅读十万粉博客专家，简书优秀创作者兼《程序员》专题管理员。但最关键的还是在牛客网著有《Java源码面试解析指南》，阅读过万。   2 春招建议 结合我多年面试求职经历，也有了各种神奇的面试体验。 比如有的公司真的在乎地域，你家乡哪的呀，离公司近不近，有没有对象或者...

大部分工程师开发完一个系统后，部署生产环境的时候往往不对JVM进行参数设置，直接用默认JVM参数，这绝对是系统负载逐渐增高的时最大问题 如你不设置-Xmx、-Xms之类的堆内存大小，你启动一个系统，可能默认就给你几百MB的堆内存大小，新生代和老年代可能都是几百M。 很多后台系统都用默认JVM参数部署启动，前期没啥问题，但中后期开始，当有一定用户量和一定负载，就会出现惊喜。 Eden过小，导致频繁触发YGC，Survivor过小，导致经常在YGC后存活对象其实也没多少，但Survivor放不下，导致对象经常进入老年代，导致老年代过段时间就满，然后触发Full GC。 所以当时这个垂直电商APP的...

JVM参数示范(基于JDK 1.8) 用如下JVM参数运行代码： # 初始新生代大小 5M -XX:NewSize=5242880 # 最大新生代大小 5M -XX:MaxNewSize=5242880 # 初始堆大小 10M -XX:InitialHeapSize=10485760 # 最大堆大小 10M -XX:MaxHeapSize=10485760 -XX:SurvivorRatio=8 # 大对象阈值是10MB -XX:PretenureSizeThreshold=10485760 -XX:+UseParNewGC -XX:+UseConcMarkSweepGC  如何打印JVM G...

更多精彩在公众号：JavaEdge 0 前言 线程就是为了能自动分配CPU时间片而生。异步模式设计可显著减少线程等待，在高吞吐量场景中，极大提升系统整体性能，降低时延。因此，像MQ这种需要超高吞吐量和超低时延中间件系统，其核心流程大量采用异步。 异步的本质是为了不占用过多的线程对象。比如一个响应时间是1秒的http1.1请求，并且不考虑http pipeline：  同步模式下，一个请求在未返回前，需要独占一个线程和一个httpconnection 异步模式下，一个请求在未返回前，只需要独占一个httpconnection,那个线程在提交完io任务后就回到线程池了  即QPS 5000时，同步...

无论是读取副本还是写入副本，都是通过底层的Partition对象完成的，而这些分区对象全部保存在上节课所学的allPartitions字段中。可以说，理解这些字段的用途，是后续我们探索副本管理器类功能的重要前提。 现在，我们就来学习下副本读写功能。整个Kafka的同步机制，本质上就是副本读取+副本写入，搞懂了这两个功能，你就知道了Follower副本是如何同步Leader副本数据的。 appendRecords-副本写入 向副本底层日志写入消息的逻辑就实现在ReplicaManager#appendRecords。 Kafka需副本写入的场景：  生产者向Leader副本写入消息 Follow...

挥别 2021 转眼间，2021 进入倒计时，2022 年的元旦就要到了，马上就要变成编程两年半时长的java程序员了。 2021是比较稳定的一年了，也是在今年，职业发展才走上了正轨。 大家都知道程序员 35 是个难过的槛，所以毕业十年的时间，我们能做出的职场规划是有时效限制的，每一次的选择，都可能决定了十年后的人生。 关于职业选择 也许仗着自己还很年轻，觉得世界充满机遇。2021 年的第一份工作还是比价稳定的，在一家酒店集团，过着 965 的躺平生活。但长期安逸的生活，可能并不适合我，为了寻求技术上的突破，认识更多的大佬，***月时还是选择了离职，来了裁拉拉。 关于社招 万年不变的牛客简历模...

更多干货，尽在公众号：JavaEdge  Kafka是分布式的，基于发布订阅的消息系统。 1 特点  同时为发布和订阅提供高吞吐量Kafka每秒可生产约25万条消息（50 MB），每秒处理55万条消息（110 MB） 持久化默认就将消息持久化到磁盘，因此可用于批量消费，例如ETL，以及实时应用程序。通过将数据持久化到硬盘以及防止数据丢失。以O(1)时间复杂度提供消息持久化能力，即使对TB级以上数据也能保证常数时间复杂度的访问性能。 分布式系统，易于向外扩展所有的producer、broker和consumer都会有多个，均为分布式的。无需停机即可扩展机器。消息被处理的状态是在consumer端...

最近在准备面试BAT，特地整理一份面试资料，覆盖Java核心技术、JVM、并发、微服务、数据库、算法等     关注公众号：JavaEdge，后台回复「面试」即可白嫖！   读这源码有何用？   ReplicaStateMachine是内部组件，一般用户感觉不到存在，但搞懂它，对从根本定位一些数据不一致问题大有裨益。部署3-Broker（A、B和C）Kafka集群，版本2.0.0。在这3个Broker上创建一个单分区、双副本主题。    若两个副本分别位于A、B，而Controller在C   当关闭A、B后，zk会显示该主题的Leader是-1，ISR为空    但若两个副本依处A、B，而C...

rtrt

每年都有无数怀揣IT梦想的年轻人涌入上海，希望在魔都闯出自己的一片天。而租房无疑是第一个拦路虎。结合我自己实习和社招时的租房经验，特地写这篇上海租房攻略。希望能对学弟学妹们有所帮助。  1 上海租金行情   以人民广场中心为核心向外扩展，可以划分为内环，中环，外环，郊环四块，本文主要讨论前三。       租金估算     小区房源单价除以10 ≈ 该小区2室1厅的租金。     如某小区房价为5w元，则该小区：     两室一厅租金约为5k元/月  主卧≈两室一厅租金*0.6  次卧≈两室一厅租金*0.4  一室户≈两室一厅租金*0.7    上海目前的二手房，内环：中环：外环的房价大致为8...

0 前言 应用程序之间要想互相通信，一起配合来实现业务功能，还需传输协议支持。 传输协议就是应用程序之间对话的语言。设计传输协议，并无太多规范和要求，只需通信双方的应用程序都能正确处理该协议&&无歧义。 1 断句 1.1 分隔符 传输协议也是种语言，传输数据时，首要解决的就是断句。  对传输层，收到的数据是怎样的？  就是一段段的字节，但因网络不确定性，你收到的分段并不一定是生产者发出去的分段。  那在协议中也加上“标点符号”不就行？  而且，并不需要像自然语言中那么多种的标点符号，而只需定义一个分隔符即可。 这办法的确可行，很多传输协议就采用这种方法，比如HTTP 1.0协议...

控制结构？没错！你最爱的 if、for都是一类坏味道，没想到吧？自己竟然每天都沉浸在写坏味道的体验中。 控制语句，到底何错之有呢？ 嵌套代码 CR 如下分发我刚写完的一篇博客的案例：逻辑很简单，但有多层缩进，for 循环一层，里面有俩 if ，又多加两层。若逻辑再复杂点，缩进岂不是像啤酒肚一般越来越大？  为啥代码会写成这鬼样子呢?  因为你在写流水账，如机器人般地按需求一步步翻译成代码。代码逻辑肯定没错，但功能实现后，未重新整理代码。  现在就得消除缩进。  从for循环入手，通常for循环处理集合，而循环里处理的是该集合中的元素。所以，可将循环中的内容提取成方法，只处理一个元素：这就是一次...