色婷婷亚洲精品天,日韩性爱网,精品欧美色视频网站在线观看,亚洲色图在线观看视频,蜜乳一区二区三区有限公司,国产搞屄视频,99热在线观看免费精品,老汉色老汉首页aV亚洲

經(jīng)常有粉絲問程序汪有沒有多線程的代碼案例，網(wǎng)上找到一個(gè)開源的小案例，看了下不錯(cuò)，大家可以參考一波，多線程用好了提升效率減少超時(shí)，用不好系統(tǒng)反而被拖垮

來源：https://gitee.com/string18/excel-utils

前言

公司項(xiàng)目最近有一個(gè)需要：報(bào)表導(dǎo)出。整個(gè)系統(tǒng)下來，起碼超過一百張報(bào)表需要導(dǎo)出。這個(gè)時(shí)候如何優(yōu)雅的實(shí)現(xiàn)報(bào)表導(dǎo)出，釋放生產(chǎn)力就顯得很重要了。下面主要給大家分享一下該工具類的使用方法與實(shí)現(xiàn)思路。

實(shí)現(xiàn)的功能點(diǎn)

對(duì)于每個(gè)報(bào)表都相同的操作，我們很自然的會(huì)抽離出來，這個(gè)很簡(jiǎn)單。而最重要的是：如何把那些每個(gè)報(bào)表不相同的操作進(jìn)行良好的封裝，盡可能的提高復(fù)用性；針對(duì)以上的原則，主要實(shí)現(xiàn)了一下關(guān)鍵功能點(diǎn)：

導(dǎo)出任意類型的數(shù)據(jù)
自由設(shè)置表頭
自由設(shè)置字段的導(dǎo)出格式

使用實(shí)例

上面說到了本工具類實(shí)現(xiàn)了三個(gè)功能點(diǎn)，自然在使用的時(shí)候設(shè)置好這三個(gè)要點(diǎn)即可：

設(shè)置數(shù)據(jù)列表
設(shè)置表頭
設(shè)置字段格式

下面的export函數(shù)可以直接向客戶端返回一個(gè)excel數(shù)據(jù)，其中productInfoPos為待導(dǎo)出的數(shù)據(jù)列表，ExcelHeaderInfo用來保存表頭信息，包括表頭名稱，表頭的首列，尾列，首行，尾行。

因?yàn)槟J(rèn)導(dǎo)出的數(shù)據(jù)格式都是字符串型，所以還需要一個(gè)Map參數(shù)用來指定某個(gè)字段的格式化類型（例如數(shù)字類型，小數(shù)類型、日期類型）。這里大家知道個(gè)大概怎么使用就好了，下面會(huì)對(duì)這些參數(shù)進(jìn)行詳細(xì)解釋

@Override
????public?void?export(HttpServletResponse?response,?String?fileName)?{
????????//?待導(dǎo)出數(shù)據(jù)
????????List?productInfoPos?=?this.multiThreadListProduct();
????????ExcelUtils?excelUtils?=?new?ExcelUtils(productInfoPos,?getHeaderInfo(),?getFormatInfo());
????????excelUtils.sendHttpResponse(response,?fileName,?excelUtils.getWorkbook());
????}

????//?獲取表頭信息
????private?List?getHeaderInfo()?{
????????return?Arrays.asList(
????????????????new?ExcelHeaderInfo(1,?1,?0,?0,?"id"),
????????????????new?ExcelHeaderInfo(1,?1,?1,?1,?"商品名稱"),

????????????????new?ExcelHeaderInfo(0,?0,?2,?3,?"分類"),
????????????????new?ExcelHeaderInfo(1,?1,?2,?2,?"類型ID"),
????????????????new?ExcelHeaderInfo(1,?1,?3,?3,?"分類名稱"),

????????????????new?ExcelHeaderInfo(0,?0,?4,?5,?"品牌"),
????????????????new?ExcelHeaderInfo(1,?1,?4,?4,?"品牌ID"),
????????????????new?ExcelHeaderInfo(1,?1,?5,?5,?"品牌名稱"),

????????????????new?ExcelHeaderInfo(0,?0,?6,?7,?"商店"),
????????????????new?ExcelHeaderInfo(1,?1,?6,?6,?"商店ID"),
????????????????new?ExcelHeaderInfo(1,?1,?7,?7,?"商店名稱"),

????????????????new?ExcelHeaderInfo(1,?1,?8,?8,?"價(jià)格"),
????????????????new?ExcelHeaderInfo(1,?1,?9,?9,?"庫存"),
????????????????new?ExcelHeaderInfo(1,?1,?10,?10,?"銷量"),
????????????????new?ExcelHeaderInfo(1,?1,?11,?11,?"插入時(shí)間"),
????????????????new?ExcelHeaderInfo(1,?1,?12,?12,?"更新時(shí)間"),
????????????????new?ExcelHeaderInfo(1,?1,?13,?13,?"記錄是否已經(jīng)刪除")
????????);
????}

????//?獲取格式化信息
????private?Map?getFormatInfo()?{
????????Map?format?=?new?HashMap<>();
????????format.put("id",?ExcelFormat.FORMAT_INTEGER);
????????format.put("categoryId",?ExcelFormat.FORMAT_INTEGER);
????????format.put("branchId",?ExcelFormat.FORMAT_INTEGER);
????????format.put("shopId",?ExcelFormat.FORMAT_INTEGER);
????????format.put("price",?ExcelFormat.FORMAT_DOUBLE);
????????format.put("stock",?ExcelFormat.FORMAT_INTEGER);
????????format.put("salesNum",?ExcelFormat.FORMAT_INTEGER);
????????format.put("isDel",?ExcelFormat.FORMAT_INTEGER);
????????return?format;
????}

實(shí)現(xiàn)效果

源碼分析

哈哈，自己分析自己的代碼，有點(diǎn)意思。由于不方便貼出太多的代碼，大家可以先到github上clone源碼，再回來閱讀文章。Java項(xiàng)目分享

https://github.com/dearKundy/excel-utils

LZ使用的poi 4.0.1版本的這個(gè)工具，想要實(shí)用海量數(shù)據(jù)的導(dǎo)出自然得使用SXSSFWorkbook這個(gè)組件。關(guān)于poi的具體用法在這里我就不多說了，這里主要是給大家講解如何對(duì)poi進(jìn)行封裝使用。

成員變量

我們重點(diǎn)看ExcelUtils這個(gè)類，這個(gè)類是實(shí)現(xiàn)導(dǎo)出的核心，先來看一下三個(gè)成員變量

????private?List?list;
????private?List?excelHeaderInfos;
????private?Map?formatInfo;

list

該成員變量用來保存待導(dǎo)出的數(shù)據(jù)

ExcelHeaderInfo

該成員變量主要用來保存表頭信息，因?yàn)槲覀冃枰x多個(gè)表頭信息，所以需要使用一個(gè)列表來保存，ExcelHeaderInfo構(gòu)造函數(shù)如下ExcelHeaderInfo(int firstRow, int lastRow, int firstCol, int lastCol, String title)

firstRow：該表頭所占位置的首行
lastRow：該表頭所占位置的尾行
firstCol：該表頭所占位置的首列
lastCol：該表頭所占位置的尾行
title：該表頭的名稱

ExcelFormat

該參數(shù)主要用來格式化字段，我們需要預(yù)先約定好轉(zhuǎn)換成那種格式，不能隨用戶自己定。所以我們定義了一個(gè)枚舉類型的變量，該枚舉類只有一個(gè)字符串類型成員變量，用來保存想要轉(zhuǎn)換的格式，例如FORMAT_INTEGER就是轉(zhuǎn)換成整型。關(guān)注我是程序汪

因?yàn)槲覀冃枰邮芏鄠€(gè)字段的轉(zhuǎn)換格式，所以定義了一個(gè)Map類型來接收，該參數(shù)可以省略（默認(rèn)格式為字符串）

public?enum?ExcelFormat?{

????FORMAT_INTEGER("INTEGER"),
????FORMAT_DOUBLE("DOUBLE"),
????FORMAT_PERCENT("PERCENT"),
????FORMAT_DATE("DATE");

????private?String?value;

????ExcelFormat(String?value)?{
????????this.value?=?value;
????}

????public?String?getValue()?{
????????return?value;
????}
}

核心方法

1. 創(chuàng)建表頭

該方法用來初始化表頭，而創(chuàng)建表頭最關(guān)鍵的就是poi中Sheet類的addMergedRegion(CellRangeAddress var1)方法，該方法用于單元格融合。

我們會(huì)遍歷ExcelHeaderInfo列表，按照每個(gè)ExcelHeaderInfo的坐標(biāo)信息進(jìn)行單元格融合，然后在融合之后的每個(gè)單元首行和首列的位置創(chuàng)建單元格，然后為單元格賦值即可，通過上面的步驟就完成了任意類型的表頭設(shè)置。

????//?創(chuàng)建表頭
????private?void?createHeader(Sheet?sheet,?CellStyle?style)?{
????????for?(ExcelHeaderInfo?excelHeaderInfo?:?excelHeaderInfos)?{
????????????Integer?lastRow?=?excelHeaderInfo.getLastRow();
????????????Integer?firstRow?=?excelHeaderInfo.getFirstRow();
????????????Integer?lastCol?=?excelHeaderInfo.getLastCol();
????????????Integer?firstCol?=?excelHeaderInfo.getFirstCol();

????????????//?行距或者列距大于0才進(jìn)行單元格融合
????????????if?((lastRow?-?firstRow)?!=?0?||?(lastCol?-?firstCol)?!=?0)?{
????????????????sheet.addMergedRegion(new?CellRangeAddress(firstRow,?lastRow,?firstCol,?lastCol));
????????????}
????????????//?獲取當(dāng)前表頭的首行位置
????????????Row?row?=?sheet.getRow(firstRow);
????????????//?在表頭的首行與首列位置創(chuàng)建一個(gè)新的單元格
????????????Cell?cell?=?row.createCell(firstCol);
????????????//?賦值單元格
????????????cell.setCellValue(excelHeaderInfo.getTitle());
????????????cell.setCellStyle(style);
????????????sheet.setColumnWidth(firstCol,?sheet.getColumnWidth(firstCol)?*?17?/?12);
????????}
????}

2. 轉(zhuǎn)換數(shù)據(jù)

在進(jìn)行正文賦值之前，我們先要對(duì)原始數(shù)據(jù)列表轉(zhuǎn)換成字符串的二維數(shù)組，之所以轉(zhuǎn)成字符串格式是因?yàn)榭梢越y(tǒng)一的處理各種類型，之后有需要我們?cè)俎D(zhuǎn)換回來即可。

????//?將原始數(shù)據(jù)轉(zhuǎn)成二維數(shù)組
????private?String[][]?transformData()?{
????????int?dataSize?=?this.list.size();
????????String[][]?datas?=?new?String[dataSize][];
????????//?獲取報(bào)表的列數(shù)
????????Field[]?fields?=?list.get(0).getClass().getDeclaredFields();
????????//?獲取實(shí)體類的字段名稱數(shù)組
????????List?columnNames?=?this.getBeanProperty(fields);
????????for?(int?i?=?0;?i?????????????datas[i]?=?new?String[fields.length];
????????????for?(int?j?=?0;?j?????????????????try?{
????????????????????//?賦值
????????????????????datas[i][j]?=?BeanUtils.getProperty(list.get(i),?columnNames.get(j));
????????????????}?catch?(Exception?e)?{
????????????????????LOGGER.error("獲取對(duì)象屬性值失敗");
????????????????????e.printStackTrace();
????????????????}
????????????}
????????}
????????return?datas;
????}

這個(gè)方法中我們通過使用反射技術(shù)，很巧妙的實(shí)現(xiàn)了任意類型的數(shù)據(jù)導(dǎo)出（這里的任意類型指的是任意的報(bào)表類型，不同的報(bào)表，導(dǎo)出的數(shù)據(jù)肯定是不一樣的，那么在Java實(shí)現(xiàn)中的實(shí)體類肯定也是不一樣的）。要想將一個(gè)List轉(zhuǎn)換成相應(yīng)的二維數(shù)組，我們得知道如下的信息；關(guān)注我是程序汪

二維數(shù)組的列數(shù)
二維數(shù)組的行數(shù)
二維數(shù)組每個(gè)元素的值

如果獲取以上三個(gè)信息呢？

通過反射中的Field[] getDeclaredFields()這個(gè)方法獲取實(shí)體類的所有字段，從而間接知道一共有多少列
List的大小不就是二維數(shù)組的行數(shù)了嘛
雖然每個(gè)實(shí)體類的字段名不一樣，那么我們就真的無法獲取到實(shí)體類某個(gè)字段的值了嗎？不是的，你要知道，你擁有了反射，你就相當(dāng)于擁有了全世界，那還有什么做不到的呢。這里我們沒有直接使用反射，而是使用了一個(gè)叫做BeanUtils的工具，該工具可以很方便的幫助我們對(duì)一個(gè)實(shí)體類進(jìn)行字段的賦值與字段值的獲取。很簡(jiǎn)單，通過BeanUtils.getProperty(list.get(i), columnNames.get(j))這一行代碼，我們就獲取了實(shí)體list.get(i)中名稱為columnNames.get(j)這個(gè)字段的值。list.get(i)當(dāng)然是我們遍歷原始數(shù)據(jù)的實(shí)體類，而columnNames列表則是一個(gè)實(shí)體類所有字段名的數(shù)組，也是通過反射的方法獲取到的，具體實(shí)現(xiàn)可以參考LZ的源代碼。Java項(xiàng)目分享

3. 賦值正文

這里的正文指定是正式的表格數(shù)據(jù)內(nèi)容，其實(shí)這一些沒有太多的奇淫技巧，主要的功能在上面已經(jīng)實(shí)現(xiàn)了，這里主要是進(jìn)行單元格的賦值與導(dǎo)出格式的處理（主要是為了導(dǎo)出excel后可以進(jìn)行方便的運(yùn)算）

????//?創(chuàng)建正文
????private?void?createContent(Row?row,?CellStyle?style,?String[][]?content,?int?i,?Field[]?fields)?{
????????List?columnNames?=?getBeanProperty(fields);
????????for?(int?j?=?0;?j?????????????if?(formatInfo?==?null)?{
????????????????row.createCell(j).setCellValue(content[i][j]);
????????????????continue;
????????????}
????????????if?(formatInfo.containsKey(columnNames.get(j)))?{
????????????????switch?(formatInfo.get(columnNames.get(j)).getValue())?{
????????????????????case?"DOUBLE":
????????????????????????row.createCell(j).setCellValue(Double.parseDouble(content[i][j]));
????????????????????????break;
????????????????????case?"INTEGER":
????????????????????????row.createCell(j).setCellValue(Integer.parseInt(content[i][j]));
????????????????????????break;
????????????????????case?"PERCENT":
????????????????????????style.setDataFormat(HSSFDataFormat.getBuiltinFormat("0.00%"));
????????????????????????Cell?cell?=?row.createCell(j);
????????????????????????cell.setCellStyle(style);
????????????????????????cell.setCellValue(Double.parseDouble(content[i][j]));
????????????????????????break;
????????????????????case?"DATE":
????????????????????????row.createCell(j).setCellValue(this.parseDate(content[i][j]));
????????????????}
????????????}?else?{
????????????????row.createCell(j).setCellValue(content[i][j]);
????????????}
????????}
????}

導(dǎo)出工具類的核心方法就差不多說完了，下面說一下關(guān)于多線程查詢的問題

多扯兩點(diǎn)

1. 多線程查詢數(shù)據(jù)

理想很豐滿，現(xiàn)實(shí)雖然不是很殘酷，但是也跟想象的不一樣。LZ雖然對(duì)50w的數(shù)據(jù)分別創(chuàng)建20個(gè)線程去查詢，但是總體的效率并不是50w/20，而是僅僅快了幾秒鐘，知道原因的小伙伴可以給我留個(gè)言一起探討一下。

下面先說說具體思路：因?yàn)槎鄠€(gè)線程之間是同時(shí)執(zhí)行的，你不能夠保證哪個(gè)線程先執(zhí)行完畢，但是我們卻得保證數(shù)據(jù)順序的一致性。在這里我們使用了Callable接口，通過實(shí)現(xiàn)Callable接口的線程可以擁有返回值，我們獲取到所有子線程的查詢結(jié)果，然后合并到一個(gè)結(jié)果集中即可。

那么如何保證合并的順序呢?我們先創(chuàng)建了一個(gè)FutureTask類型的List，該FutureTask的類型就是返回的結(jié)果集。

List>>?tasks?=?new?ArrayList<>();

當(dāng)我們每啟動(dòng)一個(gè)線程的時(shí)候，就將該線程的FutureTask添加到tasks列表中，這樣tasks列表中的元素順序就是我們啟動(dòng)線程的順序。

???????????FutureTask>?task?=?new?FutureTask<>(new?listThread(map));
????????????log.info("開始查詢第{}條開始的{}條記錄",?i?*?THREAD_MAX_ROW,?THREAD_MAX_ROW);
????????????new?Thread(task).start();
????????????//?將任務(wù)添加到tasks列表中
????????????tasks.add(task);

接下來，就是順序塞值了，我們按順序從tasks列表中取出FutureTask，然后執(zhí)行FutureTask的get()方法，該方法會(huì)阻塞調(diào)用它的線程，知道拿到返回結(jié)果。這樣一套循環(huán)下來，就完成了所有數(shù)據(jù)的按順序存儲(chǔ)。

???????for?(FutureTask>?task?:?tasks)?{
????????????try?{
????????????????productInfoPos.addAll(task.get());
????????????}?catch?(Exception?e)?{
????????????????e.printStackTrace();
????????????}
????????}

2. 如何解決接口超時(shí)

如果需要導(dǎo)出海量數(shù)據(jù)，可能會(huì)存在一個(gè)問題：接口超時(shí)，主要原因就是整個(gè)導(dǎo)出過程的時(shí)間太長(zhǎng)了。

其實(shí)也很好解決，接口的響應(yīng)時(shí)間太長(zhǎng)，我們縮短響應(yīng)時(shí)間不就可以了嘛。我們使用異步編程解決方案，異步編程的實(shí)現(xiàn)方式有很多，這里我們使用最簡(jiǎn)單的spring中的Async注解，加上了這個(gè)注解的方法可以立馬返回響應(yīng)結(jié)果。

關(guān)于注解的使用方式，大家可以自己查閱一下，下面講一下關(guān)鍵的實(shí)現(xiàn)步驟：

編寫異步接口，該接口負(fù)責(zé)接收客戶端的導(dǎo)出請(qǐng)求，然后開始執(zhí)行導(dǎo)出（注意：這里的導(dǎo)出不是直接向客戶端返回，而是下載到服務(wù)器本地），只要下達(dá)了導(dǎo)出指令，就可以馬上給客戶端返回一個(gè)該excel文件的唯一標(biāo)志（用于以后查找該文件），接口結(jié)束。
編寫excel狀態(tài)接口，客戶端拿到excel文件的唯一標(biāo)志之后，開始每秒輪詢調(diào)用該接口檢查excel文件的導(dǎo)出狀態(tài)
編寫從服務(wù)器本地返回excel文件接口，如果客戶端檢查到excel已經(jīng)成功下載到到服務(wù)器本地，這個(gè)時(shí)候就可以請(qǐng)求該接口直接下載文件了。

這樣就可以解決接口超時(shí)的問題了。關(guān)注我是程序汪

源碼地址