目录
- 1. Invalid default value for ‘begin_time‘报错
- 2. [ThreadLocal](https://blog.****.net/u010445301/article/details/111322569)
- 3. 悲观锁实现单体一人一单超卖问题
- 4. redisson
- 5. 回顾秒杀优化
- 6. Nginx 负载均衡
1. Invalid default value for ‘begin_time‘报错
- mysql⽇期时间设置默认0000-00-0000:00:00出错。
- DEFAULT ‘0000-00-00 00:00:00’(零时间戳),这不满足sql_mode中的
NO_ZERO_DATE
而报错。 - sql_mode有两种,一种是
空值
,一种是严格模式
,会给出很多默认设置。在MySQL5.7之后默认使用严格模式。 -
NO_ZERO_DATE
:若设置该值,MySQL数据库不允许插入零日期,插入零日期会抛出错误而不是警告。 - 在命令行中设置sql_mode:
SET SESSION sql_mode = 'ONLY_FULL_GROUP_BY,STRICT_TRANS_TABLES,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION';
- DEFAULT ‘0000-00-00 00:00:00’(零时间戳),这不满足sql_mode中的
2. ThreadLocal
- remove 方法,直接将 ThreadLocal 对应的值从当前线程 Thread 中的 ThreadLocalMap 中删除。为什么要删除,这涉及到内存泄漏的问题。
- ThreadLocalMap 中使用的 key 为 ThreadLocal 的弱引用, 弱引用的特点是,如果这个对象只存在弱引用,那么在下一次垃圾回收的时候必然会被清理掉。
- 所以如果 ThreadLocal 没有被外部强引用的情况下,在垃圾回收的时候会被清理掉的,这样一来 ThreadLocalMap中使用这个 ThreadLocal 的 key 也会被清理掉。但是, value 是强引用,不会被清理,这样一来就会出现 key 为 null 的 value。
3. 悲观锁实现单体一人一单超卖问题
-
乐观锁适合判断数据更新问题,而当前是判断是否存在,所以可以使用悲观锁解决。
-
锁的范围尽量小,
synchronized
尽量锁代码块而不是方法,锁的范围越大性能越低。 -
锁的对象一定是一个不变的值,不能直接锁
Long
类型的 userId,每请求一次都会创建一个新的 userId 对象,synchronized 要锁不变的值, 所以要将 Long 类型的 userId 通过 toString() 方法转成String
类型的 userId, toString底层是直接 new 一个新的 String 对象,还是在变, 所以要用intern()
方法从常量池中寻找与当前字符串值一致的字符串对象, 这样就能保障一个用户发送多次请求,每次请求的 userId 都是不变的,从而完成锁的效果。 -
要锁整个事务,而不是锁事务内部的代码。如果我们锁住事务内部的代码会导致其它线程能够进入事务,当我们事务还未提交,锁一旦释放,仍然会存在超卖问题。
-
Spring 的
@Transactional
注解要想事务生效,必须使用动态代理。在同一个类中,一个方法调用另外一个有注解(比如@Async,@Transational)的方法,注解是不会生效的,所以我们需要创建一个代理对象,使用代理对象来调用方法。-
spring 在扫描bean的时候会扫描方法上是否包含@Transactional注解,如果包含,spring会为这个bean动态地生成一个子类(即代理类,proxy),代理类是继承原来那个bean的。此时,当这个有注解的方法被调用的时候,实际上是由代理类来调用的,代理类在调用之前就会启动transaction。然而,如果这个有注解的方法是被同一个类中的其他方法调用的,那么该方法的调用并没有通过代理类,而是直接通过原来的那个bean,所以就不会启动transaction,我们看到的现象就是@Transactional注解无效。
-
让代理对象生效的步骤:
- 引入 AOP 依赖,动态代理是AOP 的常见实现之一
<dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjweaver</artifactId> </dependency>
- 暴露动态代理对象,默认是关闭的
@EnableAspectJAutoProxy(exposeProxy = true)
-
-
对于集群下一人一单的并发安全问题,由于每个tomcat 都有一个属于自己的 jvm,此时这个synchronized锁会失效,synchronized是本地锁,只能提供线程级别的同步,每个JVM中都有一把synchronized锁,不能跨 JVM 进行上锁,当一个线程进入被 synchronized 关键字修饰的方法或代码块时,它会尝试获取对象的内置锁(也称为监视器锁)。如果该锁没有被其他线程占用,则当前线程获得锁,可以继续执行代码;否则,当前线程将进入阻塞状态,直到获取到锁为止。而现在我们是创建了两个节点,也就意味着有两个JVM,所以synchronized会失效! 原文链接
-
try…finally…确保发生异常时锁能够释放,注意这给地方不要使用catch,A事务方法内部调用B事务方法,A事务方法不能够直接catch,否则会导致事务失效。
// 3、创建订单(使用分布式锁) Long userId = ThreadLocalUtls.getUser().getId(); SimpleRedisLock lock = new SimpleRedisLock(stringRedisTemplate, "order:" + userId); boolean isLock = lock.tryLock(1200); if (!isLock) { // 索取锁失败,重试或者直接抛异常(这个业务是一人一单,所以直接返回失败信息) return Result.fail("一人只能下一单"); } try { // 索取锁成功,创建代理对象,使用代理对象调用第三方事务方法, 防止事务失效 IVoucherOrderService proxy = (IVoucherOrderService) AopContext.currentProxy(); return proxy.createVoucherOrder(userId, voucherId); } finally { lock.unlock(); }
4. redisson
- 可重入:利用hash 结构记录线程id 和重入次数
- 可重试:利用信号量和 PubSub 功能实现等待、唤醒、获取锁失败的重试机制
- 超时续约:利用 watchDog ,每个一段时间(releaseTime / 3) 重置超时时间
获取锁,根据订阅发的通知,在自己获取锁时,判断自己的剩余时间,去监听获取。
避免业务未完成锁超时释放发问题,采用看门狗的机制,每过一段时间去重置有效期. - 主从一致性问题:利用 Redission 的
multiLock
,多个独立的 Redis 节点, 必须在所有节点都获取重入锁,才算获取锁成功
5. 回顾秒杀优化
遇到自增 ID 问题,通过实现分布式ID解决了问题;后面我们在单体系统下遇到了一人多单超卖问题,我们通过乐观锁解决了;我们对业务进行了变更,将一人多单变成了一人一单,结果在高并发场景下同一用户发送相同请求仍然出现了超卖问题,我们通过悲观锁解决了;由于用户量的激增,我们将单体系统升级成了集群,结果由于锁只能在一个JVM中可见导致又出现了,在高并发场景下同一用户发送下单请求出现超卖问题,我们通过实现分布式锁成功解决集群下的超卖问题;由于我们最开始实现的分布式锁比较简单,会出现超时释放导致超卖问题,我们通过给锁添加线程标识成功解决了;但是释放锁时,判断锁是否是当前线程 和 删除锁两个操作不是原子性的,可能导致超卖问题,我们通过将两个操作封装到一个Lua脚本成功解决了;为了解决锁的不可重入性,我们通过将锁以hash结构的形式存储,每次释放锁都value-1,获取锁value+1,从而实现锁的可重入性,并且将释放锁和获取锁的操作封装到Lua脚本中以确保原子性。最最后,我们发现可以直接使用现有比较成熟的方案Redisson来解决上诉出现的所有问题,不可重试、不可重入、超时释放、原子性等问题Redisson都提供相对应的解决方法。
原文链接
6. Nginx 负载均衡
搭建集群环境时,修改 Nginx 配置后要重启。 nginx.exe -s reload