java高并发写入用户信息到数据库的几种方法
作者:程序员小董 发布时间:2023-07-09 08:45:49
假定存在这样一种情况
多个用户对数据库进行写,我们的业务逻辑规定,每个用户只能写一次,大部分用户也只发一次请求。
public void write(Uers u){
// do something
}
但是有一种情况(1%的情况下吧)的就是有的用户会发两次甚至更多次写请求(因为数据库限制,我们不方便在主键上做文章)。
如果这个特殊的用户发送的两次请求时间间隔比较大,那就简单了,再每次写入的时候,写去数据库里看看,这个人有没有写过,如果已经写过了,就直接抛弃这个请求。
public void write(Uers u){
if(!checkIfExistUser(u)){
// do something
}
}
不过最大的问题就是,如果用户几乎在瞬时,发送了两个写操作。
而且假定我们的do something比较耗时,那么上面的策略就有可能失败。
为啥失败?我不用解释了吧。
那咋办?
方法一
万年不变的synchronized。
public synchronized void write(Uers u){
if(!checkIfExistUser(u)){
// do something
}
}
当然,我们得承认,有了上面的方法,就不会出现,数据库里有两条张三的记录了
但上面的锁的粒度太大了,张三写的时候,李四也不能写了。
其实我们想要的只是:张三自己本人,不能同时多次写入。
方法二
类 String 维护一个字符串池。 当调用 intern 方法时,如果池已经包含一个等于此 String 对象的字符串(该对象由 equals(Object) 方法确定),则返回池中的字符串。可见,当String相同时,String.intern()总是返回同一个对象,因此就实现了对同一用户加锁。由于锁的粒度局限于具体用户,使系统获得了最大程度的并发。
public synchronized void write(Uers u){
synchronized(u.getUserId.intern()) {
// do something
}
}
上面的思路就保证了张三写的时候,李四可以写,但是不能两个张三一块写。
方法三
其实我个人觉得,方法二已经很好了,如果非要说方法二还有什么问题的话,只能说:
String.inter()的缺陷是类 String 维护一个字符串池是放在JVM perm区的,如果用户数特别多,导致放入字符串池的String不可控,有可能导致OOM错误或者过多的Full GC。
那咋办?
public synchronized void write(Uers u){
String userSuffix=getSuffix(u);
synchronized(userSuffix.intern()) {
// do something
}
}
至于那个获得后缀的策略,大家自己想。
有了这个策略,我就能保证1亿个用户,可能只有10000个不同的后缀。
有可能张三李四的后缀一样,但是张三李四同时发请求的概率,应该也不会太大。就算真的同时发了,那你等一下不行么?
方法四
Map locks = new Map(); List lockKeys = new List(); for(int number : 1 - 10000) { Object lockKey = new Object(); lockKeys.add(lockKey); locks.put(lockKey, new Object()); } public void doSomeThing(String uid) { Object lockKey = lockKeys.get(uid.hash() % lockKeys.size()); Object lock = locks.get(lockKey); synchronized(lock) { // do something } }
个人感觉和方法三的核心差不多。
方法五
如果是集群情况下,两个张三几乎瞬时进入两台服务器,那java语言级别的锁都得报废。
可以使用redis的分布式锁
方法六
使用zookeeper
只是听说有这么一个思路,但是本人没用过zookeeper,这个方法就不多说了。
来源:http://blog.csdn.net/dlf123321/article/details/57955491
猜你喜欢
- java 计算同比增长工具类为了数据的严谨性,统一装换为BigDecimal,话不多说,看代码。package com.pig4cloud.
- 0 实验环境在Android Studio中进行有关代码的编写和界面效果展示。SQLite数据库的图形化工具SQLiteStudio下载网址
- EhCache 是一个纯Java的进程内缓存框架,具有快速、精干等特点,是Hibernate中默认的CacheProvider。ehcach
- 最近做了很多项目,不同的系统,不同的部署方式,这里做个记录1.在jar包目录新建一个start.bat 文件,然后写入启动命令j
- 1. 公共字段自动填充1.1 问题分析在新增员工时需要设置创建时间、创建人、修改时间、修改人等字段,在编辑员工时需要设置修改时间、修改人等字
- 参数传递即将参数传输到程序后台中,后台可能做一些处理,然后再将内容存入数据库之类嗒!参数传递的方法较多,一一说明如下。1、Action中直接
- [LeetCode] 3. Longest Substring Without Repeating Characters 最长无重复字符的子
- FTP(File Transfer Protocol)就是文件传输协议。通过FTP客户端从远程FTP服务器上拷贝文件到本地计算机称为下载,将
- 这篇文章主要介绍了SpringBoot跨域Access-Control-Allow-Origin实现解析,文中通过示例代码介绍的非常详细,对
- 一,栈1,概念在我们软件应用 ,栈这种后进先出数据结构的应用是非常普遍的。比如你用浏 览器上网时不管什么浏览器都有 个"后退&qu
- 开发环境使用jdk1.8.0_60,把springboot 项目打成war包后,部署到apache-tomcat-7.0.68时报错如下,换
- 引言在高并发的场景下,异步是一个极其重要的优化方向。前段时间,生产环境发生一次事故,笔者认为事故的场景非常具备典型性 。写这篇文章,笔者想和
- mybatis多个区间处理如图:要实现车辆数不同区间查询条件思路a.前端传数组,数组里面放"1-5"String类型值
- @Lazy用于指定该Bean是否取消预初始化。主要用于修饰Spring Bean类,用于指定该Bean的预初始化行为,使用该Annotati
- 什么是枚举?枚举是JDK5引入的新特性。在某些情况下,一个类的对象是固定的,就可以定义为枚举。在实际使用中,枚举类型也可以作为一种规范,保障
- 首先:因为工作需要,需要对接socket.io框架对接,所以目前只能使用netty-socketio。websocket是不支持对接sock
- 1、实现原理不同过滤器和 * 底层实现方式大不相同,过滤器 是基于函数回调的, * 则是基于Java的反射机制( * )实现的。1、拦
- 定义与结构 备忘录(Memento)模式又称标记(Token)模式。GOF给备忘录模式的定义为:在不破坏
- 需求在配置类中,从application.properties中读取一个复杂list。如List<Person>或者初始化一个m
- 类注解@component 标注类,泛指各种组件,类不属于各种分类的时候,用它做标注。@Service 标注类,声明该类为业务层组件,用于处