商品详情

作者: 异步_缓存_队排好 | 来源:发表于2019-05-29 09:11 被阅读0次

商品详情

简介

商品详情是一个高并发访问的功能,需要考虑缓存、性能和机器压力

京东的商品详情: 一个请求过去,所有的数据都来了

服务拆分查询

  • 查询商品的基本信息
  • 查询sku组合信息
  • 点击sku组合查询商品基础信息+sku信息(特别是库存)
  • 商品的所有的属性的信息
  • 大数据查询需要注意什么?
    • 禁用联表查询
    • mysql的表是有极限的,大数据表分表;

做好容错

  • 如果sku组合查询库存以及售价出现问题,返回兜底的数据.

高并发优化-多线程

多线程并不是快,而是提升系统的吞吐量,合理使用多线程可以使系统抗住大量的流量

多线程实现的几种方式

  • 继承 Thread类
class Thread01 extends Thread{

    @Override
    public void run() {
        try {
            TimeUnit.SECONDS.sleep(3);
        }catch (Exception e){

        }
        System.out.println("Thread01-当前线程"+Thread.currentThread());
    }
}

public static void main(String[] args) {
    System.out.println("主线程......");
    Thread01 thread01 = new Thread01();
    //异步化。
    new Thread(thread01).start();

    System.out.println("主线程结束......");
}
主线程......
主线程结束......
Thread01-当前线程Thread[Thread-1,5,main]
  • 实现Runable接口
class Thread02 implements Runnable{

    @Override
    public void run() {
        try {
            TimeUnit.SECONDS.sleep(3);
        }catch (Exception e){

        }
        System.out.println("Thread02-当前线程"+Thread.currentThread());
    }
}

new Thread(new Thread02()).start();

以上没有使用线程里面的返回值

  • 使用callable
class Thread03 implements Callable<String>{

    @Override
    public String call() throws Exception {
        try {
            System.out.println("Callable开始运行");
            TimeUnit.SECONDS.sleep(3);
        }catch (Exception e){

        }
        System.out.println("Callable运行结束");
        return "OK";
    }
}

FutureTask<String> task = new FutureTask<>(new Thread03());
new Thread(task).start();

//获取异步运行的结果
String s = task.get();//获取结果会等待执行完
System.out.println("异步获取到的结果是:"+s);

让线程池来帮我们执行任务

  • 使用Future

Future就是对具体的Runable或者Callable任务的执行结果进行取消、查询是否完成、获取结果.以通过get方法获取执行的结果,该方法会阻塞直到任务返回结果

public interface Future<V> {
    boolean cancel(boolean mayInterruptIfRunning);
    boolean isCancelled();
    boolean isDone();
    V get() throws InterruptedException, ExecutionException;
    V get(long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException;
}
Future提供了三种功能:
  1)判断任务是否完成;
  2)能够中断任务;
  3)能够获取任务执行结果。
FutureTask是Future和Runable的实现

  • ExecutorService
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
Java通过Executors提供四种线程池,分别为:
    newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。
    newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。
    newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行。
    newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。

  • ComPletableFuture(异步编排)

Future接口可以构建异步应用,但依然有其局限性。它很难直接表述多个Future 结果之间的依赖性。实际开发中,我们经常需要达成以下目的:

  • 将多个异步计算的结果合并成一个
  • 等待Future集合中的所有的任务都能完成
  • Future完成事件(任务完成以后触发的动作)
CompletableFuture<Void> skuFuture = CompletableFuture.supplyAsync(() -> {
            //1s
            //拿到库存
        }).thenAcceptAsync((stock)->{
            //2s
            //拿到上一步的商品id
            //拿到上一步结果整体封装
        });

thenAccept和thenApply的区别是什么?

thenAccept thenApply
结果 能接受上一步的结果 能接受上一步的结果
处理 不能做出处理 可以做处理,把上一步的结果,拿过来接着进行修改

thenAccept和thenAcceptAsync的区别是?

thenAccept thenAcceptAsync
处理的方式 同步的方式 异步的方式
时间
例子 上一步结果1s+本次处理2s=3s 上一步1s+异步2s = 最多等2s

参考文档

[TOC]

相关文章

  • 商品详情

    4个链接 1. 公司介绍:让阳光照亮您的黑夜(亚马逊是否可以展示?) :研发部门、生产车间、品质监管部、销售部等各...

  • 商品详情

    1、加载本地H5 2、自适应宽高 代码 // 详情 { //创建网页配置对象 WKWebV...

  • 商品详情

    商品详情页面 主要结构,商品图片的轮播图,商品购买区域,商品参数区域 使用mui-card样式构建商品详情界面的三...

  • 商品详情

    商品详情 简介 商品详情是一个高并发访问的功能,需要考虑缓存、性能和机器压力京东的商品详情: 一个请求过去,所有的...

  • 电商平台 商品,详情 ,评价 运用主子路由三者切换

    html