Kafka宕机引发的高可用问题 问题要从一次Kafka的宕机开始说起。 笔者所在的是一家金融科技公司，但公司内部并没有采用在金融支付领域更为流行的RabbitMQ，而是采用了设计之初就为日志处理而生的Kafka，所以我一直很好奇Kafka的高可用实现和保障。从Kafka部署后，系统内部使用的Kafka一直运行稳定，没有出现不可用的情况。 但最近系统测试人员常反馈偶有Kafka消费者收不到消息的情况，登陆管理界面发现三个节点中有一个节点宕机挂掉了。但是按照高可用的理念，三个节点还有两个节点可用怎么就引起了整个集群的消费者都接收不到消息呢？ 要解决这个问题，就要从Kafka的高可用实现开始...

RestTemplate 用法 RestTemplate简介 RestTemplate 是一个同步的web http客户端请求模板工具,spring框架做的抽象模板， 常见的http客户端请求工具有: JDK的HttpURLConnection apache的HttpClient 常见的 OkHttp 3.一般默认用的是：HttpURLConnection如下 //底层执行引擎httpUrlconnection RestTemplate tempalte=new R...

背景 项目中有个需求，根据多个整型id查询对应的信息 理论上最终sql应该是如下所示： select userName form t_user where userId in(1,2,3,4,5,6); 踩坑 但前端传来的参数 Integer[] userIdArr 想着就把userIdArr转成1,2,3,4,5,6就行了 /** * [1,2,3] to 1,2,3 * * @return public static String intArrToString(Integer[] arr) { return StringU...

mvn 工具依赖检查 在很多的项目中，往往都存在一些冗余的JAR包依赖，可能是某次的测试加入但是之后没有删除，可能是引用传递的依赖，也可能是历史代码但在后面升级后已经有其他的替换方案了，可没有剔除原先的依赖等等情况。想要更好的提升构建速度以及减少依赖存在漏洞的可能性，那么就需要从源头出发，优化项目相关的依赖JAR，剔除一些无用的依赖。我们可以通过mvn dependency:analyze的方式去分析依赖情况。 mvn dependency:analyze 使用该命令对项目进行了扫描分析，以下是分析结果，截取其中一部分 [INFO] --- maven-dependency-pl...

在我们目前在Evojam最大的Java项目中，我们已经调整了策略模式的配方。我们通过一小撮枚举和功能性句法糖来添加我们的个人风格。与往常一样，最简单的解释方法是使用示例。让我们直接进入它。 设置场景 拍摄照片时，曝光取决于三个值。如果您随机选择它们，则结果可能会比您预期的更明亮或模糊。幸运的是，即使是老式模拟相机也可以让您使用完全手动以外的模式。以下类表示拍照前所需的所有控件： 爪哇岛 @lombok.Valuebrclass CameraControls {brbr Mode mode;brbr FilmSpeed filmSpeed;br Apertu...

背景 在我们平常的编码中，通常会将一些对象保存起来，这主要考虑的是对象的创建成本。 比如像线程资源、数据库连接资源或者 TCP 连接等，这类对象的初始化通常要花费比较长的时间，如果频繁地申请和销毁，就会耗费大量的系统资源，造成不必要的性能损失。 并且这些对象都有一个显著的特征，就是通过轻量级的重置工作，可以循环、重复地使用。 这个时候，我们就可以使用一个虚拟的池子，将这些资源保存起来，当使用的时候，我们就从池子里快速获取一个即可。 在 Java 中，池化技术应用非常广泛，常见的就有数据库连接池、线程池等...

一、JMM的内存可见性保证 按程序类型，Java程序的内存可见性保证可以分为下列3类： 单线程程序：单线程程序不会出现内存可见性问题。编译器、runtime和处理器会共同确保单线程程序的执行结果与该程序在顺序一致性模型中的执行结果相同。 正确同步的多线程程序：正确同步的多线程程序的执行将具有顺序一致性（程序的执行结果与该程序在顺序一致性内存模型中的执行结果相同）。这是JMM关注的重点，JMM通过限制编译器和处理器的重排序来为程序员提供内存可见性保证。 未同步/未正确同步的多线程程序：JMM为它们提供了最小安全性保障：线程执行时读取到的值，要么是之前某个线程写入的值，要么...