mirror of
https://gitee.com/chinabugotech/hutool.git
synced 2025-12-06 09:09:10 +08:00
Compare commits
14 Commits
eb0c039c05
...
d2485f7612
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d2485f7612 | ||
|
|
b3d17e70ae | ||
|
|
c34bdaf776 | ||
|
|
6088516bf2 | ||
|
|
7393f66d06 | ||
|
|
4d4bf08fc1 | ||
|
|
28502528f5 | ||
|
|
bdbe51fe31 | ||
|
|
da8971a352 | ||
|
|
d2d4f8499b | ||
|
|
2db66af020 | ||
|
|
efee8a14b0 | ||
|
|
6ad6a8022e | ||
|
|
a31e3ff096 |
288
hutool-core/src/main/java/cn/hutool/v7/core/cache/impl/SieveCache.java
vendored
Normal file
288
hutool-core/src/main/java/cn/hutool/v7/core/cache/impl/SieveCache.java
vendored
Normal file
@ -0,0 +1,288 @@
|
||||
/*
|
||||
* Copyright (c) 2013-2025 Hutool Team and hutool.cn
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package cn.hutool.v7.core.cache.impl;
|
||||
|
||||
import cn.hutool.v7.core.lang.mutable.Mutable;
|
||||
import cn.hutool.v7.core.lang.mutable.MutableObj;
|
||||
|
||||
import java.io.Serial;
|
||||
import java.util.HashMap;
|
||||
import java.util.Iterator;
|
||||
import java.util.concurrent.locks.ReentrantLock;
|
||||
|
||||
/**
|
||||
* SIEVE 缓存算法实现<br>
|
||||
* <p>
|
||||
* SIEVE 是一种比 LRU 更简单且通常更高效的缓存算法。<br>
|
||||
* 核心特性:<br>
|
||||
* 缓存命中时,仅将节点的 {@code visited} 标记设为 true,不移动节点位置。<br>
|
||||
* 淘汰时,使用 {@code hand} 指针从尾部扫描,淘汰 {@code visited=false} 的节点。<br>
|
||||
* 新加入节点 {@code visited = false} 且置于头部,Hand 指针扫描时会优先淘汰它,提供抗扫描能力。<br>
|
||||
* </p>
|
||||
* 来自:<a href="https://github.com/chinabugotech/hutool/pull/4157">pr#4157@Github</a>
|
||||
*
|
||||
* @param <K> 键类型
|
||||
* @param <V> 值类型
|
||||
* @author Lettuceleaves
|
||||
*/
|
||||
public class SieveCache<K, V> extends LockedCache<K, V> {
|
||||
@Serial
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
/**
|
||||
* 双向链表头节点
|
||||
*/
|
||||
private SieveCacheObj<K, V> head;
|
||||
/**
|
||||
* 双向链表尾节点
|
||||
*/
|
||||
private SieveCacheObj<K, V> tail;
|
||||
/**
|
||||
* 下一次扫描的起始位置
|
||||
*/
|
||||
private SieveCacheObj<K, V> hand;
|
||||
|
||||
/**
|
||||
* 构造<br>
|
||||
* 默认无超时
|
||||
*
|
||||
* @param capacity 容量
|
||||
*/
|
||||
public SieveCache(final int capacity) {
|
||||
this(capacity, 0);
|
||||
}
|
||||
|
||||
/**
|
||||
* 构造
|
||||
*
|
||||
* @param capacity 容量
|
||||
* @param timeout 默认超时时间,单位:毫秒
|
||||
*/
|
||||
public SieveCache(int capacity, final long timeout) {
|
||||
if (Integer.MAX_VALUE == capacity) {
|
||||
capacity -= 1;
|
||||
}
|
||||
|
||||
this.capacity = capacity;
|
||||
this.timeout = timeout;
|
||||
|
||||
// 这里的设置 capacity + 1, 1.0f 避免触发扩容
|
||||
this.cacheMap = new HashMap<>(capacity + 1, 1.0f);
|
||||
this.lock = new ReentrantLock();
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void putWithoutLock(final K key, final V object, final long timeout) {
|
||||
final Mutable<K> keyObj = MutableObj.of(key);
|
||||
SieveCacheObj<K, V> co = (SieveCacheObj<K, V>) cacheMap.get(keyObj);
|
||||
|
||||
if (co != null) {
|
||||
final SieveCacheObj<K, V> newCo = new SieveCacheObj<>(key, object, timeout);
|
||||
|
||||
// 新加入的节点,默认刚访问过,防止立刻被淘汰
|
||||
newCo.visited = true;
|
||||
|
||||
// 替换旧节点
|
||||
replaceNode(co, newCo);
|
||||
cacheMap.put(keyObj, newCo);
|
||||
} else {
|
||||
co = new SieveCacheObj<>(key, object, timeout);
|
||||
cacheMap.put(keyObj, co);
|
||||
addToHead(co);
|
||||
co.visited = false;
|
||||
|
||||
if (cacheMap.size() > capacity) {
|
||||
pruneCache();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 在双向链表中用 newNode 替换 oldNode,保持链表结构不变
|
||||
*
|
||||
* @param oldNode 旧节点
|
||||
* @param newNode 新节点
|
||||
*/
|
||||
private void replaceNode(final SieveCacheObj<K, V> oldNode, final SieveCacheObj<K, V> newNode) {
|
||||
newNode.prev = oldNode.prev;
|
||||
newNode.next = oldNode.next;
|
||||
|
||||
// 更新前向指针
|
||||
if (oldNode.prev != null) {
|
||||
oldNode.prev.next = newNode;
|
||||
} else {
|
||||
head = newNode;
|
||||
}
|
||||
|
||||
// 更新后向指针
|
||||
if (oldNode.next != null) {
|
||||
oldNode.next.prev = newNode;
|
||||
} else {
|
||||
tail = newNode;
|
||||
}
|
||||
|
||||
// 将hand转移至新节点,防止扫描时淘汰热点数据
|
||||
if (hand == oldNode) {
|
||||
hand = newNode;
|
||||
}
|
||||
|
||||
oldNode.prev = null;
|
||||
oldNode.next = null;
|
||||
}
|
||||
|
||||
@Override
|
||||
protected CacheObj<K, V> getOrRemoveExpiredWithoutLock(final K key) {
|
||||
final Mutable<K> keyObj = MutableObj.of(key);
|
||||
final SieveCacheObj<K, V> co = (SieveCacheObj<K, V>) cacheMap.get(keyObj);
|
||||
|
||||
if (null != co) {
|
||||
if (co.isExpired()) {
|
||||
removeWithoutLock(key);
|
||||
return null;
|
||||
}
|
||||
co.visited = true;
|
||||
co.lastAccess = System.currentTimeMillis();
|
||||
}
|
||||
return co;
|
||||
}
|
||||
|
||||
@Override
|
||||
protected CacheObj<K, V> removeWithoutLock(final K key) {
|
||||
final Mutable<K> keyObj = MutableObj.of(key);
|
||||
final SieveCacheObj<K, V> co = (SieveCacheObj<K, V>) cacheMap.remove(keyObj);
|
||||
if (co != null) {
|
||||
removeNode(co);
|
||||
}
|
||||
return co;
|
||||
}
|
||||
|
||||
/**
|
||||
* 优先清理过期对象,如果容量仍溢出,反向扫描visited为false的节点,设置true节点为false
|
||||
*/
|
||||
@Override
|
||||
protected int pruneCache() {
|
||||
int count = 0;
|
||||
|
||||
if (isPruneExpiredActive()) {
|
||||
final Iterator<CacheObj<K, V>> values = cacheObjIter();
|
||||
CacheObj<K, V> co;
|
||||
while (values.hasNext()) {
|
||||
co = values.next();
|
||||
if (co.isExpired()) {
|
||||
values.remove();
|
||||
removeNode((SieveCacheObj<K, V>) co);
|
||||
onRemove(co.key, co.obj);
|
||||
count++;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (cacheMap.size() > capacity) {
|
||||
if (hand == null) {
|
||||
hand = tail;
|
||||
}
|
||||
|
||||
while (cacheMap.size() > capacity) {
|
||||
if (hand == null) {
|
||||
hand = tail;
|
||||
}
|
||||
|
||||
if (!hand.visited) {
|
||||
final SieveCacheObj<K, V> victim = hand;
|
||||
hand = hand.prev;
|
||||
|
||||
final Mutable<K> keyObj = MutableObj.of(victim.key);
|
||||
cacheMap.remove(keyObj);
|
||||
removeNode(victim);
|
||||
onRemove(victim.key, victim.obj);
|
||||
count++;
|
||||
} else {
|
||||
hand.visited = false;
|
||||
hand = hand.prev;
|
||||
}
|
||||
}
|
||||
}
|
||||
return count;
|
||||
}
|
||||
|
||||
/**
|
||||
* 将节点加入链表头部
|
||||
*
|
||||
* @param node 节点
|
||||
*/
|
||||
private void addToHead(final SieveCacheObj<K, V> node) {
|
||||
node.next = head;
|
||||
node.prev = null;
|
||||
if (head != null) {
|
||||
head.prev = node;
|
||||
}
|
||||
head = node;
|
||||
if (tail == null) {
|
||||
tail = node;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 从链表中移除节点
|
||||
*
|
||||
* @param node 节点
|
||||
*/
|
||||
private void removeNode(final SieveCacheObj<K, V> node) {
|
||||
if (node == hand) {
|
||||
hand = node.prev;
|
||||
}
|
||||
|
||||
if (node.prev != null) {
|
||||
node.prev.next = node.next;
|
||||
} else {
|
||||
head = node.next;
|
||||
}
|
||||
|
||||
if (node.next != null) {
|
||||
node.next.prev = node.prev;
|
||||
} else {
|
||||
tail = node.prev;
|
||||
}
|
||||
|
||||
node.next = null;
|
||||
node.prev = null;
|
||||
}
|
||||
|
||||
/**
|
||||
* 给节点添加visited属性,用于Sieve缓存淘汰策略
|
||||
*/
|
||||
private static class SieveCacheObj<K, V> extends CacheObj<K, V> {
|
||||
@Serial
|
||||
private static final long serialVersionUID = 1L;
|
||||
/**
|
||||
* 是否被访问过
|
||||
*/
|
||||
boolean visited = false;
|
||||
/**
|
||||
* 前向节点
|
||||
*/
|
||||
SieveCacheObj<K, V> prev;
|
||||
/**
|
||||
* 后向节点
|
||||
*/
|
||||
SieveCacheObj<K, V> next;
|
||||
|
||||
protected SieveCacheObj(final K key, final V obj, final long ttl) {
|
||||
super(key, obj, ttl);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -175,7 +175,7 @@ public class HexUtil extends Hex {
|
||||
* @since 5.7.4
|
||||
*/
|
||||
public static int hexToInt(final String value) {
|
||||
return Integer.parseInt(value, 16);
|
||||
return Integer.parseInt(removeHexPrefix(value), 16);
|
||||
}
|
||||
|
||||
/**
|
||||
@ -197,7 +197,7 @@ public class HexUtil extends Hex {
|
||||
* @since 5.7.4
|
||||
*/
|
||||
public static long hexToLong(final String value) {
|
||||
return Long.parseLong(value, 16);
|
||||
return Long.parseLong(removeHexPrefix(value), 16);
|
||||
}
|
||||
|
||||
/**
|
||||
@ -223,7 +223,7 @@ public class HexUtil extends Hex {
|
||||
if (null == hexStr) {
|
||||
return null;
|
||||
}
|
||||
return new BigInteger(hexStr, 16);
|
||||
return new BigInteger(removeHexPrefix(hexStr), 16);
|
||||
}
|
||||
|
||||
/**
|
||||
@ -263,4 +263,24 @@ public class HexUtil extends Hex {
|
||||
return builder.toString();
|
||||
}
|
||||
|
||||
/**
|
||||
* 移除Hex字符串前缀,前缀包括:0x, 0X, #
|
||||
*
|
||||
* @param hexStr 16进制字符串
|
||||
* @return 移除前缀后的字符串
|
||||
*/
|
||||
private static String removeHexPrefix(final String hexStr) {
|
||||
if (StrUtil.length(hexStr) > 1) {
|
||||
final char c0 = hexStr.charAt(0);
|
||||
switch (c0) {
|
||||
case '0':
|
||||
if (hexStr.charAt(1) == 'x' || hexStr.charAt(1) == 'X') {
|
||||
return hexStr.substring(2);
|
||||
}
|
||||
case '#':
|
||||
return hexStr.substring(1);
|
||||
}
|
||||
}
|
||||
return hexStr;
|
||||
}
|
||||
}
|
||||
|
||||
@ -89,7 +89,7 @@ public class DateModifier {
|
||||
case ROUND:
|
||||
final int min = isAM ? 0 : 12;
|
||||
final int max = isAM ? 11 : 23;
|
||||
final int href = (max - min) / 2 + 1;
|
||||
final int href = min + (max - min) / 2 + 1;
|
||||
final int value = calendar.get(Calendar.HOUR_OF_DAY);
|
||||
calendar.set(Calendar.HOUR_OF_DAY, (value < href) ? min : max);
|
||||
break;
|
||||
|
||||
@ -133,9 +133,11 @@ public class ConstructorUtil {
|
||||
* 对于某些特殊的接口,按照其默认实现实例化,例如:
|
||||
* <pre>
|
||||
* Map -》 HashMap
|
||||
* Collction -》 ArrayList
|
||||
* List -》 ArrayList
|
||||
* Set -》 HashSet
|
||||
* Queue -》 LinkedList
|
||||
* Deque -》 LinkedList
|
||||
* Collection-》 ArrayList
|
||||
* </pre>
|
||||
*
|
||||
* @param <T> 对象类型
|
||||
|
||||
@ -46,7 +46,7 @@ import java.util.*;
|
||||
*
|
||||
* @param <T> 对象类型
|
||||
*/
|
||||
public class PossibleObjectCreator<T> implements ObjectCreator<T> {
|
||||
public record PossibleObjectCreator<T>(Class<T> clazz) implements ObjectCreator<T> {
|
||||
|
||||
/**
|
||||
* 创建默认的对象实例化器
|
||||
@ -59,8 +59,6 @@ public class PossibleObjectCreator<T> implements ObjectCreator<T> {
|
||||
return new PossibleObjectCreator<>(clazz);
|
||||
}
|
||||
|
||||
final Class<T> clazz;
|
||||
|
||||
/**
|
||||
* 构造
|
||||
*
|
||||
@ -120,12 +118,21 @@ public class PossibleObjectCreator<T> implements ObjectCreator<T> {
|
||||
}
|
||||
|
||||
/**
|
||||
* 某些特殊接口的实例化按照默认实现进行
|
||||
* 对于某些特殊的接口,按照其默认实现实例化,例如:
|
||||
* <pre>
|
||||
* Map -》 HashMap
|
||||
* List -》 ArrayList
|
||||
* Set -》 HashSet
|
||||
* Queue -》 LinkedList
|
||||
* Deque -》 LinkedList
|
||||
* Collection-》 ArrayList
|
||||
* </pre>
|
||||
*
|
||||
* @param type 类型
|
||||
* @return 默认类型
|
||||
*/
|
||||
private static Class<?> resolveType(final Class<?> type) {
|
||||
if (Object.class != type) {
|
||||
if (type.isAssignableFrom(AbstractMap.class)) {
|
||||
return HashMap.class;
|
||||
} else if (type.isAssignableFrom(List.class)) {
|
||||
@ -134,6 +141,11 @@ public class PossibleObjectCreator<T> implements ObjectCreator<T> {
|
||||
return TreeSet.class;
|
||||
} else if (type.isAssignableFrom(Set.class)) {
|
||||
return HashSet.class;
|
||||
} else if (type.isAssignableFrom(Queue.class)) {
|
||||
return LinkedList.class;
|
||||
} else if (type.isAssignableFrom(Deque.class)) {
|
||||
return LinkedList.class;
|
||||
}
|
||||
}
|
||||
|
||||
return type;
|
||||
|
||||
@ -30,7 +30,7 @@ public abstract class AbstractFilter implements BloomFilter {
|
||||
@Serial
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
private final BitSet bitSet;
|
||||
protected final BitSet bitSet;
|
||||
/**
|
||||
* 容量
|
||||
*/
|
||||
@ -50,12 +50,12 @@ public abstract class AbstractFilter implements BloomFilter {
|
||||
|
||||
@Override
|
||||
public boolean contains(final String str) {
|
||||
return bitSet.get(Math.abs(hash(str)));
|
||||
return bitSet.get(hash(str));
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean add(final String str) {
|
||||
final int hash = Math.abs(hash(str));
|
||||
final int hash = hash(str);
|
||||
if (bitSet.get(hash)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
@ -16,8 +16,13 @@
|
||||
|
||||
package cn.hutool.v7.core.text.bloom;
|
||||
|
||||
import cn.hutool.v7.core.lang.Assert;
|
||||
|
||||
import java.io.Serial;
|
||||
import java.util.function.Function;
|
||||
import java.util.Arrays;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
import java.util.function.ToIntFunction;
|
||||
|
||||
/**
|
||||
* 基于Hash函数方法的{@link BloomFilter}
|
||||
@ -33,26 +38,70 @@ public class FuncFilter extends AbstractFilter {
|
||||
* 创建FuncFilter
|
||||
*
|
||||
* @param size 最大值
|
||||
* @param hashFunc Hash函数
|
||||
* @param hashFuncs Hash函数
|
||||
* @return FuncFilter
|
||||
*/
|
||||
public static FuncFilter of(final int size, final Function<String, Number> hashFunc) {
|
||||
return new FuncFilter(size, hashFunc);
|
||||
@SafeVarargs
|
||||
public static FuncFilter of(final int size, final ToIntFunction<String>... hashFuncs) {
|
||||
return new FuncFilter(size, hashFuncs);
|
||||
}
|
||||
|
||||
private final Function<String, Number> hashFunc;
|
||||
// 允许接收多个哈希函数
|
||||
private final List<ToIntFunction<String>> hashFuncs;
|
||||
|
||||
/**
|
||||
* @param size 最大值
|
||||
* @param hashFunc Hash函数
|
||||
* @param hashFuncs Hash函数
|
||||
*/
|
||||
public FuncFilter(final int size, final Function<String, Number> hashFunc) {
|
||||
@SafeVarargs
|
||||
public FuncFilter(final int size, final ToIntFunction<String>... hashFuncs) {
|
||||
super(size);
|
||||
this.hashFunc = hashFunc;
|
||||
Assert.notEmpty(hashFuncs, "Hash functions must not be empty");
|
||||
this.hashFuncs = Collections.unmodifiableList(Arrays.asList(hashFuncs));
|
||||
}
|
||||
|
||||
/**
|
||||
* 兼容父类,如果存在多个哈希函数,就使用第一个
|
||||
*
|
||||
* @param str 字符串
|
||||
*/
|
||||
@Override
|
||||
public int hash(final String str) {
|
||||
return hash(str, hashFuncs.get(0));
|
||||
}
|
||||
|
||||
/**
|
||||
*
|
||||
* @param str 字符串
|
||||
* @param hashFunc 哈希函数
|
||||
* @return HashCode 指定哈希函数的计算结果
|
||||
*/
|
||||
public int hash(final String str, final ToIntFunction<String> hashFunc) {
|
||||
// 通过位运算获取正数
|
||||
return (hashFunc.applyAsInt(str) & 0x7FFFFFFF) % size;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int hash(final String str) {
|
||||
return hashFunc.apply(str).intValue() % size;
|
||||
public boolean contains(final String str) {
|
||||
for (final ToIntFunction<String> hashFunc : hashFuncs) {
|
||||
if (!bitSet.get(hash(str, hashFunc))) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean add(final String str) {
|
||||
boolean add = false;
|
||||
int hash;
|
||||
for (final ToIntFunction<String> hashFunc : hashFuncs) {
|
||||
hash = hash(str, hashFunc);
|
||||
if (!bitSet.get(hash)) {
|
||||
bitSet.set(hash);
|
||||
add = true;
|
||||
}
|
||||
}
|
||||
return add;
|
||||
}
|
||||
}
|
||||
|
||||
155
hutool-core/src/test/java/cn/hutool/v7/core/cache/SieveCacheTest.java
vendored
Normal file
155
hutool-core/src/test/java/cn/hutool/v7/core/cache/SieveCacheTest.java
vendored
Normal file
@ -0,0 +1,155 @@
|
||||
/*
|
||||
* Copyright (c) 2013-2025 Hutool Team and hutool.cn
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
|
||||
package cn.hutool.v7.core.cache;
|
||||
|
||||
import cn.hutool.v7.core.cache.impl.SieveCache;
|
||||
import cn.hutool.v7.core.thread.ThreadUtil;
|
||||
import cn.hutool.v7.core.util.RandomUtil;
|
||||
import org.junit.jupiter.api.Assertions;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import java.util.concurrent.CountDownLatch;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
/**
|
||||
* SIEVE 缓存算法单元测试
|
||||
*/
|
||||
public class SieveCacheTest {
|
||||
|
||||
@Test
|
||||
public void evictionLogicTest() {
|
||||
final SieveCache<String, String> cache = new SieveCache<>(3);
|
||||
|
||||
cache.put("A", "A");
|
||||
cache.put("B", "B");
|
||||
cache.put("C", "C");
|
||||
|
||||
cache.get("A");
|
||||
|
||||
cache.put("D", "D");
|
||||
|
||||
Assertions.assertEquals("A", cache.get("A"));
|
||||
Assertions.assertEquals("C", cache.get("C"));
|
||||
Assertions.assertEquals("D", cache.get("D"));
|
||||
|
||||
Assertions.assertNull(cache.get("B"), "B 应该被淘汰,因为它是未访问过的节点");
|
||||
}
|
||||
|
||||
|
||||
@Test
|
||||
public void expiryTest() {
|
||||
final SieveCache<String, String> cache = new SieveCache<>(3);
|
||||
cache.put("k1", "v1", 100);
|
||||
cache.put("k2", "v2", 10000);
|
||||
|
||||
ThreadUtil.sleep(200);
|
||||
|
||||
Assertions.assertNull(cache.get("k1"), "k1 应该过期");
|
||||
Assertions.assertEquals("v2", cache.get("k2"), "k2 应该存在");
|
||||
Assertions.assertEquals(1, cache.size(), "size 应该为 1");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void listenerTest() {
|
||||
final AtomicInteger removeCount = new AtomicInteger();
|
||||
final SieveCache<Integer, Integer> cache = new SieveCache<>(2);
|
||||
|
||||
cache.setListener((key, value) -> {
|
||||
removeCount.incrementAndGet();
|
||||
});
|
||||
|
||||
cache.put(1, 1);
|
||||
cache.put(2, 2);
|
||||
cache.put(3, 3);
|
||||
|
||||
Assertions.assertEquals(1, removeCount.get());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void concurrencyPressureTest() throws InterruptedException {
|
||||
final int threadCount = 20;
|
||||
final int loopCount = 2000;
|
||||
final int capacity = 100;
|
||||
|
||||
final SieveCache<String, String> cache = new SieveCache<>(capacity);
|
||||
final CountDownLatch latch = new CountDownLatch(threadCount);
|
||||
final AtomicInteger errorCount = new AtomicInteger(0);
|
||||
|
||||
for (int i = 0; i < threadCount; i++) {
|
||||
new Thread(() -> {
|
||||
try {
|
||||
for (int j = 0; j < loopCount; j++) {
|
||||
final String key = String.valueOf(RandomUtil.randomInt(0, 1000));
|
||||
if (RandomUtil.randomBoolean()) {
|
||||
cache.put(key, "val-" + key);
|
||||
} else {
|
||||
cache.get(key);
|
||||
}
|
||||
}
|
||||
} catch (final Exception e) {
|
||||
errorCount.incrementAndGet();
|
||||
} finally {
|
||||
latch.countDown();
|
||||
}
|
||||
}).start();
|
||||
}
|
||||
|
||||
latch.await();
|
||||
|
||||
Assertions.assertEquals(0, errorCount.get(), "并发执行不应出现异常");
|
||||
Assertions.assertTrue(cache.size() <= capacity, "缓存大小不应超过容量");
|
||||
|
||||
int iteratorCount = 0;
|
||||
for (final String ignored : cache) {
|
||||
iteratorCount++;
|
||||
}
|
||||
Assertions.assertEquals(cache.size(), iteratorCount, "迭代器数量与 size() 应一致");
|
||||
}
|
||||
|
||||
/**
|
||||
* 抗扫描能力测试
|
||||
* 如果扫描数据量过大(如 50% 容量)且热点数据无访问,热点数据的保护位会被耗尽,因此这里仅模拟少量数据的扫描攻击。
|
||||
*/
|
||||
@Test
|
||||
public void scanResistanceTest() {
|
||||
final int capacity = 10;
|
||||
final SieveCache<Integer, Integer> cache = new SieveCache<>(capacity);
|
||||
|
||||
// 填满热点数据
|
||||
for (int i = 0; i < capacity; i++) {
|
||||
cache.put(i, i);
|
||||
}
|
||||
|
||||
// 模拟热点访问
|
||||
for (int i = 0; i < capacity; i++) {
|
||||
cache.get(i);
|
||||
}
|
||||
|
||||
// 插入 1 个冷数据
|
||||
cache.put(10, 10);
|
||||
|
||||
int retainedHotItems = 0;
|
||||
for (int i = 0; i < capacity; i++) {
|
||||
if (cache.get(i) != null) {
|
||||
retainedHotItems++;
|
||||
}
|
||||
}
|
||||
|
||||
Assertions.assertNull(cache.get(10), "冷数据 (10) 应该被淘汰");
|
||||
Assertions.assertEquals(capacity, retainedHotItems, "所有热点数据 (0-9) 应该被保留");
|
||||
}
|
||||
}
|
||||
@ -1149,4 +1149,31 @@ public class DateUtilTest {
|
||||
final DateTime dt = DateUtil.parse(dateStr1);
|
||||
assertEquals("2025-07-28 20:00:00", dt.toString());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void cellingAmPmTest(){
|
||||
final String dateStr2 = "2020-02-29 10:59:34";
|
||||
final Date date2 = DateUtil.parse(dateStr2);
|
||||
|
||||
|
||||
DateTime dateTime = DateUtil.ceiling(date2, DateField.AM_PM, false);
|
||||
assertEquals("2020-02-29 11:59:59.999", dateTime.toString(DateFormatPool.NORM_DATETIME_MS_PATTERN));
|
||||
|
||||
dateTime = DateUtil.ceiling(date2, DateField.AM_PM, true);
|
||||
assertEquals("2020-02-29 11:59:59.000", dateTime.toString(DateFormatPool.NORM_DATETIME_MS_PATTERN));
|
||||
}
|
||||
|
||||
@Test void roundAmPmTest() {
|
||||
final String dateStr = "2020-02-29 13:59:34";
|
||||
final Date date = DateUtil.parse(dateStr);
|
||||
|
||||
final DateTime dateTime = DateUtil.round(date, DateField.AM_PM);
|
||||
assertEquals("2020-02-29 12:59:59.000", dateTime.toString(DateFormatPool.NORM_DATETIME_MS_PATTERN));
|
||||
|
||||
final String dateStr2 = "2020-02-29 18:59:34";
|
||||
final Date date2 = DateUtil.parse(dateStr2);
|
||||
|
||||
final DateTime dateTime2 = DateUtil.round(date2, DateField.AM_PM);
|
||||
assertEquals("2020-02-29 23:59:59.000", dateTime2.toString(DateFormatPool.NORM_DATETIME_MS_PATTERN));
|
||||
}
|
||||
}
|
||||
|
||||
@ -16,42 +16,42 @@
|
||||
|
||||
package cn.hutool.v7.core.reflect;
|
||||
|
||||
import cn.hutool.v7.core.date.Week;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
import cn.hutool.v7.core.date.Week;
|
||||
import org.junit.jupiter.api.Assertions;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import java.util.Collection;
|
||||
import java.util.Hashtable;
|
||||
import java.util.Map;
|
||||
import java.util.*;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.*;
|
||||
|
||||
public class ConstructorUtilTest {
|
||||
@Test
|
||||
public void noneStaticInnerClassTest() {
|
||||
final ReflectTestBeans.NoneStaticClass testAClass = ConstructorUtil.newInstanceIfPossible(ReflectTestBeans.NoneStaticClass.class);
|
||||
Assertions.assertNotNull(testAClass);
|
||||
Assertions.assertEquals(2, testAClass.getA());
|
||||
assertNotNull(testAClass);
|
||||
assertEquals(2, testAClass.getA());
|
||||
}
|
||||
|
||||
@Test
|
||||
public void newInstanceIfPossibleTest(){
|
||||
//noinspection ConstantConditions
|
||||
final int intValue = ConstructorUtil.newInstanceIfPossible(int.class);
|
||||
Assertions.assertEquals(0, intValue);
|
||||
assertEquals(0, intValue);
|
||||
|
||||
final Integer integer = ConstructorUtil.newInstanceIfPossible(Integer.class);
|
||||
Assertions.assertEquals(Integer.valueOf(0), integer);
|
||||
assertEquals(Integer.valueOf(0), integer);
|
||||
|
||||
final Map<?, ?> map = ConstructorUtil.newInstanceIfPossible(Map.class);
|
||||
Assertions.assertNotNull(map);
|
||||
assertNotNull(map);
|
||||
|
||||
final Collection<?> collection = ConstructorUtil.newInstanceIfPossible(Collection.class);
|
||||
Assertions.assertNotNull(collection);
|
||||
assertNotNull(collection);
|
||||
|
||||
final Week week = ConstructorUtil.newInstanceIfPossible(Week.class);
|
||||
Assertions.assertEquals(Week.SUNDAY, week);
|
||||
assertEquals(Week.SUNDAY, week);
|
||||
|
||||
final int[] intArray = ConstructorUtil.newInstanceIfPossible(int[].class);
|
||||
Assertions.assertArrayEquals(new int[0], intArray);
|
||||
@ -61,20 +61,20 @@ public class ConstructorUtilTest {
|
||||
void newInstanceTest() {
|
||||
final TestBean testBean = ConstructorUtil.newInstance(TestBean.class);
|
||||
Assertions.assertNull(testBean.getA());
|
||||
Assertions.assertEquals(0, testBean.getB());
|
||||
assertEquals(0, testBean.getB());
|
||||
}
|
||||
|
||||
@Test
|
||||
void newInstanceAllArgsTest() {
|
||||
final TestBean testBean = ConstructorUtil.newInstance(TestBean.class, "aValue", 1);
|
||||
Assertions.assertEquals("aValue", testBean.getA());
|
||||
Assertions.assertEquals(1, testBean.getB());
|
||||
assertEquals("aValue", testBean.getA());
|
||||
assertEquals(1, testBean.getB());
|
||||
}
|
||||
|
||||
@Test
|
||||
void newInstanceHashtableTest() {
|
||||
final Hashtable<?, ?> testBean = ConstructorUtil.newInstance(Hashtable.class);
|
||||
Assertions.assertNotNull(testBean);
|
||||
assertNotNull(testBean);
|
||||
}
|
||||
|
||||
@Data
|
||||
@ -84,4 +84,43 @@ public class ConstructorUtilTest {
|
||||
private String a;
|
||||
private int b;
|
||||
}
|
||||
|
||||
@Test
|
||||
public void newInstanceIfPossibleTest2() {
|
||||
// 测试Object.class不应该被错误地实例化为HashMap,应该返回Object实例
|
||||
final Object objectInstance = ConstructorUtil.newInstanceIfPossible(Object.class);
|
||||
assertNotNull(objectInstance);
|
||||
assertEquals(Object.class, objectInstance.getClass());
|
||||
|
||||
// 测试Map.class能够正确实例化为HashMap
|
||||
final Map<?, ?> mapInstance = ConstructorUtil.newInstanceIfPossible(Map.class);
|
||||
assertNotNull(mapInstance);
|
||||
assertInstanceOf(HashMap.class, mapInstance);
|
||||
|
||||
// 测试Collection.class能够正确实例化为ArrayList
|
||||
final Collection<?> collectionInstance = ConstructorUtil.newInstanceIfPossible(Collection.class);
|
||||
assertNotNull(collectionInstance);
|
||||
assertInstanceOf(ArrayList.class, collectionInstance);
|
||||
|
||||
|
||||
// 测试List.class能够正确实例化为ArrayList
|
||||
final List<?> listInstance = ConstructorUtil.newInstanceIfPossible(List.class);
|
||||
assertNotNull(listInstance);
|
||||
assertInstanceOf(ArrayList.class, listInstance);
|
||||
|
||||
// 测试Set.class能够正确实例化为HashSet
|
||||
final Set<?> setInstance = ConstructorUtil.newInstanceIfPossible(Set.class);
|
||||
assertNotNull(setInstance);
|
||||
assertInstanceOf(HashSet.class, setInstance);
|
||||
|
||||
// 测试Queue接口能够正确实例化为LinkedList
|
||||
final Queue<?> queueInstance = ConstructorUtil.newInstanceIfPossible(Queue.class);
|
||||
assertNotNull(queueInstance);
|
||||
assertInstanceOf(LinkedList.class, queueInstance);
|
||||
|
||||
// 测试Deque接口能够正确实例化为LinkedList
|
||||
final Deque<?> dequeInstance = ConstructorUtil.newInstanceIfPossible(Deque.class);
|
||||
assertNotNull(dequeInstance);
|
||||
assertInstanceOf(LinkedList.class, dequeInstance);
|
||||
}
|
||||
}
|
||||
|
||||
@ -22,11 +22,12 @@ import org.junit.jupiter.api.Test;
|
||||
|
||||
public class BitMapBloomFilterTest {
|
||||
|
||||
private static final int SIZE = 2 * 1024 * 1024 * 8;
|
||||
|
||||
@Test
|
||||
public void filterTest() {
|
||||
final int size = 2 * 1024 * 1024 * 8;
|
||||
|
||||
final CombinedBloomFilter filter = new CombinedBloomFilter(FuncFilter.of(size, HashUtil::rsHash));
|
||||
final CombinedBloomFilter filter = new CombinedBloomFilter(FuncFilter.of(SIZE, HashUtil::rsHash));
|
||||
filter.add("123");
|
||||
filter.add("abc");
|
||||
filter.add("ddd");
|
||||
@ -35,4 +36,68 @@ public class BitMapBloomFilterTest {
|
||||
Assertions.assertTrue(filter.contains("ddd"));
|
||||
Assertions.assertTrue(filter.contains("123"));
|
||||
}
|
||||
@Test
|
||||
public void multiHashFuncTest() {
|
||||
final FuncFilter filter = FuncFilter.of(SIZE,
|
||||
HashUtil::rsHash,
|
||||
HashUtil::jsHash,
|
||||
HashUtil::pjwHash,
|
||||
HashUtil::elfHash,
|
||||
HashUtil::bkdrHash,
|
||||
HashUtil::sdbmHash,
|
||||
HashUtil::djbHash,
|
||||
HashUtil::dekHash,
|
||||
HashUtil::apHash,
|
||||
HashUtil::javaDefaultHash
|
||||
);
|
||||
|
||||
filter.add("Hutool");
|
||||
filter.add("BloomFilter");
|
||||
filter.add("Java");
|
||||
|
||||
Assertions.assertTrue(filter.contains("Hutool"));
|
||||
Assertions.assertTrue(filter.contains("BloomFilter"));
|
||||
Assertions.assertTrue(filter.contains("Java"));
|
||||
Assertions.assertFalse(filter.contains("Python"));
|
||||
Assertions.assertFalse(filter.contains("Go"));
|
||||
Assertions.assertFalse(filter.contains("hutool"));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void combinedMultiHashTest() {
|
||||
final FuncFilter multiHashFuncFilter = FuncFilter.of(SIZE,
|
||||
HashUtil::bkdrHash,
|
||||
HashUtil::apHash,
|
||||
HashUtil::djbHash
|
||||
);
|
||||
final CombinedBloomFilter filter = new CombinedBloomFilter(multiHashFuncFilter);
|
||||
filter.add("123123WASD-WASD");
|
||||
Assertions.assertTrue(filter.contains("123123WASD-WASD"));
|
||||
Assertions.assertFalse(filter.contains("123123WASD-WASD-false"));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void chineseStringWithThreeHashesTest() {
|
||||
final FuncFilter filter = FuncFilter.of(SIZE,
|
||||
HashUtil::bkdrHash,
|
||||
HashUtil::apHash,
|
||||
HashUtil::djbHash
|
||||
);
|
||||
|
||||
final String s1 = "你好世界";
|
||||
final String s2 = "双亲委派";
|
||||
final String s3 = "测试工程师";
|
||||
|
||||
filter.add(s1);
|
||||
filter.add(s2);
|
||||
filter.add(s3);
|
||||
Assertions.assertTrue(filter.contains(s1), "应包含: " + s1);
|
||||
Assertions.assertTrue(filter.contains(s2), "应包含: " + s2);
|
||||
Assertions.assertTrue(filter.contains(s3), "应包含: " + s3);
|
||||
Assertions.assertFalse(filter.contains("我好世界"), "多字");
|
||||
Assertions.assertFalse(filter.contains("父亲委派"), "改字");
|
||||
Assertions.assertFalse(filter.contains("测试"), "子串");
|
||||
Assertions.assertFalse(filter.contains(""), "空串");
|
||||
Assertions.assertFalse(filter.contains("👍"), "未添加的");
|
||||
}
|
||||
}
|
||||
|
||||
@ -20,8 +20,11 @@ import cn.hutool.v7.core.codec.binary.HexUtil;
|
||||
import org.junit.jupiter.api.Assertions;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
|
||||
import static org.junit.jupiter.api.Assertions.assertEquals;
|
||||
|
||||
/**
|
||||
* HexUtil单元测试
|
||||
* @author Looly
|
||||
@ -36,22 +39,22 @@ public class HexUtilTest {
|
||||
final String hex = HexUtil.encodeStr(str, CharsetUtil.UTF_8);
|
||||
final String decodedStr = HexUtil.decodeStr(hex);
|
||||
|
||||
Assertions.assertEquals(str, decodedStr);
|
||||
assertEquals(str, decodedStr);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void issueI50MI6Test(){
|
||||
final String s = HexUtil.encodeStr("烟".getBytes(StandardCharsets.UTF_16BE));
|
||||
Assertions.assertEquals("70df", s);
|
||||
assertEquals("70df", s);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void toUnicodeHexTest() {
|
||||
String unicodeHex = HexUtil.toUnicodeHex('\u2001');
|
||||
Assertions.assertEquals("\\u2001", unicodeHex);
|
||||
assertEquals("\\u2001", unicodeHex);
|
||||
|
||||
unicodeHex = HexUtil.toUnicodeHex('你');
|
||||
Assertions.assertEquals("\\u4f60", unicodeHex);
|
||||
assertEquals("\\u4f60", unicodeHex);
|
||||
}
|
||||
|
||||
@Test
|
||||
@ -86,20 +89,50 @@ public class HexUtilTest {
|
||||
public void formatHexTest(){
|
||||
final String hex = "e8c670380cb220095268f40221fc748fa6ac39d6e930e63c30da68bad97f885d";
|
||||
final String formatHex = HexUtil.format(hex);
|
||||
Assertions.assertEquals("e8 c6 70 38 0c b2 20 09 52 68 f4 02 21 fc 74 8f a6 ac 39 d6 e9 30 e6 3c 30 da 68 ba d9 7f 88 5d", formatHex);
|
||||
assertEquals("e8 c6 70 38 0c b2 20 09 52 68 f4 02 21 fc 74 8f a6 ac 39 d6 e9 30 e6 3c 30 da 68 ba d9 7f 88 5d", formatHex);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void formatHexTest2(){
|
||||
final String hex = "e8c670380cb220095268f40221fc748fa6";
|
||||
final String formatHex = HexUtil.format(hex, "0x");
|
||||
Assertions.assertEquals("0xe8 0xc6 0x70 0x38 0x0c 0xb2 0x20 0x09 0x52 0x68 0xf4 0x02 0x21 0xfc 0x74 0x8f 0xa6", formatHex);
|
||||
assertEquals("0xe8 0xc6 0x70 0x38 0x0c 0xb2 0x20 0x09 0x52 0x68 0xf4 0x02 0x21 0xfc 0x74 0x8f 0xa6", formatHex);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void decodeHexTest(){
|
||||
final String s = HexUtil.encodeStr("6");
|
||||
final String s1 = HexUtil.decodeStr(s);
|
||||
Assertions.assertEquals("6", s1);
|
||||
assertEquals("6", s1);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void hexToIntTest() {
|
||||
final String hex1 = "FF";
|
||||
assertEquals(255, HexUtil.hexToInt(hex1));
|
||||
final String hex2 = "0xFF";
|
||||
assertEquals(255, HexUtil.hexToInt(hex2));
|
||||
final String hex3 = "#FF";
|
||||
assertEquals(255, HexUtil.hexToInt(hex3));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void hexToLongTest() {
|
||||
final String hex1 = "FF";
|
||||
assertEquals(255L, HexUtil.hexToLong(hex1));
|
||||
final String hex2 = "0xFF";
|
||||
assertEquals(255L, HexUtil.hexToLong(hex2));
|
||||
final String hex3 = "#FF";
|
||||
assertEquals(255L, HexUtil.hexToLong(hex3));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void toBigIntegerTest() {
|
||||
final String hex1 = "FF";
|
||||
assertEquals(new BigInteger("FF", 16), HexUtil.toBigInteger(hex1));
|
||||
final String hex2 = "0xFF";
|
||||
assertEquals(new BigInteger("FF", 16), HexUtil.toBigInteger(hex2));
|
||||
final String hex3 = "#FF";
|
||||
assertEquals(new BigInteger("FF", 16), HexUtil.toBigInteger(hex3));
|
||||
}
|
||||
}
|
||||
|
||||
@ -0,0 +1,57 @@
|
||||
package cn.hutool.v7.poi.word;
|
||||
|
||||
import org.apache.poi.xwpf.usermodel.XWPFRun;
|
||||
|
||||
import java.awt.Color;
|
||||
import java.awt.Font;
|
||||
|
||||
/**
|
||||
* 字体样式
|
||||
*
|
||||
* @param font 字体信息
|
||||
* @param color 字体颜色
|
||||
* @author looly
|
||||
* @since 7.0.0
|
||||
*/
|
||||
public record FontStyle(Font font, Color color) {
|
||||
|
||||
/**
|
||||
* 构造
|
||||
*
|
||||
* @param name 字体名称
|
||||
* @param style 字体样式,见{@link Font#PLAIN}, {@link Font#BOLD}, {@link Font#ITALIC}
|
||||
* @param size 字体大小
|
||||
*/
|
||||
@SuppressWarnings("MagicConstant")
|
||||
public FontStyle(final String name, final int style, final int size) {
|
||||
this(new Font(name, style, size), null);
|
||||
}
|
||||
|
||||
/**
|
||||
* 构造
|
||||
*
|
||||
* @param name 字体名称
|
||||
* @param style 字体样式,见{@link Font#PLAIN}, {@link Font#BOLD}, {@link Font#ITALIC}
|
||||
* @param size 字体大小
|
||||
* @param color 字体颜色
|
||||
*/
|
||||
@SuppressWarnings("MagicConstant")
|
||||
public FontStyle(final String name, final int style, final int size, final Color color) {
|
||||
this(new Font(name, style, size), color);
|
||||
}
|
||||
|
||||
/**
|
||||
* 填充字体样式到段落
|
||||
*
|
||||
* @param run 段落对象
|
||||
*/
|
||||
public void fill(final XWPFRun run) {
|
||||
run.setFontFamily(font.getFamily());
|
||||
run.setFontSize(font.getSize());
|
||||
run.setBold(font.isBold());
|
||||
run.setItalic(font.isItalic());
|
||||
if (null != color) {
|
||||
run.setColor(String.format("%02X", color.getRGB()));
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -16,13 +16,13 @@
|
||||
|
||||
package cn.hutool.v7.poi.word;
|
||||
|
||||
import org.apache.poi.common.usermodel.PictureType;
|
||||
import cn.hutool.v7.core.io.file.FileUtil;
|
||||
import cn.hutool.v7.core.array.ArrayUtil;
|
||||
import cn.hutool.v7.core.io.IORuntimeException;
|
||||
import cn.hutool.v7.core.io.IoUtil;
|
||||
import cn.hutool.v7.core.io.file.FileUtil;
|
||||
import cn.hutool.v7.core.lang.Assert;
|
||||
import cn.hutool.v7.core.array.ArrayUtil;
|
||||
import cn.hutool.v7.poi.POIException;
|
||||
import org.apache.poi.common.usermodel.PictureType;
|
||||
import org.apache.poi.openxml4j.exceptions.InvalidFormatException;
|
||||
import org.apache.poi.util.Units;
|
||||
import org.apache.poi.xwpf.usermodel.ParagraphAlignment;
|
||||
@ -30,7 +30,6 @@ import org.apache.poi.xwpf.usermodel.XWPFDocument;
|
||||
import org.apache.poi.xwpf.usermodel.XWPFParagraph;
|
||||
import org.apache.poi.xwpf.usermodel.XWPFRun;
|
||||
|
||||
import java.awt.Font;
|
||||
import java.io.*;
|
||||
|
||||
/**
|
||||
@ -51,7 +50,7 @@ public class Word07Writer implements Closeable {
|
||||
*/
|
||||
protected boolean isClosed;
|
||||
|
||||
// region ----- Constructor start
|
||||
// region ----- Constructor
|
||||
|
||||
/**
|
||||
* 构造
|
||||
@ -111,14 +110,15 @@ public class Word07Writer implements Closeable {
|
||||
return this;
|
||||
}
|
||||
|
||||
// region ----- addText
|
||||
/**
|
||||
* 增加一个段落
|
||||
*
|
||||
* @param font 字体信息{@link Font}
|
||||
* @param font 字体信息{@link FontStyle}
|
||||
* @param texts 段落中的文本,支持多个文本作为一个段落
|
||||
* @return this
|
||||
*/
|
||||
public Word07Writer addText(final Font font, final String... texts) {
|
||||
public Word07Writer addText(final FontStyle font, final String... texts) {
|
||||
return addText(null, font, texts);
|
||||
}
|
||||
|
||||
@ -126,11 +126,11 @@ public class Word07Writer implements Closeable {
|
||||
* 增加一个段落
|
||||
*
|
||||
* @param align 段落对齐方式{@link ParagraphAlignment}
|
||||
* @param font 字体信息{@link Font}
|
||||
* @param font 字体信息{@link FontStyle}
|
||||
* @param texts 段落中的文本,支持多个文本作为一个段落
|
||||
* @return this
|
||||
*/
|
||||
public Word07Writer addText(final ParagraphAlignment align, final Font font, final String... texts) {
|
||||
public Word07Writer addText(final ParagraphAlignment align, final FontStyle font, final String... texts) {
|
||||
final XWPFParagraph p = this.doc.createParagraph();
|
||||
if (null != align) {
|
||||
p.setAlignment(align);
|
||||
@ -141,15 +141,13 @@ public class Word07Writer implements Closeable {
|
||||
run = p.createRun();
|
||||
run.setText(text);
|
||||
if (null != font) {
|
||||
run.setFontFamily(font.getFamily());
|
||||
run.setFontSize(font.getSize());
|
||||
run.setBold(font.isBold());
|
||||
run.setItalic(font.isItalic());
|
||||
font.fill(run);
|
||||
}
|
||||
}
|
||||
}
|
||||
return this;
|
||||
}
|
||||
// endregion
|
||||
|
||||
/**
|
||||
* 增加表格数据
|
||||
@ -164,6 +162,7 @@ public class Word07Writer implements Closeable {
|
||||
return this;
|
||||
}
|
||||
|
||||
// region ----- addPicture
|
||||
/**
|
||||
* 增加图片,单独成段落
|
||||
*
|
||||
@ -249,7 +248,9 @@ public class Word07Writer implements Closeable {
|
||||
}
|
||||
return this;
|
||||
}
|
||||
// endregion
|
||||
|
||||
// region ----- flush
|
||||
/**
|
||||
* 将Excel Workbook刷出到预定义的文件<br>
|
||||
* 如果用户未自定义输出的文件,将抛出{@link NullPointerException}<br>
|
||||
@ -308,6 +309,7 @@ public class Word07Writer implements Closeable {
|
||||
}
|
||||
return this;
|
||||
}
|
||||
// endregion
|
||||
|
||||
/**
|
||||
* 关闭Word文档<br>
|
||||
|
||||
@ -40,8 +40,8 @@ public class WordWriterTest {
|
||||
@Disabled
|
||||
public void writeTest() {
|
||||
final Word07Writer writer = new Word07Writer();
|
||||
writer.addText(new Font("方正小标宋简体", Font.PLAIN, 22), "我是第一部分", "我是第二部分");
|
||||
writer.addText(new Font("宋体", Font.PLAIN, 22), "我是正文第一部分", "我是正文第二部分");
|
||||
writer.addText(new FontStyle("方正小标宋简体", Font.PLAIN, 22), "我是第一部分", "我是第二部分");
|
||||
writer.addText(new FontStyle("宋体", Font.PLAIN, 22), "我是正文第一部分", "我是正文第二部分");
|
||||
writer.flush(FileUtil.file("e:/wordWrite.docx"));
|
||||
writer.close();
|
||||
Console.log("OK");
|
||||
@ -60,7 +60,7 @@ public class WordWriterTest {
|
||||
|
||||
@Test
|
||||
@Disabled
|
||||
public void writeTableTest(){
|
||||
public void writeTableTest() {
|
||||
final Word07Writer writer = new Word07Writer();
|
||||
final Map<String, Object> map = new LinkedHashMap<>();
|
||||
map.put("姓名", "张三");
|
||||
@ -94,9 +94,9 @@ public class WordWriterTest {
|
||||
final ArrayList<Map<String, Object>> mapArrayList = ListUtil.of(data, data2);
|
||||
|
||||
// 添加段落(标题)
|
||||
writer.addText(new Font("方正小标宋简体", Font.PLAIN, 22), "我是第一部分");
|
||||
writer.addText(new FontStyle("方正小标宋简体", Font.PLAIN, 22), "我是第一部分");
|
||||
// 添加段落(正文)
|
||||
writer.addText(new Font("宋体", Font.PLAIN, 13), "我是正文第一部分");
|
||||
writer.addText(new FontStyle("宋体", Font.PLAIN, 13), "我是正文第一部分");
|
||||
writer.addTable(mapArrayList);
|
||||
// 写出到文件
|
||||
writer.flush(FileUtil.file("d:/test/a.docx"));
|
||||
@ -105,7 +105,7 @@ public class WordWriterTest {
|
||||
}
|
||||
|
||||
@Test
|
||||
public void overflowTest(){
|
||||
public void overflowTest() {
|
||||
final Word07Writer word07Writer = new Word07Writer();
|
||||
final List<Object> list = ListUtil.of(false);
|
||||
final List<Object> list2 = ListUtil.of(false);
|
||||
@ -117,7 +117,7 @@ public class WordWriterTest {
|
||||
|
||||
@Test
|
||||
@Disabled
|
||||
public void writeBeanAsTableTest(){
|
||||
public void writeBeanAsTableTest() {
|
||||
final List<Vo> of = ListUtil.of(
|
||||
new Vo("测试1", new BigDecimal(12), new BigDecimal(2)),
|
||||
new Vo("测试2", new BigDecimal(13), new BigDecimal(2)),
|
||||
@ -133,7 +133,7 @@ public class WordWriterTest {
|
||||
|
||||
@Data
|
||||
@AllArgsConstructor
|
||||
private static class Vo{
|
||||
private static class Vo {
|
||||
private String name;
|
||||
private BigDecimal amount;
|
||||
private BigDecimal onYear;
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user