你好,感谢邀请,回答如下:

1.问题引入

电商的秒杀和抢购,对我们来说,都不是一个陌生的东西。然而,从技术的角度来说,这对于Web系统是一个巨大的考验。当一个Web系统,在一秒钟内收到数以万计甚至更多请求时,系统的优化和稳定至关重要。

2.大规模并发带来的挑战

高并发秒杀功能,整个Web系统遇到了很多的问题和挑战。如果Web系统不做针对性的优化,会轻而易举地陷入到异常状态。现在我们来讨论下,优化的思路和方法。

第一: 请求接口的合理设计

第二:高并发的挑战:一定要“快”

第三:重启与过载保护

第四:时间控制方案

1.从线程方面解决

最简单粗暴的一种实现方案:Thread.sleep(800),但事实上这种方案一定会被很快pass,因为这种方式存在一个隐患,如果在多线程环境下,线程很容易被interrupt,这样代码就会抛出异常,这样线程就会挂起,导致整个线程异常结束。实在是不够优雅,违背了我们设计的初衷。

2.使用Timer

在jdk中提供了定时器类,类的主要作用就是控制一定的时间来简单的定时执行某个任务。有点简单的elasticJob的设计味道。下面一个最简单的例子来看一下如何实现定时任务:

public class TimmerTest {

/**

* 测试方法

*/

public void test() {

Timer timer = new Timer();

timer.schedule(new MyTask(), 800);

}

public class MyTask extends TimerTask {

/**

* 运行方法

*/

@Override

public void run() {

System.out.println("输出");

}

}

}

从方法来看,类继承自MyTask就可以实现定时执行,这种方法是可以实现延时的效果,但是它有一个致命的缺点:对代码的侵入性太大,为了实现定时我们不得已将对应的方法封装成一个类,然后放在定时器里执行。但未免也有点太得不偿失了,所以这种方式也被pass掉!

但是这里延伸一下,java可结合queartz实现的定时任务。

Quartz是一个任务调度框架。

一个例子:

package com.test.quartz; import static org.quartz.DateBuilder.newDate; import static org.quartz.JobBuilder.newJob; import static org.quartz.SimpleScheduleBuilder.simpleSchedule; import static org.quartz.TriggerBuilder.newTrigger; import java.util.GregorianCalendar; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.Trigger; import org.quartz.impl.StdSchedulerFactory; import org.quartz.impl.calendar.AnnualCalendar; public class QuartzTest { public static void main(String[] args) { try { //创建scheduler Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); //定义一个Trigger Trigger trigger = newTrigger().withIdentity("trigger1", "group1") //定义name/group .startNow()//一旦加入scheduler,立即生效 .withSchedule(simpleSchedule() //使用SimpleTrigger .withIntervalInSeconds(1) //每隔一秒执行一次 .repeatForever()) //一直执行,奔腾到老不停歇 .build(); //定义一个JobDetail JobDetail job = newJob(HelloQuartz.class) //定义Job类为HelloQuartz类,这是真正的执行逻辑所在 .withIdentity("job1", "group1") //定义name/group .usingJobData("name", "quartz") //定义属性 .build(); //加入这个调度 scheduler.scheduleJob(job, trigger); //启动之 scheduler.start(); //运行一段时间后关闭 Thread.sleep(10000); scheduler.shutdown(true); } catch (Exception e) { e.printStackTrace(); } } }

package com.test.quartz; import java.util.Date; import org.quartz.DisallowConcurrentExecution; import org.quartz.Job; import org.quartz.JobDetail; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; public class HelloQuartz implements Job { public void execute(JobExecutionContext context) throws JobExecutionException { JobDetail detail = context.getJobDetail(); String name = detail.getJobDataMap().getString("name"); System.out.println("say hello to " + name + " at " + new Date()); } }

这个例子覆盖了Quartz最重要的3个基本要素:

Scheduler:调度器。所有的调度都是由它控制。

Trigger: 定义触发的条件。例子中,它的类型是SimpleTrigger,每隔1秒中执行一次(什么是SimpleTrigger下面会有详述)。

JobDetail & Job: JobDetail 定义的是任务数据,而真正的执行逻辑是在Job中,例子中是HelloQuartz。 为什么设计成JobDetail + Job,不直接使用Job?这是因为任务是有可能并发执行,如果Scheduler直接使用Job,就会存在对同一个Job实例并发访问的问题。而JobDetail & Job 方式,sheduler每次执行,都会根据JobDetail创建一个新的Job实例,这样就可以规避并发访问的问题。

3.redis延时

通过EXPIRE命令可以设置键的过期时间,一旦超过预设的时间,值就会变成(nil)。利用这一点,加入一些业务参数,我们就可以有效的实现延时的目的。通过redis的过期时间使用redis的好处有以下几点:

1:对代码的侵入性低,不用额外起另外的线程来执行。只需要加入一个方法就可以对单流程的时间控制

2:实现方便灵活,通过key设值可以加入一些唯一性的id来表示业务含义,从而保证业务的稳健实现

3:简单,真正的代码实现起来只有很少

4.在springboot中配置redis简单示例:

pom.xml中依赖:

org.springframework.boot

spring-boot-starter-data-redis

io.lettuce

lettuce-core

redis.clients

jedis

redisTemplate实例化

@Configuration

public class RedisConfig {

@Autowired

private RedisTemplate redisTemplate;

/**

* redisTemplate实例化

*

* @return

*/

@Bean

public RedisTemplate redisTemplateInit() {

//设置序列化Key的实例化对象

redisTemplate.setKeySerializer(new StringRedisSerializer());

//设置序列化Value的实例化对象

redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());

return redisTemplate;

}

}

redisTemplate模板

@Component

public class RedisManager {

private static final Logger LOGGER = LoggerFactory.getLogger(RedisManager.class);

@Autowired

private RedisTemplate redisTemplate;

/**

* 设置对象

*

* @param key key

* @param value value值

* @param 返回值泛型

* @return 正确的值: 错误的值:null

*/

@SuppressWarnings("unchecked")

public ValueOperations setObject(final String key, final T value) {

final ValueOperations operation = redisTemplate.opsForValue();

operation.set(key, value);

return operation;

}

/**

* 设置对象及失效时间 (单位:秒)

*

* @param key key

* @param value value值

* @param 返回值泛型

* @param time 秒值

* @return 正确的值: 错误的值:null

*/

@SuppressWarnings("unchecked")

public ValueOperations setObject(final String key, final T value, final long time) {

final ValueOperations operation = redisTemplate.opsForValue();

operation.set(key, value, time, TimeUnit.SECONDS);

return operation;

}

/**

* 设置对象及失效时间(单位:毫秒)

*

* @param key key

* @param value value值

* @param 返回值泛型

* @param time 秒值

* @return 正确的值: 错误的值:null

*/

@SuppressWarnings("unchecked")

public ValueOperations setObjectForMillSeconds(final String key, final T value, final long time) {

final ValueOperations operation = redisTemplate.opsForValue();

operation.set(key, value, time, TimeUnit.MILLISECONDS);

return operation;

}

/**

* 获取对象

*

* @param key 键

* @return 正确的值:Object值对象

* 错误的值:null

*/

@SuppressWarnings("unchecked")

public Object getObject(final String key) {

final ValueOperations valueOperations = redisTemplate.opsForValue();

if (valueOperations == null || !redisTemplate.hasKey(key)) {

return null;

}

final Object object = valueOperations.get(key);

return object;

}

/**

* 从缓存中获取string值

*

* @param key

* @return*/

@SuppressWarnings("unchecked")

public String getString(final String key) {

String value = "";

final ValueOperations valueOperations = redisTemplate.opsForValue();

if (valueOperations != null && redisTemplate.hasKey(key)) {

final Object object = valueOperations.get(key);

if (null != object) {

http://LOGGER.info("--getString--object not empty");

value = object.toString();

} else {

http://LOGGER.info("--getString--object empty");

}

}

return value;

}

在redis中实现时间控制

public class RedisTest extends OrderProviderApplicationTests {

@Autowired

private RedisManager redisManager;

@Test

public void test() {

controlTime("10000001", 10L);

}

public void controlTime(String requestId, Long timeOut) {

if (Objects.isNull(requestId) || Objects.isNull(timeOut)) {

return;

}

//something code

final String value = "value";

redisManager.setObject(requestId, value, timeOut);

final long startTime = System.currentTimeMillis();

System.out.println("开始控制时间");

//start

for (; ; ) {

if (Objects.isNull(redisManager.getObject(requestId))) {

break;

}

}

final long endTime = System.currentTimeMillis();

final long useTime = endTime - startTime;

System.out.println("一共耗费时间:" + useTime);

}

}

这些回答希望能够给你一个思路以供参考。

java限时抢购_java在商家促销中的限时抢购是怎么实现的?时间是怎么控制的?...相关推荐

  1. java 解析括号_Java如何解析括号中的负数?

    在金融应用中,负数通常用括号表示.在这篇文章中,我们将学习如何解析或转换括号中的负数以产生表示的数字值.要将文本/字符串解析为数字,我们可以使用java.text.DecimalFormat该类. 在 ...

  2. java ee 修改_java ee 在数据库中执行增删改查

    1.先建一个主页面里面包含着添加方法 学生信息 {//1.连接数据库// 1)加载驱动 Class.forName("oracle.jdbc.driver.OracleDriver" ...

  3. java list 最小值_Java 实例 – 查找 List 中的最大最小值

    Java 实例 - 查找 List 中的最大最小值 以下实例演示了如何使用 Collections 类的 max() 和 min() 方法来获取List中最大最小值: /* author by w3c ...

  4. java soap附件_java - 附件在SoapUI中工作,但在Java中不能使用SAAJ API吗? - 堆栈内存溢出...

    我能够使用SoapUI附加一个完全相同的SOAP Request的zip文件,但不能使用SAAJ Api的Java. 这是我在SOAPUI和JAVA中使用的SOAP请求: projectName ci ...

  5. java 链表 传递_java 链表 传递过程中的问题

    具体情况如下一共有三个类,分别是主类main,从TXT文件中读取入链表的类read,还有一个是对链表内容进行查询的类inquiryread读取并没有问题,read中有加入检测M.List.add(A) ...

  6. 如何用java创建超链接_Java如何在PPT中的幻灯片上创建超链接?

    在Java编程中,如何在PPT中的幻灯片上创建超链接? 注意:需要访问网址:http://poi.apache.org/download.html , 下载一个Apache POI软件包.这里下载最新 ...

  7. 如何更改java源码_java – 如何在Android中更改ImageView源码

    这是我的xml,它位于我活动中出现的片段上. android:id="@+id/frame1" android:layout_width="wrap_content&qu ...

  8. java 循环依赖_java – 如何在Gradle中解决循环依赖

    我正在将Java项目从Ant迁移到Gradle.我认为最好的解决方案是使用Gradle的多项目支持,但我找不到摆脱循环依赖的方法. 原始项目设置为具有以下布局: - project/ - common ...

  9. 容易答错的java面试题_Java程序员面试中最容易答错的8道面试题,你中招了吗?...

    1. static 和 final 的用法 static 的作用从三个方面来谈,分别是静态变量.静态方法.静态类. 静态变量:声明为 static 的静态变量实质上就是全局变量,当声明一个对象时,并不 ...

最新文章

  1. 参数匹配模型——Python学习之参数(二)
  2. 数据挖掘之关联分析五(序列模式)
  3. 学习笔记(18):Python网络编程并发编程-守护进程
  4. 【译】用SQL统一所有:一种有效的、语法惯用的流和表管理方法
  5. tensorflow.python.framework.tensor_shape.TensorShape 类
  6. 高程3总结#第23章离线应用与客户端存储
  7. 软考高项-了解软考高项
  8. ESP32-C3入门教程 WiFi篇⑥——基于串口的 WiFi 智能配网
  9. 全球十大外汇交易平台2020最新排名
  10. Latex排版论文——傻瓜式操作一晚排出毕业论文
  11. 鸟哥的Linux私房菜:首次登陆与在线求助,LINUX最简单的命令及应用(一)
  12. 网络防火墙的配置与管理
  13. 如何理解界面陷阱电荷呢(interface trapped charge)和费米钉扎效应?
  14. 业务:品类和品类管理
  15. 基于Vite+React构建在线Excel
  16. 做好工作交接对自己多重要,说到心坎了
  17. 待办事项 数据库表设计
  18. synchronized 和 AQS
  19. 【数学建模】基于SIR模型实现新冠病毒COVID-19估计附matlab代码
  20. 2021资源网源码二开模板

热门文章

  1. 寻找树中两个结点的最低公共祖先
  2. 【Python人工智能】Python全栈体系(十九)
  3. 论文:Exploring Phrase Grounding without Training: Contextualisation and Extension to Text-Based Image
  4. Powerdesigner导出为excel文档
  5. python字符串下标从0开始还是1_python字符串下标与切片及使用方法
  6. c上标3下标5怎么算用计算机,c上标3下标5怎么算
  7. 职业秘书写给女友的求婚信
  8. 戴尔商用笔记本选购指南
  9. 程序人生——hello的一生
  10. DataFun Talk之算法架构系列活动 ——AI在反欺诈中的应用实践