java服务器间http通讯，同时传输文件流和数据，并接收返回的文件流或数据
废话：这里使用的是HttpUrlConnection，httpclient没有试过，这篇文章也是收集了很多大佬的成果，但是由于太久远了找不到原文了，如果有大佬看到提醒一下，愿意贴上原文链接的哈，抱歉抱歉，现在实现了同时传输文件和数据，但是response返回的文件和数据只能接收一个，如果大家有同时接收的方法，望告知，谢谢大家了。
需求：其实就是服务器间通过http进行通讯，不走前端的那种，公司需求给某个网址主动发文件流，并且接收response中的反馈文件流或者错误信息。
连接工具类HttpUrlConnection.java,现在支持传多个数据，一个文件，如果需要多个文件，照着改改应该没问题的
@Componentpublic class HttpUrlConnection {
//头部格式
private static final String nextLine = "\r\n";
private static final String twoHyphens = "--";
//随便写一个
private static final String boundary = java.util.UUID.randomUUID().toString();
/**
* @Description:java项目的服务端之间的通信
* @Param: [requestUrl,请求url
* jsessionId, 浏览器的访问的Cookie，即被访问的服务端的session。若被访问的服务器没有做url过滤器，则该参数可以为null。
* file, 发送出去的文件
* feedbackFile, 收到的反馈文件存放位置
* name,对方用来接收文件的名字
* params,要传的参数
* @Return: java.util.Map
* @Author: Liting
* @Date: 2019-11-26 08:54
*/
public static Map httpUrlConnection(String requestUrl, String jsessionId, File file, String feedbackFile, String name, Map<String,String> params) throws IOException {
HttpURLConnection con = (HttpURLConnection) new URL(requestUrl).openConnection();
if (!Utils.isEmpty(jsessionId)) {
con.setRequestProperty("Cookie", "JSESSIONID=" + jsessionId);
}
// 设置是否向httpUrlConnection输出，因为这个是post请求，参数要放在
// http正文内，因此需要设为true, 默认情况下是false;
con.setDoOutput(true);
// 设置是否从httpUrlConnection读入，默认情况下是true;
con.setDoInput(true);
// 设定请求的方法为"POST"，默认是GET
con.setRequestMethod("POST");
// Post 请求不能使用缓存
con.setUseCaches(false);
//设置接收返回值的格式
con.setRequestProperty("Accept", "text/plain, */*");
//设置接收编码
con.setRequestProperty("Accept-Language", "zh-cn");
con.setRequestProperty("Host","127.0.0.1");
//设置请求参数格式以及boundary分割线
con.setRequestProperty("Content-Type", "multipart/form-data;boundary=" + boundary);
con.setRequestProperty("User-Agent"," WinHttpClient");
//开启长连接可以持续传输
con.setRequestProperty("Connection", "Keep-Alive");
//连接超时时间20秒con.setConnectTimeout(20000);
//读取超时时间20秒con.setReadTimeout(20000);
OutputStream out = con.getOutputStream();
//分隔符头部
//拼接参数
if (!Utils.isEmpty(params)){
int i = 0;
for (String paramName : params.keySet()){
StringBuffer strBufparam = new StringBuffer();
strBufparam.append(twoHyphens);
strBufparam.append(boundary);
strBufparam.append(nextLine);
strBufparam.append("Content-Disposition: form-data;name=\""+paramName+"\"");
strBufparam.append(nextLine);
strBufparam.append("Content-Type: " + "text/plain");
strBufparam.append(nextLine);
strBufparam.append("Content-Length: " + params.get(paramName).getBytes().length);
strBufparam.append(nextLine);
strBufparam.append(nextLine);
strBufparam.append(params.get(paramName));
i++;
if (i!=params.size()){
strBufparam.append(nextLine);
}
out.write(strBufparam.toString().getBytes());
}
}
//拼接文件
if (!Utils.isEmpty(file)){
StringBuffer strBufFile = new StringBuffer();
strBufFile.append(nextLine);
strBufFile.append(twoHyphens);
strBufFile.append(boundary);
strBufFile.append(nextLine);
strBufFile.append("Content-Disposition: form-data; name=\""+name+"\"; filename=\"" + file.getName() + "\"");
strBufFile.append(nextLine);
strBufFile.append("Content-Type: " + "application/x-tar");
strBufFile.append(nextLine);
strBufFile.append("Content-Length: " + file.length());
strBufFile.append(nextLine);
strBufFile.append(nextLine);
//写入输出流
out.write(strBufFile.toString().getBytes());
//读取本地文件流
FileInputStream inputStream = new FileInputStream(file);
byte[] data = new byte[2048];
int len = 0;
int sum = 0;
while ((len = inputStream.read(data)) != -1) {
//将读取到的本地文件流读取到HttpsURLConnection,进行上传
out.write(data, 0, len);
sum = len + sum;
}
//文件写入完成后加回车
out.write(nextLine.getBytes());
inputStream.close();
}
//写入结束分隔符
String footer = nextLine + twoHyphens + boundary + twoHyphens + nextLine;
out.write(footer.getBytes());
out.flush();
out.close();
con.connect();
int responseCode = con.getResponseCode();
if (responseCode == HttpURLConnection.HTTP_OK) {
if (!Utils.isEmpty(feedbackFile)) {//有返回文件的时候
String fileName = "";
try {
fileName = con.getHeaderField(1).substring(21, con.getHeaderField(1).length() - 1);
fileName = "EBDT"+fileName.split("_")[1];
System.out.println(fileName);
}catch (Exception e){
return null;
}
BufferedInputStream in = new BufferedInputStream(con.getInputStream());
File f = new File(feedbackFile);
if (!f.exists()) {
f.mkdirs();
}
File res = new File(feedbackFile+"/"+fileName);
FileOutputStream fos = new FileOutputStream(res);
byte[] by = new byte[1024];
int length = 0;
while ((length = in.read(by)) != -1) {
fos.write(by, 0, length);
}
fos.close();
in.close();
con.disconnect();
if (Utils.isEmpty(fos)) {
return null;
}
//处理接收到的文件
//保存到本地
Map map = new HashMap();
map.put("fileName",fileName);
return map;
}else{
//接收到的return中的值
BufferedReader br = new BufferedReader(new InputStreamReader(
con.getInputStream()));
String s = br.readLine();
br.close();
con.disconnect();
try{
if (!Utils.isEmpty(s)){
Object m = JSONObject.parse(s);
Map map = (Map) m;
return map;
}
}catch (Exception e){
Map map = new HashMap();
map.put("feedback",s);
return map;
}
}
return new HashMap();
} else {
con.disconnect();
return null;
}
}
}
main方法测试
public static void main(String[] args) throws IOException { Map<String,String> map = new HashMap<>();
map.put("name","张三");
map.put("age","23");
File file = new File("D:\\1.xml");
Map map1 = HttpUrlConnection.httpUrlConnection("http://127.0.0.1/user/addUser", "69e4baee-ff22-4cdf-a73b-6156c5d6d2c1", file, "",
"files", map);
System.out.println(map1);
}
结果
到这就是全部了，如有问题欢迎留言
以上是 java服务器间http通讯，同时传输文件流和数据，并接收返回的文件流或数据 的全部内容， 来源链接： utcz.com/z/392885.html
