修改文件的上传超时时间,

修改线程数
广州市市一联众
zhanghai 12 months ago
parent 9fdc6a8dbc
commit 15462c6a27

@ -15,9 +15,9 @@ public class FileUploader {
public static CommonResult uploadFilesWithParams(List<File> files, String uploadUrl, List<FormField> params) throws IOException { public static CommonResult uploadFilesWithParams(List<File> files, String uploadUrl, List<FormField> params) throws IOException {
OkHttpClient client = new OkHttpClient.Builder() OkHttpClient client = new OkHttpClient.Builder()
.connectTimeout(600, TimeUnit.SECONDS) .connectTimeout(6000, TimeUnit.SECONDS)
.readTimeout(600, TimeUnit.SECONDS) .readTimeout(6000, TimeUnit.SECONDS)
.writeTimeout(600, TimeUnit.SECONDS) .writeTimeout(6000, TimeUnit.SECONDS)
.build(); .build();
MultipartBody.Builder builder = new MultipartBody.Builder(); MultipartBody.Builder builder = new MultipartBody.Builder();
for (File file : files) { for (File file : files) {

@ -34,8 +34,8 @@ public class UpdateService {
public void upload() { public void upload() {
String uniUrl = "http://192.168.8.74"; String uniUrl = "http://192.168.8.74";
List<CardInfo> cardInfos = null; List<CardInfo> cardInfos = null;
ExecutorService executor2 = Executors.newFixedThreadPool(20); ExecutorService executor2 = Executors.newFixedThreadPool(10);
ExecutorService executor = Executors.newFixedThreadPool(60); ExecutorService executor = Executors.newFixedThreadPool(90);
do { do {
try{ try{
cardInfos = this.updateData(); cardInfos = this.updateData();
@ -69,7 +69,7 @@ public class UpdateService {
Future future = executor.submit(() -> { Future future = executor.submit(() -> {
try { try {
String cmd = "C:\\Debug\\lianzhong.exe 003 192.168.8.74 " + cardInfo.getId() + " " + picture.getPicid() + " " + cardInfo.getPatno() + " " + cardInfo.getOutdateStr() + " " + picture.getPicname() + " " + picture.getFileUrl() + " " + uniUrl + " " + picture.getRotatedegree(); String cmd = "C:\\Debug\\lianzhong.exe 003 192.168.8.74 " + cardInfo.getId() + " " + picture.getPicid() + " " + cardInfo.getPatno() + " " + cardInfo.getOutdateStr() + " " + picture.getPicname() + " " + picture.getFileUrl() + " " + uniUrl + " " + picture.getRotatedegree();
log.info(cmd); // log.info(cmd);
java.lang.Process process = java.lang.Runtime.getRuntime().exec(cmd);//执行命令生成cube java.lang.Process process = java.lang.Runtime.getRuntime().exec(cmd);//执行命令生成cube
process.waitFor(); process.waitFor();
} catch (Exception e) { } catch (Exception e) {
@ -107,7 +107,7 @@ public class UpdateService {
List<FormField> params = new ArrayList<>(); List<FormField> params = new ArrayList<>();
String s = new Gson().toJson(uploadInfos); String s = new Gson().toJson(uploadInfos);
params.add(new FormField("uploadFileParams", s)); params.add(new FormField("uploadFileParams", s));
log.info("请求参数:"+s); log.info("请求参数:"+cardInfo.getPatno());
// 上传 // 上传
try { try {
CommonResult commonResult = FileUploader.uploadFilesWithParams(files, "http://192.168.161.102:9511/fileUploadJpg", params); CommonResult commonResult = FileUploader.uploadFilesWithParams(files, "http://192.168.161.102:9511/fileUploadJpg", params);

Loading…
Cancel
Save