常见网关、数据类型、Excel导入

冷不防 2022-12-28 08:26 72阅读 0赞

## 一、常见的开源网关 ##

**1、Nginx+Lua**：OpenResty、Kong 等。

**2、Java**：Zuul1/Zuul2、Spring Cloud Gateway、gravitee-gateway、Dromara Soul 等。

**3、Go**：janus、GoKu API Gateway 等。

**4、Node.js**：Express Gateway、MicroGateway 等。

## 二、网关的主流技术类型 ##

Servlet + 线程池
    NIO(Tomcat / Jetty) + Servlet 3.0 异步
    NettyServer + NettyClient

## 三、table数据类型 ##

import java.util.LinkedHashMap;
    import java.util.Map;
    
    public class TableUtil<R, C, V> { 
    	
    	private final Map<R, Map<C, V>> table;
    	
    	private TableUtil(Map<R, Map<C, V>> _table) { 
    		table = _table;
    	}
    	
    	public static <R, C, V> TableUtil<R, C,V> getTable() { 
    		Map<R, Map<C, V>> newTable = new LinkedHashMap<R, Map<C,V>>();
    		return new TableUtil<R, C, V>(newTable);
    	}
    	
    	public V get(R rowKey, C columnKey) { 
    		if (rowKey == null || columnKey == null) { 
    			return null;
    		}
    		Map<C, V> columns = table.get(rowKey);
    		if (columns == null) { 
    			return null;
    		}
    		return columns.get(columnKey);
    	}
    	
    	public void set(R rowKey, C columnKey, V value) { 
    		if (rowKey == null || columnKey == null) { 
    			return;
    		}
    		Map<C, V> columns = table.get(rowKey);
    		if (columns == null) { 
    			columns = new LinkedHashMap<C, V>();
    			table.putIfAbsent(rowKey, columns);
    		}
    		columns.put(columnKey, value);
    	}
    
    }

## 四、Excel导入 ##

@Autowired
      private UserService userService;
    
      @PostMapping("/batchImport")
      public void batchImport(MultipartFile file) { 
            ParamValidUtil.validParam(file, "上传文件");
            String filename = file.getOriginalFilename();
            Pattern pattern = compile("^.+(.xlsx|.xls|.XLSX|.XLS)$");
            Matcher matcher = pattern.matcher(filename);
            if (matcher.matches()) { 
                try { 
                    Map<String, Object> map = userService.batchImport(file);
                } catch (Exception e) { 
                    log.error("批量导入错误原因:{}", e.getMessage());
               }
         }
      }

import com.imooc.stream.util.ExcelTools;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.stereotype.Service;
    import org.springframework.web.multipart.MultipartFile;
    
    import java.io.*;
    import java.util.*;
    
    @Slf4j
    @Service
    public class UserService { 
    
        private static final String[] INFO_CODE = new String[]{ "姓名", "用户"};
    
    
        public Map<String, Object> batchImport(MultipartFile file) throws IOException { 
            Map<String, Object> map = new HashMap<>(3);
            // MultipartFile 转 File
            File files;
            if (Objects.equals(file, "") || file.getSize() <= 0) { 
                map.put("count", 0);
                return map;
            } else { 
                InputStream ins = file.getInputStream();
                files = new File(Objects.requireNonNull(file.getOriginalFilename()));
                inputStreamToFile(ins, files);
            }
            // 解析Excel
            List<Map<String, Object>> list = ExcelTools.readExcel(files, INFO_CODE);
            //文件使用结束, 删除
            File del = new File(files.toURI());
            boolean delete = del.delete();
            log.info("文件删除状态：{}", delete);
            if (list == null || list.isEmpty()) { 
                map.put("count", 0);
                return map;
            }
            Iterator<Map<String, Object>> iterator = list.iterator();
            //成功条数
            int count = 0;
            //失败条数
            int overCount = 0;
            String message = null;
            while (iterator.hasNext()) { 
                Map<String, Object> next = iterator.next();
                Object name = next.get("姓名");
                Object user = next.get("用户");
                if (Objects.nonNull(name) && Objects.nonNull(user)) { 
                    count++;
                } else { 
                    message = "导入数据失败！";
                    overCount++;
                }
            }
            map.put("count", count);
            if (overCount > 0) { 
                map.put("message", message);
                map.put("overCount", overCount);
            }
            return map;
        }
    
    
        /** * 流 转 File * @param ins * @param file */
        public static void inputStreamToFile(InputStream ins, File file) { 
            try (OutputStream os = new FileOutputStream(file)){ 
                int bytesRead;byte[] buffer = new byte[8192];
                while ((bytesRead = ins.read(buffer, 0, 8192)) != -1) { 
                    os.write(buffer, 0, bytesRead);
                }
                os.close();
                ins.close();
            } catch (Exception e) { 
                log.error("流转文件失败：{}", e);
            }
        }
    }

import lombok.extern.slf4j.Slf4j;
    import org.apache.poi.ss.usermodel.*;
    import java.io.File;
    import java.io.FileInputStream;
    import java.text.DecimalFormat;
    import java.text.SimpleDateFormat;
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    @Slf4j
    public class ExcelTools { 
    
        public static List<Map<String, Object>> readExcel(File file, String[] metaName) { 
            SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd");
            List<Map<String, Object>> list = new ArrayList<>();
            //同时支持Excel 2003、2007 这种方式 Excel 2003/2007/2010 都是可以处理的
            try (FileInputStream is = new FileInputStream(file); Workbook workbook = WorkbookFactory.create(is)){ 
                //Sheet的数量
                int sheetCount = workbook.getNumberOfSheets();
                //遍历每个Sheet
                for (int s = 0; s < sheetCount; s++) { 
                    Sheet sheet = workbook.getSheetAt(s);
                    //获取总行数
                    int rowCount = sheet.getPhysicalNumberOfRows();
                    //遍历每一行 //跳过第一行
                    for (int r = 1; r < rowCount; r++) { 
                        Map<String, Object> map = new HashMap<>();
                        Row row = sheet.getRow(r);
                        //获取总列数
                        int cellCount = row.getPhysicalNumberOfCells();
                        //遍历每一列
                        for (int c = 0; c < cellCount; c++) { 
                            Cell cell = row.getCell(c);
                            CellType cellType = cell.getCellType();
                            String cellValue;
                            //文本
                            if (CellType.STRING.equals(cellType)) { 
                                cellValue = cell.getStringCellValue();
                                //数字、日期
                            } else if (CellType.NUMERIC.equals(cellType)) { 
                                if (DateUtil.isCellDateFormatted(cell)) { 
                                    //日期型
                                    cellValue = fmt.format(cell.getDateCellValue());
                                } else { 
                                    DecimalFormat df = new DecimalFormat("0");
                                    //数字
                                    cellValue = String.valueOf(df.format(cell.getNumericCellValue()));
                                }
                                //布尔型
                            } else if (CellType.BOOLEAN.equals(cellType)) { 
                                cellValue = String.valueOf(cell.getBooleanCellValue());
                                //空白
                            } else if (CellType.BLANK.equals(cellType)) { 
                                cellValue = cell.getStringCellValue();
                                //错误
                            } else if (CellType.ERROR.equals(cellType)) { 
                                cellValue = "错误";
                                //公式
                            } else if (CellType.FORMULA.equals(cellType)) { 
                                cellValue = "错误";
                            } else { 
                                cellValue = "错误";
                            }
                            map.put(metaName[c], cellValue);
                            log.info(cellValue + " ");
                        }
                        list.add(map);
                    }
                }
            } catch (Exception e) { 
                log.error("工具类异常:{}", e);
            }
            return list;
        }
    
    }

import org.apache.commons.lang3.StringUtils;
    import org.springframework.util.CollectionUtils;
    import java.lang.reflect.Field;
    import java.util.Collection;
    
    public class ParamValidUtil { 
        /** * 单个参数非空判断 */
        public static void validParam(Object param, String statusMessage) { 
            if (param instanceof String) { 
                if (StringUtils.isEmpty((String) param)) { 
                    throw new RuntimeException(statusMessage + "不能为空!");
                }
            }else if(param instanceof Collection){ 
                if (CollectionUtils.isEmpty((Collection<?>) param)) { 
                    throw new RuntimeException(statusMessage + "不能为空!");
                }
            } { 
                if (param == null) { 
                    throw new RuntimeException(statusMessage + "不能为空!");
                }
            }
        }
    }

依赖

<dependency>
                <groupId>org.apache.poi</groupId>
                <artifactId>poi-ooxml</artifactId>
                <version>4.1.0</version>
            </dependency>