Skip to content

Instantly share code, notes, and snippets.

@trackscorer
Created September 13, 2018 10:14
Show Gist options
  • Save trackscorer/236800e1186a39f7892ebf128bfbc850 to your computer and use it in GitHub Desktop.
Save trackscorer/236800e1186a39f7892ebf128bfbc850 to your computer and use it in GitHub Desktop.
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
/**
* Http 请求访问工具类
*
* @author will_awoke
* @version 2014-6-26
* @see HttpAccessUtil
* @since
*/
public class HttpAccessUtil
{
/**
* 日志
*/
private static Logger log = Logger.getLogger(HttpAccessUtil.class);
/**
* 采取post方式提交序列化后的object对象 </br>
* 另请参考:java.io.ObjectInputStream/ObjectOutputStream
* @param requestUrl 请求地址
* @param connTimeoutMills 设置连接主机超时,单位:毫秒
* @param readTimeoutMills 设置从主机读取数据超时,单位:毫秒
* @param serializedObject 序列化后的object对象
*
* @return remoteHttp返回的结果
*/
public static String httpPostSerialObject(String requestUrl, int connTimeoutMills,
int readTimeoutMills, Object serializedObject) throws Exception
{
HttpURLConnection httpUrlConn = null;
InputStream inputStream = null;
InputStreamReader inputStreamReader = null;
BufferedReader bufferedReader = null;
ObjectOutputStream oos = null;
StringBuffer buffer = new StringBuffer();
try
{
URL url = new URL(requestUrl);
httpUrlConn = (HttpURLConnection)url.openConnection();
// 设置content_type=SERIALIZED_OBJECT
// 如果不设此项,在传送序列化对象时,当WEB服务默认的不是这种类型时可能抛java.io.EOFException
httpUrlConn.setRequestProperty("Content-Type","application/x-java-serialized-object");
httpUrlConn.setConnectTimeout(connTimeoutMills);
httpUrlConn.setReadTimeout(readTimeoutMills);
// 设置是否向httpUrlConn输出,因为是post请求,参数要放在http正文内,因此需要设为true, 默认情况下是false
httpUrlConn.setDoOutput(true);
// 设置是否从httpUrlConn读入,默认情况下是true
httpUrlConn.setDoInput(true);
// 不使用缓存
httpUrlConn.setUseCaches(false);
// 设置请求方式,默认是GET
httpUrlConn.setRequestMethod("POST");
httpUrlConn.connect();
if (serializedObject != null)
{
// 此处getOutputStream会隐含的进行connect,即:如同调用上面的connect()方法,
// 所以在开发中不调用上述的connect()也可以,不过建议最好显式调用
// write object(impl Serializable) using ObjectOutputStream
oos = new ObjectOutputStream(httpUrlConn.getOutputStream());
oos.writeObject(serializedObject);
oos.flush();
// outputStream不是一个网络流,充其量是个字符串流,往里面写入的东西不会立即发送到网络,
// 而是存在于内存缓冲区中,待outputStream流关闭时,根据输入的内容生成http正文。所以这里的close是必须的
oos.close();
}
// 将返回的输入流转换成字符串
// 无论是post还是get,http请求实际上直到HttpURLConnection的getInputStream()这个函数里面才正式发送出去
inputStream = httpUrlConn.getInputStream();//注意,实际发送请求的代码段就在这里
inputStreamReader = new InputStreamReader(inputStream, "UTF-8");
bufferedReader = new BufferedReader(inputStreamReader);
String str = null;
while ((str = bufferedReader.readLine()) != null)
{
buffer.append(str);
}
}
catch (Exception e)
{
log.error(requestUrl + " error ", e);
throw e;
}
finally
{
try
{
IOUtils.closeQuietly(bufferedReader);
IOUtils.closeQuietly(inputStreamReader);
IOUtils.closeQuietly(inputStream);
IOUtils.closeQuietly(oos);
if (httpUrlConn != null)
{
httpUrlConn.disconnect();
}
}
catch (Exception e)
{
log.error(e);
}
}
return buffer.toString();
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment