家资是何物，积帙列梁梠。这篇文章主要讲述高并发下的批量处理与单个处理（利用jdk8新特性处理，提高性能）相关的知识，希望能为你提供帮助。
【高并发下的批量处理与单个处理（利用jdk8新特性处理，提高性能）】1、技术选型：
SpringBoot
2、案例：
实体类：

package com.zhangwl.complicatedemo.pojo;

import java.sql.Timestamp;

/**
* @ClassName Goods
* @Description
* @Author zhangwl
* @Date 2019/10/3 0:54
* @Version 1.0
**/
public class Goods {

private String goodsName;
private Timestamp goodsDate;
private String goodsCode;
private String serialNumber;

public Goods() {
}

public Goods(String goodsName, Timestamp goodsDate, String goodsCode, String serialNumber) {
this.goodsName = goodsName;
this.goodsDate = goodsDate;
this.goodsCode = goodsCode;
this.serialNumber = serialNumber;
}

public String getGoodsName() {
return goodsName;
}

public void setGoodsName(String goodsName) {
this.goodsName = goodsName;
}

public Timestamp getGoodsDate() {
return goodsDate;
}

public void setGoodsDate(Timestamp goodsDate) {
this.goodsDate = goodsDate;
}

public String getGoodsCode() {
return goodsCode;
}

public void setGoodsCode(String goodsCode) {
this.goodsCode = goodsCode;
}

public String getSerialNumber() {
return serialNumber;
}

public void setSerialNumber(String serialNumber) {
this.serialNumber = serialNumber;
}

@Override
public String toString() {
return "Goods{" +
"goodsName=‘" + goodsName + ‘\‘‘ +
", goodsDate=" + goodsDate +
", goodsCode=‘" + goodsCode + ‘\‘‘ +
", serialNumber=‘" + serialNumber + ‘\‘‘ +
‘}‘;
}
}

package com.zhangwl.complicatedemo.pojo;

import java.util.Map;
import java.util.concurrent.CompletableFuture;

/**
* @ClassName Request
* @Description 封装请求的实体，达到批量求的目的
* @Author zhangwl
* @Date 2019/10/5 17:22
* @Version 1.0
**/
public class Request {

private String goodsCode;

CompletableFuture< Map< String, Object> > future = null;

public Request() {
}

public Request(String goodsCode, CompletableFuture< Map< String, Object> > future) {
this.goodsCode = goodsCode;
this.future = future;
}

public CompletableFuture< Map< String, Object> > getFuture() {
return future;
}

public void setFuture(CompletableFuture< Map< String, Object> > future) {
this.future = future;
}

public String getGoodsCode() {
return goodsCode;
}

public void setGoodsCode(String goodsCode) {
this.goodsCode = goodsCode;
}

@Override
public String toString() {
return "Request{" +
"goodsCode=‘" + goodsCode + ‘\‘‘ +
‘}‘;
}
}
******************************************************************************************************************************************
业务层：

package com.zhangwl.complicatedemo.service;

import com.zhangwl.complicatedemo.pojo.Goods;

import java.util.Map;
import java.util.concurrent.ExecutionException;

/**
* @ClassName GoodsService
* @Description
* @Author zhangwl
* @Date 2019/10/3 0:52
* @Version 1.0
**/
public interface GoodsService {

Map< String, Goods> findGoodsByGoodsCode(String goodsCode);

Map< String ,Object> getGoodsByGoodsCode(String goodsCode) throws ExecutionException, InterruptedException;
}

package com.zhangwl.complicatedemo.service;

import com.zhangwl.complicatedemo.pojo.Goods;
import org.springframework.stereotype.Service;

import java.util.List;
import java.util.Map;

/**
* @ClassName RemoteGoodsServiceCall
* @Description 远程调用接口
* @Author zhangwl
* @Date 2019/10/6 11:33
* @Version 1.0
**/
public interface RemoteGoodsService {

Map< String, Goods> findGoodsByGoodsCode(String goodsCode);

List< Map< String, Object> > findGoodsByBatchGoodsCode(List< String> goodsCodes);
}

package com.zhangwl.complicatedemo.service.impl;

import com.zhangwl.complicatedemo.pojo.Goods;
import com.zhangwl.complicatedemo.pojo.Request;
import com.zhangwl.complicatedemo.service.GoodsService;
import com.zhangwl.complicatedemo.service.RemoteGoodsService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import java.util.*;
import java.util.concurrent.*;

/**
* @ClassName GoodsServiceImpl
* @Description
* @Author zhangwl
* @Date 2019/10/3 0:52
* @Version 1.0
**/
@Service
public class GoodsServiceImpl implements GoodsService {

@Autowired
private RemoteGoodsService remoteGoodsService;


private LinkedBlockingQueue< Request> linkedBlockingQueue = new LinkedBlockingQueue< > ();

@Override
public Map< String, Goods> findGoodsByGoodsCode(String goodsCode) {
Map< String, Goods> map = remoteGoodsService.findGoodsByGoodsCode(goodsCode);
return map;
}

@Override
public Map< String, Object> getGoodsByGoodsCode(String goodsCode) throws ExecutionException, InterruptedException {
/*jdk8将请求结果一一映射(通知)到线程*/
CompletableFuture< Map< String, Object> > future = new CompletableFuture< Map< String, Object> > ();
Request request = new Request(goodsCode, future);
linkedBlockingQueue.add(request);
/*一直阻塞等待,有结果则返回结果*/
return future.get();
}

@PostConstruct
public void init() {
/*创建一个定时器*/
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
scheduledExecutorService.scheduleAtFixedRate(() -> {
int size = linkedBlockingQueue.size();
if (size == 0) {
return;
}
List< Request> requests = new LinkedList< > ();
/*说明队列中有数据*/
linkedBlockingQueue.forEach(o -> {
/*从队列中获取数据*/
Request request = linkedBlockingQueue.poll();
requests.add(request);
});

List< String> params = new LinkedList< > ();
/*批量处理调用接口*/
requests.forEach(o -> {
params.add(o.getGoodsCode());
});
List< Map< String, Object> > goodsMapList = remoteGoodsService.findGoodsByBatchGoodsCode(params);
Map< String, Map< String, Object> > mapResult = new HashMap< > ();
goodsMapList.forEach(o -> {
Set< String> keys = o.keySet();
keys.forEach(o1 -> mapResult.put(o1,o));
});
requests.forEach(o -> {
Map< String, Object> result = mapResult.get(o.getGoodsCode());
o.getFuture().complete(result);
});
}, 0, 10, TimeUnit.MILLISECONDS);
}

}

package com.zhangwl.complicatedemo.service.impl;

import com.zhangwl.complicatedemo.pojo.Goods;
import com.zhangwl.complicatedemo.service.RemoteGoodsService;
import com.zhangwl.complicatedemo.utils.CommonUtils;
import org.springframework.stereotype.Service;

import java.sql.Timestamp;
import java.time.Instant;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

/**
* @ClassName RemoteGoodsServiceCallImpl
* @Description
* @Author zhangwl
* @Date 2019/10/6 11:34
* @Version 1.0
**/
@Service
public class RemoteGoodsServiceImpl implements RemoteGoodsService {
@Override
public Map< String, Goods> findGoodsByGoodsCode(String goodsCode) {
String uuid = CommonUtils.getUUIDString();
Goods goods = new Goods();
long mills = System.currentTimeMillis();
goods.setGoodsName("name" + mills + uuid.substring(0, 3));
goods.setGoodsDate(Timestamp.from(Instant.now()));
goods.setSerialNumber(uuid);
Map< String, Goods> map = new HashMap< > ();
map.put(goodsCode, goods);
return map;
}

@Override
public List< Map< String, Object> > findGoodsByBatchGoodsCode(List< String> goodsCodes) {
List< Map< String, Object> > resultList = new LinkedList< > ();
goodsCodes.forEach(o -> {
String uuid = CommonUtils.getUUIDString();
Goods goods = new Goods();
long mills = System.currentTimeMillis();
goods.setGoodsName("name" + mills + uuid.substring(0, 3));
goods.setGoodsDate(Timestamp.from(Instant.now()));
goods.setGoodsCode(o);
goods.setSerialNumber(uuid);
Map< String, Object> map = new HashMap< > ();
map.put(o, goods);
resultList.add(map);
});
return resultList;
}
}

******************************************************************************************************************************************
测试类：

package com.zhangwl.complicatedemo;

import com.alibaba.fastjson.JSON;
import com.zhangwl.complicatedemo.pojo.Goods;
import com.zhangwl.complicatedemo.service.GoodsService;
import com.zhangwl.complicatedemo.utils.CommonUtils;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.Map;
import java.util.Set;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutionException;

@RunWith(SpringRunner.class)
@SpringBootTest
public class ComplicatedemoApplicationTests {

private static final int T_NUM = 10000;

/*同步计数器*/
private CountDownLatch countDownLatch1 = new CountDownLatch(T_NUM);
private CountDownLatch countDownLatch2 = new CountDownLatch(T_NUM);


@Autowired
private GoodsService goodsService;

@Test
public void contextLoads_01() throws InterruptedException {
for (int i = 0; i < T_NUM; i++) {
Thread t = new Thread(() -> {
try {
countDownLatch1.await();
Map< String, Goods> goodsMap = goodsService.findGoodsByGoodsCode(CommonUtils.getUUIDString());
Set< String> keys = goodsMap.keySet();
keys.forEach(o -> {
String goodsJson = JSON.toJSONString(goodsMap.get(o));
System.out.println(goodsJson);
});
} catch (InterruptedException e) {
e.printStackTrace();
}
});
t.start();
countDownLatch1.countDown();
}

Thread.sleep(3000);
}

/*
* 利用jdk8提高并发处理的能力
*/
@Test
public void contextLoads_02() throws InterruptedException {
for (int i = 0; i < T_NUM; i++) {
Thread t = new Thread(() -> {
try {
countDownLatch2.await();
Map< String, Object> goodsMap = goodsService.getGoodsByGoodsCode(CommonUtils.getUUIDString());
Set< String> keys = goodsMap.keySet();
keys.forEach(o -> {
String goodsJson = JSON.toJSONString(goodsMap.get(o));
System.out.println(goodsJson);
});
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
});
t.start();
countDownLatch2.countDown();
}

Thread.sleep(2000);
}

}

运行结果：
测试类中,

contextLoads_02测试方法的性能优于contextLoads_01方法。

推荐阅读

• 

  南宁：房贷利率新政实施后买房能省多少钱？
• 

  drive|希捷推出 Xbox 专用外置 SSD：1TB 约 1095元，USB 3.2 Gen1 接口
• 

  农户贷款如何界定 「一般农户指什么」
• 

  java用什么软件写代码，JAVA用什么软件编写
• 

  不要吃发物 不要吃过甜过咸和酸性的食物
• 

  八角金盘的介绍-八角金盘的作用
• 

  flutter添加横线，flutter虚线边框
• 

  为什么戒烟后会发胖？
• 

  佛珠多肉烂根怎么办 佛珠多肉烂了怎么办
• 

  中国知名菜刀有什么牌子？中国十大菜刀品牌排行
• 

  从入门到精通，轻松应对各种错误 打印机1700代码解析
• 

  水果礼盒制作步骤大全图解 水果礼盒的制作技巧是怎么样的
• 

  支付宝花呗当面花怎么使用？使用方法及店铺详细介绍
• 

  恒为科技的军方服务器具有怎样的性能？ 恒为科技军方服务器怎么样
• 

  gis中画的图成无效的书签，gis图没了
• 

  工商银行主要业务有哪些
• 

  iphone皮套
• 

  爱普生1430喷墨机清零
• 

  关于vb.neteval的信息
• 

  非诚勿扰影视产业分析

• Android之各个版本之间的变化
• 一个博文引起代码优化的思路
• 一道短小精悍的JS小题目
• 构建一个简单的Spring Boot项目
• 管道符
• Intel推出两款新处理器路线图公布
• 浅谈软件工程个人规划
• 给定一个只包含字符’(’，’)’，’{’，’}’，’[‘和’]&#39;的字符串，判断输入字符串是否有效
• 数字通信之信源编码信道编码调制