如何解析非标准的 HTTP 响应？

Question

我很难弄清楚如何解析非标准的 HTTP 响应。

无标准响应包含ICY 200 OK 而不是HTTP 200 OK。这是一个发送非标准 HTTP 响应的示例 URL。
http://50.117.121.162:80

自 Android 4.4 起，HttpURLConnection 将不再使用这些非标准响应。我曾尝试使用 Apache 的 HttpClient，但由于没有标准的 HTTP 响应，它不起作用。然后，我尝试按照添加custom response parser 的指南进行操作，但Android 似乎没有执行此操作所需的所有类。

我真的很难找到解决方案。可能在HttpClient 或HttpURLConnection 解析之前修改非标准响应可以工作，但我不确定这是否可能......

任何帮助将不胜感激。

Answer 1

在对小型/精简 http 客户端库进行大量研究后，我遇到了 apache httpclient for android 的这个端口。该库为 http 连接提供了完整的支持。然后我只是简单地修改了源代码，特别是 BasicLineParser 以将 ICY 替换为 HTTP/1.0。

Answer 2

我在使用 KitKat 时遇到了类似的问题，并且成功地使用了 here 的两个类用于 http 帖子。它们非常易于使用，您也可以轻松修改协议参数。

Answer 3

在 Android 4.4 中有另一个解决方案，但它需要使用 Apache HttpClient。这是基于向 Apache Http 引擎提供自定义响应解析器的可能性，该引擎可以将 ICY 200 OK 更改为 HTTP/1.0 200 OK。这是基于以下中提出的一般想法：

http://hc.apache.org/httpcomponents-client-4.2.x/tutorial/html/advanced.html

我已经成功使用了以下代码。

public class IcyClientConnection extends DefaultClientConnection{

@Override
protected HttpMessageParser createResponseParser(SessionInputBuffer buffer,
        HttpResponseFactory responseFactory, HttpParams params) {

    return new IcyHttpResponseParser(
            buffer, 
            new BasicLineParser (), 
            responseFactory, 
            params);

}

}


public class IcyClientConnectionOperator extends DefaultClientConnectionOperator {

    public IcyClientConnectionOperator(SchemeRegistry schemes) {
        super(schemes);
    }

    @Override
    public OperatedClientConnection createConnection() {

        return new IcyClientConnection();
    }

}



public class IcyClientConnManager extends SingleClientConnManager  {


    public IcyClientConnManager(HttpParams params, SchemeRegistry schreg) {
        super(params, schreg);
    }

    @Override
    protected ClientConnectionOperator createConnectionOperator(
            SchemeRegistry schreg) {
        return new IcyClientConnectionOperator(schreg);
    }

}

现在您必须扩展默认使用的解析器，并添加代码来更改错误的服务器重播以更正一个。通常代码会阻塞hasProtocolVersion。

public class IcyHttpResponseParser extends DefaultResponseParser{

    private CharArrayBuffer icyLineBuf;

    private int icyMaxGarbageLines = 1000;
    private final HttpResponseFactory icyResponseFactory;




public IcyHttpResponseParser(SessionInputBuffer buffer, LineParser parser,
        HttpResponseFactory responseFactory, HttpParams params) {
    super(buffer, parser, responseFactory, params);

    this.icyLineBuf = new CharArrayBuffer(128);
    icyResponseFactory = responseFactory;
}

@Override
protected HttpMessage parseHead(SessionInputBuffer sessionBuffer)
        throws IOException, HttpException {
    int count = 0;
    ParserCursor cursor = null;
    do {
        // clear the buffer
        this.icyLineBuf.clear();
        final int i = sessionBuffer.readLine(this.icyLineBuf);

        //look for ICY and change to HTTP to provide compatibility with non standard shoutcast servers

        String tmp = icyLineBuf.substring(0, this.icyLineBuf.length());
        if(tmp.contains("ICY ")){
            tmp = tmp.replace("ICY", "HTTP/1.0");
        }
        //copy
        this.icyLineBuf = new CharArrayBuffer(128);
        System.arraycopy(tmp.toCharArray(), 0, icyLineBuf.buffer(), 0, tmp.length());
        icyLineBuf.setLength( tmp.length());


        if (i == -1 && count == 0) {
            // The server just dropped connection on us
            throw new NoHttpResponseException("The target server failed to respond");
        }
        cursor = new ParserCursor(0, this.icyLineBuf.length());
        if (lineParser.hasProtocolVersion(this.icyLineBuf, cursor)) {
            // Got one
            break;
        } else if (i == -1 || count >= this.icyMaxGarbageLines) {
            // Giving up
            throw new ProtocolException("The server failed to respond with a " +
                    "valid HTTP response");
        }
        //if (this.log.isDebugEnabled()) {
        //   this.log.debug("Garbage in response: " + this.lineBuf.toString());
       // }
        count++;
    } while(true);
    //create the status line from the status string
    final StatusLine statusline = lineParser.parseStatusLine(this.icyLineBuf, cursor);
    return this.icyResponseFactory.newHttpResponse(statusline, null);
}
}

---

插入HttpClient：

Scheme http = new Scheme("http", PlainSocketFactory.getSocketFactory(), 80);
Scheme ftp = new Scheme("ftp", PlainSocketFactory.getSocketFactory(), 21);

SchemeRegistry sr = new SchemeRegistry();
sr.register(http);
sr.register(ftp);

HttpClient httpClient = new DefaultHttpClient(new IcyClientConnManager(params, sr), params);

这仍在测试中，但初步结果很有希望。

Answer 4

感谢@Michael M，您甚至可以通过继承 BasicLineParser 而不是继承 DefaultResponseParser 来简化它。

I've uploaded the code into a gist

使用它：

IcyGetRequest request = new IcyGetRequest(urlStr);
HttpResponse response = request.get();
int responseCode = response.getStatusLine().getStatusCode();

Answer 5

创建一个创建套接字代理的可运行对象，然后您将能够使用 HTTP/1.0 而不是 ICY 进行响应，然后只需使用您的播放器连接到这个本地套接字代理

Answer 6

这里是对Michal M 的解决方案的修改，以防您不喜欢创建大量子类只是为了配置已经可用的HttpClient 类。

final SchemeRegistry schemeRegistry = new SchemeRegistry();
schemeRegistry.register(new Scheme("http", PlainSocketFactory.getSocketFactory(), 80));
HttpClient httpClient = new DefaultHttpClient() {
    @Override
    protected ClientConnectionManager createClientConnectionManager() {
        return new SingleClientConnManager(getParams(), schemeRegistry) {
            @Override
            protected ClientConnectionOperator createConnectionOperator(SchemeRegistry schreg) {
                return new DefaultClientConnectionOperator(schreg) {
                    @Override
                    public OperatedClientConnection createConnection() {
                        return new DefaultClientConnection() {
                            @Override
                            protected HttpMessageParser createResponseParser(SessionInputBuffer buffer, HttpResponseFactory responseFactory, HttpParams params) {
                                return new IcyHttpResponseParser(buffer, new BasicLineParser(), responseFactory, params);
                            }
                        };
                    }
                };
            }
        };
    }
};

如果可以从DefaultHttpClient 类中以某种方式获取，则可能有一种方法可以使SchemeRegistry 过时。