From f750e6a9c2f8954aeea06eb7e11795d02875371d Mon Sep 17 00:00:00 2001 From: tianbin Date: Mon, 1 Feb 2021 19:25:14 +0800 Subject: [PATCH 01/36] ExcelBO EmailBO --- pom.xml | 28 ++- ...\344\270\252\344\275\215\347\275\256.java" | 36 ++++ .../algorithm_practice/other/NthPrime.java | 23 -- src/main/java/common/bo/EmailBO.java | 29 +++ src/main/java/common/bo/excel/SheetBO.java | 32 +++ src/main/java/common/bo/excel/WorkBookBO.java | 87 ++++++++ src/main/java/common/model/Person.java | 15 ++ src/main/java/common/model/PersonDTO.java | 15 ++ src/main/java/common/util/CommonBeanUtil.java | 63 ++++++ src/main/java/common/util/EmailUtils.java | 79 +++++++ .../common/util/batchInsert/NameUtil.java | 84 ++++++++ .../common/util/batchInsert/RandomValue.java | 177 +++++++++++++++ ...1_\345\205\254\345\271\263\351\224\201.md" | 204 ++++++++++++++++++ ...36\345\205\254\345\271\263\351\224\201.md" | 52 +++++ ...36\345\205\254\345\271\263\351\224\201.md" | 0 .../README.md" | 17 +- src/main/resources/excel/report.xls | 0 .../CommonBeanUtilTest.java" | 43 ++++ .../\351\233\206\345\220\210/ListTest.java" | 25 ++- .../\351\233\206\345\220\210/MapTest.java" | 2 +- .../\351\233\206\345\220\210/SetTest.java" | 14 +- src/main/test/org/tianbin/temp/DataGen.java | 24 +++ src/main/test/org/tianbin/temp/ExcelGen.java | 69 ++++++ 23 files changed, 1081 insertions(+), 37 deletions(-) delete mode 100644 src/main/java/algorithm_practice/other/NthPrime.java create mode 100644 src/main/java/common/bo/EmailBO.java create mode 100644 src/main/java/common/bo/excel/SheetBO.java create mode 100644 src/main/java/common/bo/excel/WorkBookBO.java create mode 100644 src/main/java/common/model/PersonDTO.java create mode 100644 src/main/java/common/util/CommonBeanUtil.java create mode 100644 src/main/java/common/util/EmailUtils.java create mode 100644 src/main/java/common/util/batchInsert/NameUtil.java create mode 100644 src/main/java/common/util/batchInsert/RandomValue.java create mode 100644 "src/main/java/org/tianbin/java/\345\271\266\345\217\221/AQS\346\272\220\347\240\201\351\230\205\350\257\273/ReentrantLock\345\217\257\351\207\215\345\205\245\351\224\201_\345\205\254\345\271\263\351\224\201.md" create mode 100644 "src/main/java/org/tianbin/java/\345\271\266\345\217\221/AQS\346\272\220\347\240\201\351\230\205\350\257\273/ReentrantLock\345\217\257\351\207\215\345\205\245\351\224\201_\351\235\236\345\205\254\345\271\263\351\224\201.md" create mode 100644 "src/main/java/org/tianbin/java/\345\271\266\345\217\221/AQS\346\272\220\347\240\201\351\230\205\350\257\273/synchronized\344\270\215\345\217\257\351\207\215\345\205\245\351\224\201_\351\235\236\345\205\254\345\271\263\351\224\201.md" create mode 100644 src/main/resources/excel/report.xls create mode 100644 "src/main/test/org/tianbin/java/\345\217\215\345\260\204/CommonBeanUtilTest.java" create mode 100644 src/main/test/org/tianbin/temp/DataGen.java create mode 100644 src/main/test/org/tianbin/temp/ExcelGen.java diff --git a/pom.xml b/pom.xml index 50622b0e..05b2c08b 100644 --- a/pom.xml +++ b/pom.xml @@ -20,6 +20,31 @@ + + + io.github.biezhi + oh-my-email + 0.0.3 + + + + org.apache.poi + poi + 3.17 + + + + com.esotericsoftware + reflectasm + 1.11.9 + + + + org.springframework + spring-beans + 4.3.8.RELEASE + + cglib @@ -99,7 +124,8 @@ com.google.guava guava - 23.0 + 28.1-jre + compile diff --git "a/src/main/java/algorithm_practice/LeetCode/code000/M034_\345\234\250\346\216\222\345\272\217\346\225\260\347\273\204\344\270\255\346\237\245\346\211\276\345\205\203\347\264\240\347\232\204\347\254\254\344\270\200\344\270\252\345\222\214\346\234\200\345\220\216\344\270\200\344\270\252\344\275\215\347\275\256.java" "b/src/main/java/algorithm_practice/LeetCode/code000/M034_\345\234\250\346\216\222\345\272\217\346\225\260\347\273\204\344\270\255\346\237\245\346\211\276\345\205\203\347\264\240\347\232\204\347\254\254\344\270\200\344\270\252\345\222\214\346\234\200\345\220\216\344\270\200\344\270\252\344\275\215\347\275\256.java" index 8a0b46a8..503cc43e 100644 --- "a/src/main/java/algorithm_practice/LeetCode/code000/M034_\345\234\250\346\216\222\345\272\217\346\225\260\347\273\204\344\270\255\346\237\245\346\211\276\345\205\203\347\264\240\347\232\204\347\254\254\344\270\200\344\270\252\345\222\214\346\234\200\345\220\216\344\270\200\344\270\252\344\275\215\347\275\256.java" +++ "b/src/main/java/algorithm_practice/LeetCode/code000/M034_\345\234\250\346\216\222\345\272\217\346\225\260\347\273\204\344\270\255\346\237\245\346\211\276\345\205\203\347\264\240\347\232\204\347\254\254\344\270\200\344\270\252\345\222\214\346\234\200\345\220\216\344\270\200\344\270\252\344\275\215\347\275\256.java" @@ -40,7 +40,43 @@ public void testCase() { System.out.println(JSON.toJSONString(searchRange(nums2, target2))); } + /** + * 标准的二分查找 + */ public int[] searchRange(int[] nums, int target) { + int[] res = new int[]{-1, -1}; + if (nums.length == 0) { + return res; + } + + int left = 0; + int right = nums.length - 1; + + while (left <= right) { + int mid = left + (right - left) / 2; + + if (nums[mid] > target) { + right = mid - 1; + } else if (nums[mid] == target) { + res[0] = res[1] = mid; + while (res[0]-1 >= 0 && nums[res[0]-1] == target) { + res[0]--; + } + + while (res[1]+1 < nums.length && nums[res[1]+1] == target) { + res[1]++; + } + + return res; + } else { + left = mid + 1; + } + } + + return res; + } + + public int[] searchRange2(int[] nums, int target) { int lo = 0; int hi = nums.length - 1; int[] result = {-1, -1}; diff --git a/src/main/java/algorithm_practice/other/NthPrime.java b/src/main/java/algorithm_practice/other/NthPrime.java deleted file mode 100644 index 7a329e9b..00000000 --- a/src/main/java/algorithm_practice/other/NthPrime.java +++ /dev/null @@ -1,23 +0,0 @@ -package algorithm_practice.other; - -import junit.framework.TestCase; -import org.junit.Test; - -/* -求第N个质数，求第N个素数 - */ -public class NthPrime extends TestCase { - - @Test - public void testCase() { - int n = 6; - System.out.println(getNthPrime(n)); - } - - /* - - */ - private int getNthPrime(int n) { - return 0; - } -} diff --git a/src/main/java/common/bo/EmailBO.java b/src/main/java/common/bo/EmailBO.java new file mode 100644 index 00000000..704fe8ab --- /dev/null +++ b/src/main/java/common/bo/EmailBO.java @@ -0,0 +1,29 @@ +package common.bo; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.io.File; +import java.util.List; + +/** + * Created by nibnait on 2021/01/27 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +public class EmailBO { + + private String fromNickName; + + private String toAddress; + + private String ccAddress; + + private String subject; + + private String content; + + private List attachFiles; +} diff --git a/src/main/java/common/bo/excel/SheetBO.java b/src/main/java/common/bo/excel/SheetBO.java new file mode 100644 index 00000000..80d006e9 --- /dev/null +++ b/src/main/java/common/bo/excel/SheetBO.java @@ -0,0 +1,32 @@ +package common.bo.excel; + +import org.apache.poi.hssf.usermodel.HSSFCell; +import org.apache.poi.hssf.usermodel.HSSFRow; +import org.apache.poi.hssf.usermodel.HSSFSheet; + +import java.util.List; + +/** + * Created by nibnait on 2021/01/21 + */ +public class SheetBO { + + private HSSFSheet sheet; + private Integer rowIndex; + + public SheetBO(HSSFSheet sheet) { + this.sheet = sheet; + rowIndex = 0; + } + + public void appendRow(List row) { + HSSFRow hssfRow = sheet.createRow(rowIndex); + HSSFCell hssfCell; + rowIndex += 1; + for (int i = 0; i < row.size(); i++) { + hssfCell = hssfRow.createCell(i); + hssfCell.setCellValue(row.get(i)); + } + } + +} diff --git a/src/main/java/common/bo/excel/WorkBookBO.java b/src/main/java/common/bo/excel/WorkBookBO.java new file mode 100644 index 00000000..21a99377 --- /dev/null +++ b/src/main/java/common/bo/excel/WorkBookBO.java @@ -0,0 +1,87 @@ +package common.bo.excel; + + +import lombok.Data; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.collections4.CollectionUtils; +import org.apache.commons.lang3.StringUtils; +import org.apache.poi.hssf.usermodel.HSSFSheet; +import org.apache.poi.hssf.usermodel.HSSFWorkbook; +import org.springframework.core.io.Resource; +import org.springframework.core.io.support.PathMatchingResourcePatternResolver; +import org.springframework.core.io.support.ResourcePatternResolver; + +import java.io.File; +import java.nio.file.Files; +import java.nio.file.Path; +import java.nio.file.Paths; +import java.util.ArrayList; +import java.util.List; + +/** + * Created by nibnait on 2021/01/21 + */ +@Data +@Slf4j +public class WorkBookBO { + + private HSSFWorkbook workbook; + + private List sheetList = new ArrayList<>(); + + public WorkBookBO() { + workbook = new HSSFWorkbook(); + sheetList.add(new SheetBO(workbook.createSheet("Sheet1"))); + } + + public WorkBookBO(int sheetSize, List> sheetTitle, String... sheetName) { + workbook = new HSSFWorkbook(); + if (CollectionUtils.isEmpty(sheetTitle) || sheetName == null + || sheetTitle.size() != sheetName.length) { + // 直接创建一个默认的sheet + sheetList.add(new SheetBO(workbook.createSheet("Sheet1"))); + return; + } + + for (int i = 0; i < sheetSize; i++) { + HSSFSheet sheet = workbook.createSheet(sheetName[i]); + SheetBO sheetBO = new SheetBO(sheet); + sheetBO.appendRow(sheetTitle.get(i)); + sheetList.add(sheetBO); + } + } + + /** + * 将 workbook 写成文件 + * @param sourceFileName resources/excel 目录下的文件名 + * @param targetFileName targetFileName 重命名文件（可以为空） + */ + public File writeToFile(String sourceFileName, String targetFileName) { + + if (StringUtils.isBlank(sourceFileName)) { + return null; + } + + File sourceFile = null; + String sourceFilePathName = "/excel/" + sourceFileName + ".xls"; + try { + ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver(); + Resource[] resources = resolver.getResources(sourceFilePathName); + sourceFile = resources[0].getFile(); + workbook.write(sourceFile); + workbook.close(); + resources = resolver.getResources(sourceFilePathName); + sourceFile = resources[0].getFile(); + + if (StringUtils.isNotBlank(targetFileName) && sourceFile != null) { + String path = sourceFile.getPath(); + Path copy = Files.copy(Paths.get(path), Paths.get(path.replaceAll(sourceFileName, targetFileName))); + return copy.toFile(); + } + } catch (Exception e) { + log.error("fail to write excel sourceFile", e); + } + + return sourceFile; + } +} diff --git a/src/main/java/common/model/Person.java b/src/main/java/common/model/Person.java index aeda0eff..057b5c4a 100644 --- a/src/main/java/common/model/Person.java +++ b/src/main/java/common/model/Person.java @@ -4,6 +4,8 @@ import lombok.Data; import lombok.NoArgsConstructor; +import java.util.Objects; + /** * 实体类 * Created by nibnait on 2020-02-24 @@ -16,4 +18,17 @@ public class Person { private String name; private Integer age; + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + Person person = (Person) o; + return Objects.equals(name, person.name) && + Objects.equals(age, person.age); + } + + @Override + public int hashCode() { + return Objects.hash(name, age); + } } \ No newline at end of file diff --git a/src/main/java/common/model/PersonDTO.java b/src/main/java/common/model/PersonDTO.java new file mode 100644 index 00000000..3aa4109a --- /dev/null +++ b/src/main/java/common/model/PersonDTO.java @@ -0,0 +1,15 @@ +package common.model; + +import lombok.Data; + +/** + * 实体类 + * Created by nibnait on 2020-02-24 + */ +@Data +public class PersonDTO { + + private String name; + private Integer age; + +} \ No newline at end of file diff --git a/src/main/java/common/util/CommonBeanUtil.java b/src/main/java/common/util/CommonBeanUtil.java new file mode 100644 index 00000000..f7a82fa5 --- /dev/null +++ b/src/main/java/common/util/CommonBeanUtil.java @@ -0,0 +1,63 @@ +package common.util; + +import com.esotericsoftware.reflectasm.MethodAccess; +import org.apache.commons.lang3.StringUtils; +import org.springframework.beans.BeanUtils; + +import java.lang.reflect.Field; +import java.util.ArrayList; +import java.util.List; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; +import java.util.function.Supplier; + +/** + * Created by nibnait on 2020/12/31 + */ +public class CommonBeanUtil extends BeanUtils { + + private static final ConcurrentMap localCache = new ConcurrentHashMap<>(); + + public static MethodAccess get(Class clazz) { + if (localCache.containsKey(clazz)) { + return localCache.get(clazz); + } + + MethodAccess methodAccess = MethodAccess.get(clazz); + localCache.putIfAbsent(clazz, methodAccess); + return methodAccess; + } + + public static T copyProperties(S source, Supplier targetSupplier) { + T target = targetSupplier.get(); + if (source == null) { + return target; + } + + MethodAccess sourceMethodAccess = get(source.getClass()); + MethodAccess targetMethodAccess = get(target.getClass()); + Field[] declaredFields = source.getClass().getDeclaredFields(); + for (Field field : declaredFields) { + String name = field.getName(); + Object value = sourceMethodAccess.invoke(source, "get" + StringUtils.capitalize(name), null); + try { + targetMethodAccess.invoke(target, "set" + StringUtils.capitalize(name), value); + } catch (Exception e) { + // source 中未设置 get 方法的字段，会直接跳过 + // target 中没有 source 中的字段，也会直接跳过 + } + } + + return target; + } + + public static List copyListProperties(List sources, Supplier targetSupplier) { + List list = new ArrayList<>(sources.size()); + for (S source : sources) { + T target = copyProperties(source, targetSupplier); + list.add(target); + } + return list; + } + +} \ No newline at end of file diff --git a/src/main/java/common/util/EmailUtils.java b/src/main/java/common/util/EmailUtils.java new file mode 100644 index 00000000..4cdfe554 --- /dev/null +++ b/src/main/java/common/util/EmailUtils.java @@ -0,0 +1,79 @@ +package common.util; + +import common.bo.EmailBO; +import io.github.biezhi.ome.OhMyEmail; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; + +import java.io.File; +import java.util.List; +import java.util.Properties; + +@Slf4j +public class EmailUtils { + + + private static final String COMP_EMAIL = "w@tianbin.org"; + private static final String COMP_PW = "xxx"; + + private static final String SENDER_NAME = "系统"; + + + public static void initEmailCfg(){ + Properties props = new Properties(); + props.setProperty("username", COMP_EMAIL); + props.setProperty("password", COMP_PW); + // 开启debug调试 + props.setProperty("mail.debug", "false"); //false + // 发送服务器需要身份验证 + props.setProperty("mail.smtp.auth", "true"); + // 设置邮件服务器主机名 + props.setProperty("mail.host", "smtp.partner.outlook.cn"); + props.setProperty("mail.smtp.host", "smtp.partner.outlook.cn"); + // 发送邮件协议名称 + props.setProperty("mail.transport.protocol", "smtp"); + props.setProperty("mail.smtp.port", "587"); + props.put("mail.smtp.starttls.enable", "true"); + + OhMyEmail.config(props); + } + + + public static void sendEmail(EmailBO emailBO) { + OhMyEmail.config(OhMyEmail.SMTP_ENT_QQ(false), COMP_EMAIL, COMP_PW); + + if (StringUtils.isBlank(emailBO.getToAddress()) || StringUtils.isBlank(emailBO.getSubject())) { + return; + } + + initEmailCfg(); + + String fromNickName = emailBO.getFromNickName(); + if (StringUtils.isBlank(fromNickName)) { + fromNickName = SENDER_NAME; + } + + try { + OhMyEmail ohMyEmail = OhMyEmail.subject(emailBO.getSubject()) + .from(fromNickName) + .to(emailBO.getToAddress()); + + if (StringUtils.isNotBlank(emailBO.getCcAddress())) { + ohMyEmail.cc(emailBO.getCcAddress()); + } + List files = emailBO.getAttachFiles(); + if(files != null && !files.isEmpty()){ + for(File file:files){ + ohMyEmail.attach(file); + } + } + + ohMyEmail.html(emailBO.getContent()); + ohMyEmail.send(); + } catch (Exception e) { + log.error("EmailUtils.sendEmailAttachFiles error ", e); + } + + } + +} diff --git a/src/main/java/common/util/batchInsert/NameUtil.java b/src/main/java/common/util/batchInsert/NameUtil.java new file mode 100644 index 00000000..f0bda852 --- /dev/null +++ b/src/main/java/common/util/batchInsert/NameUtil.java @@ -0,0 +1,84 @@ +package common.util.batchInsert; + +import java.io.UnsupportedEncodingException; +import java.util.Random; + +/** + * 随机生成姓名的工具类 + * Created by nibnait on 2020/11/29 + */ +public class NameUtil { + + /** + * 随机生成一个中文姓名 + * @return + */ + public static String getRandomName(int i){ + Random random=new Random(); + /* 598 百家姓 */ + /*String[] Surname= {"赵","钱","孙","李","周","吴","郑","王","冯","陈","褚","卫","蒋","沈","韩","杨","朱","秦","尤","许", + "何","吕","施","张","孔","曹","严","华","金","魏","陶","姜","戚","谢","邹","喻","柏","水","窦","章","云","苏","潘","葛","奚","范","彭","郎", + "鲁","韦","昌","马","苗","凤","花","方","俞","任","袁","柳","酆","鲍","史","唐","费","廉","岑","薛","雷","贺","倪","汤","滕","殷", + "罗","毕","郝","邬","安","常","乐","于","时","傅","皮","卞","齐","康","伍","余","元","卜","顾","孟","平","黄","和", + "穆","萧","尹","姚","邵","湛","汪","祁","毛","禹","狄","米","贝","明","臧","计","伏","成","戴","谈","宋","茅","庞","熊","纪","舒", + "屈","项","祝","董","梁","杜","阮","蓝","闵","席","季","麻","强","贾","路","娄","危","江","童","颜","郭","梅","盛","林","刁","钟", + "徐","邱","骆","高","夏","蔡","田","樊","胡","凌","霍","虞","万","支","柯","昝","管","卢","莫","经","房","裘","缪","干","解","应", + "宗","丁","宣","贲","邓","郁","单","杭","洪","包","诸","左","石","崔","吉","钮","龚","程","嵇","邢","滑","裴","陆","荣","翁","荀", + "羊","于","惠","甄","曲","家","封","芮","羿","储","靳","汲","邴","糜","松","井","段","富","巫","乌","焦","巴","弓","牧","隗","山", + "谷","车","侯","宓","蓬","全","郗","班","仰","秋","仲","伊","宫","宁","仇","栾","暴","甘","钭","厉","戎","祖","武","符","刘","景", + "詹","束","龙","叶","幸","司","韶","郜","黎","蓟","溥","印","宿","白","怀","蒲","邰","从","鄂","索","咸","籍","赖","卓","蔺","屠", + "蒙","池","乔","阴","郁","胥","能","苍","双","闻","莘","党","翟","谭","贡","劳","逄","姬","申","扶","堵","冉","宰","郦","雍","却", + "璩","桑","桂","濮","牛","寿","通","边","扈","燕","冀","浦","尚","农","温","别","庄","晏","柴","瞿","阎","充","慕","连","茹","习", + "宦","艾","鱼","容","向","古","易","慎","戈","廖","庾","终","暨","居","衡","步","都","耿","满","弘","匡","国","文","寇","广","禄", + "阙","东","欧","殳","沃","利","蔚","越","夔","隆","师","巩","厍","聂","晁","勾","敖","融","冷","訾","辛","阚","那","简","饶","空", + "曾","毋","沙","乜","养","鞠","须","丰","巢","关","蒯","相","查","后","荆","红","游","郏","竺","权","逯","盖","益","桓","公","仉", + "督","岳","帅","缑","亢","况","郈","有","琴","归","海","晋","楚","闫","法","汝","鄢","涂","钦","商","牟","佘","佴","伯","赏","墨", + "哈","谯","篁","年","爱","阳","佟","言","福","南","火","铁","迟","漆","官","冼","真","展","繁","檀","祭","密","敬","揭","舜","楼", + "疏","冒","浑","挚","胶","随","高","皋","原","种","练","弥","仓","眭","蹇","覃","阿","门","恽","来","綦","召","仪","风","介","巨", + "木","京","狐","郇","虎","枚","抗","达","杞","苌","折","麦","庆","过","竹","端","鲜","皇","亓","老","是","秘","畅","邝","还","宾", + "闾","辜","纵","侴","万俟","司马","上官","欧阳","夏侯","诸葛","闻人","东方","赫连","皇甫","羊舌","尉迟","公羊","澹台","公冶","宗正", + "濮阳","淳于","单于","太叔","申屠","公孙","仲孙","轩辕","令狐","钟离","宇文","长孙","慕容","鲜于","闾丘","司徒","司空","兀官","司寇", + "南门","呼延","子车","颛孙","端木","巫马","公西","漆雕","车正","壤驷","公良","拓跋","夹谷","宰父","谷梁","段干","百里","东郭","微生", + "梁丘","左丘","东门","西门","南宫","第五","公仪","公乘","太史","仲长","叔孙","屈突","尔朱","东乡","相里","胡母","司城","张廖","雍门", + "毋丘","贺兰","綦毋","屋庐","独孤","南郭","北宫","王孙"};*/ + + String[] Surname= {"黄","郑","孙","李","周","吴","刘","王","冯","陈","柏","卫","蒋","沈","韩","杨","朱","秦","欧阳","许"}; + + int index=random.nextInt(Surname.length-1); + String name =""; + name = Surname[index]; //获得一个随机的姓氏 + + /* 从常用字中选取一个或两个字作为名 */ + if(random.nextBoolean()){ + name+=getChinese()+getChinese(); + }else { + name+=getChinese(); + } + return name; + } + + /** + * 随机获取一个汉字 + * @return + */ + public static String getChinese() { + String str = null; + int highPos, lowPos; + Random random = new Random(); + highPos = (176 + Math.abs(random.nextInt(71)));//区码，0xA0打头，从第16区开始，即0xB0=11*16=176,16~55一级汉字，56~87二级汉字 + random=new Random(); + lowPos = 161 + Math.abs(random.nextInt(94));//位码，0xA0打头，范围第1~94列 + + byte[] bArr = new byte[2]; + bArr[0] = (new Integer(highPos)).byteValue(); + bArr[1] = (new Integer(lowPos)).byteValue(); + try { + str = new String(bArr, "GB2312"); //区位码组合成汉字 + } catch (UnsupportedEncodingException e) { + e.printStackTrace(); + } + return str; + } + +} + diff --git a/src/main/java/common/util/batchInsert/RandomValue.java b/src/main/java/common/util/batchInsert/RandomValue.java new file mode 100644 index 00000000..65590e93 --- /dev/null +++ b/src/main/java/common/util/batchInsert/RandomValue.java @@ -0,0 +1,177 @@ +package common.util.batchInsert; + +import java.io.File; +import java.io.FileOutputStream; +import java.nio.ByteBuffer; +import java.nio.channels.FileChannel; +import java.util.HashMap; +import java.util.Map; + +public class RandomValue { + + public static String base = "abcdefghijklmnopqrstuvwxyz0123456789"; + private static String firstName="赵钱孙李周吴郑王冯陈褚卫蒋沈韩杨朱秦尤许何吕施张孔曹严华金魏陶姜戚谢邹喻柏水窦章云苏潘葛奚范彭郎鲁韦昌马苗凤花方俞任袁柳酆鲍史唐费廉岑薛雷贺倪汤滕殷罗毕郝邬安常乐于时傅皮卞齐康伍余元卜顾孟平黄和穆萧尹姚邵湛汪祁毛禹狄米贝明臧计伏成戴谈宋茅庞熊纪舒屈项祝董梁杜阮蓝闵席季麻强贾路娄危江童颜郭梅盛林刁钟徐邱骆高夏蔡田樊胡凌霍虞万支柯咎管卢莫经房裘缪干解应宗宣丁贲邓郁单杭洪包诸左石崔吉钮龚程嵇邢滑裴陆荣翁荀羊於惠甄魏加封芮羿储靳汲邴糜松井段富巫乌焦巴弓牧隗山谷车侯宓蓬全郗班仰秋仲伊宫宁仇栾暴甘钭厉戎祖武符刘姜詹束龙叶幸司韶郜黎蓟薄印宿白怀蒲台从鄂索咸籍赖卓蔺屠蒙池乔阴郁胥能苍双闻莘党翟谭贡劳逄姬申扶堵冉宰郦雍却璩桑桂濮牛寿通边扈燕冀郏浦尚农温别庄晏柴瞿阎充慕连茹习宦艾鱼容向古易慎戈廖庚终暨居衡步都耿满弘匡国文寇广禄阙东殴殳沃利蔚越夔隆师巩厍聂晁勾敖融冷訾辛阚那简饶空曾毋沙乜养鞠须丰巢关蒯相查后江红游竺权逯盖益桓公万俟司马上官欧阳夏侯诸葛闻人东方赫连皇甫尉迟公羊澹台公冶宗政濮阳淳于仲孙太叔申屠公孙乐正轩辕令狐钟离闾丘长孙慕容鲜于宇文司徒司空亓官司寇仉督子车颛孙端木巫马公西漆雕乐正壤驷公良拓拔夹谷宰父谷粱晋楚阎法汝鄢涂钦段干百里东郭南门呼延归海羊舌微生岳帅缑亢况后有琴梁丘左丘东门西门商牟佘佴伯赏南宫墨哈谯笪年爱阳佟第五言福百家姓续"; + private static String girl="秀娟英华慧巧美娜静淑惠珠翠雅芝玉萍红娥玲芬芳燕彩春菊兰凤洁梅琳素云莲真环雪荣爱妹霞香月莺媛艳瑞凡佳嘉琼勤珍贞莉桂娣叶璧璐娅琦晶妍茜秋珊莎锦黛青倩婷姣婉娴瑾颖露瑶怡婵雁蓓纨仪荷丹蓉眉君琴蕊薇菁梦岚苑婕馨瑗琰韵融园艺咏卿聪澜纯毓悦昭冰爽琬茗羽希宁欣飘育滢馥筠柔竹霭凝晓欢霄枫芸菲寒伊亚宜可姬舒影荔枝思丽晨花函妮蓓彤静漫呈碧" + + "梦雯昭冰娅楠月菲娅欣" + + "彦敏蕾雪初寒紫林欣美" + + "璐美妍阳花琛华初慧月" + + "欣初雪锦紫婷枫沛鑫雪" + + "晨漫娜婷初呈彦格雨萱" + + "柔菲彩玥梅阳莲婧淑家" + + "玥柔雪昭美静怡诗呈华" + + "淑沛采妍静昭玉祥梅怡" + + "橘萱锦月杉馨彩婧芙萱" + + "昭花彩姿慧雅格漫彩雪" + + "莲雅林怡彦枫初月璐楠" + + "雨初昭香克采梅梦莉美" + + "呈心帛静婧雪彩娜茜雅" + + "梦妍梦帆雪惠雪蔚云栀" + + "雅美琛枫灵初雅洁露娅" + + "彤漫旭枫锦娅婧漫凡雪" + + "文洁霞曦静芝凡怡桂岚" + + "茹冬芙锦帛锦楠桃曼璐" + + "花香寒媛冬优呈霞梅露" + + "函嘉薇娅梦漫华玥弦冰" + + "锦梦冬彬芝蕾琪美彩枫" + + "婷枫彬桂彩菡楠彤可锦" + + "茹彩祥枫妍初梅楠歆妮" + + "文彤莲静雪霞静馨华采" + + "香珍菲锦彩玲克婷可采" + + "璇昭呈婧香茜美晨彤枫" + + "冰莲家嘉玥锦舒梦蔚娜" + + "漫萱鹤涵美丽玉萱美彩" + + "玉彩彩昕梅初彩锦钰旭" + + "紫淑楠鑫桐曦玥倩初云" + + "惠萱春珠初雅鸿敏芙彩" + + "芙玥静梅彩蕾采玥菲美" + + "妍彩可玉桂橘嘉紫婷钰" + + "静桂薇桂桐鸿俊欣初芝" + + "香凡香欣采蔚栀璟昭梅" + + "雯雪雪婧枫梦雅馨静雅" + + "彩芳茹阳云薇莲曦婷阳" + + "鑫慧芳橘韵彦柏珊雨梅" + + "林琬妮倩美碧彩彩蓓沛" + + "正月芸晨初锦莲馨婷寒" + + "萱雪萱柏枫欣钰锦楠惠" + + "莲露蔚婷华香馨彦琬旭" + + "璐采玥婷家雯瑶雅妍雅" + + "菲函钰薇媛沛帆月初诗" + + "桂蕾华韵美玥文莲鹤柏" + + "依菡姿丽锦菡美梓雪蕾" + + "欢玉锦凌婷紫弦心彩嘉"; + private static String boy="加诚晨信振泽斌晨初骞然裕潍震运安畅驰骏材天晨谷骞延弘烁铭濡贤骏腾运运龙宇强涛帝宇胤鸿辰钊骞嘉谛华振驰辰年柔凯家康运星海礼骏允运良权初锋坤振福奇博俊皓祥运骏振胤辰锐起成凯韦福运信帝强驰楷腾礼星骏晨辰俊休栋骏颜良荣铭枫国骏柏奇运谛郁尧盛骏暄腾驰星辰星宇嘉星逸天震祯震振锟运骞康星槐震祜谷树林加星谛成福晨骏升荣振星嘉郁骏杰辰禧鹏祯鑫成振琛卓运哲运枫祯辰天钊强恒晨星轩龙邦文树梓驰材骏鹏信爵驰喆震盛骏博盛骏晨彬树翰柔祯驰振帆祥宇骏澄芃辰帆海诚宇祯逸韦泽嘉辰鹏睿梓胤轩运初驰振潍骏楷子栋树爵然博槐晓爵杞荣星骞振轩骏海骏年枫运骏栋睿骏运辰晨康星鸿芃翱柔安彬翱楷逸栋潍天骏弘奇骞年濡骏锦轩桀运日浩骏寅涛逸晨辰然锦骞星嘉骏宇辰佑星初树斌鸿骏皓骏良初逸杰骞杞福运运振良梓振振泽辰升翱宇伟康震晨祥星信阳振康辰泽潍平骏震博骏禧平子晨柏翰濡鸿文桀升郁邦鹤晖帆皓允凯峰吉博寅天骞佑升良栋伟刚勇毅俊峰强军平保东文辉力明永健世广志义兴良海山仁波宁贵福生龙元全国胜学祥才发武新利清飞彬富顺信子杰涛昌成康星光天达安岩中茂进林有坚和彪博诚先敬震振壮会思群豪心邦承乐绍功松善厚庆磊民友裕河哲江超浩亮政谦亨奇固之轮翰朗伯宏言若鸣朋斌梁栋维启克伦翔旭鹏泽晨辰士以建家致树炎德行时泰盛雄琛钧冠策腾楠榕风航弘"; + private static String[] road="重庆大厦,黑龙江路,十梅庵街,遵义路,湘潭街,瑞金广场,仙山街,仙山东路,仙山西大厦,白沙河路,赵红广场,机场路,民航街,长城南路,流亭立交桥,虹桥广场,长城大厦,礼阳路,风岗街,中川路,白塔广场,兴阳路,文阳街,绣城路,河城大厦,锦城广场,崇阳街,华城路,康城街,正阳路,和阳广场,中城路,江城大厦,顺城路,安城街,山城广场,春城街,国城路,泰城街,德阳路,明阳大厦,春阳路,艳阳街,秋阳路,硕阳街,青威高速,瑞阳街,丰海路,双元大厦,惜福镇街道,夏庄街道,古庙工业园,中山街,太平路,广西街,潍县广场,博山大厦,湖南路,济宁街,芝罘路,易州广场,荷泽四路,荷泽二街,荷泽一路,荷泽三大厦,观海二广场,广西支街,观海一路,济宁支街,莒县路,平度广场,明水路,蒙阴大厦,青岛路,湖北街,江宁广场,郯城街,天津路,保定街,安徽路,河北大厦,黄岛路,北京街,莘县路,济南街,宁阳广场,日照街,德县路,新泰大厦,荷泽路,山西广场,沂水路,肥城街,兰山路,四方街,平原广场,泗水大厦,浙江路,曲阜街,寿康路,河南广场,泰安路,大沽街,红山峡支路,西陵峡一大厦,台西纬一广场,台西纬四街,台西纬二路,西陵峡二街,西陵峡三路,台西纬三广场,台西纬五路,明月峡大厦,青铜峡路,台西二街,观音峡广场,瞿塘峡街,团岛二路,团岛一街,台西三路,台西一大厦,郓城南路,团岛三街,刘家峡路,西藏二街,西藏一广场,台西四街,三门峡路,城武支大厦,红山峡路,郓城北广场,龙羊峡路,西陵峡街,台西五路,团岛四街,石村广场,巫峡大厦,四川路,寿张街,嘉祥路,南村广场,范县路,西康街,云南路,巨野大厦,西江广场,鱼台街,单县路,定陶街,滕县路,钜野广场,观城路,汶上大厦,朝城路,滋阳街,邹县广场,濮县街,磁山路,汶水街,西藏路,城武大厦,团岛路,南阳街,广州路,东平街,枣庄广场,贵州街,费县路,南海大厦,登州路,文登广场,信号山支路,延安一街,信号山路,兴安支街,福山支广场,红岛支大厦,莱芜二路,吴县一街,金口三路,金口一广场,伏龙山路,鱼山支街,观象二路,吴县二大厦,莱芜一广场,金口二街,海阳路,龙口街,恒山路,鱼山广场,掖县路,福山大厦,红岛路,常州街,大学广场,龙华街,齐河路,莱阳街,黄县路,张店大厦,祚山路,苏州街,华山路,伏龙街,江苏广场,龙江街,王村路,琴屿大厦,齐东路,京山广场,龙山路,牟平街,延安三路,延吉街,南京广场,东海东大厦,银川西路,海口街,山东路,绍兴广场,芝泉路,东海中街,宁夏路,香港西大厦,隆德广场,扬州街,郧阳路,太平角一街,宁国二支路,太平角二广场,天台东一路,太平角三大厦,漳州路一路,漳州街二街,宁国一支广场,太平角六街,太平角四路,天台东二街,太平角五路,宁国三大厦,澳门三路,江西支街,澳门二路,宁国四街,大尧一广场,咸阳支街,洪泽湖路,吴兴二大厦,澄海三路,天台一广场,新湛二路,三明北街,新湛支路,湛山五街,泰州三广场,湛山四大厦,闽江三路,澳门四街,南海支路,吴兴三广场,三明南路,湛山二街,二轻新村镇,江南大厦,吴兴一广场,珠海二街,嘉峪关路,高邮湖街,湛山三路,澳门六广场,泰州二路,东海一大厦,天台二路,微山湖街,洞庭湖广场,珠海支街,福州南路,澄海二街,泰州四路,香港中大厦,澳门五路,新湛三街,澳门一路,正阳关街,宁武关广场,闽江四街,新湛一路,宁国一大厦,王家麦岛,澳门七广场,泰州一路,泰州六街,大尧二路,青大一街,闽江二广场,闽江一大厦,屏东支路,湛山一街,东海西路,徐家麦岛函谷关广场,大尧三路,晓望支街,秀湛二路,逍遥三大厦,澳门九广场,泰州五街,澄海一路,澳门八街,福州北路,珠海一广场,宁国二路,临淮关大厦,燕儿岛路,紫荆关街,武胜关广场,逍遥一街,秀湛四路,居庸关街,山海关路,鄱阳湖大厦,新湛路,漳州街,仙游路,花莲街,乐清广场,巢湖街,台南路,吴兴大厦,新田路,福清广场,澄海路,莆田街,海游路,镇江街,石岛广场,宜兴大厦,三明路,仰口街,沛县路,漳浦广场,大麦岛,台湾街,天台路,金湖大厦,高雄广场,海江街,岳阳路,善化街,荣成路,澳门广场,武昌路,闽江大厦,台北路,龙岩街,咸阳广场,宁德街,龙泉路,丽水街,海川路,彰化大厦,金田路,泰州街,太湖路,江西街,泰兴广场,青大街,金门路,南通大厦,旌德路,汇泉广场,宁国路,泉州街,如东路,奉化街,鹊山广场,莲岛大厦,华严路,嘉义街,古田路,南平广场,秀湛路,长汀街,湛山路,徐州大厦,丰县广场,汕头街,新竹路,黄海街,安庆路,基隆广场,韶关路,云霄大厦,新安路,仙居街,屏东广场,晓望街,海门路,珠海街,上杭路,永嘉大厦,漳平路,盐城街,新浦路,新昌街,高田广场,市场三街,金乡东路,市场二大厦,上海支路,李村支广场,惠民南路,市场纬街,长安南路,陵县支街,冠县支广场,小港一大厦,市场一路,小港二街,清平路,广东广场,新疆路,博平街,港通路,小港沿,福建广场,高唐街,茌平路,港青街,高密路,阳谷广场,平阴路,夏津大厦,邱县路,渤海街,恩县广场,旅顺街,堂邑路,李村街,即墨路,港华大厦,港环路,馆陶街,普集路,朝阳街,甘肃广场,港夏街,港联路,陵县大厦,上海路,宝山广场,武定路,长清街,长安路,惠民街,武城广场,聊城大厦,海泊路,沧口街,宁波路,胶州广场,莱州路,招远街,冠县路,六码头,金乡广场,禹城街,临清路,东阿街,吴淞路,大港沿,辽宁路,棣纬二大厦,大港纬一路,贮水山支街,无棣纬一广场,大港纬三街,大港纬五路,大港纬四街,大港纬二路,无棣二大厦,吉林支路,大港四街,普集支路,无棣三街,黄台支广场,大港三街,无棣一路,贮水山大厦,泰山支路,大港一广场,无棣四路,大连支街,大港二路,锦州支街,德平广场,高苑大厦,长山路,乐陵街,临邑路,嫩江广场,合江路,大连街,博兴路,蒲台大厦,黄台广场,城阳街,临淄路,安邱街,临朐路,青城广场,商河路,热河大厦,济阳路,承德街,淄川广场,辽北街,阳信路,益都街,松江路,流亭大厦,吉林路,恒台街,包头路,无棣街,铁山广场,锦州街,桓台路,兴安大厦,邹平路,胶东广场,章丘路,丹东街,华阳路,青海街,泰山广场,周村大厦,四平路,台东西七街,台东东二路,台东东七广场,台东西二路,东五街,云门二路,芙蓉山村,延安二广场,云门一街,台东四路,台东一街,台东二路,杭州支广场,内蒙古路,台东七大厦,台东六路,广饶支街,台东八广场,台东三街,四平支路,郭口东街,青海支路,沈阳支大厦,菜市二路,菜市一街,北仲三路,瑞云街,滨县广场,庆祥街,万寿路,大成大厦,芙蓉路,历城广场,大名路,昌平街,平定路,长兴街,浦口广场,诸城大厦,和兴路,德盛街,宁海路,威海广场,东山路,清和街,姜沟路,雒口大厦,松山广场,长春街,昆明路,顺兴街,利津路,阳明广场,人和路,郭口大厦,营口路,昌邑街,孟庄广场,丰盛街,埕口路,丹阳街,汉口路,洮南大厦,桑梓路,沾化街,山口路,沈阳街,南口广场,振兴街,通化路,福寺大厦,峄县路,寿光广场,曹县路,昌乐街,道口路,南九水街,台湛广场,东光大厦,驼峰路,太平山,标山路,云溪广场,太清路".split(","); + private static final String[] email_suffix="@gmail.com,@yahoo.com,@msn.com,@hotmail.com,@aol.com,@ask.com,@live.com,@qq.com,@0355.net,@163.com,@163.net,@263.net,@3721.net,@yeah.net,@googlemail.com,@126.com,@sina.com,@sohu.com,@yahoo.com.cn".split(","); + + public static int getNum(int start,int end) { + return (int)(Math.random()*(end-start+1)+start); + } + + /** + * 返回Email + * @param lMin 最小长度 + * @param lMax 最大长度 + * @return + */ + public static String getEmail(int lMin,int lMax) { + int length=getNum(lMin,lMax); + StringBuffer sb = new StringBuffer(); + for (int i = 0; i < length; i++) { + int number = (int)(Math.random()*base.length()); + sb.append(base.charAt(number)); + } + sb.append(email_suffix[(int)(Math.random()*email_suffix.length)]); + return sb.toString(); + } + + /** + * 返回手机号码 + */ + private static String[] telFirst="134,135,136,137,138,139,150,151,152,157,158,159,130,131,132,155,156,133,153".split(","); + private static String getTel() { + int index=getNum(0,telFirst.length-1); + String first=telFirst[index]; + String second=String.valueOf(getNum(1,888)+10000).substring(1); + String third=String.valueOf(getNum(1,9100)+10000).substring(1); + return first+second+third; + } + + /** + * 返回中文姓名 + */ + private static String name_sex = ""; + private static String getChineseName() { + int index=getNum(0, firstName.length()-1); + String first=firstName.substring(index, index+1); + int sex=getNum(0,1); + String str=boy; + int length=boy.length(); + if(sex==0){ + str=girl; + length=girl.length(); + name_sex = "女"; + }else { + name_sex="男"; + } + index=getNum(0,length-1); + String second=str.substring(index, index+1); + int hasThird=getNum(0,1); + String third=""; + if(hasThird==1){ + index=getNum(0,length-1); + third=str.substring(index, index+1); + } + return first+second+third; + } + + /** + * 返回地址 + * @return + */ + private static String getRoad() { + int index=getNum(0,road.length-1); + String first=road[index]; + String second=String.valueOf(getNum(11,150))+"号"; + String third="-"+getNum(1,20)+"-"+getNum(1,10); + return first+second+third; + } + + /** + * 数据封装 + * @return + */ + public static Map getAddress() { + Map map=new HashMap(); + map.put("name", getChineseName()); + map.put("gender", name_sex); + map.put("road", getRoad()); + map.put("phone", getTel()); + map.put("email", getEmail(6,9)); + return map; + } + + public static void main(String[] args) throws Exception{ + StringBuffer stringBuffer = new StringBuffer(); + for (int i = 0; i < 100; i++) { + Map address = getAddress(); + stringBuffer.append("insert into student(address,gender,name,phone,email) values"+"(" +"'"+ address.get("road")+"'" + "," +"'"+ address.get("gender")+"'" + ","+"'" + address.get("name") +"'"+ "," +"'"+ address.get("phone") +"'"+ "," +"'"+ address.get("email")+"'" + ");\r\n"); +// System.out.println(getEmailName(6,9)); + } + System.out.println(stringBuffer); + + +// File file = new File("/Users/nibnait/Desktop/student.sql"); +// if (!file.exists()) { +// file.createNewFile(); +// } +// FileOutputStream fos = new FileOutputStream(file); +// FileChannel channel = fos.getChannel(); +// ByteBuffer byteBuffer = ByteBuffer.allocateDirect(stringBuffer.length()); +// byteBuffer.put(stringBuffer.toString().getBytes()); +// byteBuffer.flip(); +// channel.write(byteBuffer); +// fos.write(stringBuffer.toString().getBytes()); + } + + +} diff --git "a/src/main/java/org/tianbin/java/\345\271\266\345\217\221/AQS\346\272\220\347\240\201\351\230\205\350\257\273/ReentrantLock\345\217\257\351\207\215\345\205\245\351\224\201_\345\205\254\345\271\263\351\224\201.md" "b/src/main/java/org/tianbin/java/\345\271\266\345\217\221/AQS\346\272\220\347\240\201\351\230\205\350\257\273/ReentrantLock\345\217\257\351\207\215\345\205\245\351\224\201_\345\205\254\345\271\263\351\224\201.md" new file mode 100644 index 00000000..eb4a9840 --- /dev/null +++ "b/src/main/java/org/tianbin/java/\345\271\266\345\217\221/AQS\346\272\220\347\240\201\351\230\205\350\257\273/ReentrantLock\345\217\257\351\207\215\345\205\245\351\224\201_\345\205\254\345\271\263\351\224\201.md" @@ -0,0 +1,204 @@ + +## lock (sync.lock()) + +```java + final void lock() { + acquire(1); + } + + public final void acquire(int arg) { + // tryAcquire == true：获取锁成功。啥也不干 + // tryAcquire == false: 获取锁失败，addWaiter()，acquireQueued + if (!tryAcquire(arg) && + acquireQueued(addWaiter(Node.EXCLUSIVE), arg)) { + + selfInterrupt(); + } + } + + protected final boolean tryAcquire(int acquires) { + final Thread current = Thread.currentThread(); + int c = getState(); + if (c == 0) { + // c == 0 && 没有等待队列 && casState(0, 1)成功： + if (!hasQueuedPredecessors() && + compareAndSetState(0, acquires)) { + setExclusiveOwnerThread(current); + return true; + } + } else if (current == getExclusiveOwnerThread()) { + // 重入的情况：state+1 + int nextc = c + acquires; + if (nextc < 0) + throw new Error("Maximum lock count exceeded"); + setState(nextc); + return true; + } + return false; + } + + private Node addWaiter(Node mode) { + // Node.EXCLUSIVE = null; 独占锁 + Node node = new Node(Thread.currentThread(), mode); + + // tail != null，说明其他线程抢先casTail成功，当前node需要放到 tail的后面，重新casTail(tail, node) + Node pred = tail; + if (pred != null) { + node.prev = pred; + if (compareAndSetTail(pred, node)) { + pred.next = node; + return node; + } + } + + // 将node 链到等待队列的末尾。 + enq(node); + return node; + } + + private Node enq(final Node node) { + for (;;) { + Node t = tail; + if (t == null) { + // 第一次进入for循环，将 head 和 tail 都指向 new Node() + if (compareAndSetHead(new Node())) + tail = head; + } else { + // 第二次进入for循环，node.prev = t, casTail(t, node), t.next = node + node.prev = t; + if (compareAndSetTail(t, node)) { + t.next = node; + return t; + } + } + } + } + + final boolean acquireQueued(final Node node, int arg) { + boolean failed = true; + try { + boolean interrupted = false; + for (;;) { + // p = node.prev + final Node p = node.predecessor(); + + // 如果 node.prev == head，重新 tryAcquire + if (p == head && tryAcquire(arg)) { + setHead(node); + p.next = null; // help GC + failed = false; + return interrupted; + } + + // 抢锁失败之后判断是否要要阻塞 + if (shouldParkAfterFailedAcquire(p, node) && + parkAndCheckInterrupt()) + interrupted = true; + } + } finally { + if (failed) + cancelAcquire(node); + } + } + + private static boolean shouldParkAfterFailedAcquire(Node pred, Node node) { + int ws = pred.waitStatus; + if (ws == Node.SIGNAL) + /* + * pred.waitStatus == SIGNAL == -1，prev(前一个节点)已经被唤醒，所以node(当前节点)可以安全的被阻塞 + */ + return true; + if (ws > 0) { + /* + * prev节点已经被取消，需要去判断 prev.prev.waitStatus， + * 直到prev.waitStatus <= 0: prev.next = node; + * + * 即：循环清除掉所有已经取消的节点。 + */ + do { + node.prev = pred = pred.prev; + } while (pred.waitStatus > 0); + pred.next = node; + } else { + /* + * waitStatus must be 0 or PROPAGATE(-3). Indicate that we + * need a signal, but don't park yet. Caller will need to + * retry to make sure it cannot acquire before parking. + * + * casWaitStatus(prev, ws, SIGNAL) + * 死循环将prev(前一个节点) 设为SIGNAL，直到设置成功，return true + */ + compareAndSetWaitStatus(pred, ws, Node.SIGNAL); + } + return false; + } + +``` + + +## unlock(sync.release(1)) + +```java + public void unlock() { + sync.release(1); + } + + public final boolean release(int arg) { + if (tryRelease(arg)) { + Node h = head; + if (h != null && h.waitStatus != 0) + unparkSuccessor(h); + return true; + } + return false; + } + + // 可重入锁 + protected final boolean tryRelease(int releases) { + int c = getState() - releases; + if (Thread.currentThread() != getExclusiveOwnerThread()) + throw new IllegalMonitorStateException(); + boolean free = false; + if (c == 0) { + free = true; + setExclusiveOwnerThread(null); + } + setState(c); + return free; + } + + /** + 1. 判断node.waitStatus + < 0: 直接将waitStatus 设为0 + 2. 尝试唤醒node = node.next + 如果node.next.waitStauts = 1(取消状态)，则从 tail往前遍历 + unpark 从 tail往前第一个非取消状态的线程。 + */ + private void unparkSuccessor(Node node) { + /* + * If status is negative (i.e., possibly needing signal) try + * to clear in anticipation of signalling. It is OK if this + * fails or if status is changed by waiting thread. + */ + int ws = node.waitStatus; + if (ws < 0) + compareAndSetWaitStatus(node, ws, 0); + + /* + * Thread to unpark is held in successor, which is normally + * just the next node. But if cancelled or apparently null, + * traverse backwards from tail to find the actual + * non-cancelled successor. + */ + Node s = node.next; + if (s == null || s.waitStatus > 0) { + s = null; + for (Node t = tail; t != null && t != node; t = t.prev) + if (t.waitStatus <= 0) + s = t; + } + if (s != null) + LockSupport.unpark(s.thread); + } + +``` \ No newline at end of file diff --git "a/src/main/java/org/tianbin/java/\345\271\266\345\217\221/AQS\346\272\220\347\240\201\351\230\205\350\257\273/ReentrantLock\345\217\257\351\207\215\345\205\245\351\224\201_\351\235\236\345\205\254\345\271\263\351\224\201.md" "b/src/main/java/org/tianbin/java/\345\271\266\345\217\221/AQS\346\272\220\347\240\201\351\230\205\350\257\273/ReentrantLock\345\217\257\351\207\215\345\205\245\351\224\201_\351\235\236\345\205\254\345\271\263\351\224\201.md" new file mode 100644 index 00000000..0aa33ea1 --- /dev/null +++ "b/src/main/java/org/tianbin/java/\345\271\266\345\217\221/AQS\346\272\220\347\240\201\351\230\205\350\257\273/ReentrantLock\345\217\257\351\207\215\345\205\245\351\224\201_\351\235\236\345\205\254\345\271\263\351\224\201.md" @@ -0,0 +1,52 @@ + +## lock (sync.lock()) + +```java + final void lock() { + if (compareAndSetState(0, 1)) + setExclusiveOwnerThread(Thread.currentThread()); + else + acquire(1); + } + + public final void acquire(int arg) { + if (!tryAcquire(arg) && + acquireQueued(addWaiter(Node.EXCLUSIVE), arg)) + selfInterrupt(); + } + + protected final boolean tryAcquire(int acquires) { + return nonfairTryAcquire(acquires); + } + + final boolean nonfairTryAcquire(int acquires) { + final Thread current = Thread.currentThread(); + int c = getState(); + if (c == 0) { + // c == 0 && casState(0, 1) 成功 ==> 抢锁成功。否则直接入队。 + if (compareAndSetState(0, acquires)) { + setExclusiveOwnerThread(current); + return true; + } + } + else if (current == getExclusiveOwnerThread()) { + int nextc = c + acquires; + if (nextc < 0) // overflow + throw new Error("Maximum lock count exceeded"); + setState(nextc); + return true; + } + return false; + } + +``` + +## unlock(sync.release(1)) +```java + public void unlock() { + sync.release(1); + } + + 释放锁没有公平非公平之分。 + +``` \ No newline at end of file diff --git "a/src/main/java/org/tianbin/java/\345\271\266\345\217\221/AQS\346\272\220\347\240\201\351\230\205\350\257\273/synchronized\344\270\215\345\217\257\351\207\215\345\205\245\351\224\201_\351\235\236\345\205\254\345\271\263\351\224\201.md" "b/src/main/java/org/tianbin/java/\345\271\266\345\217\221/AQS\346\272\220\347\240\201\351\230\205\350\257\273/synchronized\344\270\215\345\217\257\351\207\215\345\205\245\351\224\201_\351\235\236\345\205\254\345\271\263\351\224\201.md" new file mode 100644 index 00000000..e69de29b diff --git "a/src/main/java/org/tianbin/java/\345\271\266\345\217\221/\346\202\262\350\247\202\351\224\201vs\344\271\220\350\247\202\351\224\201/README.md" "b/src/main/java/org/tianbin/java/\345\271\266\345\217\221/\346\202\262\350\247\202\351\224\201vs\344\271\220\350\247\202\351\224\201/README.md" index f0721870..346d3f27 100644 --- "a/src/main/java/org/tianbin/java/\345\271\266\345\217\221/\346\202\262\350\247\202\351\224\201vs\344\271\220\350\247\202\351\224\201/README.md" +++ "b/src/main/java/org/tianbin/java/\345\271\266\345\217\221/\346\202\262\350\247\202\351\224\201vs\344\271\220\350\247\202\351\224\201/README.md" @@ -11,27 +11,34 @@ - 悲观锁适合写操作多的场景，先加锁可以保证写操作时数据正确。 - 乐观锁适合读操作多的场景，不加锁的特点能够使其读操作的性能大幅提升。 -**1. 锁的实现** +### **1. 锁的实现** synchronized 是 JVM 实现的，而 ReentrantLock 是 JDK 实现的。 -**2. 性能** +### **2. 性能** 新版本 Java 对 synchronized 进行了很多优化，例如自旋锁等，synchronized 与 ReentrantLock 大致相同。 -**3. 等待可中断** +### **3. 等待可中断** 当持有锁的线程长期不释放锁的时候，正在等待的线程可以选择放弃等待，改为处理其他事情。 ReentrantLock 可中断，而 synchronized 不行。 -**4. 公平锁** +### **4. 公平锁** 公平锁是指多个线程在等待同一个锁时，必须按照申请锁的时间顺序来依次获得锁。 synchronized 中的锁是非公平的，ReentrantLock 默认情况下也是非公平的，但是也可以是公平的。 -**5. 锁绑定多个条件** +#### 源码阅读： + - [ReentrantLock 公平锁](../AQS源码阅读/ReentrantLock可重入锁_公平锁.md) + + - [ReentrantLock 非公平锁](../AQS源码阅读/ReentrantLock可重入锁_非公平锁.md) + - [synchronized 非公平锁](../AQS源码阅读/synchronized不可重入锁_非公平锁.md) + + +### **5. 锁绑定多个条件** 一个 ReentrantLock 可以同时绑定多个 Condition 对象。 diff --git a/src/main/resources/excel/report.xls b/src/main/resources/excel/report.xls new file mode 100644 index 00000000..e69de29b diff --git "a/src/main/test/org/tianbin/java/\345\217\215\345\260\204/CommonBeanUtilTest.java" "b/src/main/test/org/tianbin/java/\345\217\215\345\260\204/CommonBeanUtilTest.java" new file mode 100644 index 00000000..a90aeb3d --- /dev/null +++ "b/src/main/test/org/tianbin/java/\345\217\215\345\260\204/CommonBeanUtilTest.java" @@ -0,0 +1,43 @@ +package org.tianbin.java.反射; + +import com.alibaba.fastjson.JSON; +import common.model.Person; +import common.model.PersonDTO; +import common.util.CommonBeanUtil; +import org.junit.Test; + +import java.util.ArrayList; +import java.util.List; + +/** + * Created by nibnait on 2021/01/15 + */ +public class CommonBeanUtilTest { + + @Test + public void copyProperties() { + Person source = new Person(); + source.setName("111"); + source.setAge(22); + + PersonDTO personDTO = CommonBeanUtil.copyProperties(source, PersonDTO::new); + + System.out.println(JSON.toJSONString(personDTO)); + } + + @Test + public void copyListProperties() { + List personList = new ArrayList<>(); + Person p1 = new Person(); + p1.setName("111"); + p1.setAge(22); + personList.add(p1); + Person p2 = new Person(); + p2.setName("333"); + p2.setAge(44); + personList.add(p2); + + List personDTOList = CommonBeanUtil.copyListProperties(personList, PersonDTO::new); + System.out.println(JSON.toJSONString(personDTOList)); + } +} diff --git "a/src/main/test/org/tianbin/java/\351\233\206\345\220\210/ListTest.java" "b/src/main/test/org/tianbin/java/\351\233\206\345\220\210/ListTest.java" index 98e27fb2..0e98c4dd 100644 --- "a/src/main/test/org/tianbin/java/\351\233\206\345\220\210/ListTest.java" +++ "b/src/main/test/org/tianbin/java/\351\233\206\345\220\210/ListTest.java" @@ -3,25 +3,38 @@ import com.alibaba.fastjson.JSONObject; import com.google.common.base.Functions; import com.google.common.collect.Lists; -import junit.framework.TestCase; +import common.util.CommonBeanUtil; import org.junit.Test; import java.util.ArrayList; +import java.util.Collections; import java.util.List; /* Created by nibnait on 2020-01-09 */ -public class ListTest extends TestCase { +public class ListTest { @Test - public void testCase02() { - List eveList = new ArrayList<>(); - List oddList = new ArrayList<>(); - + public void copyListProperties() { + List list = Lists.newArrayList(2,1,3); + System.out.println(list); + Collections.sort(list); + System.out.println(list); + } + @Test + public void testSubList() { + List list = Lists.newArrayList(1,2,3); + System.out.println(list.subList(0,0)); + } + @Test + public void sort() { + List list = Lists.newArrayList(2,3,1); + Collections.sort(list); + System.out.println(list); } diff --git "a/src/main/test/org/tianbin/java/\351\233\206\345\220\210/MapTest.java" "b/src/main/test/org/tianbin/java/\351\233\206\345\220\210/MapTest.java" index 0593778f..ac8a9211 100644 --- "a/src/main/test/org/tianbin/java/\351\233\206\345\220\210/MapTest.java" +++ "b/src/main/test/org/tianbin/java/\351\233\206\345\220\210/MapTest.java" @@ -12,7 +12,7 @@ Created by nibnait on 2020-01-15 */ -public class MapTest extends TestCase { +public class MapTest { @Test diff --git "a/src/main/test/org/tianbin/java/\351\233\206\345\220\210/SetTest.java" "b/src/main/test/org/tianbin/java/\351\233\206\345\220\210/SetTest.java" index f0afeb08..c5fa5dd7 100644 --- "a/src/main/test/org/tianbin/java/\351\233\206\345\220\210/SetTest.java" +++ "b/src/main/test/org/tianbin/java/\351\233\206\345\220\210/SetTest.java" @@ -1,10 +1,13 @@ package org.tianbin.java.集合; +import com.google.common.collect.Lists; +import com.google.common.collect.Sets; import common.util.StringUtil; import junit.framework.TestCase; import org.apache.commons.collections4.CollectionUtils; import org.junit.Test; +import java.util.ArrayList; import java.util.Set; import java.util.stream.Collectors; import java.util.stream.Stream; @@ -13,7 +16,16 @@ Created by nibnait on 2020-01-14 */ -public class SetTest extends TestCase { +public class SetTest { + + @Test + public void test01() { + ArrayList list1 = Lists.newArrayList(1, 2, 3); + ArrayList list2 = Lists.newArrayList(2, 3, 4); + + System.out.println(Lists.newArrayList(Sets.difference(Sets.newHashSet(list1), Sets.newHashSet(list2)))); + System.out.println(Lists.newArrayList(Sets.intersection(Sets.newHashSet(list1), Sets.newHashSet(list2)))); + } @Test public void testCase() { diff --git a/src/main/test/org/tianbin/temp/DataGen.java b/src/main/test/org/tianbin/temp/DataGen.java new file mode 100644 index 00000000..b87f2cd6 --- /dev/null +++ b/src/main/test/org/tianbin/temp/DataGen.java @@ -0,0 +1,24 @@ +package org.tianbin.temp; + +import org.junit.Test; + +/** + * Created by nibnait on 2021/01/27 + */ +public class DataGen { + @Test + public void test() { + String ipIdStr = "3000001,3000002,3000003,3000004,3000005,3000006,3000007,3000008,3000009,3000010,3000011,3000012,3000013,3000014,3000015,3000016,3000017,3000018,3000019,3000020,3000021,3000022,3000023,3000024,3000025,3000026,3000027,3000028,3000029,3000030,3000031,3000032,3000033,3000034,3000035,3000036,3000037,3000038,3000039,3000040,3000041,3000042,3000043,3000044,3000045,3000046,3000047,3000048,3000049,3000050,3000051,3000052,3000053,3000054,3000055,3000056,3000057,3000058,3000059,3000060,3000061,3000062,3000063,3000064,3000065,3000066,3000067,3000068,3000069,3000070,3000071,3000072,3000073,3000074,3000075,3000076,3000077,3000078,3000079,3000080,3000081,3000082,3000083,3000084,3000085,3000086,3000087,3000088,3000089,3000090,3000091,3000092,3000093,3000094,3000095,3000096,3000097,3000098,3000099,3000100,3000101,3000102,3000103,3000104,3000105,3000106,3000107,3000108,3000109,3000110,3000111,3000112,3000113,3000114,3000115,3000116,3000117,3000118,3000119,3000120,3000121,3000122,3000123,3000124,3000125,3000126,3000127,3000128,3000129,3000130,3000131,3000132,3000133,3000134,3000135,3000136,3000137,3000138,3000139,3000140,3000141,3000142,3000143,3000144,3000145,3000146,3000147,3000148,3000149,3000150,3000151,3000152,3000153,3000154,3000155,3000156,3000157,3000158,3000159,3000160,3000161,3000162,3000163,3000164,3000165,3000166,3000167,3000168,3000169,3000170,3000171,3000172,3000173,3000174,3000175,3000176,3000177,3000178,3000179,3000180,3000181,3000182,3000183,3000184,3000185,3000186,3000187,3000188,3000189,3000190,3000191,3000192,3000193,3000194,3000195,3000196,3000197,3000198,3000199,3000200,3000201,3000202,3000203,3000204,3000205,3000206,3000207,3000208,3000209,3000210,3000211,3000212,3000213,3000214,3000215,3000216,3000217,3000218,3000219,3000220,3000221,3000222,3000223,3000224,3000225,3000226,3000227,3000228,3000229,3000230,3000231,3000232,3000233,3000234,3000235,3000236,3000237,3000238,3000239,3000240,3000241,3000242,3000243,3000244,3000245,3000246,3000247,3000248,3000249,3000250,3000251,3000252,3000253,3000254,3000255,3000256,3000257,3000258,3000259,3000260,3000261,3000262,3000263,3000264,3000265,3000266,3000267,3000268,3000269,3000270,3000271,3000272,3000273,3000274,3000275,3000276,3000277,3000278,3000279,3000280,3000281,3000282,3000283,3000284,3000285,3000286,3000287,3000288,3000289,3000290,3000291,3000292,3000293,3000294,3000295,3000296,3000297,3000298,3000299,3000300,3000301,3000302,3000303,3000304,3000305,3000306,3000307,3000308,3000309,3000310,3000311,3000312,3000313,3000314,3000315,3000316,3000317,3000318,3000319,3000320,3000321,3000322,3000323,3000324,3000325,3000326,3000327,3000328,3000329,3000330,3000331,3000332,3000333,3000334,3000335,3000336,3000337,3000338,3000339,3000340,3000341,3000342,3000343,3000344,3000345,3000346,3000347,3000348,3000349,3000350,3000351,3000352,3000353,3000354,3000355,3000356,3000357,3000358,3000359,3000360,3000361,3000362,3000363,3000364,3000365,3000366,3000367,3000368,3000369,3000370,3000371,3000372,3000373,3000374,3000375,3000376,3000377,3000378,3000379,3000380,3000381,3000382,3000383,3000384,3000385,3000386,3000387,3000388,3000389,3000390,3000391,3000392,3000393,3000394,3000395,3000396,3000397,3000398,3000399,3000400,3000401,3000402,3000403,3000404,3000405,3000406,3000407,3000408,3000409,3000410,3000411,3000412,3000413,3000414,3000415,3000416,3000417,3000418,3000419,3000420,3000421,3000422,3000423,3000424,3000425,3000426,3000427,3000428,3000429,3000430,3000431,3000432,3000433,3000434,3000435,3000436,3000437,3000438,3000439,3000440,3000441,3000442,3000443,3000444,3000445,3000446,3000447,3000448,3000449,3000450,3000451,3000452,3000453,3000454,3000455,3000456,3000457,3000458,3000459,3000460,3000461,3000462,3000463,3000464,3000465,3000466,3000467,3000468,3000469,3000470,3000471,3000472,3000473,3000474,3000475,3000476,3000477,3000478,3000479,3000480,3000481,3000482,3000483,3000484,3000485,3000486,3000487,3000488,3000489,3000490,3000491,3000492,3000493,3000494,3000495,3000496,3000497,3000498,3000499,3000500,3000501,3000502,3000503,3000504,3000505,3000506,3000507,3000508,3000509,3000510,3000511,3000512,3000513,3000514,3000515,3000516,3000517,3000518,3000519,3000520,3000521,3000522,3000523,3000524,3000525,3000526,3000527,3000528,3000529,3000530,3000531,3000532,3000533,3000534,3000535,3000536,3000537,3000538,3000539,3000540,3000541,3000542,3000543,3000544,3000545,3000546,3000547,3000548,3000549,3000550,3000551,3000552,3000553,3000554,3000555,3000556,3000557,3000558,3000559,3000560,3000561,3000562,3000563,3000564,3000565,3000566,3000567,3000568,3000569,3000570,3000571,3000572,3000573,3000574,3000575,3000576,3000577,3000578,3000579,3000580,3000581,3000582,3000583,3000584,3000585,3000586,3000587,3000588,3000589,3000590,3000591,3000592,3000593,3000594,3000595,3000596,3000597,3000598,3100002,3100005,3100007,3100009,3100011,3100013,3100015,3100018,3100020,3100022,3100024,3100026,3100028,3100031,3100033,3100034,3100036,3100037,3100039,3100041,3100043,3100045,3100047,3100049,3100052,3100054,3100056,3100058,3100060,3100062,3100064,3100066,3100069,3100071,3100073,3100075,3100077,3100079,3100082,3100084,3100087,3100089,3100091,3100093,3100095,3100097,3100099,3100101,3100103,3100105,3100107,3100109,3100112,3100114,3100116,3100118,3100120,3100122,3100124,3100126,3100128,3100130,3100132,3100134,3100136,3100138,3100140,3100142,3100144,3100146,3100149,3100151,3100154,3100156,3100158,3100160,3100162,3100164,3100166,3100168,3100170,3100172,3100174,3100176,3100178,3100180,3100183,3100185,3100187,3100189,3100191,3100193,3100195,3100197,3100199,3100201,3100203,3100205,3100207,3100209,3100211,3100213,3100215,3100217,3100219,3100221,3100223,3100225,3100227,3100229,3100231,3100234,3100236,3100257,3100259,3100261,3100264,3100266,3100272,3100274,3100276,3100278,3100280,3100282,3100284,3100286,3100293,3100295,3100297,3100300,3100302,3100304,3100307,3100309,3100311,3100314,3100317,3100319,3100321,3100323,3100325,3100327,3100329,3100331,3100333,3100335,3100337,3100339,3100341,3100343,3100345,3100347,3100350,3100353,3100355,3100357,3100359,3100361,3100363,3100365,3100367,3100369,3100371,3100373,3100375,3100377,3100379,3100381,3100383,3100385,3100387,3100389,3100391,3100393,3100395,3100398,3100401,3100403,3100405,3100407,3100410,3100412,3100414,3100416,3100418,3100420,3100422,3100424,3100427,3100429,3100431,3100433,3100435,3100437,3100439,3100441,3100444,3100446,3100448,3100450,3100452,3100454,3100456,3100458,3100460,3100462,3100465,3100471,3100473,3100475,3100477,3100479,3100481,3100483,3100485,3100487,3100489,3100491,3100493,3100495,3100497,3100499,3100501,3100503,3100506,3100508,3100510,3100512,3100515,3100517,3100519,3100521,3100523,3100525,3100527,3100529,3100532,3100533,3100565,3100568,3100570,3100572,3100574,3100598,3100606,3100608,3100610,3100612,3100614,3100616,3100618,3100620,3100622,3100624,3100626,3100628,3100631,3100633,3100635,3100637,3100639,3100642,3100644,3100646,3100648,3100650,3100652,3100654,3100656,3100658,3100660,3100662,3100666,3100673,3100675,3100679,3100681,3100683,3100685,3100687,3100689,3100691,3100693,3100695,3100697,3100699,3100702,3100705,3100707,3100709,3100711,3100720,3100722,3100724,3100726,3100728,3100730,3100732,3100734,3100736,3100738,3100740,3100743,3100745,3100747,3100748,3100750,3100752,3100754,3100757,3100759,3100761,3100763,3100765,3100767,3100769,3100771,3100773,3100775,3100778,3100780,3100781,3100784,3100786,3100788"; + String[] split = ipIdStr.split(","); + for (String ipId : split) { + System.out.println(ipId + ",10" + ",0"); + System.out.println(ipId + ",10" + ",10"); + System.out.println(ipId + ",10" + ",20"); + System.out.println(ipId + ",10" + ",30"); + System.out.println(ipId + ",10" + ",40"); + System.out.println(ipId + ",10" + ",50"); + System.out.println(ipId + ",10" + ",60"); + System.out.println(ipId + ",10" + ",70"); + } + } +} diff --git a/src/main/test/org/tianbin/temp/ExcelGen.java b/src/main/test/org/tianbin/temp/ExcelGen.java new file mode 100644 index 00000000..848dc2f1 --- /dev/null +++ b/src/main/test/org/tianbin/temp/ExcelGen.java @@ -0,0 +1,69 @@ +package org.tianbin.temp; + +import com.google.common.collect.Lists; +import common.bo.EmailBO; +import common.util.EmailUtils; +import common.bo.excel.SheetBO; +import common.bo.excel.WorkBookBO; +import org.apache.commons.lang3.StringUtils; +import org.junit.Test; + +import java.io.File; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; + +/** + * Created by nibnait on 2021/01/21 + */ +public class ExcelGen { + + @Test + public void test() { + System.out.println(StringUtils.isBlank(" ")); + } + + private static final String DELAY_DELIVERY_REPORT_FILE_NAME = "报表-%s"; + public static final String DATE_TIME_FORMAT = "yyyyMMdd-HHmm"; + + @Test + public void excelGen() { + + String targetFileName = String.format(DELAY_DELIVERY_REPORT_FILE_NAME, + getNowDateTime(DATE_TIME_FORMAT)); + + WorkBookBO workBookBO = new WorkBookBO(); + SheetBO sheet = workBookBO.getSheetList().get(0); + + xiegehanshu(sheet); + + File delay_delivery_report = workBookBO.writeToFile("report", targetFileName); + + System.out.println(delay_delivery_report.getName()); + + EmailUtils.sendEmail(new EmailBO("111", + "tianbin@bilibili.com", + null, + "222", + getEmailContent(), + Lists.newArrayList(delay_delivery_report))); + } + + public static String getNowDateTime(String dateFormat) { + return LocalDateTime.now().format(DateTimeFormatter.ofPattern(dateFormat)); + } + + + private void xiegehanshu(SheetBO sheet) { + sheet.appendRow(Lists.newArrayList("123", "234")); + } + + private String getEmailContent() { + StringBuilder content = new StringBuilder("
Hi All:
"); + content.append(" "); + content.append("2021年1月21日"); + content.append(" 报表如下，请核实："); + content.append("
"); + content.append("
"); + return content.toString(); + } +} From 228935359c08385e6ff78ee3dd9143c73998810c Mon Sep 17 00:00:00 2001 From: tianbin Date: Tue, 13 Jul 2021 10:40:16 +0800 Subject: [PATCH 02/36] CompareUtil --- pom.xml | 21 ++ ...350\275\254\351\223\276\350\241\2502.java" | 2 +- ...\345\205\245\346\216\222\345\272\217.java" | 2 +- ...\345\272\217\351\223\276\350\241\250.java" | 2 +- ...\350\275\254\351\223\276\350\241\250.java" | 2 +- ...\345\201\266\351\223\276\350\241\250.java" | 2 +- .../java/common/bo/compare/CompareBO.java | 56 +++++ .../common/bo/compare/CompareResultDTO.java | 37 +++ src/main/java/common/model/Person.java | 9 + src/main/java/common/model/PersonDTO.java | 5 +- src/main/java/common/util/CommonBeanUtil.java | 83 ++++++- src/main/java/common/util/CompareUtil.java | 18 -- src/main/java/common/util/DateTimeUtil.java | 125 ++++++++-- .../java/common/util/compare/CompareUtil.java | 40 ++++ .../common/util/compare/JacksonUtils.java | 219 ++++++++++++++++++ .../java/common/util/compare/JsonUtils.java | 211 +++++++++++++++++ .../CompareUtil.java" | 77 ++++-- .../java/\345\217\215\345\260\204/Main.java" | 101 +++++--- .../BigDecimalTest.java" | 46 +++- .../DoubleTest.java" | 49 ++++ .../IntegerTest.java" | 40 ++++ .../StringTest.java" | 9 + .../threadpool/b1_FutureTaskDemo.java" | 6 +- .../b2_CompletableFutureDemo2.java" | 78 +++++++ .../List\347\261\273.java" | 2 +- .../Map\347\261\273.java" | 2 +- .../test/common/util/DateTimeUtilTest.java | 16 ++ src/main/test/org/tianbin/Main.java | 4 +- .../org/tianbin/{temp => excel}/ExcelGen.java | 2 +- .../test/org/tianbin/excel/ExcelRead.java | 10 + .../test/org/tianbin/java/ObjectTest.java | 19 ++ .../test/org/tianbin/java/SwitchCaseTest.java | 28 +++ .../CommonBeanUtilTest.java" | 24 +- ...\350\203\275\346\265\213\350\257\225.java" | 125 ++++++++++ .../java/\345\217\215\345\260\204/README.md" | 0 .../ListStreamTest.java" | 47 ++++ .../\351\233\206\345\220\210/ListTest.java" | 1 - 37 files changed, 1411 insertions(+), 109 deletions(-) create mode 100644 src/main/java/common/bo/compare/CompareBO.java create mode 100644 src/main/java/common/bo/compare/CompareResultDTO.java delete mode 100644 src/main/java/common/util/CompareUtil.java create mode 100644 src/main/java/common/util/compare/CompareUtil.java create mode 100644 src/main/java/common/util/compare/JacksonUtils.java create mode 100644 src/main/java/common/util/compare/JsonUtils.java create mode 100644 "src/main/java/org/tianbin/java/\345\237\272\346\234\254\346\225\260\346\215\256\347\261\273\345\236\213/DoubleTest.java" create mode 100644 "src/main/java/org/tianbin/java/\345\237\272\346\234\254\346\225\260\346\215\256\347\261\273\345\236\213/IntegerTest.java" create mode 100644 "src/main/java/org/tianbin/java/\345\271\266\345\217\221/threadpool/b2_CompletableFutureDemo2.java" rename "src/main/java/org/tianbin/java/\351\233\206\345\220\210/List.java" => "src/main/java/org/tianbin/java/\351\233\206\345\220\210/List\347\261\273.java" (95%) rename "src/main/java/org/tianbin/java/\351\233\206\345\220\210/Map.java" => "src/main/java/org/tianbin/java/\351\233\206\345\220\210/Map\347\261\273.java" (96%) create mode 100644 src/main/test/common/util/DateTimeUtilTest.java rename src/main/test/org/tianbin/{temp => excel}/ExcelGen.java (98%) create mode 100644 src/main/test/org/tianbin/excel/ExcelRead.java create mode 100644 src/main/test/org/tianbin/java/ObjectTest.java create mode 100644 src/main/test/org/tianbin/java/SwitchCaseTest.java create mode 100644 "src/main/test/org/tianbin/java/\345\217\215\345\260\204/CopyProperties_\346\200\247\350\203\275\346\265\213\350\257\225.java" create mode 100644 "src/main/test/org/tianbin/java/\345\217\215\345\260\204/README.md" create mode 100644 "src/main/test/org/tianbin/java/\351\233\206\345\220\210/ListStreamTest.java" diff --git a/pom.xml b/pom.xml index 05b2c08b..b69e97fd 100644 --- a/pom.xml +++ b/pom.xml @@ -20,6 +20,11 @@ + + cn.hutool + hutool-all + 5.4.5 + io.github.biezhi @@ -128,6 +133,22 @@ compile + + com.json.comparison + comparison-core + 1.2 + + + com.fasterxml.jackson.core + jackson-core + 2.11.2 + + + com.fasterxml.jackson.core + jackson-databind + 2.11.2 + + diff --git "a/src/main/java/algorithm_practice/LeetCode/code000/M092_\345\217\215\350\275\254\351\223\276\350\241\2502.java" "b/src/main/java/algorithm_practice/LeetCode/code000/M092_\345\217\215\350\275\254\351\223\276\350\241\2502.java" index 3f9c3794..9b508125 100644 --- "a/src/main/java/algorithm_practice/LeetCode/code000/M092_\345\217\215\350\275\254\351\223\276\350\241\2502.java" +++ "b/src/main/java/algorithm_practice/LeetCode/code000/M092_\345\217\215\350\275\254\351\223\276\350\241\2502.java" @@ -1,7 +1,7 @@ package algorithm_practice.LeetCode.code000; import common.datastruct.ListNode; -import common.util.CompareUtil; +import common.util.compare.CompareUtil; import common.util.ConstructListNode; import common.util.SysOut; import org.junit.Assert; diff --git "a/src/main/java/algorithm_practice/LeetCode/code100/M147_\345\257\271\351\223\276\350\241\250\350\277\233\350\241\214\346\217\222\345\205\245\346\216\222\345\272\217.java" "b/src/main/java/algorithm_practice/LeetCode/code100/M147_\345\257\271\351\223\276\350\241\250\350\277\233\350\241\214\346\217\222\345\205\245\346\216\222\345\272\217.java" index 824370cd..5ffe8174 100644 --- "a/src/main/java/algorithm_practice/LeetCode/code100/M147_\345\257\271\351\223\276\350\241\250\350\277\233\350\241\214\346\217\222\345\205\245\346\216\222\345\272\217.java" +++ "b/src/main/java/algorithm_practice/LeetCode/code100/M147_\345\257\271\351\223\276\350\241\250\350\277\233\350\241\214\346\217\222\345\205\245\346\216\222\345\272\217.java" @@ -1,7 +1,7 @@ package algorithm_practice.LeetCode.code100; import common.datastruct.ListNode; -import common.util.CompareUtil; +import common.util.compare.CompareUtil; import common.util.ConstructListNode; import common.util.SysOut; import org.junit.Assert; diff --git "a/src/main/java/algorithm_practice/LeetCode/code100/M148_\346\216\222\345\272\217\351\223\276\350\241\250.java" "b/src/main/java/algorithm_practice/LeetCode/code100/M148_\346\216\222\345\272\217\351\223\276\350\241\250.java" index 9ffa6b9e..3ade1f19 100644 --- "a/src/main/java/algorithm_practice/LeetCode/code100/M148_\346\216\222\345\272\217\351\223\276\350\241\250.java" +++ "b/src/main/java/algorithm_practice/LeetCode/code100/M148_\346\216\222\345\272\217\351\223\276\350\241\250.java" @@ -1,7 +1,7 @@ package algorithm_practice.LeetCode.code100; import common.datastruct.ListNode; -import common.util.CompareUtil; +import common.util.compare.CompareUtil; import common.util.ConstructListNode; import common.util.SysOut; import org.junit.Assert; diff --git "a/src/main/java/algorithm_practice/LeetCode/code200/E206_\345\217\215\350\275\254\351\223\276\350\241\250.java" "b/src/main/java/algorithm_practice/LeetCode/code200/E206_\345\217\215\350\275\254\351\223\276\350\241\250.java" index 2580b991..c7b3a761 100644 --- "a/src/main/java/algorithm_practice/LeetCode/code200/E206_\345\217\215\350\275\254\351\223\276\350\241\250.java" +++ "b/src/main/java/algorithm_practice/LeetCode/code200/E206_\345\217\215\350\275\254\351\223\276\350\241\250.java" @@ -1,7 +1,7 @@ package algorithm_practice.LeetCode.code200; import common.datastruct.ListNode; -import common.util.CompareUtil; +import common.util.compare.CompareUtil; import common.util.ConstructListNode; import common.util.SysOut; import org.junit.Assert; diff --git "a/src/main/java/algorithm_practice/LeetCode/code300/M328_\345\245\207\345\201\266\351\223\276\350\241\250.java" "b/src/main/java/algorithm_practice/LeetCode/code300/M328_\345\245\207\345\201\266\351\223\276\350\241\250.java" index b87313cc..a69f20ca 100644 --- "a/src/main/java/algorithm_practice/LeetCode/code300/M328_\345\245\207\345\201\266\351\223\276\350\241\250.java" +++ "b/src/main/java/algorithm_practice/LeetCode/code300/M328_\345\245\207\345\201\266\351\223\276\350\241\250.java" @@ -1,7 +1,7 @@ package algorithm_practice.LeetCode.code300; import common.datastruct.ListNode; -import common.util.CompareUtil; +import common.util.compare.CompareUtil; import common.util.ConstructListNode; import common.util.SysOut; import org.junit.Assert; diff --git a/src/main/java/common/bo/compare/CompareBO.java b/src/main/java/common/bo/compare/CompareBO.java new file mode 100644 index 00000000..4b7d7160 --- /dev/null +++ b/src/main/java/common/bo/compare/CompareBO.java @@ -0,0 +1,56 @@ +package common.bo.compare; + +import lombok.AllArgsConstructor; +import lombok.Data; + +import java.util.Collections; +import java.util.HashSet; +import java.util.LinkedHashSet; +import java.util.Set; + +/** + * Created by nibnait on 2021/06/23 + */ +@Data +public class CompareBO { + + /** + * 当前对比的字段 + */ + private String currentField; + + /** + * 排除字段 + */ + private Set excludeFields = new HashSet<>(); + + /** + * 聚焦字段 + */ + private Set focusFields = new HashSet<>(); + + /** + * 系统默认优化项: pageInfo + */ + private Set optimizations = new LinkedHashSet<>(Collections.singletonList(OptimizationType.IGNORE_NEW_FIELDS)); + + @AllArgsConstructor + public enum OptimizationType { + /** + * 优化类型 + */ + PAGE_HELPER("pageHelper 分页插件"), + IGNORE_NEW_FIELDS("比对时忽略新增字段"), + IGNORE_MISSING_FIELDS("比对时忽略丢失字段"), + ; + + String desc; + } + + public static CompareBO newNoOptimizeCompareBO() { + CompareBO compareBO = new CompareBO(); + compareBO.setOptimizations(new LinkedHashSet<>()); + return compareBO; + } + +} diff --git a/src/main/java/common/bo/compare/CompareResultDTO.java b/src/main/java/common/bo/compare/CompareResultDTO.java new file mode 100644 index 00000000..768c685e --- /dev/null +++ b/src/main/java/common/bo/compare/CompareResultDTO.java @@ -0,0 +1,37 @@ +package common.bo.compare; + +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.util.List; + +/** + * Created by nibnait on 2021/06/23 + */ +@Data +@NoArgsConstructor +public class CompareResultDTO { + + private boolean isMatch; + + private List modifiedFields; + + private List missingFields; + + private List newFields; + + private String message; + + @Data + public static class FieldComparison { + private String field; + + private Object expected; + + private Object actual; + } + + public CompareResultDTO(boolean isMatch) { + this.isMatch = isMatch; + } +} diff --git a/src/main/java/common/model/Person.java b/src/main/java/common/model/Person.java index 057b5c4a..f784f512 100644 --- a/src/main/java/common/model/Person.java +++ b/src/main/java/common/model/Person.java @@ -17,6 +17,15 @@ public class Person { private String name; private Integer age; + private Byte gender; + private String phone; + private Boolean isBigBoolean; + private boolean isSmallBoolean; + + public Person(String name, Integer age) { + this.name = name; + this.age = age; + } @Override public boolean equals(Object o) { diff --git a/src/main/java/common/model/PersonDTO.java b/src/main/java/common/model/PersonDTO.java index 3aa4109a..3376e85a 100644 --- a/src/main/java/common/model/PersonDTO.java +++ b/src/main/java/common/model/PersonDTO.java @@ -11,5 +11,8 @@ public class PersonDTO { private String name; private Integer age; - + private Byte gender; + private String phone; + private Boolean isBigBoolean; + private boolean isSmallBoolean; } \ No newline at end of file diff --git a/src/main/java/common/util/CommonBeanUtil.java b/src/main/java/common/util/CommonBeanUtil.java index f7a82fa5..8881ddc1 100644 --- a/src/main/java/common/util/CommonBeanUtil.java +++ b/src/main/java/common/util/CommonBeanUtil.java @@ -1,6 +1,7 @@ package common.util; import com.esotericsoftware.reflectasm.MethodAccess; +import net.sf.cglib.beans.BeanCopier; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; @@ -16,7 +17,48 @@ */ public class CommonBeanUtil extends BeanUtils { + public static T copyProperties_BeanCopier(F source, Supplier targetSupplier) { + T target = targetSupplier.get(); + + BeanCopier copier = BeanCopier.create(source.getClass(), target.getClass(), false); + copier.copy(source, target, null); + + return target; + } + + public static T copyProperties_BeanUtils(F source, Supplier targetSupplier) { + T target = targetSupplier.get(); + + BeanUtils.copyProperties(source, target); + + return target; + } + + public static T copyProperties_fieldGetSet(F source, Supplier targetSupplier) { + T target = targetSupplier.get(); + + if (source == null) { + return null; + } + Field[] fromDeclaredFields = source.getClass().getDeclaredFields(); + + for (Field field : fromDeclaredFields) { + try { + field.setAccessible(true); + + Object value = field.get(source); + field.set(target, value); + } catch (Exception e) { + // source 中未设置 get 方法的字段，会直接跳过 + // target 中没有 source 中的字段，也会直接跳过 + } + } + + return target; + } + private static final ConcurrentMap localCache = new ConcurrentHashMap<>(); + private static final ConcurrentMap localCacheFields = new ConcurrentHashMap<>(); public static MethodAccess get(Class clazz) { if (localCache.containsKey(clazz)) { @@ -28,7 +70,17 @@ public static MethodAccess get(Class clazz) { return methodAccess; } - public static T copyProperties(S source, Supplier targetSupplier) { + public static Field[] getFields(Class clazz) { + if (localCacheFields.containsKey(clazz)) { + return localCacheFields.get(clazz); + } + + Field[] declaredFields = clazz.getDeclaredFields(); + localCacheFields.putIfAbsent(clazz, declaredFields); + return declaredFields; + } + + public static T copyProperties_methodInvoke(S source, Supplier targetSupplier) { T target = targetSupplier.get(); if (source == null) { return target; @@ -38,9 +90,32 @@ public static T copyProperties(S source, Supplier targetSupplier) { MethodAccess targetMethodAccess = get(target.getClass()); Field[] declaredFields = source.getClass().getDeclaredFields(); for (Field field : declaredFields) { - String name = field.getName(); - Object value = sourceMethodAccess.invoke(source, "get" + StringUtils.capitalize(name), null); try { + String name = field.getName(); + Object value = sourceMethodAccess.invoke(source, "get" + StringUtils.capitalize(name), null); + targetMethodAccess.invoke(target, "set" + StringUtils.capitalize(name), value); + } catch (Exception e) { + // source 中未设置 get 方法的字段，会直接跳过 + // target 中没有 source 中的字段，也会直接跳过 + } + } + + return target; + } + + public static T copyProperties_methodInvoke_V2(S source, Supplier targetSupplier) { + T target = targetSupplier.get(); + if (source == null) { + return target; + } + + MethodAccess sourceMethodAccess = get(source.getClass()); + MethodAccess targetMethodAccess = get(target.getClass()); + Field[] declaredFields = getFields(source.getClass()); + for (Field field : declaredFields) { + try { + String name = field.getName(); + Object value = sourceMethodAccess.invoke(source, "get" + StringUtils.capitalize(name), null); targetMethodAccess.invoke(target, "set" + StringUtils.capitalize(name), value); } catch (Exception e) { // source 中未设置 get 方法的字段，会直接跳过 @@ -54,7 +129,7 @@ public static T copyProperties(S source, Supplier targetSupplier) { public static List copyListProperties(List sources, Supplier targetSupplier) { List list = new ArrayList<>(sources.size()); for (S source : sources) { - T target = copyProperties(source, targetSupplier); + T target = copyProperties_methodInvoke(source, targetSupplier); list.add(target); } return list; diff --git a/src/main/java/common/util/CompareUtil.java b/src/main/java/common/util/CompareUtil.java deleted file mode 100644 index 4e0c0c3b..00000000 --- a/src/main/java/common/util/CompareUtil.java +++ /dev/null @@ -1,18 +0,0 @@ -package common.util; - -import common.datastruct.ListNode; - -/** - * Created by nibnait on 2020/11/20 - */ -public class CompareUtil { - - public static boolean compareListNode(ListNode left, ListNode right) { - while (left != null && right != null && left.val == right.val) { - left = left.next; - right = right.next; - } - return left == right; - } - -} diff --git a/src/main/java/common/util/DateTimeUtil.java b/src/main/java/common/util/DateTimeUtil.java index e10073df..e007da4d 100644 --- a/src/main/java/common/util/DateTimeUtil.java +++ b/src/main/java/common/util/DateTimeUtil.java @@ -1,6 +1,10 @@ package common.util; +import com.alibaba.fastjson.JSON; +import com.google.common.collect.Lists; +import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.lang3.StringUtils; +import org.apache.commons.lang3.math.NumberUtils; import java.text.DateFormat; import java.text.ParseException; @@ -8,6 +12,7 @@ import java.time.*; import java.time.format.DateTimeFormatter; import java.util.Date; +import java.util.List; public class DateTimeUtil { @@ -108,9 +113,9 @@ public static String localDateTimeToString(LocalDateTime localDateTime, String d } /** - * Date - * LocalDate ==> java.util.Date - * LocalDateTime ( Date.from(ZonedDateTime.toInstant) ) + * Date + * LocalDate ==> java.util.Date + * LocalDateTime ( Date.from(ZonedDateTime.toInstant) ) */ public static Date toUtilDate(Object date) { if (date == null) { @@ -140,8 +145,8 @@ public static Date toUtilDate(Object date) { /** * Date ==> LocalDate - * .toIns - * (ZonedDateTime) + * .toIns + * (ZonedDateTime) */ public static LocalDate dateToLocalDate(Date date) { ZonedDateTime zonedDateTime = date.toInstant().atZone(defaultZoneId); @@ -150,14 +155,13 @@ public static LocalDate dateToLocalDate(Date date) { /** * Date ==> LocalDateTime - * (ZonedDateTime) + * (ZonedDateTime) */ public static LocalDateTime dateToLocalDateTime(Date date) { ZonedDateTime zonedDateTime = date.toInstant().atZone(defaultZoneId); return zonedDateTime.toLocalDateTime(); } - public static final String LONG_TIME_VALID = "长期有效"; /** * 获取当前时间戳 */ @@ -165,24 +169,41 @@ public static Long getTimeInMillis() { return System.currentTimeMillis(); } + /** + * LocalDateTime ==> 秒timestamp + */ + public static Long LocalDateTimeToSecond() { + return LocalDateTime.now().toEpochSecond(ZoneOffset.of("+8")); + } + + /** + * LocalDateTime ==> 毫秒timestamp + */ + public static Long LocalDateTimeToMillSecond() { + return LocalDateTime.now().toInstant(ZoneOffset.of("+8")).toEpochMilli(); + } + + public static final String LONG_TIME_VALID = "长期有效"; + /** * 判断是否在有效期内 + * * @param expireDate * @return */ public static boolean isValidDate(String expireDate) { - if(StringUtils.isBlank(expireDate)){ + if (StringUtils.isBlank(expireDate)) { return false; } - if(LONG_TIME_VALID.equals(expireDate)){ + if (LONG_TIME_VALID.equals(expireDate)) { return true; } - try{ + try { LocalDate expireLocalDate = DateTimeUtil.string2Date(expireDate); - if(LocalDate.now().compareTo(expireLocalDate) < 0){ + if (LocalDate.now().compareTo(expireLocalDate) < 0) { return true; } - }catch (Exception e){ + } catch (Exception e) { return false; } return false; @@ -190,6 +211,7 @@ public static boolean isValidDate(String expireDate) { /** * 比较两个日期相差多少天 + * * @param startTime * @param endTime * @return @@ -198,8 +220,83 @@ public static Long durationDays(LocalDateTime startTime, LocalDateTime endTime) return Duration.between(startTime, endTime).toDays(); } + public static Long durationMillis(LocalDateTime startTime, LocalDateTime endTime) { + return Duration.between(startTime, endTime).toMillis(); + } + + /** + * 校验时期合法性 + */ + public static boolean isDateValid(List date) { + boolean isvalid = true; + if (CollectionUtils.isEmpty(date)) { + return false; + } + + try { + if (date.size() == 1) { + return NumberUtils.isParsable(date.get(0)); + } + if (date.size() == 2) { + LocalDate.of(Integer.parseInt(date.get(0)), Integer.parseInt(date.get(1)), 1); + } + if (date.size() == 3) { + if (NumberUtils.isParsable(date.get(2))) { + LocalDate.of(Integer.parseInt(date.get(0)), Integer.parseInt(date.get(1)), Integer.parseInt(date.get(2))); + } else { + LocalDate.of(Integer.parseInt(date.get(0)), Integer.parseInt(date.get(1)), 1); + if (!Lists.newArrayList("上旬", "中上旬", "中旬", "中下旬", "下旬").contains(date.get(2))) { + isvalid = false; + } + } + } + if (date.size() > 3) { + isvalid = false; + } + } catch (Exception e) { + isvalid = false; + } + return isvalid; + } + public static void main(String[] args) { - String s = localDateTimeToString(LocalDateTime.now(), TIME_MILLISECOND_FORMAT); - System.out.println(s); + List date = Lists.newArrayList("2020", "02", "29"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2021", "02", "29"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2022", "02", "29"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2023", "02", "29"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2019", "02", "29"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2024", "02", "29"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2024", "04", "31"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2024", "05", "31"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2020", "02"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2020"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2020", "02", "上旬"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2020", "02", "xx"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); + + date = Lists.newArrayList("2020", "02", "中旬", "lj"); + System.out.println(isDateValid(date) + "\t" + JSON.toJSONString(date)); } } diff --git a/src/main/java/common/util/compare/CompareUtil.java b/src/main/java/common/util/compare/CompareUtil.java new file mode 100644 index 00000000..129bea67 --- /dev/null +++ b/src/main/java/common/util/compare/CompareUtil.java @@ -0,0 +1,40 @@ +package common.util.compare; + +import com.alibaba.fastjson.JSON; +import com.google.common.collect.Sets; +import common.bo.compare.CompareBO; +import common.bo.compare.CompareResultDTO; +import common.datastruct.ListNode; +import lombok.extern.slf4j.Slf4j; + +import java.util.Set; + +/** + * Created by nibnait on 2020/11/20 + */ +@Slf4j +public class CompareUtil { + + public static boolean compareListNode(ListNode left, ListNode right) { + while (left != null && right != null && left.val == right.val) { + left = left.next; + right = right.next; + } + return left == right; + } + + public static boolean match(T actual, T expect) { + return match(actual, expect, Sets.newHashSet()); + } + + public static boolean match(T actual, T expect, Set excludeFields) { + CompareBO compareBO = CompareBO.newNoOptimizeCompareBO(); + compareBO.setExcludeFields(excludeFields); + + CompareResultDTO compareResultDTO = JsonUtils.diffStr(JSON.toJSONString(actual), JSON.toJSONString(expect), compareBO); + if (!compareResultDTO.isMatch()) { + log.info("差异字段: {}", JSON.toJSONString(compareResultDTO)); + } + return compareResultDTO.isMatch(); + } +} diff --git a/src/main/java/common/util/compare/JacksonUtils.java b/src/main/java/common/util/compare/JacksonUtils.java new file mode 100644 index 00000000..af9bb61c --- /dev/null +++ b/src/main/java/common/util/compare/JacksonUtils.java @@ -0,0 +1,219 @@ +package common.util.compare; + +import com.alibaba.fastjson.JSON; +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.node.ArrayNode; +import com.fasterxml.jackson.databind.node.ObjectNode; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; + +import java.math.BigDecimal; +import java.text.SimpleDateFormat; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.List; + +@Slf4j +public class JacksonUtils { + + private static final ObjectMapper MAPPER = new ObjectMapper(); + private static final String SEPARATOR = ":"; + public static final String ARRAY_SIGN = "*"; + public static final String MINUS_SIGN = "\"-\""; + public static final String ARRAY_SIGN_REPLACE = "#"; + public static final String PLACEHOLDER_SIGN = "{}"; + private static final String BLANK_REPLACE = " "; + private static final String EMPTY = ""; + + static { + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + MAPPER.setDateFormat(dateFormat); + MAPPER.setSerializationInclusion(JsonInclude.Include.NON_NULL); + } + + public static String replace(String json, String path, Object value) { + if (StringUtils.isBlank(path)) { + return json; + } + // 使用 # 替换, 否则会因为正则导致替换失败 + path = path.replace(ARRAY_SIGN, ARRAY_SIGN_REPLACE); + // 判断是否多级路径 + int lastNodeIndex = path.lastIndexOf(SEPARATOR); + if (lastNodeIndex == -1) { + return replaceField(json, path, path, value); + } + // 判断是否需要循环解析 + if (!path.contains(ARRAY_SIGN_REPLACE)) { + return replaceField(json, path, path.substring(lastNodeIndex + 1), value); + } + // 需要循环解析, 递归 + String prePath = path.substring(0, getArraySignIndex(path)); + String prePathValue = focus(json, prePath); + JsonNode prePathJsonNode = json2Node(prePathValue); + for (int i = 0; i < prePathJsonNode.size(); i++) { + json = replace(json, path.replaceFirst(ARRAY_SIGN_REPLACE, i + ""), value); + } + return json; + } + + private static int getArraySignIndex(String path) { + return path.indexOf(ARRAY_SIGN_REPLACE) == 0 ? 0 : path.indexOf(ARRAY_SIGN_REPLACE) - 1; + } + + public static String focus(String json, String path) { + if (StringUtils.isBlank(path)) { + return json; + } + // 使用 # 替换, 否则会因为正则导致替换失败 + path = path.replace(ARRAY_SIGN, ARRAY_SIGN_REPLACE); + // 判断是否多级路径 + int lastNodeIndex = path.lastIndexOf(SEPARATOR); + if (lastNodeIndex == -1) { + return focusField(json, path); + } + // 判断是否需要循环解析 + if (!path.contains(ARRAY_SIGN_REPLACE)) { + return focusField(json, path); + } + // 需要循环解析, 递归 + List