Compare commits
7 Commits
016e0b0962
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
| acb1304650 | |||
| 56afd301fb | |||
| a240c00996 | |||
| fbcf21e990 | |||
| f3623d03a2 | |||
| e63d1103d8 | |||
| 016c0b7e2f |
58
pom.xml
58
pom.xml
@ -16,6 +16,64 @@
|
||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||
</properties>
|
||||
|
||||
<build>
|
||||
<plugins>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-deploy-plugin</artifactId>
|
||||
<version>3.1.3</version>
|
||||
</plugin>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-source-plugin</artifactId>
|
||||
<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>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-javadoc-plugin</artifactId>
|
||||
<version>3.11.2</version>
|
||||
<executions>
|
||||
<execution>
|
||||
<id>attach-javadocs</id>
|
||||
<phase>package</phase>
|
||||
<goals>
|
||||
<goal>jar</goal>
|
||||
</goals>
|
||||
</execution>
|
||||
</executions>
|
||||
</plugin>
|
||||
</plugins>
|
||||
</build>
|
||||
|
||||
<distributionManagement>
|
||||
<repository>
|
||||
<id>timi_nexus</id>
|
||||
<url>https://nexus.imyeyu.com/repository/maven-releases/</url>
|
||||
</repository>
|
||||
</distributionManagement>
|
||||
|
||||
<repositories>
|
||||
<repository>
|
||||
<id>timi_nexus</id>
|
||||
<url>https://nexus.imyeyu.com/repository/maven-public/</url>
|
||||
<releases>
|
||||
<enabled>true</enabled>
|
||||
</releases>
|
||||
<snapshots>
|
||||
<enabled>true</enabled>
|
||||
</snapshots>
|
||||
</repository>
|
||||
</repositories>
|
||||
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>com.imyeyu.io</groupId>
|
||||
|
||||
@ -1,5 +1,6 @@
|
||||
package com.imyeyu.network;
|
||||
|
||||
import com.imyeyu.utils.Encoder;
|
||||
import org.apache.hc.client5.http.fluent.Form;
|
||||
import org.apache.hc.core5.http.NameValuePair;
|
||||
|
||||
@ -13,13 +14,27 @@ import java.util.Map;
|
||||
* @author 夜雨
|
||||
* @since 2025-06-26 15:41
|
||||
*/
|
||||
public class FormMap<K, V> extends HashMap<K, V> {
|
||||
public class ArgMap<K, V> extends HashMap<K, V> {
|
||||
|
||||
public List<NameValuePair> build() {
|
||||
public List<NameValuePair> toNameValuePair() {
|
||||
Form form = Form.form();
|
||||
for (Map.Entry<K, V> item : entrySet()) {
|
||||
form.add(item.getKey().toString(), item.getValue().toString());
|
||||
}
|
||||
return form.build();
|
||||
}
|
||||
|
||||
public String toURL() {
|
||||
StringBuilder sb = new StringBuilder();
|
||||
for (Map.Entry<K, V> item : entrySet()) {
|
||||
sb.append(item.getKey().toString()).append('=').append(Encoder.urlArg(item.getValue().toString()));
|
||||
sb.append('&');
|
||||
}
|
||||
sb.deleteCharAt(sb.length() - 1);
|
||||
return sb.toString();
|
||||
}
|
||||
|
||||
public String toURL(String url) {
|
||||
return url + "?" + toURL();
|
||||
}
|
||||
}
|
||||
@ -1,6 +1,7 @@
|
||||
package com.imyeyu.network;
|
||||
|
||||
import org.apache.hc.client5.http.fluent.Request;
|
||||
import org.apache.hc.core5.util.Timeout;
|
||||
|
||||
import java.io.IOException;
|
||||
|
||||
@ -28,6 +29,26 @@ public class CommonRequest {
|
||||
return new CommonRequest(Request.post(url));
|
||||
}
|
||||
|
||||
public CommonRequest timeout(long ms) {
|
||||
request.connectTimeout(Timeout.ofMilliseconds(ms)).responseTimeout(Timeout.ofMilliseconds(ms));
|
||||
return this;
|
||||
}
|
||||
|
||||
public CommonRequest header(String key, String value) {
|
||||
request.addHeader(key, value);
|
||||
return this;
|
||||
}
|
||||
|
||||
public CommonRequest token(String token) {
|
||||
request.addHeader("Token", token);
|
||||
return this;
|
||||
}
|
||||
|
||||
public CommonRequest language(String langHeader) {
|
||||
request.addHeader("Accept-Language", langHeader);
|
||||
return this;
|
||||
}
|
||||
|
||||
public String asString() throws IOException {
|
||||
return request.execute().returnContent().asString();
|
||||
}
|
||||
@ -39,4 +60,8 @@ public class CommonRequest {
|
||||
public byte[] asBytes() throws IOException {
|
||||
return request.execute().returnContent().asBytes();
|
||||
}
|
||||
|
||||
public void execute() throws IOException {
|
||||
request.execute();
|
||||
}
|
||||
}
|
||||
|
||||
@ -34,6 +34,27 @@ public class FileRequest extends CommonRequest {
|
||||
return new FileRequest(Request.post(url));
|
||||
}
|
||||
|
||||
@Override
|
||||
public FileRequest timeout(long ms) {
|
||||
super.timeout(ms);
|
||||
return this;
|
||||
}
|
||||
|
||||
public FileRequest header(String key, String value) {
|
||||
request.addHeader(key, value);
|
||||
return this;
|
||||
}
|
||||
|
||||
public FileRequest token(String token) {
|
||||
request.addHeader("Token", token);
|
||||
return this;
|
||||
}
|
||||
|
||||
public FileRequest language(String langHeader) {
|
||||
request.addHeader("Accept-Language", langHeader);
|
||||
return this;
|
||||
}
|
||||
|
||||
public void toFile(String path, String fileName) throws IOException, NoPermissionException {
|
||||
toFile(new File(IO.fitPath(path) + fileName));
|
||||
}
|
||||
|
||||
@ -7,6 +7,7 @@ import com.google.gson.JsonParser;
|
||||
import com.google.gson.reflect.TypeToken;
|
||||
import com.imyeyu.java.TimiJava;
|
||||
import org.apache.hc.client5.http.fluent.Request;
|
||||
import org.apache.hc.core5.http.ContentType;
|
||||
|
||||
import java.io.IOException;
|
||||
|
||||
@ -45,6 +46,32 @@ public class GsonRequest extends CommonRequest {
|
||||
return this;
|
||||
}
|
||||
|
||||
@Override
|
||||
public GsonRequest timeout(long ms) {
|
||||
super.timeout(ms);
|
||||
return this;
|
||||
}
|
||||
|
||||
public GsonRequest header(String key, String value) {
|
||||
request.addHeader(key, value);
|
||||
return this;
|
||||
}
|
||||
|
||||
public GsonRequest token(String token) {
|
||||
request.addHeader("Token", token);
|
||||
return this;
|
||||
}
|
||||
|
||||
public GsonRequest language(String langHeader) {
|
||||
request.addHeader("Accept-Language", langHeader);
|
||||
return this;
|
||||
}
|
||||
|
||||
public GsonRequest body(Object object) {
|
||||
request.bodyString(getGson().toJson(object), ContentType.APPLICATION_JSON);
|
||||
return this;
|
||||
}
|
||||
|
||||
public <T> T resultAs(Class<T> clazz) throws IOException {
|
||||
return getGson().fromJson(super.asString(), clazz);
|
||||
}
|
||||
|
||||
@ -42,10 +42,33 @@ public class ProgressiveRequest extends FileRequest {
|
||||
return new ProgressiveRequest(Request.post(url), callback);
|
||||
}
|
||||
|
||||
@Override
|
||||
public ProgressiveRequest timeout(long ms) {
|
||||
super.timeout(ms);
|
||||
return this;
|
||||
}
|
||||
|
||||
public ProgressiveRequest header(String key, String value) {
|
||||
request.addHeader(key, value);
|
||||
return this;
|
||||
}
|
||||
|
||||
public ProgressiveRequest token(String token) {
|
||||
request.addHeader("Token", token);
|
||||
return this;
|
||||
}
|
||||
|
||||
public ProgressiveRequest language(String langHeader) {
|
||||
request.addHeader("Accept-Language", langHeader);
|
||||
return this;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void toFile(Path outputPath) throws IOException, NoPermissionException {
|
||||
processResponse(request.execute(), IO.getOutputStream(outputPath.toFile()));
|
||||
}
|
||||
|
||||
@Override
|
||||
public void toFile(File file) throws IOException, NoPermissionException {
|
||||
processResponse(request.execute(), IO.getOutputStream(file));
|
||||
}
|
||||
@ -55,6 +78,7 @@ public class ProgressiveRequest extends FileRequest {
|
||||
return new String(asBytes());
|
||||
}
|
||||
|
||||
@Override
|
||||
public byte[] asBytes() throws IOException {
|
||||
ByteArrayOutputStream os = new ByteArrayOutputStream();
|
||||
processResponse(request.execute(), os);
|
||||
|
||||
@ -28,6 +28,33 @@ public class TimiRequest extends GsonRequest {
|
||||
return new TimiRequest(Request.post(url));
|
||||
}
|
||||
|
||||
@Override
|
||||
public TimiRequest timeout(long ms) {
|
||||
super.timeout(ms);
|
||||
return this;
|
||||
}
|
||||
|
||||
public TimiRequest header(String key, String value) {
|
||||
request.addHeader(key, value);
|
||||
return this;
|
||||
}
|
||||
|
||||
public TimiRequest token(String token) {
|
||||
request.addHeader("Token", token);
|
||||
return this;
|
||||
}
|
||||
|
||||
public TimiRequest language(String langHeader) {
|
||||
request.addHeader("Accept-Language", langHeader);
|
||||
return this;
|
||||
}
|
||||
|
||||
@Override
|
||||
public TimiRequest body(Object object) {
|
||||
super.body(object);
|
||||
return this;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String asString() throws IOException {
|
||||
return resultAs(String.class);
|
||||
@ -53,4 +80,12 @@ public class TimiRequest extends GsonRequest {
|
||||
}
|
||||
return resp.getData();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void execute() throws IOException {
|
||||
TimiResponse<?> resp = getGson().fromJson(asJsonObject(), TypeToken.getParameterized(TimiResponse.class, Object.class).getType());
|
||||
if (resp.isFail()) {
|
||||
throw resp.toException();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@ -0,0 +1,41 @@
|
||||
package com.imyeyu.network.test;
|
||||
|
||||
import com.imyeyu.io.IOSize;
|
||||
import com.imyeyu.network.FileRequest;
|
||||
import com.imyeyu.network.ProgressiveRequest;
|
||||
import org.apache.hc.client5.http.fluent.Request;
|
||||
import org.apache.hc.core5.http.Header;
|
||||
import org.apache.hc.core5.http.HttpResponse;
|
||||
import org.junit.Test;
|
||||
|
||||
/**
|
||||
* @author 夜雨
|
||||
* @since 2025-07-14 15:30
|
||||
*/
|
||||
public class ProgressRequestTest {
|
||||
|
||||
private static final String URL1 = "http://localhost:8091/system/file/download/video/test92MB.mp4?key=GS60MF78GbPhImiCN4fsi3T2E5tDfP1scxufVhbuccaxldba0okpQPgKq4ntyr0J";
|
||||
private static final String URL2 = "https://git.imyeyu.com/test92MB.mp4";
|
||||
private static final String URL3 = "http://localhost:8092/test/download";
|
||||
|
||||
@Test
|
||||
public void testGet() throws Exception {
|
||||
ProgressiveRequest.get(URL1, (total, read, now) -> {
|
||||
System.out.println(1D * read / total);
|
||||
return true;
|
||||
}).asBytes();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testLength() throws Exception {
|
||||
long length = FileRequest.wrap(Request.head(URL2)).length();
|
||||
System.out.println(IOSize.format(length));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testLength2() throws Exception {
|
||||
HttpResponse response = Request.head(URL3).execute().returnResponse();
|
||||
final Header contentLengthHeader = response.getHeader("Content-Length");
|
||||
System.out.println(contentLengthHeader.getValue());
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user