所以我搜索了网络(主要是 SO，谷歌)以找到使用 Android 进行套接字编程的好例子。我做过很多 Android 开发(只是没有使用套接字)。我不明白为什么我的 readLine() 总是返回 NULL。请忽略丑陋的代码，这是给 friend 的快速而肮脏的原型(prototype)。我的总体目标是建立与服务器的连接，发送 header 数据(GET/MOUNTPOINT Content-Type:......等......)，并根据我需要继续流或关闭的响应接收响应它。这是我最近尝试的代码:

                    String userPass = new     String(Base64.encodeToString("user:password".getBytes(),     Base64.DEFAULT));
            boolean connected = false;
            String requestmsg = "GET /MOUNTPOINT" + " HTTP/1.0\r\n";
            requestmsg += "User-Agent: MYCUSTOMAGENT\r\n";
            requestmsg += "Accept: */*\r\n";
            requestmsg += "Connection: close\r\n";

            requestmsg += "Authorization: Basic " + userPass;

            requestmsg += "\r\n";
            DataOutputStream dos =  null;
            DataInputStream dis = null;
            try {

                Log.d("ClientActivity", "Connecting...");
                Socket socket = new Socket("1.2.3.4", 9000);
                connected = true;
                String data = "";

                while (connected) {
                    try {
                        Log.d("ClientActivity", "C: Sending command.");

                        dos = new DataOutputStream(socket.getOutputStream());
                        dis = new DataInputStream(socket.getInputStream());

                        dos.write(requestmsg.getBytes());
                        Log.i("ClientActivity", "RequestMsg Sent");

                        StringBuilder sb = new StringBuilder();

                        while ((data = dis.readLine()) != null)
                            {
                                sb.append(data);
                            }
                            Log.i("ClientActivity", "C: Sent.");
                    } catch (Exception e) {
                        Log.e("ClientActivity", "S: Error", e);

                    }
                }
                socket.close();
                Log.d("ClientActivity", "C: Closed.");
            } catch (Exception e) {
                Log.e("ClientActivity", "C: Error", e);
                connected = false;
            }

我试过使用 HttpClient API，但它在 header 中插入了“GET/”消息，我需要指定“GET/MOUNTPOINT”。另外我不知道 HttpClient 是否允许流式传输。我也试过 URLConnection，但它也默认插入 GET 或 POST。感谢您的帮助!

我也试过以下方法:

SocketAddress sockaddr = new InetSocketAddress("1.2.3.4", 9000);
nsocket = new Socket();

nsocket.connect(sockaddr, 10 * 1000); // 10 second connection timeout
    if (nsocket.isConnected()) {
        //nsocket.setSoTimeout(20 * 1000); // 20 second timeout once data is flowing
        nis = nsocket.getInputStream();
        nos = nsocket.getOutputStream();
        Log.i(NTAG, "Socket created, streams assigned");
        // Build request message
        requestmsg = "GET /MOUNTPOINT" + " HTTP/1.0\r\n";
        requestmsg += "User-Agent: MYANDROIDAGENT\r\n";
        requestmsg += "Accept: */*\r\n";
        requestmsg += "Connection: close\r\n";
        requestmsg += "Authorization: Basic " + userPass;
        requestmsg += "\r\n";

        nos.write(requestmsg.getBytes());


        nos.write(genGPGGA().getBytes());
        Log.i(NTAG, "Waiting for inital data...");
        byte[] buffer = new byte[4096];
        int read = nis.read(buffer); // This is blocking
        //Log.i("ReadNTRIP", tempdata.toString());
        String test = "TESTING";

        while (read != -1) {
            tempdata = new byte[read];
            System.arraycopy(buffer, 0, tempdata, 0, read);
            read = nis.read(buffer, 0, 4096); // This is blocking

        }
    }
} catch (SocketTimeoutException ex) {
    ex.printStackTrace();
} catch (Exception e) {
    e.printStackTrace();
} finally {
    try {
        nis.close();
        nos.close();
        nsocket.close();
    } catch (IOException e) {
        e.printStackTrace();
    } catch (Exception e) {
        e.printStackTrace();
    }
    Log.i(NTAG, "Finished");

}

但是读取总是返回-1。我准备拔头发了。

编辑:我增加了赏金(值(value)很小)——我没有太多的代表可以提供，但这个问题已经成为我的障碍。要获得赏金，请编写一个简单的 android 程序连接到 thor.lsu.edu，端口 9000，发送一个简单的 GET/HTTP/1.0 命令并实际取回数据(使用套接字 - 不能使用 URLConnection 或 HttpClient)。贴出程序和结果截图。我已经尝试了很多不同的方法，我不知道还能做什么(使用 InputStreams、BufferedInputStreams、InputStreamReaders 等)。我什至使用了一个示例 Android 程序(THAT WORKS)，但我仍然没有在我的实现中取回数据。我不知道这是时间问题还是什么。

谢谢

编辑:我注意到我什至无法浏览到 http://thor.lsu.edu:9000在安卓浏览器中。它给出了数据连接问题。知道为什么这个端口可能被阻止吗？

最佳答案

我所做的只是对您的代码进行了一些修改。我认为主要的变化只是没有使用 DataInputStream，因为文档明确表示不再在此数据结构上使用 readLine()。 http://download.oracle.com/javase/1.4.2/docs/api/java/io/DataInputStream.html#readLine%28%29

我还删除了授权内容，因为它不是必需的。如果您在某处运行此代码，您会注意到日志打印出了 HTTP 响应。

String requestmsg = "GET /MOUNTPOINT" + " HTTP/1.0\r\n";
    requestmsg += "User-Agent: MYCUSTOMAGENT\r\n";
    requestmsg += "Accept: */*\r\n";
    requestmsg += "Connection: close\r\n";

    // requestmsg += "Authorization: Basic " + userPass;

    requestmsg += "\r\n";
    DataOutputStream dos = null;
    BufferedReader dis = null;
    try {

        Log.d("ClientActivity", "Connecting...");
        Socket socket = new Socket("thor.lsu.edu", 9000);
        String data = "";

        try {
            Log.d("ClientActivity", "C: Sending command.");

            dos = new DataOutputStream(socket.getOutputStream());
            dis = new BufferedReader(new InputStreamReader(socket.getInputStream()));

            dos.write(requestmsg.getBytes());
            Log.i("ClientActivity", "RequestMsg Sent");

            StringBuilder sb = new StringBuilder();

            while ((data = dis.readLine()) != null) {
                sb.append(data);
            }
            Log.i("ClientActivity", "C: Sent.");
            Log.i("ClientActivity", "C: Received " + sb.toString());
        } catch (Exception e) {
            Log.e("ClientActivity", "S: Error", e);

        }

        socket.close();
        Log.d("ClientActivity", "C: Closed.");
    } catch (Exception e) {
        Log.e("ClientActivity", "C: Error", e);
    }

关于Android 套接字编程... 给出了什么？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/6638228/