Compare commits

..

4 Commits

Author SHA1 Message Date
82a48bd1d2 add CI workflow
All checks were successful
CI/CD / build-deploy (pull_request) Successful in 40s
2026-01-19 17:46:27 +08:00
d0d4e0e633 add toOutputStream(InputStream is, OutputStream os, long start, long end) 2026-01-05 01:51:58 +08:00
77979be5fe add IOSize.parse(String) 2025-10-24 11:58:46 +08:00
cd9eee61f3 add IO.md5(InputStream) 2025-10-24 11:58:28 +08:00
4 changed files with 215 additions and 37 deletions

111
.gitea/workflows/ci.yml Normal file
View File

@ -0,0 +1,111 @@
name: CI/CD
on:
pull_request:
branches:
- master
types:
- closed
jobs:
build-deploy:
runs-on: act_runner_java
if: ${{ github.event.pull_request.merged == true }}
env:
JAVA_HOME: /usr/lib/jvm/java-21-openjdk
steps:
- name: Checkout code
run: |
git clone ${{ github.server_url }}/${{ github.repository }}.git .
git checkout ${{ github.sha }}
- name: Set up environment
run: |
echo "PR #${{ github.event.number }} merged into master"
echo "Source branch: ${{ github.event.pull_request.head.ref }}"
echo "Target branch: ${{ github.event.pull_request.base.ref }}"
- name: Run tests
run: |
echo "Running test suite..."
- name: Build project
run: |
mvn -B -DskipTests clean package source:jar javadoc:jar
- name: Deploy to Nexus
if: success()
run: |
if [ -z "${{ secrets.NEXUS_USERNAME }}" ] || [ -z "${{ secrets.NEXUS_PASSWORD }}" ]; then
echo "Missing secrets.NEXUS_USERNAME or secrets.NEXUS_PASSWORD"
exit 1
fi
mkdir -p ~/.m2
cat > ~/.m2/settings.xml <<EOF
<settings xmlns="http://maven.apache.org/SETTINGS/1.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/SETTINGS/1.0.0 http://maven.apache.org/xsd/settings-1.0.0.xsd">
<servers>
<server>
<id>timi-nexus</id>
<username>${{ secrets.NEXUS_USERNAME }}</username>
<password>${{ secrets.NEXUS_PASSWORD }}</password>
</server>
</servers>
</settings>
EOF
version=$(mvn -q -DforceStdout help:evaluate -Dexpression=project.version)
artifact_id=$(mvn -q -DforceStdout help:evaluate -Dexpression=project.artifactId)
main_jar="target/${artifact_id}-${version}.jar"
sources_jar="target/${artifact_id}-${version}-sources.jar"
javadoc_jar="target/${artifact_id}-${version}-javadoc.jar"
if [ ! -f "$main_jar" ] || [ ! -f "$sources_jar" ] || [ ! -f "$javadoc_jar" ]; then
echo "Missing build artifacts in target"
exit 1
fi
mvn -B deploy:deploy-file \
-Dfile="$main_jar" \
-Dsources="$sources_jar" \
-Djavadoc="$javadoc_jar" \
-DpomFile="./pom.xml" \
-Durl="https://nexus.imyeyu.com/repository/maven-releases/" \
-DrepositoryId="timi-nexus" \
-Dhttps.protocols=TLSv1.2 \
-Djdk.tls.client.protocols=TLSv1.2
- name: Create release
if: ${{ success() && startsWith(github.event.pull_request.title, 'v') }}
env:
GITEA_TOKEN: ${{ secrets.RUNNER_TOKEN }}
GITEA_SERVER_URL: ${{ github.server_url }}
GITEA_REPOSITORY: ${{ github.repository }}
RELEASE_TAG: ${{ github.event.pull_request.title }}
RELEASE_TARGET: ${{ github.sha }}
run: |
if [ -z "$GITEA_TOKEN" ]; then
echo "Missing secrets.RUNNER_TOKEN"
exit 1
fi
api_url="$GITEA_SERVER_URL/api/v1/repos/$GITEA_REPOSITORY/releases"
payload=$(cat <<EOF
{
"tag_name": "$RELEASE_TAG",
"name": "$RELEASE_TAG",
"target_commitish": "$RELEASE_TARGET",
"draft": false,
"prerelease": false
}
EOF
)
response=$(curl -sS -X POST "$api_url" \
-H "Authorization: token $GITEA_TOKEN" \
-H "Content-Type: application/json" \
-d "$payload")
release_id=$(echo "$response" | grep -o '"id":[0-9]*' | head -n 1 | grep -o '[0-9]*')
if [ -z "$release_id" ] || echo "$response" | grep -q '"message"'; then
echo "Create release failed: $response"
exit 1
fi
echo "Release created: id=$release_id"
for asset_path in target/*.jar; do
asset_name=$(basename "$asset_path")
curl -sS -X POST "$api_url/$release_id/assets?name=$asset_name" \
-H "Authorization: token $GITEA_TOKEN" \
-H "Content-Type: application/octet-stream" \
--data-binary @"$asset_path"
done

22
pom.xml
View File

@ -6,7 +6,7 @@
<groupId>com.imyeyu.io</groupId> <groupId>com.imyeyu.io</groupId>
<artifactId>timi-io</artifactId> <artifactId>timi-io</artifactId>
<version>0.0.1</version> <version>0.0.2</version>
<packaging>jar</packaging> <packaging>jar</packaging>
<properties> <properties>
@ -27,29 +27,11 @@
<groupId>org.apache.maven.plugins</groupId> <groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-source-plugin</artifactId> <artifactId>maven-source-plugin</artifactId>
<version>3.3.1</version> <version>3.3.1</version>
<executions>
<execution>
<id>attach-sources</id>
<phase>package</phase>
<goals>
<goal>jar-no-fork</goal>
</goals>
</execution>
</executions>
</plugin> </plugin>
<plugin> <plugin>
<groupId>org.apache.maven.plugins</groupId> <groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-javadoc-plugin</artifactId> <artifactId>maven-javadoc-plugin</artifactId>
<version>3.11.2</version> <version>3.11.2</version>
<executions>
<execution>
<id>attach-javadocs</id>
<phase>package</phase>
<goals>
<goal>jar</goal>
</goals>
</execution>
</executions>
</plugin> </plugin>
</plugins> </plugins>
</build> </build>
@ -78,7 +60,7 @@
<dependency> <dependency>
<groupId>com.imyeyu.utils</groupId> <groupId>com.imyeyu.utils</groupId>
<artifactId>timi-utils</artifactId> <artifactId>timi-utils</artifactId>
<version>0.0.1</version> <version>0.0.2</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.junit.jupiter</groupId> <groupId>org.junit.jupiter</groupId>

View File

@ -643,6 +643,24 @@ public class IO implements OS.FileSystem {
return !interrupt; return !interrupt;
} }
public static void toOutputStream(InputStream is, OutputStream os, long start, long end) throws IOException {
long skip = is.skip(start);
if (skip != start) {
throw new TimiException(TimiCode.ERROR, "skip fail");
}
byte[] buffer = new byte[8192];
long remaining = end - start + 1;
while (0 < remaining) {
int toRead = (int) Math.min(buffer.length, remaining);
int read = is.read(buffer, 0, toRead);
if (read == -1) {
break;
}
os.write(buffer, 0, read);
remaining -= read;
}
}
/** /**
* 写入字节到文件随机访问对象,此操作不会关闭流 * 写入字节到文件随机访问对象,此操作不会关闭流
* *
@ -1029,15 +1047,23 @@ public class IO implements OS.FileSystem {
* *
* @param file 文件 * @param file 文件
* @return MD5 * @return MD5
* @throws NoSuchAlgorithmException JDK 不支持此算法
*/ */
public static String md5(File file) throws NoSuchAlgorithmException { public static String md5(File file) throws FileNotFoundException {
try { return md5(getInputStream(file));
}
/**
* 计算输入流 MD5
*
* @param stream 输入流
* @return MD5
*/
public static String md5(InputStream stream) {
try (stream) {
MessageDigest md = MessageDigest.getInstance("MD5"); MessageDigest md = MessageDigest.getInstance("MD5");
InputStream is = getInputStream(file);
byte[] buffer = new byte[8192]; byte[] buffer = new byte[8192];
int l; int l;
while ((l = is.read(buffer)) != -1) { while ((l = stream.read(buffer)) != -1) {
md.update(buffer, 0, l); md.update(buffer, 0, l);
} }
byte[] bytes = md.digest(); byte[] bytes = md.digest();
@ -1046,9 +1072,8 @@ public class IO implements OS.FileSystem {
chars[j++] = Text.HEX_DIGITS_LOWER[bytes[i] >>> 4 & 0xF]; chars[j++] = Text.HEX_DIGITS_LOWER[bytes[i] >>> 4 & 0xF];
chars[j++] = Text.HEX_DIGITS_LOWER[bytes[i] & 0xF]; chars[j++] = Text.HEX_DIGITS_LOWER[bytes[i] & 0xF];
} }
is.close();
return new String(chars); return new String(chars);
} catch (IOException e) { } catch (IOException | NoSuchAlgorithmException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
} }

View File

@ -1,5 +1,10 @@
package com.imyeyu.io; package com.imyeyu.io;
import com.imyeyu.java.TimiJava;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
/** /**
* 字节大小工具 * 字节大小工具
* *
@ -38,20 +43,13 @@ public class IOSize {
EB; EB;
/** /**
* 转换指定单位字节量 * 转换字节量
* *
* @param unit 单位
* @param value 值 * @param value 值
* @return 该单位值字节量 * @return 该单位值字节量
*/ */
public static long value(Unit unit, double value) { public long toBytes(double value) {
Unit[] values = values(); return (long) (value * Math.pow(1024, ordinal()));
for (int i = 0; i < values.length; i++) {
if (values[i] == unit) {
return (long) (value * Math.pow(1024, i));
}
}
return (long) value;
} }
} }
@ -165,4 +163,66 @@ public class IOSize {
} }
return "0"; return "0";
} }
/**
* 将格式化的储存量字符串解析为字节量
* <p>支持格式10GB, 10 GB, 1TB, 1.24 KB 等(单位不区分大小写)</p>
* <pre>
* // 返回 102400
* IOSize.parse("100 KB");
* // 返回 1073741824
* IOSize.parse("1GB");
* </pre>
*
* @param sizeStr 格式化后的储存量字符串
* @return 字节量
* @throws IllegalArgumentException 格式无效
*/
public static long parse(String sizeStr) {
if (TimiJava.isEmpty(sizeStr)) {
throw new IllegalArgumentException("not found sizeStr");
}
// 正则匹配:可选符号 + 数字(含小数点)+ 可选空格 + 单位
Pattern pattern = Pattern.compile("([-+]?\\d+(?:\\.\\d+)?)\\s*([a-zA-Z]+)");
Matcher matcher = pattern.matcher(sizeStr.trim());
if (matcher.find()) {
double value;
try {
value = Double.parseDouble(matcher.group(1));
} catch (NumberFormatException e) {
throw new IllegalArgumentException("invalid number format: " + matcher.group(1), e);
}
if (value < 0) {
throw new IllegalArgumentException("size cannot be negative: " + value);
}
String unitStr = matcher.group(2).toUpperCase();
Unit unit;
try {
unit = Unit.valueOf(unitStr);
} catch (IllegalArgumentException e) {
// 处理单字母单位缩写K/M/G/T/P/E
unit = switch (unitStr.charAt(0)) {
case 'K' -> Unit.KB;
case 'M' -> Unit.MB;
case 'G' -> Unit.GB;
case 'T' -> Unit.TB;
case 'P' -> Unit.PB;
case 'E' -> Unit.EB;
case 'B' -> Unit.B;
default -> throw new IllegalArgumentException("Unknown unit: " + unitStr);
};
}
return unit.toBytes(value);
}
// 尝试解析纯数字(无单位,默认字节)
try {
long bytes = Long.parseLong(sizeStr.trim());
if (bytes < 0) {
throw new IllegalArgumentException("size cannot be negative: " + bytes);
}
return bytes;
} catch (NumberFormatException e) {
throw new IllegalArgumentException("invalid size format: " + sizeStr, e);
}
}
} }