utils

1. 项目目标

2. 工具使用示例

超大文本极速读取工具类

功能(使用说明)

public static void main(String[] args) {
 AtomicLong counter = new AtomicLong(0);
 String bigFilePath = "/Users/renhongqiang/Downloads/work-doc/2000W/test.csv";
 BigFileReader.Builder builder = new BigFileReader.Builder(bigFilePath, line -> System.out.println(String.format("total record: %s,line is: %s", counter.incrementAndGet(), line)));
 BigFileReader bigFileReader = builder
 .threadPoolSize(100)
 .charset(StandardCharsets.UTF_8)
 .bufferSize(1024 * 1024).build();
 bigFileReader.start();
}

校验工具类使用说明

日期工具类使用说明

获取当天零点

Date today = Dates.today();

将日期类型格式化为字符串

Date date = Dates.addDays(custDate, 32);
String format = Dates.format(date);

将字符串类型parse为日期类型

Date custDate = Dates.parse("2020-04-23 25", Dates.DATE_FORMAT);

对日期时间的各类操作

Date date = Dates.addDays(custDate, 32);
Date addM = Dates.addMinutes(date,5);

拓展集合使用说明

list转map

Order order = new Order("Carli","12112");
Order order2 = new Order("Michale","11223");
Order order3 = new Order("Marry","642321");
List<Order> list = new ArrayList<>();
list.add(order);
list.add(order2);
list.add(order3);
Map<String, Order> kvFieldBean = ExtCollections.kvFieldBean(Order::getOwner, list);

list中key相同合并操作

Order order = new Order("Carli","12112");
Order order2 = new Order("Carli","11223");
Order order3 = new Order("Marry","642321");
List<Order> list = new ArrayList<>();
list.add(order);
list.add(order2);
list.add(order3);
Map<String, List<Order>> kvFieldBeans = ExtCollections.kvFieldBeans(Order::getOwner, list);
System.out.println(kvFieldBeans);

list中任选k,v字段,重组为map

Order order = new Order("Carli","12112");
Order order2 = new Order("Carli","11223");
Order order3 = new Order("Marry","642321");
List<Order> list = new ArrayList<>();
list.add(order);
list.add(order2);
list.add(order3);
Map<String, String> map = ExtCollections.kv(Order::getId, Order::getOwner, list);

身份证工具类说明

有效身份证号自动生成

@Test
public void testGenerate() {
 System.out.println(IdCards.generate());
 System.out.println(IdCards.generateByAreaName("东城区"));
}

年龄提取

IdCards.parseAge("420102199401015244")

出生年月提取

IdCards.parseBirthday("420102199401015244")

身份证合法性校验

boolean checkCardId = IdCards.checkCardId("420102199401015244");

15到18位身份证转换

String idCard = IdCards.trans15To18("420102199401015")

日志格式化工具说明

敏感或超长字符串截断

@Test
 public void testHide() {
 Person person = new Person();
 System.out.println(LogFormats.formatLog(person));
 }
 @Data
 public static class Person {
 @HideImg
 private String img = "/9jhfsdhajfksjdfhuhiuwbjbdfoasuhrttttttthhhhhhhhhhhhhhhhhhdfuf";
 @HideAnn
 private String password = "128397287827802hhfashfkjhasfh";
 @HideCollection
 private List<String> cellphones = new ArrayList<>();
 }

敏感信息直接置为******

敏感字段集合直接过滤

随机工具类说明

指定概率命中

@Test
public void testHit() {
 int count = 1;
 for (int i = 0; i < 1000000; i++) {
 boolean hit = Randoms.isScoreAHit(1, 1000);
 if (hit) {
 System.out.println(count++);
 }
 }
}

随机生成指定长度数字、字符串或数字字符串混合

@Test
public void testRandomNumOrA() {
 for (int i = 0; i < 10; i++) {
 //指定5-8位长度字符串
 System.out.println(Randoms.randomOfA(5, 8));
 //指定4-7位长度数字
 System.out.println(Randoms.randomOfD(4,7));
 //指定4个长度的数字和字母混合字符串
 System.out.println(Randoms.randomOfDA(4));
 }
}

生成8-16位含数字、小写和大写字母的随机密码,有校验

@Test
public void testRandomRegStr() {
 System.out.println(Randoms.checkAndGetResultString());
}

字符串工具类说明

下划线变驼峰(LineToHump)

@Test
public void testLineToHump() {
 String authUser = "auth_user";
 System.out.println(Strings.lineToHump(authUser));
}

驼峰变下划线(HumpToLine)

@Test
public void testHumpToLine() {
 String authUser = "authUser";
 System.out.println(Strings.humpToLine(authUser));
}

截取字符串(Cut string)

@Test
public void testSubString() {
 String demoString = "demo_string_123";
 System.out.println(Strings.substring(demoString,1,3));
}

速率监控工具说明

初始化一个监控工具

ProgressListener downProgress = new ProgressListener("下载计数器", datas.size())

添加统计维度

picProgress.addCount("下载成功数");
picProgress.addCount("下载失败数");

开启统计

picProgress.startLog();

说明

过期map使用说明

过期map

ExpireMap<String, String> map = new ExpireMap<>(1, 10);
map.put("aaa", "test", 3, TimeUnit.SECONDS);

基于Redis滑动窗口限流组件

 import common.utils.ratelimiter.SlidingWindow;
 import org.springframework.beans.factory.annotation.Autowired;
 @Autowired
 SlidingWindow slidingWindow;
 String key = "";
 slidingWindow.isActionAllowed(key,60L,10);

3. 安装使用

 <dependency>
 <groupId>common</groupId>
 <artifactId>utils</artifactId>
 <version>1.0-SNAPSHOT</version>
 </dependency>