public class Main {
public static String BOUNDARY = "----------" + System.currentTimeMillis();
/**
* 向服务器发送post请求
* @param serverUrl URL地址
* @return 服务器返回结果
* @param formText 文本表单
* @throws Exception
*
*/
public static String sendHttpPostRequest(String serverUrl, String[] filePaths, Map<String, String> formText) throws Exception {
// 向服务器发送post请求
URL url = null;
try {
url = new URL(serverUrl);
} catch (MalformedURLException e) {
e.printStackTrace();
return e.getMessage();
}
HttpURLConnection connection = null;
try {
connection = (HttpURLConnection) url.openConnection();
} catch (IOException e) {
e.printStackTrace();
return e.getMessage();
}
// 发送POST请求头信息
connection.setDoOutput(true);
connection.setDoInput(true);
connection.setUseCaches(false);
try {
connection.setRequestMethod("POST");
} catch (ProtocolException e) {
e.printStackTrace();
return e.getMessage();
}
connection.setRequestProperty("Connection", "Keep-Alive");
connection.setRequestProperty("Charset", "UTF-8");
connection.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + BOUNDARY);
StringBuilder message = new StringBuilder();//存放请求信息
// 链接服务器获得输出流
try (OutputStream out = new DataOutputStream(connection.getOutputStream())) {
// 第一部分：传递文本表单
for (String key : formText.keySet()) {
message.append("--").append(BOUNDARY).append("\r\n").append("Content-Disposition: form-data; name=\"")
.append(key + "\"").append("\r\n").append("\r\n").append(formText.get(key)).append("\r\n");
}
// 写入文本表单信息
String boundaryMessage1 = message.toString();
out.write(boundaryMessage1.getBytes("utf-8"));
// 第二部分： 循环读取上传文件读取个文件
for (int i = 0; i < filePaths.length; i++) {
File file = new File(filePaths[i]);
if (!file.exists()) {
throw new Exception("文件不存在或路径错误!");
}
message.delete(0, message.length());
message.append("--");
message.append(BOUNDARY);
message.append("\r\n");
message.append("Content-Disposition: form-data;name=\"files\";filename=\"" + file.getName() + "\"\r\n");
message.append("Content-Type:application/octet-stream\r\n\r\n");
byte[] head = message.toString().getBytes("utf-8");
// 输出文件表头
out.write(head);
// 文件正文部分
// 把文件已流文件的方式 推入到url中
try (DataInputStream in = new DataInputStream(new FileInputStream(file))) {
int bytes = 0;
byte[] bufferOut = new byte[1024];
while ((bytes = in.read(bufferOut)) != -1) {
out.write(bufferOut, 0, bytes);
}
} catch (IOException e) {
e.printStackTrace();
}
// 写入两个文件之间得分隔符，如果没有两个文件内容会被写在一个文件中
out.write("\r\n".getBytes("utf-8"));
}
// 结尾部分
byte[] foot = ("\r\n--" + BOUNDARY + "--\r\n").getBytes("utf-8");// 定义最后数据分隔线
out.write(foot);
out.flush();
} catch (IOException e1) {
e1.printStackTrace();
return e1.getMessage();
}
// 4. 从服务器获得回答的内容
String strLine = "";
String strResponse = "";
try (InputStream responseIO = connection.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(responseIO));) {
while ((strLine = reader.readLine()) != null) {
strResponse += strLine + "\n";
}
} catch (IOException e) {
e.printStackTrace();
return e.getMessage();
}
return strResponse;
}
public static void main(String[] args) {
//map用于存放input数据key对应name value对应map的value
Map<String, String> map = new HashMap<String, String>();
String specUrl = "";//文件上传接口
//这里的String[] 数组用于存放文件路径集合
map = addTestData();
String[] str = addTestData2();
try {
String response = sendHttpPostRequest(specUrl,str,map);
System.out.println(response);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
//测试数据
//文件以外的其它参数
public static Map<String,String> addTestData() {
Map<String,String> map = new HashMap<>();
map.put("id","378708d81a274d35abf54fa0413cfd9e");
return map;
}
//文件路径
public static String[] addTestData2() {
String[] args = new String[] {"D:/ssss.sql"};
return args;
}
}
网友评论