解释
我也遇到了这个问题，并通过提供我自己的实现来解决它，sun.net.www.protocol.http.HttpURLConnection我用它来处理任何 AJAX 请求。我的类，方便地调用AjaxHttpURLConnection，挂钩到getInputStream()函数中，但不返回其原始输入流。相反，我给出了一个PipedInputStreamback的实例WebEngine。然后我读取来自原始输入流的所有数据并将其传递给我的管道流。这样，我获得了 2 个好处：
- 我知道何时收到最后一个字节，因此 AJAX 请求已被完全处理。
- 我什至可以抓取所有传入的数据并已经使用它（如果我愿意的话）。
例子
首先，您必须告诉 Java 使用您的 URLConnection 实现而不是默认实现。为此，您必须为其提供您自己的URLStreamHandlerFactory. 您可以在 SO（例如这个）或通过 Google 找到有关此主题的许多线程。为了设置您的工厂实例，请将以下内容放在您main方法的早期位置。这就是我的样子。
import java.net.URLStreamHandler;
import java.net.URLStreamHandlerFactory;
public class MyApplication extends Application {
// ...
public static void main(String[] args) {
URL.setURLStreamHandlerFactory(new URLStreamHandlerFactory() {
public URLStreamHandler createURLStreamHandler(String protocol) {
if ("http".equals(protocol)) {
return new MyUrlConnectionHandler();
}
return null; // Let the default handlers deal with whatever comes here (e.g. https, jar, ...)
}
});
launch(args);
}
}
其次，我们必须想出自己的方法Handler来告诉程序何时使用哪种类型的URLConnection.
import java.io.IOException;
import java.net.Proxy;
import java.net.URL;
import java.net.URLConnection;
import sun.net.www.protocol.http.Handler;
import sun.net.www.protocol.http.HttpURLConnection;
public class MyUrlConnectionHandler extends Handler {
@Override
protected URLConnection openConnection(URL url, Proxy proxy) throws IOException {
if (url.toString().contains("ajax=1")) {
return new AjaxHttpURLConnection(url, proxy, this);
}
// Return a default HttpURLConnection instance.
return new HttpURLConnection(url, proxy);
}
}
最后但并非最不重要的一点是，AjaxHttpURLConnection.
import java.io.IOException;
import java.io.InputStream;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
import java.net.Proxy;
import java.net.URL;
import java.util.concurrent.locks.ReentrantLock;
import org.apache.commons.io.IOUtils;
import sun.net.www.protocol.http.Handler;
import sun.net.www.protocol.http.HttpURLConnection;
public class AjaxHttpURLConnection extends HttpURLConnection {
private PipedInputStream pipedIn;
private ReentrantLock lock;
protected AjaxHttpURLConnection(URL url, Proxy proxy, Handler handler) {
super(url, proxy, handler);
this.pipedIn = null;
this.lock = new ReentrantLock(true);
}
@Override
public InputStream getInputStream() throws IOException {
lock.lock();
try {
// Do we have to set up our own input stream?
if (pipedIn == null) {
PipedOutputStream pipedOut = new PipedOutputStream();
pipedIn = new PipedInputStream(pipedOut);
InputStream in = super.getInputStream();
/*
* Careful here! for some reason, the getInputStream method seems
* to be calling itself (no idea why). Therefore, if we haven't set
* pipedIn before calling super.getInputStream(), we will run into
* a loop or into EOFExceptions!
*/
// TODO: timeout?
new Thread(new Runnable() {
public void run() {
try {
// Pass the original data on to the browser.
byte[] data = IOUtils.toByteArray(in);
pipedOut.write(data);
pipedOut.flush();
pipedOut.close();
// Do something with the data? Decompress it if it was
// gzipped, for example.
// Signal that the browser has finished.
} catch (IOException e) {
e.printStackTrace();
}
}
}).start();
}
} finally {
lock.unlock();
}
return pipedIn;
}
}
进一步的考虑
- 如果您使用多个
WebEngine对象，可能很难判断哪个对象实际打开了URLConnection，以及哪个浏览器已完成加载。
- 您可能已经注意到我只处理 http 连接。我还没有测试我的方法可以在多大程度上转移到 https 等（这里不是专家：O）。
- 如您所见，我知道何时实际使用 my 的唯一方法
AjaxHttpURLConnection是相应的 url 何时包含ajax=1. 就我而言，这就足够了。但是，由于我不太擅长 html 和 http，因此我不知道它们是否WebEngine可以以任何不同的方式发出 AJAX 请求（例如，标头字段？）。如果有疑问，您总是可以简单地返回我们修改后的 url 连接的实例，但这当然意味着一些开销。
- 如开头所述，如果您愿意，可以在从输入流中检索到数据后立即处理数据。
WebEngine您可以以类似的方式获取您发送的请求数据。只需包装getOutputStream()函数并放置另一个中间流来抓取正在发送的任何内容，然后将其传递给原始输出流。