商品详情

简介

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

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

服务拆分查询

• 查询商品的基本信息
• 查询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和thenAcceptAsync的区别是？

参考文档

[TOC]