容器化运行RabbitMQ，可以参考我之前的一篇文章容器化运行RabbitMQ 本篇不讲解RabbitMQ的理论知识，均采用最简配置 那么消息队列，需要一个消息的生产者与消费者 创建一个生产者：引入相关的依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> application中的配置 serv...

拉取最新版本的RabbitMQ镜像 docker pull rabbitmq 运行容器 docker run -d --name rabbitmq -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin -p 15672:15672 -p 5672:5672 rabbitmq 指定了管理界面默认的用户名与密码，15672是管理界面的端口，5672是服务的端口，都需要暴露出来。 这个时候需要进入容器，开启管理功能，其中977cfb682dd3为容器id   doc...

首先，我们构造一个死锁场景。 如何构造一个死锁呢？ 很简单，只要让线程1占有对象a的锁后，再去请求对象b的锁。与此同时，对象2已经占有了对象b的锁，再请求对象a的锁。线程1与线程2互相等待，形成了死锁。(在面试中，也会被经常地要求手写死锁) 代码如下： package com.example.dl; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @RestControl...

对JVM的调优，需要大量的场景以及经验，本篇主要是从一个理论的角度，粗浅地 对堆这边不太熟悉的同学，可以先参考我的这一篇文章说说java中的堆区 我把堆区的主要结构以及参数放在下面，这样可以参照着图来看： 一、如何设置最大年龄 每发生一次Young GC，就会将Eden区和当前的Survivor区的存活对象一次性地转入到另外一个Survivor区中，并将之前的Eden区以及Survivor区清空。所以年轻代的存活对象，基本上就是在两块Survivor区中换来换去，每换一次，年龄增加1岁。当到达最大年龄时（最大年龄由-XX:MaxTenuringTh...

前奏篇 2020年6月19日的下午，是一个周五。在这个悠闲的时光里，我翘着二郎腿，写着再普通不过的curd。 突然，主管仿佛捕捉到了我迷离的眼神，慢慢地走到我的旁边，拉着我的衣角。 我想：该不会我摸鱼被发现了吧，主管想炸了我的鱼塘？ 主管：成都某行那边有个项目，需要暂时找个人过去支撑一下。你看我们这边有家室的有家室，有女朋友的有女朋友，你啥也没有，无依无靠，领导打算派你过去支撑一个月到一个半月。 我：.......（没有女朋友也不要说出来啊）好的，多谢领导赏识，...

前言 MySQL中的锁分为表锁以及行锁，从字面意思就可以得知，表锁是对一整张表进行加锁，而行锁是针对于特定的行。在Server层面，提供了表锁的实现，而行锁则由存储引擎实现。Innodb引擎支持行锁，Myisam则不支持行锁。 下面从锁模式以及加锁方法来大致阐述Mysql中的锁。 锁模式 锁模式分为读锁、写锁、意向锁 读锁 读锁，也称共享锁（Share Lock），可以简称为S锁。 某个事务对某行或某表加了读锁后，其他事务依然可以读取，但不能修改。 可以同时有多个事务对某行或某表加读锁。 写锁 写锁，也称独占锁（Exclusive...

一、前言 对ThreadLocal不熟悉的同学，可以先参考我的另外一篇文章浅谈ThreadLocal 在讨论内存泄漏之前，需要明白java中的四种引用，同样可以移步到java中的四种引用 什么是内存泄露？ 大白话讲，就是我自己创建的对象，在一系列操作后，我访问不到该对象了，我认为它已经被回收掉了，但该对象却一直存在与内存中。 二、示例 先给出一个简单例子，用来说明引用与对象的指向关系 package com.yang.testThreadLocal; public class Main { private static ThreadLocal<I...

前言 这篇文章简单总结一下Stream中的常用方法,，当然一般都是和Lambda配合着使用的。 对Lambda不熟悉的同学，可以参考这篇进行入门对Lambda的理解，Lambda真是越用越爽 如果刚刚入门Lambda，但对Consumer、Supplier、Predicate与Function不怎么熟悉的同学，可以参考这篇文章快速理解Consumer、Supplier、Predicate与Function 如果已经对Lambda很熟悉的同学，但对其执行原理不太懂的同学，可以参考我的这篇文章Lambda执行原理 先给出一个示例 下面有五个学生，放入到集合中 ...

一、什么是binlog binlog其实在日常的开发中是听得很多的，因为很多时候数据的更新就依赖着binlog。 举个很简单的例子：我们的数据是保存在数据库里边的嘛，现在我们对某个商品的某个字段的内容改了（数据库变更），而用户检索的出来数据是走搜索引擎的。为了让用户能搜到最新的数据，我们需要把引擎的数据也改掉。 一句话：数据库的变更，搜索引擎的数据也需要变更。 于是，我们就会监听binlog的变更，如果binlog有变更了，那我们就需要将变更写到对应的数据源。 什么是binlog？ binlog记录了数据库表结构和表数据变更，比如update/de...

这篇文章，我打算从以下几个方面来讲。 1）多线程下的 HashMap 有什么问题？ 2）怎样保证线程安全，为什么选用 ConcurrentHashMap？ 3）ConcurrentHashMap 1.7 源码解析 底层存储结构 常用变量 构造函数 put() 方法 ensureSegment() 方法 scanAndLockForPut() 方法 rehash() 扩容机制 g...

一、前言 Spring中的AOP思想就是对代理模式的经典运用，下面先讲讲代理模式的核心思想，以静态代理为例。 二、示例 下面有这样一个例子，委托人在遭遇利益受损的时候，可以委托律师帮忙打官司。 先定义一个描述行为的接口： package com.design.proxy.statics; public interface Action { void handle(); } 委托人，实现这个接口，主要的行为是寻找律师。 package com.design.proxy.statics; /** * 委托人 */...

前言 开门见山，HashMap这样做有两点原因 提升计算效率，更快算出元素的位置 减少哈希碰撞，使得元素分布均匀 提升计算效率 我们先看put方法的细节： public V put(K key, V value) { return putVal(hash(key), key, value, false, true); } 其中hash(key)如下： static final int hash(Object key) { int h; return (key == null...

前言 AtomicInteger、AtomicLong使用非阻塞的CAS算法原子性地更新某一个变量，比synchronized这些阻塞算法拥有更好的性能，但是在高并发情况下，大量线程同时去更新一个变量，由于同一时间只有一个线程能够成功，绝大部分的线程在尝试更新失败后，会通过自旋的方式再次进行尝试，严重占用了CPU的时间片。 AtomicLong的实现原理图： LongAdder是JDK8新增的原子操作类，它提供了一种新的思路，既然AtomicLong的性能瓶颈是由于大量线程同时更新一个变量造成的，那么能不能把这个变量拆分出来，变成多个变量，然后让线程去竞争...

前言 线程池内部是多个线程的集合，在创建初期，线程池会创建出多个空闲的线程，当有一个任务需要执行时，线程池会选择出一个线程去执行它，执行结束后，该线程不会被销毁，而是可以继续复用。 使用线程池可以大大减少线程频繁创建与销毁的开销，降低了系统资源的消耗。当任务来临时，直接复用之前的线程，而不是先创建，提高了系统的响应速度。此外，线程池可以控制最大的并发数，避免资源的过度消耗。 简单实例 先给出一个线程池的简单例子： package com.xue.testThreadPool; import java.util.concurrent.ExecutorService;...