Commit c847a7c7 by 王祖波

优化

parent d5d03481
...@@ -15,6 +15,7 @@ import java.awt.image.BufferedImage; ...@@ -15,6 +15,7 @@ import java.awt.image.BufferedImage;
import java.io.ByteArrayOutputStream; import java.io.ByteArrayOutputStream;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream;
import java.net.URL; import java.net.URL;
import java.util.Iterator; import java.util.Iterator;
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ArrayBlockingQueue;
...@@ -39,7 +40,7 @@ public class ImageCombined { ...@@ -39,7 +40,7 @@ public class ImageCombined {
40, 40,
60L, 60L,
TimeUnit.SECONDS, TimeUnit.SECONDS,
new ArrayBlockingQueue<>(60), new ArrayBlockingQueue<>(40),
new ThreadPoolExecutor.AbortPolicy() new ThreadPoolExecutor.AbortPolicy()
); );
...@@ -107,13 +108,16 @@ public class ImageCombined { ...@@ -107,13 +108,16 @@ public class ImageCombined {
private static BufferedImage loadImageWithReader(String url) { private static BufferedImage loadImageWithReader(String url) {
try { try {
URL imageUrl = new URL(url); URL imageUrl = new URL(url);
ImageInputStream input = ImageIO.createImageInputStream(imageUrl.openStream()); try (InputStream inputStream = imageUrl.openStream();
Iterator<ImageReader> readers = ImageIO.getImageReaders(input); ImageInputStream imageInputStream = ImageIO.createImageInputStream(inputStream)) {
Iterator<ImageReader> readers = ImageIO.getImageReaders(imageInputStream);
if (readers.hasNext()) { if (readers.hasNext()) {
ImageReader reader = readers.next(); ImageReader reader = readers.next();
reader.setInput(input, true); reader.setInput(imageInputStream, true);
return reader.read(0); return reader.read(0);
} }
}
} catch (IOException e) { } catch (IOException e) {
logger.error("读取异常: {}", url, e); logger.error("读取异常: {}", url, e);
} }
......
import cn.hutool.core.io.FileUtil; import cn.hutool.core.io.FileUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.http.HttpUtil; import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
...@@ -78,8 +80,12 @@ public class QWmediaTest { ...@@ -78,8 +80,12 @@ public class QWmediaTest {
try { try {
semaphore.acquire(); // 获取许可,控制并发请求 semaphore.acquire(); // 获取许可,控制并发请求
jo.put("imageUrl", list.get(requestId)); jo.put("imageUrl", list.get(requestId));
String post = HttpUtil.post("https://www.gicdev.com/haoban-manage3-wx/combined-qw-materialid.json", jo.toJSONString()); HttpResponse execute = HttpRequest.post("https://www.gicdev.com/haoban-manage3-wx/combined-qw-materialid.json").timeout(1000000).body(jo.toJSONString()).execute();
System.out.println(post); String body = execute.body();
String headerValue = execute.header("x-request-id");
// String post = HttpUtil.post("https://www.gicdev.com/haoban-manage3-wx/combined-qw-materialid.json", jo.toJSONString());
System.out.println(body);
System.out.println(headerValue);
} catch (Exception e) { } catch (Exception e) {
System.out.println("异常: " + e.getMessage()); System.out.println("异常: " + e.getMessage());
} finally { } finally {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment