面试网站建设问题,网站建设公司岗位,免费网页设计,环保部网站建设项目验收方案目录
1. 异步
1.1 初始化线程的 4 种方式
1.1.1 继承 Thread
1.1.2 实现 Runnable 接口
1.1.3 实现 Callable 接口 FutureTask
1.1.4 线程池
1.1.5 以上 4 种方式总结#xff1a;
1.2 线程池详解
1.2.1 初始化线程池的 2 种方式
1.2.1.1 使用 Executors 创建
1.2…目录
1. 异步
1.1 初始化线程的 4 种方式
1.1.1 继承 Thread
1.1.2 实现 Runnable 接口
1.1.3 实现 Callable 接口 FutureTask
1.1.4 线程池
1.1.5 以上 4 种方式总结
1.2 线程池详解
1.2.1 初始化线程池的 2 种方式
1.2.1.1 使用 Executors 创建
1.2.1.2 使用 ThreadPoolExecutor 创建
1.2.1.2.1 ThreadPoolExecutor 线程池的七大参数
1.2.1.2.2 运行流程
1.2.1.2.3 线程池面试题
1.2.2 常见的 4 种线程池
1.2.3 使用线程池的好处
1.3 CompletableFuture异步编排
1.3.1 启动异步任务
1.3.1.1 runAsync没有返回值
1.3.1.2 supplyAsync有返回值
1.3.2 完成回调与异常感知
1.3.2.1 完成回调 whenComplete
1.3.2.2 异常感知 exceptionally
1.3.3 handle 最终处理
1.3.4 线程串行化
1.3.4.1 thenRunAsync
1.3.4.2 thenAcceptAsync
1.3.4.3 thenApplyAsync
1.3.5 两个任务组合 - 都要完成
1.3.5.1 runAfterBothAsync
1.3.5.2 thenAcceptBothAsync
1.3.5.3 thenCombineAsync
1.3.6 两个任务组合 - 一个完成
1.3.6.1 runAfterEitherAsync
1.3.6.2 acceptEitherAsync
1.3.6.3 applyToEitherAsync
1.3.7 多任务组合
1.3.7.1 allOf
1.3.7.2 anyOf
2. 商品详情
2.1 环境搭建
2.1.1 SwitchHosts增加配置
2.1.2 nginx配置
2.1.3 配置网关转发
2.1.4 商品详情页面搭建
2.1.5 模型抽取
2.1.6 商品详情的业务代码
2.1.6.1 controller层
2.1.6.2 service层
2.1.6.3 获取sku的图片信息
2.1.6.4 获取spu的规格参数
2.1.6.5 获取spu的销售属性组合
2.1.7 详情页渲染【P207-P209】
2.1.8 异步编排优化
2.1.8.1 自定义线程池
2.1.8.1.1 引入依赖
2.1.8.1.2 线程池属性配置类 2.1.8.1.3 配置文件中配置
2.1.8.1.4 自定义线程池
2.1.8.2 异步编排优化商品详情业务
2.1.8.2.1 controller层
2.1.8.2.2 service层 1. 异步
1.1 初始化线程的 4 种方式
1.1.1 继承 Thread
public class ThreadTest {public static void main(String[] args) {System.out.println(main...start...);// 1. 继承Thread类Thread01 thread01 new Thread01();thread01.start(); // 启动线程System.out.println(main...end...);}public static class Thread01 extends Thread{Overridepublic void run() {System.out.println(当前线程Thread.currentThread().getId());int i 10/2;System.out.println(运行结果i);}}
}
测试结果 1.1.2 实现 Runnable 接口
public class ThreadTest {public static void main(String[] args) {System.out.println(main...start...);// 1. 继承Thread类//Thread01 thread01 new Thread01();//thread01.start(); // 启动线程// 2. 实现Runnable接口Runnable01 runnable01 new Runnable01();new Thread(runnable01).start();System.out.println(main...end...);}public static class Thread01 extends Thread{Overridepublic void run() {System.out.println(当前线程Thread.currentThread().getId());int i 10/2;System.out.println(运行结果i);}}public static class Runnable01 implements Runnable{Overridepublic void run() {System.out.println(当前线程Thread.currentThread().getId());int i 10/2;System.out.println(运行结果i);}}
} 1.1.3 实现 Callable 接口 FutureTask FutureTask的get()方法阻塞式等待整个线程的执行完成获取线程执行返回结果。 public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);// 1. 继承Thread类//Thread01 thread01 new Thread01();//thread01.start(); // 启动线程// 2. 实现Runnable接口//Runnable01 runnable01 new Runnable01();//new Thread(runnable01).start();// 3. 实现Callable接口FutureTask 可以拿到返回结果可以处理异常Callable01 callable01 new Callable01();FutureTaskInteger futureTask new FutureTask(callable01);new Thread(futureTask).start();// 阻塞式等待整个线程执行完成获取线程执行返回结果Integer integer futureTask.get();System.out.println(main...end...integer );}public static class Thread01 extends Thread{Overridepublic void run() {System.out.println(当前线程Thread.currentThread().getId());int i 10/2;System.out.println(运行结果i);}}public static class Runnable01 implements Runnable{Overridepublic void run() {System.out.println(当前线程Thread.currentThread().getId());int i 10/2;System.out.println(运行结果i);}}public static class Callable01 implements CallableInteger{Overridepublic Integer call() throws Exception {System.out.println(当前线程Thread.currentThread().getId());int i 10/2;System.out.println(运行结果i);return i;}}
} 注意
Future可以获取异步执行结果
FutureTask继承了Runnable接口。 1.1.4 线程池
public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);// 1. 继承Thread类//Thread01 thread01 new Thread01();//thread01.start(); // 启动线程// 2. 实现Runnable接口//Runnable01 runnable01 new Runnable01();//new Thread(runnable01).start();// 3. 实现Callable接口FutureTask 可以拿到返回结果可以处理异常//Callable01 callable01 new Callable01();//FutureTaskInteger futureTask new FutureTask(callable01);//new Thread(futureTask).start();阻塞式等待整个线程执行完成获取线程执行返回结果//Integer integer futureTask.get();// 在以后的业务代码里面以上三种启动线程的方式都不用因为频繁的创建和销毁线程耗费系统资源。【将所有的多线程异步任务都交给线程池执行】//new Thread(()- System.out.println(hello)).start();// 4. 线程池 给线程池直接提交业务// 当前系统中池只有一两个例如核心业务/非核心业务每个异步任务提交给线程池让它自己去执行就行executorService.execute(new Runnable01());System.out.println(main...end...);}public static class Thread01 extends Thread{Overridepublic void run() {System.out.println(当前线程Thread.currentThread().getId());int i 10/2;System.out.println(运行结果i);}}public static class Runnable01 implements Runnable{Overridepublic void run() {System.out.println(当前线程Thread.currentThread().getId());int i 10/2;System.out.println(运行结果i);}}public static class Callable01 implements CallableInteger{Overridepublic Integer call() throws Exception {System.out.println(当前线程Thread.currentThread().getId());int i 10/2;System.out.println(运行结果i);return i;}}
}1.1.5 以上 4 种方式总结
区别
1、2不能得到返回值3可以获取返回值
1、2、3都不能控制资源
4可以控制资源性能稳定 注意 1. 在以后的业务代码里面以上三种启动线程的方式都不用因为频繁的创建和销毁线程耗费系统资源可能导致服务器资源耗尽。【将所有的多线程异步任务都交给线程池执行】 2. 当前系统中池只有一两个例如核心业务/非核心业务每个异步任务提交给线程池让它自己去执行就行 1.2 线程池详解
1.2.1 初始化线程池的 2 种方式
1.2.1.1 使用 Executors 创建
ExecutorService executorService Executors.newFixedThreadPool(10); 线程池执行任务的两种方式 executorService.execute(new Runnable01()); Future? submit executorService.submit(new Runnable01()); 区别 execute参数只能是Runnable没有返回值。 submit参数可以是Runnable、Callable返回值是Future。 1.2.1.2 使用 ThreadPoolExecutor 创建
ThreadPoolExecutor executor new ThreadPoolExecutor(5,200,10,TimeUnit.SECONDS,new LinkedBlockingQueue(100000),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());
1.2.1.2.1 ThreadPoolExecutor 线程池的七大参数
corePoolSize核心线程数【一直存在除非(allowCoreThreadTimeOut)】线程池创建好后就准备就绪等待任务。maximumPoolSize最大线程数控制资源。keepAliveTime存活时间。如果当前的线程数大于核心线程数只要线程空闲大于指定的keepAliveTime就会释放空闲的线程【maximumPoolSize-corePoolSize】。unit存活时间的时间单位。workQueue阻塞队列。如果当前对线程的需求超过核心线程数就会将多余的任务放到阻塞队列。如果有空闲的线程就会去队列里取出新的任务继续执行。threadFactory创建线程的工厂。handler拒绝策略。提交给线程池的任务量超过最大线程池大小队列长度按照我们指定的拒绝策略拒绝执行任务。 ThreadPoolExecutor.AbortPolicy抛出 RejectedExecutionException来拒绝新任务的处理。ThreadPoolExecutor.CallerRunsPolicy调用执行自己的线程运行任务。ThreadPoolExecutor.DiscardPolicy不处理新任务直接丢弃掉。ThreadPoolExecutor.DiscardOldestPolicy 此策略将丢弃最早的未处理的任务请求。
1.2.1.2.2 运行流程 1、线程池创建准备好core数量的核心线程准备接受任务。 2、core 满了 就将再进来的任务放入阻塞队列中。 空闲的 core 就会自己去阻塞队列获取任务执行。 3、阻塞队列满了 就直接开新线程执行 最大只能开到 max 指定的数量 4、如果线程数开到了 max 的数量 还有新任务进来 就会使用 RejectedExecutionHandler拒绝任务。 5、max 都执行好了。 Max-core 数量空闲的线程会在 keepAliveTime 指定的时间后自 动销毁。 最终保持到 core 大小 。
1.2.1.2.3 线程池面试题
问题一个线程池 core 7 max 20 queue 50 100 并发进来怎么分配的 答案先有 7 个能直接得到执行 接下来 50 个进入队列排队 在多开 13 个继续执行。 现在 70 个被安排上了。 剩下 30 个默认拒绝策略。
1.2.2 常见的 4 种线程池
newCachedThreadPool创建一个可缓存线程池 如果线程池长度超过处理需要 可灵活回收空闲线程 若无可回收 则新建线程。newFixedThreadPool创建一个定长线程池 可控制线程最大并发数 超出的线程会在队列中等待。newScheduledThreadPool创建一个定长线程池 支持定时及周期性任务执行。newSingleThreadExecutor创建一个单线程化的线程池 它只会用唯一的工作线程来执行任务 保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。
1.2.3 使用线程池的好处
降低资源的消耗通过重复利用已经创建好的线程降低线程的创建和销毁带来的损耗。提高响应速度因为线程池中的线程数没有超过线程池的最大上限时 有的线程处于等待分配任务的状态 当任务来时无需创建新的线程就能执行。提高线程的可管理性线程池会根据当前系统特点对池内的线程进行优化处理 减少创建和销毁线程带来的系统开销。 无限的创建和销毁线程不仅消耗系统资源 还降低系统的稳定性 使用线程池进行统一分配。
1.3 CompletableFuture异步编排 在 Java 8 中, 新增加了一个包含 50 个方法左右的类: CompletableFuture 提供了非常强大的Future 的扩展功能 可以帮助我们简化异步编程的复杂性 提供了函数式编程的能力 可以通过回调的方式处理计算结果 并且提供了转换和组合 CompletableFuture 的方法。CompletableFuture 类实现了 Future 接口 所以你还是可以像以前一样通过get方法阻塞或者轮询的方式获得结果 但是这种方式不推荐使用。 CompletableFuture 和 FutureTask 同属于 Future 接口的实现类 都可以获取线程的执行结果。
1.3.1 启动异步任务
CompletableFuture 提供了四个静态方法来创建一个异步操作。
public static CompletableFutureVoid runAsync(Runnable runnable)
public static CompletableFutureVoid runAsync(Runnable runnable,Executor executor)
public static U CompletableFutureU supplyAsync(SupplierU supplier)
public static U CompletableFutureU supplyAsync(SupplierU supplier,Executor executor)
注意
1runAsync都是没有返回结果的supplyAsync都是可以获取返回结果的
2可以传入自定义的线程池否则就用默认的线程池
3Async代表异步方法。
1.3.1.1 runAsync没有返回值
public static void main(String[] args) {System.out.println(main...start...);CompletableFutureVoid future CompletableFuture.runAsync(() - {System.out.println(当前线程 Thread.currentThread().getId());int i 10 / 2;System.out.println(运行结果 i);}, executorService);System.out.println(main...end...);
}
测试结果 1.3.1.2 supplyAsync有返回值
public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);CompletableFutureInteger future CompletableFuture.supplyAsync(() - {System.out.println(当前线程 Thread.currentThread().getId());int i 10 / 2;System.out.println(运行结果 i);return i;}, executorService);Integer integer future.get();System.out.println(main...end...integer);
} 测试结果 1.3.2 完成回调与异常感知
public CompletableFutureT whenComplete(BiConsumer? super T, ? super Throwable action)
public CompletableFutureT whenCompleteAsync(BiConsumer? super T, ? super Throwable action)
public CompletableFutureT whenCompleteAsync(BiConsumer? super T, ? super Throwable action, Executor executor)public CompletableFutureT exceptionally(FunctionThrowable, ? extends T fn)
whenComplete可以处理正常和异常的结果 exceptionally 处理异常情况。
whenComplete 和 whenCompleteAsync 的区别
whenComplete 是执行当前任务的线程执行继续执行 whenComplete 的任务。whenCompleteAsync 是执行把 whenCompleteAsync 这个任务继续提交给线程池 来进行执行。
注意方法不以 Async 结尾 意味着 Action 使用相同的线程执行 而 Async 可能会使用其他线程执行如果是使用相同的线程池 也可能会被同一个线程选中执行
1.3.2.1 完成回调 whenComplete
无异常情况
public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);//CompletableFutureVoid future CompletableFuture.runAsync(() - {// System.out.println(当前线程 Thread.currentThread().getId());// int i 10 / 2;// System.out.println(运行结果 i);//}, executorService);CompletableFutureInteger future CompletableFuture.supplyAsync(() - {System.out.println(当前线程 Thread.currentThread().getId());int i 10 / 1;System.out.println(运行结果 i);return i;}, executorService).whenComplete((result,exception)-{// 可以感知到异常但无法修改返回数据System.out.println(异步任务完成了...返回值为result;异常为exception);});//Integer integer future.get();System.out.println(main...end...);}
} 有异常情况
将 int i 10/1; 改为 int i 10/0; 1.3.2.2 异常感知 exceptionally
无异常情况不会进入exceptionally
public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);//CompletableFutureVoid future CompletableFuture.runAsync(() - {// System.out.println(当前线程 Thread.currentThread().getId());// int i 10 / 2;// System.out.println(运行结果 i);//}, executorService);CompletableFutureInteger future CompletableFuture.supplyAsync(() - {System.out.println(当前线程 Thread.currentThread().getId());int i 10 / 2;System.out.println(运行结果 i);return i;}, executorService).whenComplete((result,exception)-{// 可以感知到异常但无法修改返回数据System.out.println(异步任务完成了...返回值为result;异常为exception);}).exceptionally(throwable - {// 可以感知异常同时返回默认值return 10;});Integer integer future.get();System.out.println(main...end...integer);}
}
有异常情况
将 int i 10/2; 改为 int i 10/0; 1.3.3 handle 最终处理 一般用handle因为whencomplete如果异常不能给定默认返回结果需要再调用exceptionally而handle可以。 handle方法作用获得前一任务的返回值【handleAsync可以是异步执行的】也可以处理上一任务的异常调用exceptionally修改前一任务的返回值【只有在异常情况时给一个默认返回值】而handle方法可以简化操作。
无异常情况
public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);//CompletableFutureVoid future CompletableFuture.runAsync(() - {// System.out.println(当前线程 Thread.currentThread().getId());// int i 10 / 2;// System.out.println(运行结果 i);//}, executorService);/*** 方法执行完成后的感知*///CompletableFutureInteger future CompletableFuture.supplyAsync(() - {// System.out.println(当前线程 Thread.currentThread().getId());// int i 10 / 2;// System.out.println(运行结果 i);// return i;//}, executorService).whenComplete((result,exception)-{// // 可以感知到异常但无法修改返回数据// System.out.println(异步任务完成了...返回值为result;异常为exception);//}).exceptionally(throwable - {// // 可以感知异常同时返回默认值// return 10;//});/*** 方法执行完成后的处理*/CompletableFutureInteger future CompletableFuture.supplyAsync(() - {System.out.println(当前线程 Thread.currentThread().getId());int i 10 / 4;System.out.println(运行结果 i);return i;}).handle((res, thr) - {if (res ! null) {return res * 2;}if (thr ! null) {return 10;}return 0;});// R apply(T t, U u);Integer integer future.get();System.out.println(main...end...integer);}
} 有异常情况
将 int i 10/4; 改为 int i 10/0; 1.3.4 线程串行化
public U CompletableFutureU thenApply(Function? super T,? extends U fn)
public U CompletableFutureU thenApplyAsync(Function? super T,? extends U fn)
public U CompletableFutureU thenApplyAsync(Function? super T,? extends U fn, Executor executor)public CompletableFutureVoid thenAccept(Consumer? super T action)
public CompletableFutureVoid thenAcceptAsync(Consumer? super T action)
public CompletableFutureVoid thenAcceptAsync(Consumer? super T action,Executor executor)public CompletableFutureVoid thenRun(Runnable action)
public CompletableFutureVoid thenRunAsync(Runnable action)
public CompletableFutureVoid thenRunAsync(Runnable action,Executor executor)
thenApply 方法 当一个线程依赖另一个线程时 获取上一个任务返回的结果 并返回当前 任务的返回值。thenAccept 方法 消费处理结果。 接收任务的处理结果 并消费处理 无返回结果。thenRun 方法 只要上面的任务执行完成 就开始执行 thenRun 只是处理完任务后 执行thenRun 的后续操作 带有 Async 默认是异步执行的。 同之前。 以上都要前置任务成功完成。Function? super T,? extends UT 上一个任务返回结果的类型。U 当前任务的返回值类型 。
1.3.4.1 thenRunAsync
public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);CompletableFuture.supplyAsync(() - {System.out.println(当前线程 Thread.currentThread().getId());int i 10 / 4;System.out.println(运行结果 i);return i;}).thenRunAsync(()-{// 不接收上一步结果无返回值System.out.println(任务2启动了...);},executorService);System.out.println(main...end...);
}
执行结果 1.3.4.2 thenAcceptAsync
public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);CompletableFuture.supplyAsync(() - {System.out.println(当前线程 Thread.currentThread().getId());int i 10 / 4;System.out.println(运行结果 i);return i;}).thenAcceptAsync(res - {// thenRunAsync不接收上一步结果无返回值// thenAcceptAsync接收上一步结果无返回值 void accept(T t);System.out.println(任务2启动了... res);}, executorService);System.out.println(main...end...);
}
执行结果 1.3.4.3 thenApplyAsync
public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);CompletableFutureString future CompletableFuture.supplyAsync(() - {System.out.println(当前线程 Thread.currentThread().getId());int i 10 / 4;System.out.println(运行结果 i);return i;}).thenApplyAsync(res - {// thenRunAsync不接收上一步结果无返回值// thenAcceptAsync接收上一步结果无返回值 void accept(T t);// thenApplyAsync接收上一步结果有返回值 R apply(T t);System.out.println(任务2启动了... res);return Hello res;}, executorService);System.out.println(main...end...future.get());
}
执行结果 1.3.5 两个任务组合 - 都要完成
public U,V CompletableFutureV thenCombine(CompletionStage? extends U other,
BiFunction? super T,? super U,? extends V fn)
public U,V CompletableFutureV thenCombineAsync(CompletionStage? extends U other,
BiFunction? super T,? super U,? extends V fn)
public U,V CompletableFutureV thenCombineAsync(CompletionStage? extends U other,
BiFunction? super T,? super U,? extends V fn, Executor executor)public U CompletableFutureVoid thenAcceptBoth(CompletionStage? extends U other,
BiConsumer? super T, ? super U action)
public U CompletableFutureVoid thenAcceptBothAsync(CompletionStage? extends U other,
BiConsumer? super T, ? super U action)
public U CompletableFutureVoid thenAcceptBothAsync(CompletionStage? extends U other,
BiConsumer? super T, ? super U action, Executor executor)public CompletableFutureVoid runAfterBoth(CompletionStage? other,Runnable action)
public CompletableFutureVoid runAfterBothAsync(CompletionStage? other,Runnable action)
public CompletableFutureVoid runAfterBothAsync(CompletionStage? other,Runnable action,
Executor executor)
两个任务必须都完成 触发该任务。thenCombine 组合两个 future 获取两个 future 的返回结果 并返回当前任务的返回值thenAcceptBoth 组合两个 future 获取两个 future 任务的返回结果 然后处理任务 没有 返回值。runAfterBoth 组合两个 future 不需要获取 future 的结果 只需两个 future 处理完任务后 处理该任务。
1.3.5.1 runAfterBothAsync
public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);/*** 两个任务组合-都要完成*/CompletableFutureInteger future01 CompletableFuture.supplyAsync(() - {System.out.println(任务1线程Thread.currentThread().getId());int i 10/4;System.out.println(任务1结束。。。);return i;}, executorService);CompletableFutureString future02 CompletableFuture.supplyAsync(() - {System.out.println(任务2线程Thread.currentThread().getId());System.out.println(任务2结束。。。);return Hello;}, executorService);future01.runAfterBothAsync(future02,()-{System.out.println(任务3开始);},executorService);System.out.println(main...end...);}
}
执行结果 1.3.5.2 thenAcceptBothAsync
public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);/*** 两个任务组合-都要完成*/CompletableFutureInteger future01 CompletableFuture.supplyAsync(() - {System.out.println(任务1线程Thread.currentThread().getId());int i 10/4;System.out.println(任务1结束。。。);return i;}, executorService);CompletableFutureString future02 CompletableFuture.supplyAsync(() - {System.out.println(任务2线程Thread.currentThread().getId());System.out.println(任务2结束。。。);return Hello;}, executorService);//future01.runAfterBothAsync(future02,()-{// System.out.println(任务3开始);//},executorService);future01.thenAcceptBothAsync(future02,(f1,f2)-{//void accept(T t, U u);System.out.println(任务3开始。。。之前的结果f1-f2);},executorService);System.out.println(main...end...);}
}
执行结果 1.3.5.3 thenCombineAsync
public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);/*** 两个任务组合-都要完成*/CompletableFutureInteger future01 CompletableFuture.supplyAsync(() - {System.out.println(任务1线程Thread.currentThread().getId());int i 10/4;System.out.println(任务1结束。。。);return i;}, executorService);CompletableFutureString future02 CompletableFuture.supplyAsync(() - {System.out.println(任务2线程Thread.currentThread().getId());System.out.println(任务2结束。。。);return Hello;}, executorService);//future01.runAfterBothAsync(future02,()-{// System.out.println(任务3开始);//},executorService);//future01.thenAcceptBothAsync(future02,(f1,f2)-{// //void accept(T t, U u);// System.out.println(任务3开始。。。之前的结果f1-f2);//},executorService);CompletableFutureString future future01.thenCombineAsync(future02, (f1, f2) - {return f1 - f2 -相柳; // R apply(T t, U u);}, executorService);System.out.println(main...end...future.get());}
}
执行结果 1.3.6 两个任务组合 - 一个完成
public U CompletableFutureU applyToEither(CompletionStage? extends T other, Function? super T, U fn)
public U CompletableFutureU applyToEitherAsync(CompletionStage? extends T other, Function? super T, U fn)
public U CompletableFutureU applyToEitherAsync(CompletionStage? extends T other, Function? super T, U fn,Executor executor)public CompletableFutureVoid acceptEither(CompletionStage? extends T other, Consumer? super T action)
public CompletableFutureVoid acceptEitherAsync(CompletionStage? extends T other, Consumer? super T action)
public CompletableFutureVoid acceptEitherAsync(CompletionStage? extends T other, Consumer? super T action,Executor executor)public CompletableFutureVoid runAfterEither(CompletionStage? other,Runnable action)
public CompletableFutureVoid runAfterEitherAsync(CompletionStage? other,Runnable action)
public CompletableFutureVoid runAfterEitherAsync(CompletionStage? other,Runnable action,Executor executor)
当两个任务中 任意一个 future 任务完成的时候 执行任务。applyToEither 两个任务有一个执行完成 获取它的返回值 处理任务并有新的返回值。acceptEither 两个任务有一个执行完成 获取它的返回值 处理任务 没有新的返回值。runAfterEither 两个任务有一个执行完成 不需要获取 future 的结果 处理任务 也没有返 回值。
1.3.6.1 runAfterEitherAsync 线程1执行完成线程2睡了3秒达成runAfterEitherAsync执行条件 public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);CompletableFutureInteger future01 CompletableFuture.supplyAsync(() - {System.out.println(任务1线程Thread.currentThread().getId());int i 10/4;System.out.println(任务1结束。。。);return i;}, executorService);CompletableFutureString future02 CompletableFuture.supplyAsync(() - {System.out.println(任务2线程Thread.currentThread().getId());try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(任务2结束。。。);return Hello;}, executorService);/*** 两个任务只要有一个完成我们就执行任务3*/future01.runAfterEitherAsync(future02,()-{System.out.println(任务3开始。。。之前的结果);},executorService);System.out.println(main...end...);}
}
执行结果 1.3.6.2 acceptEitherAsync 两个任务的返回值类型要一致这里全改为Object public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);CompletableFutureObject future01 CompletableFuture.supplyAsync(() - {System.out.println(任务1线程Thread.currentThread().getId());int i 10/4;System.out.println(任务1结束。。。);return i;}, executorService);CompletableFutureObject future02 CompletableFuture.supplyAsync(() - {System.out.println(任务2线程Thread.currentThread().getId());try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(任务2结束。。。);return Hello;}, executorService);/*** 两个任务只要有一个完成我们就执行任务3*///future01.runAfterEitherAsync(future02,()-{// System.out.println(任务3开始。。。之前的结果);//},executorService);future01.acceptEitherAsync(future02,res-{System.out.println(任务3开始。。。之前的结果res);},executorService);System.out.println(main...end...);}
}
执行结果 1.3.6.3 applyToEitherAsync
public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);CompletableFutureObject future01 CompletableFuture.supplyAsync(() - {System.out.println(任务1线程Thread.currentThread().getId());int i 10/4;System.out.println(任务1结束。。。);return i;}, executorService);CompletableFutureObject future02 CompletableFuture.supplyAsync(() - {System.out.println(任务2线程Thread.currentThread().getId());try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(任务2结束。。。);return Hello;}, executorService);/*** 两个任务只要有一个完成我们就执行任务3*///future01.runAfterEitherAsync(future02,()-{// System.out.println(任务3开始。。。之前的结果);//},executorService);//future01.acceptEitherAsync(future02,res-{// System.out.println(任务3开始。。。之前的结果res);//},executorService);CompletableFutureString future future01.applyToEitherAsync(future02, res - {System.out.println(任务3开始。。。之前的结果res);return res.toString() 九头蛇;}, executorService);System.out.println(main...end...future.get());}
}
执行结果 1.3.7 多任务组合
public static CompletableFutureVoid allOf(CompletableFuture?... cfs)public static CompletableFutureObject anyOf(CompletableFuture?... cfs)
allOf 等待所有任务完成anyOf 只要有一个任务完成
1.3.7.1 allOf 让查询商品介绍睡3秒钟便于观察。 public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);CompletableFutureString futureImg CompletableFuture.supplyAsync(() - {System.out.println(查询商品的图片信息);return hello.jpg;}, executorService);CompletableFutureString futureAttr CompletableFuture.supplyAsync(() - {System.out.println(查询商品的属性);return 白色256G;}, executorService);CompletableFutureString futureDesc CompletableFuture.supplyAsync(() - {try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(查询商品介绍);return 小米;}, executorService);CompletableFutureVoid allOf CompletableFuture.allOf(futureImg, futureAttr, futureDesc);allOf.get();// 等待所有任务完成System.out.println(main...end...futureImg.get()-futureAttr.get()futureDesc.get());}
} 执行结果 1.3.7.2 anyOf
public class ThreadTest {public static ExecutorService executorService Executors.newFixedThreadPool(10);public static void main(String[] args) throws ExecutionException, InterruptedException {System.out.println(main...start...);CompletableFutureString futureImg CompletableFuture.supplyAsync(() - {System.out.println(查询商品的图片信息);return hello.jpg;}, executorService);CompletableFutureString futureAttr CompletableFuture.supplyAsync(() - {System.out.println(查询商品的属性);return 白色256G;}, executorService);CompletableFutureString futureDesc CompletableFuture.supplyAsync(() - {try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(查询商品介绍);return 小米;}, executorService);//CompletableFutureVoid allOf CompletableFuture.allOf(futureImg, futureAttr, futureDesc);//allOf.get();// 等待所有任务完成//System.out.println(main...end...futureImg.get()-futureAttr.get()futureDesc.get());CompletableFutureObject anyOf CompletableFuture.anyOf(futureImg, futureAttr, futureDesc);System.out.println(main...end...anyOf.get());}
}
执行结果 2. 商品详情
2.1 环境搭建
2.1.1 SwitchHosts增加配置 添加商品详情的域名与ip映射172.1.11.10 item.gulimall.com 2.1.2 nginx配置 配置域名 item.gulimall.com这里之前应该配置过如下 server_name gulimall.com *.gulimall.com; # 打开nginx配置文件
vi /root/docker/nginx/conf/conf.d/gulimall.conf 2.1.3 配置网关转发 将商品详情域名(item.gulimall.com)访问转发的商品服务。 - id: gulimall_host_routeuri: lb://gulimall-productpredicates:# 由以下的主机域名访问转发到商品服务- Hostgulimall.com,item.gulimall.com
2.1.4 商品详情页面搭建
1. 将shangpinxiangqing.html复制到gulimall-product/src/main/resources/templates并改名为item.html
2. 将静态资源放到nginx的/root/docker/nginx/html/static/item/路径下
3. 将item.html页面的href和src以/static/item/开头。 4. 在gulimall-product/src/main/java/com/wen/gulimall/product/web/下编写ItemController.java
5. 启动网关服务、商品服务、搜索服务进行测试1在搜索服务点击某个商品发现无法跳转至商品详情服务修改搜索服务list.html如下通过右键商品审查元素发现需要修改classda的图片跳转路径如下:
p classdaa th:href|http://item.gulimall.com/${product.skuId}.html| img th:src${product.skuImg} classdim/a
/p
Controller
public class ItemController {GetMapping(/{skuId}.html)public String item(PathVariable Long skuId){System.out.println(准备查询skuId的详情);return item;}
}
2.1.5 模型抽取
封装页面需要的详情数据模型如下
Data
public class SkuItemVo {// 获取sku的基本信息 pms_sku_infoprivate SkuInfoEntity info;// 获取sku的图片信息 pms_sku_imagesprivate ListSkuImagesEntity images;// 获取spu的销售属性组合private ListSkuItemSaleAttrVo saleAttr;// 获取spu的介绍private SpuInfoDescEntity desc;// 获取spu的规格参数信息private ListSpuItemAttrGroupVo groupAttrs;}
ToString
Data
public class SpuItemAttrGroupVo {private String groupName;private ListAttr attrs;
}
// 之前代码中存在
Data
public class Attr {private Long attrId;private String attrName;private String attrValue;
}
ToString
Data
public class SkuItemSaleAttrVo {private Long attrId;private String attrName;private ListAttrValueAndWithSkuIdVo attrValues;
}
Data
public class AttrValueAndWithSkuIdVo {// 属性值private String attrValue;// 属性编号属性名属性值对应的所有skuIdprivate String skuIds;
}
2.1.6 商品详情的业务代码
2.1.6.1 controller层
Controller
public class ItemController {Resourceprivate SkuInfoService skuInfoService;GetMapping(/{skuId}.html)public String item(PathVariable Long skuId, Model model){// 获取sku的基本信息 pms_sku_info// 获取sku的图片信息 pms_sku_images// 获取spu的销售属性组合// 获取spu的介绍// 获取spu的规格参数信息SkuItemVo vo skuInfoService.item(skuId);model.addAttribute(item,vo);return item;}
}
2.1.6.2 service层
public interface SkuInfoService extends IServiceSkuInfoEntity {...SkuItemVo item(Long skuId);
}
Service(skuInfoService)
public class SkuInfoServiceImpl extends ServiceImplSkuInfoDao, SkuInfoEntity implements SkuInfoService {Resourceprivate SkuImagesService skuImagesService;Resourceprivate SpuInfoDescService spuInfoDescService;Resourceprivate AttrGroupService attrGroupService;Resourceprivate SkuSaleAttrValueService skuSaleAttrValueService;...Overridepublic SkuItemVo item(Long skuId) {SkuItemVo skuItemVo new SkuItemVo();// 获取sku的基本信息 pms_sku_infoSkuInfoEntity info getById(skuId);skuItemVo.setInfo(info);Long spuId info.getSpuId();Long catalogId info.getCatalogId();// 获取sku的图片信息 pms_sku_imagesListSkuImagesEntity images skuImagesService.getImagesBySkuId(skuId);skuItemVo.setImages(images);// 获取spu的销售属性组合ListSkuItemSaleAttrVo saleAttrVos skuSaleAttrValueService.getSaleAttrsBySpuId(spuId);skuItemVo.setSaleAttr(saleAttrVos);// 获取spu的介绍SpuInfoDescEntity spuInfoDescEntity spuInfoDescService.getById(spuId);skuItemVo.setDesc(spuInfoDescEntity);// 获取spu的规格参数信息ListSpuItemAttrGroupVo attrGroupVos attrGroupService.getAttrGroupWithAttrsBySpuId(spuId,catalogId);skuItemVo.setGroupAttrs(attrGroupVos);return skuItemVo;}}
2.1.6.3 获取sku的图片信息
public interface SkuImagesService extends IServiceSkuImagesEntity {...ListSkuImagesEntity getImagesBySkuId(Long skuId);
}
Service(skuImagesService)
public class SkuImagesServiceImpl extends ServiceImplSkuImagesDao, SkuImagesEntity implements SkuImagesService {...Overridepublic ListSkuImagesEntity getImagesBySkuId(Long skuId) {ListSkuImagesEntity imagesEntities this.baseMapper.selectList(new QueryWrapperSkuImagesEntity().eq(sku_id, skuId));return imagesEntities;}}
2.1.6.4 获取spu的规格参数
public interface AttrGroupService extends IServiceAttrGroupEntity {...ListSpuItemAttrGroupVo getAttrGroupWithAttrsBySpuId(Long spuId, Long catalogId);
}
Service(attrGroupService)
public class AttrGroupServiceImpl extends ServiceImplAttrGroupDao, AttrGroupEntity implements AttrGroupService {...Overridepublic ListSpuItemAttrGroupVo getAttrGroupWithAttrsBySpuId(Long spuId, Long catalogId) {ListSpuItemAttrGroupVo vos this.baseMapper.getAttrGroupWithAttrsBySpuId(spuId,catalogId);return vos;}
}
Mapper
public interface AttrGroupDao extends BaseMapperAttrGroupEntity {ListSpuItemAttrGroupVo getAttrGroupWithAttrsBySpuId(Param(spuId) Long spuId, Param(catalogId) Long catalogId);}
?xml version1.0 encodingUTF-8?
!DOCTYPE mapper PUBLIC -//mybatis.org//DTD Mapper 3.0//EN http://mybatis.org/dtd/mybatis-3-mapper.dtdmapper namespacecom.wen.gulimall.product.dao.AttrGroupDaoresultMap idspuItemAttrGroupVo typecom.wen.gulimall.product.vo.SpuItemAttrGroupVoresult propertygroupName columngroupName/collection propertyattrs ofTypecom.wen.gulimall.product.vo.Attrresult propertyattrName columnattrName/result propertyattrValue columnattrValue//collection/resultMapselect idgetAttrGroupWithAttrsBySpuId resultMapspuItemAttrGroupVoSELECTpav.spu_id,ag.attr_group_id,ag.attr_group_name groupName,attr.attr_name attrName,pav.attr_value attrValueFROM pms_attr_group ag LEFT JOIN pms_attr_attrgroup_relation aar ON (ag.attr_group_idaar.attr_group_id)LEFT JOIN pms_attr attr ON (aar.attr_idattr.attr_id)LEFT JOIN pms_product_attr_value pav ON (attr.attr_id pav.attr_id)WHERE ag.catelog_id #{catalogId} AND pav.spu_id #{spuId}/select/mapper
2.1.6.5 获取spu的销售属性组合
public interface SkuSaleAttrValueService extends IServiceSkuSaleAttrValueEntity {...ListSkuItemSaleAttrVo getSaleAttrsBySpuId(Long spuId);
}
Service(skuSaleAttrValueService)
public class SkuSaleAttrValueServiceImpl extends ServiceImplSkuSaleAttrValueDao, SkuSaleAttrValueEntity implements SkuSaleAttrValueService {...Overridepublic ListSkuItemSaleAttrVo getSaleAttrsBySpuId(Long spuId) {ListSkuItemSaleAttrVo vos this.baseMapper.getSaleAttrsBySpuId(spuId);return vos;}}
Mapper
public interface SkuSaleAttrValueDao extends BaseMapperSkuSaleAttrValueEntity {ListSkuItemSaleAttrVo getSaleAttrsBySpuId(Param(spuId) Long spuId);
}
?xml version1.0 encodingUTF-8?
!DOCTYPE mapper PUBLIC -//mybatis.org//DTD Mapper 3.0//EN http://mybatis.org/dtd/mybatis-3-mapper.dtdmapper namespacecom.wen.gulimall.product.dao.SkuSaleAttrValueDaoresultMap idskuItemSaleAttrVo typecom.wen.gulimall.product.vo.SkuItemSaleAttrVoresult propertyattrId columnattr_id/result propertyattrName columnattr_name/collection propertyattrValues ofTypecom.wen.gulimall.product.vo.AttrValueAndWithSkuIdVoresult propertyattrValue columnattr_value/result propertyskuIds columnsku_ids//collection/resultMapselect idgetSaleAttrsBySpuId resultMapskuItemSaleAttrVoSELECTssav.attr_id,ssav.attr_name,ssav.attr_value,GROUP_CONCAT(DISTINCT info.sku_id) sku_idsFROM pms_sku_info info LEFT JOIN pms_sku_sale_attr_value ssav ON info.sku_idssav.sku_idWHERE info.spu_id#{spuId}GROUP BY ssav.attr_id,ssav.attr_name,ssav.attr_value/select
/mapper
2.1.7 详情页渲染【P207-P209】
!DOCTYPE html
html xmlns:thhttp://www.thymeleaf.orgheadmeta charsetUTF-8title/titlelink relstylesheet typetext/css href/static/item/scss/shop.css /link relstylesheet typetext/css href/static/item/scss/jd.css/link relstylesheet href/static/item/scss/header.css /link relstylesheet typetext/css href/static/item/bootstrap/css/bootstrap.css//headbodydiv idmaxheader!--品牌官方网站--div classminul classheader_ul_leftli classglyphicon glyphicon-home a href/static/item/shouye.html classaa京东首页/a/lili classglyphicon glyphicon-map-marker a href/static/item/javascript:;北京/aol idbeijingli stylebackground: red;a hrefjavascript:; stylecolor: white;北京/a/lilia hrefjavascript:;上海/a/lilia hrefjavascript:;天津/a/lilia hrefjavascript:;重庆/a/lilia hrefjavascript:;河北/a/lilia hrefjavascript:;山西/a/lilia hrefjavascript:;河南/a/lilia hrefjavascript:;辽宁/a/lilia hrefjavascript:;吉林/a/lilia hrefjavascript:;黑龙江/a/lilia hrefjavascript:;内蒙古/a/lilia hrefjavascript:;江苏/a/lilia hrefjavascript:;山东/a/lilia hrefjavascript:;安徽/a/lilia hrefjavascript:;浙江/a/lilia hrefjavascript:;福建/a/lilia hrefjavascript:;湖北/a/lilia hrefjavascript:;湖南/a/lilia hrefjavascript:;广东/a/lilia hrefjavascript:;广西/a/lilia hrefjavascript:;江西/a/lilia hrefjavascript:;四川/a/lilia hrefjavascript:;海南/a/lilia hrefjavascript:;贵州/a/lilia hrefjavascript:;云南/a/lilia hrefjavascript:;西藏/a/lilia hrefjavascript:;陕西/a/lilia hrefjavascript:;甘肃/a/lilia hrefjavascript:;青海/a/lilia hrefjavascript:;宁夏/a/lilia hrefjavascript:;新疆/a/lilia hrefjavascript:;港澳/a/lilia hrefjavascript:;台湾/a/lilia hrefjavascript:;钓鱼岛/a/lilia hrefjavascript:;海外/a/li/ol/li/ulul classheader_ul_rightli styleborder: 0;a href../登录页面\index.html classaa你好请登录/a/lilia href../注册页面\index.html stylecolor: red;免费注册/a |/lilia hrefjavascript:; classaa我的订单/a |/lili classjingdonga hrefjavascript:;我的京东/aspan classglyphicon glyphicon-menu-down|/spanol classjingdong_ollia hrefjavascript:;待处理订单/a/lilia hrefjavascript:;消息/a/lilia hrefjavascript:;返修退换货/a/lilia hrefjavascript:;我的回答/a/lilia hrefjavascript:;降价商品/a/lilia hrefjavascript:;我的关注/a/lili stylewidth: 100%;height: 1px;background: lavender;margin-top: 15px;/lili stylemargin-top: 0;a hrefjavascript:;我的京豆/a/lili stylemargin-top: 0;a hrefjavascript:;我的优惠券/a/lili stylemargin-bottom: 10px;a hrefjavascript:;我的白条/a/li/ol/lilia hrefjavascript:; classaa京东会员/a |/lilia hrefjavascript:; classaa企业采购/a |/lili classfuwua hrefjavascript:;客户服务/aspan classglyphicon glyphicon-menu-down/span |ol classfuwu_olh6客户/h6lia hrefjavascript:;帮助中心/a/lilia hrefjavascript:;售后服务/a/lilia hrefjavascript:;在线客服/a/lilia hrefjavascript:;意见建议/a/lilia hrefjavascript:;电话客服/a/lilia hrefjavascript:;客服邮箱/a/lili stylemargin-bottom: -5px;a hrefjavascript:;金融咨询/a/lili stylemargin-bottom: -5px;a hrefjavascript:;售全球客服/a/lih6 styleborder-top: 1px dashed darkgray;height: 30px;line-height: 30px;商户/h6li stylemargin-top: -5px;a hrefjavascript:;合作招商/a/lili stylemargin-top: -5px;a hrefjavascript:;学习中心/a/lilia hrefjavascript:;商家后台/a/lilia hrefjavascript:;京麦工作台/a/lilia hrefjavascript:;商家帮助/a/lilia hrefjavascript:;规则平台/a/li/ol/lili classdaohanga hrefjavascript:;网站导航/aspan classglyphicon glyphicon-menu-down/span |ol classdaohang_olli stylewidth: 34%;h5特色主题/h5pa hrefjavascript:;京东试用/aa hrefjavascript:;京东金融/aa hrefjavascript:;全球售/aa hrefjavascript:;国际站/a/ppa hrefjavascript:;京东会员/aa hrefjavascript:;京东预售/aa hrefjavascript:;买什么/aa hrefjavascript:;俄语站/a/ppa hrefjavascript:;装机大师/aa hrefjavascript:;0元评测/aa hrefjavascript:;定期送/aa hrefjavascript:;港澳售/a/ppa hrefjavascript:;优惠券/aa hrefjavascript:;秒杀/aa hrefjavascript:;闪购/aa hrefjavascript:;印尼站/a/ppa hrefjavascript:;京东金融科技/aa hrefjavascript:;In货推荐/aa hrefjavascript:;陪伴计划/aa hrefjavascript:;出海招商/a/p/lilih5行业频道/h5pa hrefjavascript:; classaa_2手机/aa hrefjavascript:; classaa_2智能数码/aa hrefjavascript:; classaa_2玩3C/a/ppa hrefjavascript:; classaa_2电脑办公/aa hrefjavascript:; classaa_2家用电器/aa hrefjavascript:; classaa_2京东智能/a/ppa hrefjavascript:; classaa_2服装城/aa hrefjavascript:; classaa_2美妆馆/aa hrefjavascript:; classaa_2家装城/a/ppa hrefjavascript:; classaa_2母婴/aa hrefjavascript:; classaa_2食品/aa hrefjavascript:; classaa_2运动户外/a/ppa hrefjavascript:; classaa_2农资频道/aa hrefjavascript:; classaa_2整车/aa hrefjavascript:; classaa_2图书/a/p/lilih5生活服务/h5pa hrefjavascript:; classaa_2京东众筹/aa hrefjavascript:; classaa_2白条/aa hrefjavascript:; classaa_2京东金融APP/a/ppa hrefjavascript:; classaa_2京东小金库/aa hrefjavascript:; classaa_2理财/aa hrefjavascript:; classaa_2智能家电/a/ppa hrefjavascript:; classaa_2话费/aa hrefjavascript:; classaa_2水电煤/aa hrefjavascript:; classaa_2彩票/a/ppa hrefjavascript:; classaa_2旅行/aa hrefjavascript:; classaa_2机票酒店/aa hrefjavascript:; classaa_2电影票/a/ppa hrefjavascript:; classaa_2京东到家/aa hrefjavascript:; classaa_2京东众测/aa hrefjavascript:; classaa_2游戏/a/p/lili styleborder: 0;h5更多精选/h5pa hrefjavascript:; classaa_2合作招商/aa hrefjavascript:; classaa_2京东通信/aa hrefjavascript:; classaa_2京东E卡/a/ppa hrefjavascript:; classaa_2企业采购/aa hrefjavascript:; classaa_2服务市场/aa hrefjavascript:; classaa_2办公生活馆/a/ppa hrefjavascript:; classaa_2乡村招募/aa hrefjavascript:; classaa_2校园加盟/aa hrefjavascript:; classaa_2京友邦/a/ppa hrefjavascript:; classaa_2京东社区/aa hrefjavascript:; classaa_2智能社区/aa hrefjavascript:; classaa_2游戏社区/a/ppa hrefjavascript:; classaa_2知识产权维权/aa hrefjavascript:; classaa_2/aa hrefjavascript:; classaa_2/a/p/li/ol/lili classsjjd styleborder: 0;a hrefjavascript:; classaa手机京东/adiv classerdiv classer_1div classer_1_1h6a href#手机京东/a/h6p新人专享大礼包/p/div/divdiv classer_1div classer_1_1h6a href#关注京东微信/a/h6p微信扫一扫关注新粉最高180元惊喜礼包/p/div/div!--我的理财--div classer_1 styleborder: 0;img src/static/item/img/5874a555Ne8192324.jpg/div classer_1_1h6a href#京东金融客户端/a/h6p新人专享大礼包/pdiva href#img src/static/item/img/11.png//aa href#img src/static/item/img/22.png//a/div/div/div/div/li/ul/div/headernavdiv classnav_mindiv classnav_topdiv classnav_top_onea href#img src/static/item/img/111.png//a/divdiv classnav_top_twoinput typetext/button搜索/button/divdiv classnav_top_threea href../JD_Shop/One_JDshop.html我的购物车/aspan classglyphicon glyphicon-shopping-cart/spandiv classnav_top_three_1img src/static/item/img/44.png/购物车还没有商品赶紧选购吧/div/div/divdiv classnav_downul classnav_down_ulli classnav_down_ul_1 stylewidth: 24%;float: left;a hrefjavascript:;全部商品分类/a/lili classul_lia hrefjavascript:;服装城/a/lili classul_lia hrefjavascript:;美妆馆/a/lili classul_lia hrefjavascript:;超市/a/lili classul_li styleborder-right: 1px solid lavender;a hrefjavascript:;生鲜/a/lili classul_lia hrefjavascript:;全球购/a/lili classul_lia hrefjavascript:;闪购/a/lili classul_li styleborder-right: 1px solid lavender;a hrefjavascript:;拍卖/a/lili classul_lia hrefjavascript:;金融/a/li/ul/div/div/nav/divdiv classcrumb-wrapdiv classwdiv classcrumbdiv classcrumb-itema href手机/a/divdiv classcrumb-item sep/divdiv classcrumb-itema href手机通讯/a/divdiv classcrumb-item sep/divdiv classcrumb-itema href手机/a/divdiv classcrumb-item sep/divdiv classcrumb-itemdiv classcrumb-item-one华为 (HUAWEI)img src/static/item/img/4a79b87a68623d4e8a73aff3e25fa99b.png alt classimg /div classcrumb-item-two div classcrumb-item-con clearul classcon-ulliimg src/static/item/img/5825a5a6Nde8ecb75.jpg alt //lilip荣耀8青春版 全网通标配 3GB32GB 幻海蓝/pp1099.00/p/li/ulul classcon-ulliimg src/static/item/img/5919637aN271a1301.jpg alt //lilip荣耀8青春版 全网通标配 3GB32GB 幻海蓝/pp1099.00/p/li/ulul classcon-ulliimg src/static/item/img/599a806bN9d829c1c.jpg alt //lilip荣耀8青春版 全网通标配 3GB32GB 幻海蓝/pp1099.00/p/li/ul/divdiv classcrumb-item-cons clearulli华为(huawei)/lili小米(xiaomi)/liliAPPle/lili魅族(meizu)/lili锤子/li/ululli三星/lilivivo/lili飞利浦/lili360/lili更多/li/ul/div/div/div/divdiv classcrumb-item sep/divdiv classcrumb-item华为Mate 10/div/divdiv classcontactul classcontact-ullia href#华为京东自营官方旗舰店/aspan classcontact-spspan classcontact-sp1JD/spanspan classcontact-sp2自营/span/span/lilia href#img src/static/item/img/f5831b9848b32440b381bcd30a3d96c7.png alt / 联系供应商/a/lilia href#img src/static/item/img/81a6326edc82d343a5a8860a6970f93b.png alt / JIMI/a/lilia href#img src/static/item/img/a400e3d61d5645459f769b00d9f431e7.png alt / 关注店铺/a/li/uldiv classcontact-oneulli客服/liliimg src/static/item/img/f5831b9848b32440b381bcd30a3d96c7.png alt /留言/liliimg src/static/item/img/81a6326edc82d343a5a8860a6970f93b.png alt /JIMI智能/liliimg src/static/item/img/1466134037230.jpg classcontact-img /p手机下单/p/li/uldiv classcontact-twospanimg src/static/item/img/a400e3d61d5645459f769b00d9f431e7.png alt /进店逛逛/spanspanimg src/static/item/img/a400e3d61d5645459f769b00d9f431e7.png alt /关注店铺/span/div/div/div/div/div
div classShopdiv classboxdiv classbox-one div classboxxdiv classimgboxdiv classproboximg classimg1 alt th:src${item.info.skuDefaultImg}div classhoverbox/div/divdiv classshowboximg classimg1 alt th:src${item.info.skuDefaultImg}/div/divdiv classbox-lhdiv classbox-lh-oneulli th:eachimg:${item.images} th:if${!#strings.isEmpty(img.imgUrl)}img th:src${img.imgUrl} //li/ul/divdiv idleft /divdiv idright/div/divdiv classboxx-oneullispanimg src/static/item/img/b769782fe4ecca40913ad375a71cb92d.png alt /关注/spanspanimg src/static/item/img/9224fcea62bfff479a6712ba3a6b47cc.png alt /对比/span/lili/li/ul/div/divdiv classbox-twodiv classbox-name th:text${item.info.skuTitle}华为 HUAWEI Mate 10 6GB128GB 亮黑色 移动联通电信4G手机 双卡双待/divdiv classbox-hide th:text${item.info.skuSubtitle}预订用户预计11月30日左右陆续发货麒麟970芯片AI智能拍照a hrefu/u/a/divdiv classbox-yuyuediv classyuyue-oneimg src/static/item/img/7270ffc3baecdd448958f9f5e69cf60f.png alt / 预约抢购/divdiv classyuyue-twoulliimg src/static/item/img/f64963b63d6e5849977ddd6afddc1db5.png /span190103/span 人预约/liliimg src/static/item/img/36860afb69afa241beeb33ae86678093.png / 预约剩余span idtimer/span/li/ul/div/divdiv classbox-summary clearulli京东价/lilispan/spanspan th:text${#numbers.formatDecimal(item.info.price,3,2)}4499.00/span/lili预约享资格/lilia href预约说明/a/li/ul/divdiv classbox-wrap cleardiv classbox-wrap-one clearulli增值业务/liliimg src/static/item/img/90a6fa41d0d46b4fb0ff6907ca17c478.png //liliimg src/static/item/img/2e19336b961586468ef36dc9f7199d4f.png //liliimg src/static/item/img/1f80c3d6fabfd3418e54b005312c00b5.png //li/ul/div/divdiv classbox-stockul classbox-ulli配送至/lili classbox-stock-lidiv classbox-stock-one北京朝阳区管庄img src/static/item/img/4a79b87a68623d4e8a73aff3e25fa99b.png alt classimg //divdiv classbox-stock-twodldta选择新地址/aimg src/static/item/img/4a79b87a68623d4e8a73aff3e25fa99b.png alt classbox-stock-two-img//dtdddiv classbox-stock-dddiv classbox-stock-topdiv classbox-stock-div北京/divdiv classbox-stock-div朝阳区/divdiv classbox-stock-div管庄/div/divdiv classbox-stock-fotdiv classbox-stock-con styledisplay: block;ulli北京/lili上海/lili天津/lili重庆/li/ul/divdiv classbox-stock-conulli朝阳区/lili海淀区/lili东城区/lili西城区/li/ul/divdiv classbox-stock-conulli4环到5环之内/lili管庄/lili北苑/li/ul/div/div/div/dd/dl/div/lilispan th:text${item.hasStock?有货:无货}无货/span 此商品暂时售完/li/ul/divdiv classbox-supplyul classbox-ulli/lili由span京东/span 发货并提供售后服务/li/ul/divdiv classbox-attr-3div classbox-attr clear th:eachattr:${item.saleAttr}dldt[[${attr.attrName}]]/dtdd th:eachvals:${attr.attrValues}a classsku_attr_valueth:attrskus${vals.skuIds},class${#lists.contains(#strings.listSplit(vals.skuIds,,), item.info.skuId.toString())?sku_attr_value checked:sku_attr_value}[[${vals.attrValue}]]
!-- img src/static/item/img/59ddfcb1Nc3edb8f1.jpg / 摩卡金--/a/dd/dl/div/divdiv classbox-btns cleardiv classbox-btns-oneinput typetext name id value1 /div classbox-btns-one1divbutton idjia/button/divdivbutton idjian-/button/div/div/divdiv classbox-btns-twoa href../商品分类\index.html立即预约/a/divdiv classbox-btns-threeimg src/static/item/img/e4ed3606843f664591ff1f68f7fda12d.png alt / 分享/div/divdiv classbox-footer-zodiv classbox-footer cleardldt本地活动/dtdda href·1元500MB激活到账30元 /a/dd/dl/divdiv classbox-footerdldt温馨提示/dtdd·本商品不能使用 东券 京券/dddd·请完成预约后及时抢购/dd/dl/div/div/div/div/div!--欲约抢购流程--div classqianggouliouchengdiv classliouchengh3欲约抢购流程/h3/div!--抢购步骤--ul classqianggoubuzhaoliimg src/static/item/img/shop_03.png /dl classbuzhoudt1.等待预约/dtdl预约即将开始/dl/dl/liliimg src/static/item/img/shop_04.png /dl classbuzhoudt2.预约中/dtdl2017-11-15 10:35 2017-11-15 23:59/dl/dl/liliimg src/static/item/img/shop_05.png /dl classbuzhoudt3.等待抢购/dtdl抢购即将开始/dl/dl/liliimg src/static/item/img/shop_06.png /dl classbuzhoudt4.抢购中/dtdl/dl/dl/li/ul/divdiv classShopXiangqingdiv classallLeft!--火热预约--div classhuoreyuyueh3火热预约/h3/divdiv classdangeshopxingqingul classshopdangelia href##img src/static/item/img/5a0afeddNb34732af.jpg //apa href##OPPO R11s Plus 双卡双待全面屏拍照手机香槟色 全网通(6G RAM64G ROM)标配/a/ppstrong classJ-p-200153419743699.00/strong/p/lilia href##img src/static/item/img/5a12873eN41754123.jpg //apa target_blank title詹姆士GEMRY R19plus全网通4G 智能手机 双卡双待 6128GB 鳄鱼纹雅致版新品预约 href//item.jd.com/20348283521.html詹姆士GEMRY R19plus全网通4G 智能手机 双卡双待 6128GB 鳄鱼纹雅致版新品预约/a/ppstrong classJ-p-2034828352113999.00/strong/p/lilia href##img src/static/item/img/59ec0131Nf239df75.jpg //apa target_blank title斐纳TOMEFON 德国家用无线无绳手持立式充电吸尘器 静音大吸力吸尘器TF-X60 href//item.jd.com/16683419775.html斐纳TOMEFON 德国家用无线无绳手持立式充电吸尘器 静音大吸力吸尘器TF-X60/a/ppstrong classJ-p-166834197751599.00/strong/p/lilia href##img src/static/item/img/59015444N27317512.jpg //apa target_blank title斐纳TOMEFON 扫地机器人德国智能导航规划全自动超薄扫地机器人吸尘器TF-D60 香槟金 href//item.jd.com/12187770381.html斐纳TOMEFON 扫地机器人德国智能导航规划全自动超薄扫地机器人吸尘器TF-D60 香槟金/a/ppstrong classJ-p-121877703812599.00/strong/p/li/ul/div!--看了又看--div classhuoreyuyueh3看了又看/h3/divdiv classdangeshopxingqingul classshopdangelia href##img src/static/item/img/59e55e01N369f98f2.jpg //apa target_blank title华为HUAWEI 华为 Mate10 4G手机 双卡双待 亮黑色 全网通(6GB RAM128GB ROM) href//item.jd.com/17931625443.html华为HUAWEI 华为 Mate10 4G手机 双卡双待 亮黑色 全网通(6GB RAM128GB ROM)/apstrong classJ-p-179316254434766.00/strong/p/lilia href##img src/static/item/img/584fcc3eNdb0ab94c.jpg //apa target_blank title华为 Mate 9 Pro 6GB128GB版 琥珀金 移动联通电信4G手机 双卡双待 href//item.jd.com/3749093.html华为 Mate 9 Pro 6GB128GB版 琥珀金 移动联通电信4G手机 双卡双待/a/ppstrong classJ-p-37490934899.00/strong/p/lili!--shopjieshao--a href##img src/static/item/img/59eb0df9Nd66d7585.jpg //apa target_blank title华为HUAWEI 华为 Mate10 手机 亮黑色 全网通(464G)标准版 href//item.jd.com/12306211773.html华为HUAWEI 华为 Mate10 手机 亮黑色 全网通(464G)标准版/a/ppstrong classJ-p-123062117734088.00/strong/p/lilia href##img src/static/item/img/5a002ba3N126c2f73.jpg //apa target_blank title斐纳TOMEFON 扫地机器人德国智能导航规划全自动超薄扫地机器人吸尘器TF-D60 香槟金 href//item.jd.com/12187770381.html斐纳TOMEFON 扫地机器人德国智能导航规划全自动超薄扫地机器人吸尘器TF-D60 香槟金/a/ppstrong classJ-p-121877703812599.00/strong/p/li/ulimg src/static/item/img/5a084a1aNa1aa0a71.jpg //div/div!--商品介绍--div classallquanbushopul classshopjieshaoli classjieshoa stylebackground: #e4393c;a href## stylecolor: white;商品介绍/a/lili classbaozhuanga href##规格与包装/a/lili classbaozhanga href##售后保障/a/lili classpingjiaa href##商品评价(4万)/a/lili classshuominga href##预约说明/a/li/ulbutton classLijiyuyuessss立即预约/buttonul classshopjieshaos posi styledisplay: none;li classjieshoa stylebackground: #e4393c;a href#li1 stylecolor: white;商品介绍/a/lili classbaozhuanga href#li2规格与包装/a/lili classbaozhanga href#li3售后保障/a/lili classpingjiaa href#li4商品评价(4万)/a/lili classshuominga href#li5预约说明/a/li/ul!--商品详情--div classhuaweiul classxuanxiangkali classjieshoa actives idli1div classshanpinsssss
!-- p--
!-- a href#品牌:华为HUAWEI/a--
!-- /p--
!-- table--
!-- tr--
!-- td--
!-- a href##商品名称华为Mate 10/a--
!-- /td--
!-- td--
!-- a href##商品毛重0.58kg/a--
!-- /td--
!-- td--
!-- a href##商品编号5544038/a--
!-- /td--
!-- td--
!-- a href##商品产地中国大陆/a--
!-- /td--
!-- /tr--
!-- tr--
!-- td--
!-- a href##系统安卓Android/a--
!-- /td--
!-- td--
!-- a href##前置摄像头像素800万-1599万/a--
!-- /td--
!-- td--
!-- a href##后置摄像头像素2000万及以上1200万-1999万/a--
!-- /td--
!-- td--
!-- a href##机身内存128GB/a--
!-- /td--
!-- /tr--
!-- tr--
!-- td colspan4--
!-- a href##全面屏双卡双待指纹识别Type-CVoLTE2K屏拍照神器支持NFC商务手机安全手机分辨率10/a--
!-- /td--
!-- /tr--
!-- /table--img classxiaoguo th:src${desc} th:eachdesc:${#strings.listSplit(item.desc.decript,,)} //div/lili classbaozhuang actives idli2div classguiGeboxdiv classguiGe th:eachgroup:${item.groupAttrs}h3 th:text${group.groupName}主体/h3dldiv th:eachattr:${group.attrs}dt th:text${attr.attrName}品牌/dtdd th:text${attr.attrValue}华为(HUAWEI)/dd/div/dl/div/div/li!--包装--li classbaozhang actives idli3div classoBoxdiv classshuoHoudiv classbaoZhangh2售后保障/h2/div/div!--厂家服务--div classchangJiadiv classlianBaospan classoImgimg src/static/item/img/2017.jpg alt /h3厂家服务/h3/spandiv classwenZi本产品全国联保享受三包服务质保期为一年保br /如因质量问题或故障凭厂商维修中心或特约维修点的质量检测证明享受7日内退货15日内换货15日以上在保质期内享受免费保修等安保服务br /(注如厂家在商品介绍中有售后保障的说明则此商品按照厂家说明执行售后保障服务。)您可以查询本品牌在各地售后服务中心的练习方式a href#请点击这儿查询.../abr /br //div/divdiv classlianBao oCnspan classoImgimg src/static/item/img/2017.jpg alt /h3京东承诺/h3/spandiv classwenZi本产品全国联保享受三包服务质保期为一年保br /如因质量问题或故障凭厂商维修中心或特约维修点的质量检测证明享受7日内退货15日内换货15日以上在保质期内享受免费保修等安保服务br /(注如厂家在商品介绍中有售后保障的说明则此商品按照厂家说明执行售后保障服务。)您可以查询本品牌在各地售后服务中心的练习方式a href#请点击这儿查询.../abr /br /br //div/divdiv classlianBao span classoImgimg src/static/item/img/2017.jpg alt /h3正品行货/h3/spandiv classwenZi hangHuo京东商城向您保证所售商品均为正品行货京东自营商品开具机打发票或电子发票。/div/divdiv classlianBao quanGuospan classoImgimg src/static/item/img/2017-1.jpg alt /h3全国联保/h3/spandiv classwenZi凭质保证书及京东商城发票可享受全国联保服务奢侈品、钟表除外奢侈品、钟表由京东联系保修享受法定三包售后服务与您亲临商场选购的商品享受相同的质量保证。京东商城还为您提供具有竞争力的商品价格和运费政策请您放心购买 br /注因厂家会在没有任何提前通知的情况下更改产品包装、产地或者一些附件本司不能确保客户收到的货物与商城图片、产地、附件说明完全一致。只能确保为原厂正货并且保证与当时市场上同样主流新品一致。若本商城没有及时更新请大家谅解/div/div!--权利声明--div classquanLih4权利声明:/h4div classjingDong京东上的所有商品信息、客户评价、商品咨询、网友讨论等内容是京东重要的经营资源未经许可禁止非法转载使用。br /span classoZhu注/span本站商品信息均来自于合作方其真实性、准确性和合法性由信息拥有者合作方负责。本站不提供任何保证并不承担任何法律责任。/div/divdiv classquanLi jiaGeh4价格说明:/h4div classjingDongspan classoZhu京东价/span京东价为商品的销售价是您最终决定是否购买商品的依据。br /span classoZhu划线价/span商品展示的划横线价格为参考价该价格可能是品牌专柜标价、商品吊牌价或由品牌供应商提供的正品零售价如厂商指导价、建议零售价等或该商品在京东平台上曾经展示过的销售价由于地区、时间的差异性和市场行情波动品牌专柜标价、商品吊牌价等可能会与您购物时展示的不一致该价格仅供您参考。br /span classoZhu折扣/span如无特殊说明折扣指销售商在原价、或划线价如品牌专柜标价、商品吊牌价、厂商指导价、厂商建议零售价等某一价格基础上计算出的优惠比例或优惠金额如有疑问您可在购买前联系销售商进行咨询。br /span classoZhu异常问题/span商品促销信息以商品详情页“促销”栏中的信息为准商品的具体售价以订单结算页价格为准如您发现活动商品售价或促销信息有异常建议购买前先联系销售商咨询。/div/div/div/div/li!--评价--li classPINgjia actives idli4div classh3h3商品评价/h3/divdiv classnavdiv classleftp classhaoping好评度/ppspan100%/span/p/divdiv classrightullia href##就是快424/a/lilia href##物流很快254 /a/lilia href##货真价实168/a/lilia href##有档次158/a/lilia href##国产品牌133/a/lilia href##外形美观103/a/lilia href##很给力75/a/lilia href##反应灵敏68/a/lilia href##性价比高60/a/lilia href##价格优惠50/a/lilia href##功能齐全49/a/lili stylebackground: gainsboro;a href##速度太慢5/a/ul/div/div!--全部评价--div classallpingjiaullia href##全部评价4.2万/a/lilia href##晒图500/a/lilia href##追拼200/a/lilia href##好评4.1万/a/lilia href##中评100/a/lilia href##差评100/a/lilia href##input typecheckbox/只看当前商品价格/a/lili classimga stylefloat: right;a href##推荐排序 img src/static/item/img/animaite.png/ /a/li/ul/div/lili classshuoming actives idli5/li/ul/div/div/div/divdiv classheaderadiv classLogo-tuspanimg src/static/item/img/service_items_1.png//spanspanimg src/static/item/img/service_items_2.png//spanspanimg src/static/item/img/service_items_3.png//spanspanimg src/static/item/img/service_items_4.png//span/divdiv classtabledldta href##购物指南/a/dtdda href##购物流程/a/dddda href##会员介绍/a/dddda href##生活旅行/团购/a/dddda href##常见问题/a/dddda href##大家电/a/dddda href##练习客服/a/dd/dldldta href##配送方式/a/dtdda href##上门自提/a/dddda href##211限时达/a/dddda href##配送服务查询/a/dddda href##/a/dddda href##海外配送/a/dddd/dd/dldldta href##支付方式/a/dtdda href##货到付款/a/dddda href##在线支付/a/dddda href##分期付款/a/dddda href##邮局汇款/a/dddda href##公司转账/a/dddd/dd/dldldta href##售后服务/a/dtdda href##售后政策/a/dddda href##价格保护/a/dddda href##退款说明/a/dddda href##返修/退换货/a/dddda href##取消订单/a/dddd/dd/dldl classdlsdta href##特色服务/a/dtdda href##夺宝岛/a/dddda href##DIY装机/a/dddda href##延保服务/a/dddda href##京东E卡/a/dddda href##京东通信/a/dddda href##京东JD/a/dd/dl/div!--关于我们--div classguanyuwomenullia href##关于我们/a/lili|/lilia href##联系我们/a/lili|/lilia href##联系客服/a/lili|/lilia href##合作招商/a/lili|/lilia href##商家帮助/a/lili|/lilia href##营销中心/a/lili|/lilia href##手机京东/a/lili|/lilia href##友情链接/a/lili|/lilia href##销售联盟/a/lili|/lilia href##京东社区/a/lili|/lilia href##风险检测/a/lili|/lilia href##隐私政策/a/lili|/lilia href##京东公益/a/lili|/lilia href##English Site/a/lili|/lilia href##Mdeila $ IR/a/li/ul/div!--jieshoa--p classp1img src/static/item/img/56a0a994Nf1b662dc.png /a href## 京公网安备 11000002000088号/a|a href## 京ICP证070359号/a|a href## 互联网药品信息服务资格证编号(京)-经营性-2014-0008 /a|a href##新出发京零 字第大120007号/a/pp classp1a href## 互联网出版许可证编号新出网证(京)字150号/a|a href## 出版物经营许可证/a|a href## 网络文化经营许可证京网文 /a|a href##[2014]2148-348号 /a|a href## 违法和不良信息举报电话 /a|a href##4006561155 /a/pp classp1a href## Copyright © 2004-2017 京东JD.com 版权所有/a|a href## 消费者维权热线4006067733 经营证照/a|/pp classp1a href## 京东旗下网站京东支付/a|a href## 京东云/a/pp classp3img src/static/item/img/54b8871eNa9a7067e.png /img src/static/item/img/54b8872dNe37a9860.png /img src/static/item/img/54b8875fNad1e0c4c.png /img src/static/item/img/5698dc03N23f2e3b8.jpg /img src/static/item/img/5698dc16Nb2ab99df.jpg /img src/static/item/img/56a89b8fNfbaade9a.jpg //p/divdiv classFixedbianulli classli1a classaaa href##顶部/a/li/ul/divdiv classgouwuchexiaguoimg src/static/item/img/44.png /span购物车还没有商品赶紧选购吧/span/div/bodyscript src/static/item/js/jquery1.9.js typetext/javascript charsetutf-8/scriptscript src/static/item/js/js.js typetext/javascript charsetutf-8/scriptscript$(.sku_attr_value).click(function (){// 1. 点击的元素先添加上自定义的属性。为了识别我们是刚才被点击的var skus new Array();$(this).addClass(clicked);var curr $(this).attr(skus).split(,);skus.push(curr);// 2. 去掉同一行所有的checked$(this).parent().parent().find(.sku_attr_value).removeClass(checked);// 3. 找到其他被选中的属性$(a[classsku_attr_value checked]).each(function (){skus.push($(this).attr(skus).split(,));});// 4. 使用filter取出他们的交集得到skuIdvar filterEle skus[0];for(var i1 ;iskus.length ;i){filterEle $(filterEle).filter(skus[i]);}console.log(filterEle[0])location.href http://item.gulimall.com/filterEle[0].html;});$(function (){$(.sku_attr_value).parent().css({border:solid 1px #CCC});$(a[classsku_attr_value checked]).parent().css({border:solid 1px red})})/script/html
2.1.8 异步编排优化 所有的操作针对于商品服务gulimall-product。
2.1.8.1 自定义线程池
2.1.8.1.1 引入依赖 spring-boot-configuration-processor作用你自己创建的配置类生成元数据信息这样就能在你自己的配置文件中显示出来非常的方便。【可以不加】
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-configuration-processor/artifactIdoptionaltrue/optional
/dependency
引入以上依赖配置文件中会显示 2.1.8.1.2 线程池属性配置类
gulimall-product/src/main/java/com/wen/gulimall/product/config/ThreadPoolConfigProperties.java
Data
Component
ConfigurationProperties(prefix gulimall.thread)
public class ThreadPoolConfigProperties {private Integer coreSize;private Integer maxSize;private Integer keepAliveTime;
} 2.1.8.1.3 配置文件中配置
gulimall:thread:core-size: 20max-size: 200keep-alive-time: 10
2.1.8.1.4 自定义线程池
gulimall-product/src/main/java/com/wen/gulimall/product/config/MyThreadConfig.java
/*** description 线程池配置* 注意线程池属性类ThreadPoolConfigProperties已经使用了Component放入容器中* 不需要在使用EnableConfigurationProperties(ThreadPoolConfigProperties.class)*/
//EnableConfigurationProperties(ThreadPoolConfigProperties.class)
Configuration
public class MyThreadConfig {Beanpublic ThreadPoolExecutor threadPoolExecutor(ThreadPoolConfigProperties poolProperties){return new ThreadPoolExecutor(poolProperties.getCoreSize(),poolProperties.getMaxSize(),poolProperties.getKeepAliveTime(),TimeUnit.SECONDS,new LinkedBlockingQueue(100000),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());}
}
2.1.8.2 异步编排优化商品详情业务
2.1.8.2.1 controller层
Controller
public class ItemController {Resourceprivate SkuInfoService skuInfoService;GetMapping(/{skuId}.html)public String item(PathVariable Long skuId, Model model){// 获取sku的基本信息 pms_sku_info// 获取sku的图片信息 pms_sku_images// 获取spu的销售属性组合// 获取spu的介绍// 获取spu的规格参数信息SkuItemVo vo null;try {vo skuInfoService.item(skuId);} catch (ExecutionException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}model.addAttribute(item,vo);return item;}
}
2.1.8.2.2 service层
Service(skuInfoService)
public class SkuInfoServiceImpl extends ServiceImplSkuInfoDao, SkuInfoEntity implements SkuInfoService {Resourceprivate SkuImagesService skuImagesService;Resourceprivate SpuInfoDescService spuInfoDescService;Resourceprivate AttrGroupService attrGroupService;Resourceprivate SkuSaleAttrValueService skuSaleAttrValueService;Resourceprivate ThreadPoolExecutor threadPoolExecutor;...Overridepublic SkuItemVo item(Long skuId) throws ExecutionException, InterruptedException {SkuItemVo skuItemVo new SkuItemVo();// 1.获取sku的基本信息 pms_sku_infoCompletableFutureSkuInfoEntity infoFuture CompletableFuture.supplyAsync(() - {SkuInfoEntity info getById(skuId);skuItemVo.setInfo(info);return info;}, threadPoolExecutor);CompletableFutureVoid saleAttrFuture infoFuture.thenAcceptAsync((res) - {// 3.获取spu的销售属性组合ListSkuItemSaleAttrVo saleAttrVos skuSaleAttrValueService.getSaleAttrsBySpuId(res.getSpuId());skuItemVo.setSaleAttr(saleAttrVos);}, threadPoolExecutor);CompletableFutureVoid descFuture infoFuture.thenAcceptAsync(res - {// 4.获取spu的介绍SpuInfoDescEntity spuInfoDescEntity spuInfoDescService.getById(res.getSpuId());skuItemVo.setDesc(spuInfoDescEntity);}, threadPoolExecutor);CompletableFutureVoid baseAttrFuture infoFuture.thenAcceptAsync(res - {// 5.获取spu的规格参数信息ListSpuItemAttrGroupVo attrGroupVos attrGroupService.getAttrGroupWithAttrsBySpuId(res.getSpuId(), res.getCatalogId());skuItemVo.setGroupAttrs(attrGroupVos);}, threadPoolExecutor);CompletableFutureVoid imageFuture CompletableFuture.runAsync(() - {// 2.获取sku的图片信息 pms_sku_imagesListSkuImagesEntity images skuImagesService.getImagesBySkuId(skuId);skuItemVo.setImages(images);}, threadPoolExecutor);// 等待所有任务都完成不用写infoFuture因为saleAttrFuture/descFuture/baseAttrFuture他们依赖infoFuture完成的结果CompletableFuture.anyOf(saleAttrFuture,descFuture,baseAttrFuture,imageFuture).get();return skuItemVo;}}
