线程 TCP 连接 - Android

Question

我正在尝试制作一个将一些数据包发送到嵌入式设备的 Android 应用。 由于我的嵌入式设备不支持 UDP 数据报协议，我想使用同步 TCP 来模拟它。

话虽如此，不需要来自设备的响应字符串，所以我想在从我的应用程序发送数据后立即断开 TCP 套接字。

如果有人能概述如何创建一个线程来执行连接并在某个时间范围内没有收到数据时关闭套接字，我将不胜感激。

我目前的代码很简单：

    try {
        Socket s = new Socket("localhost",12345);

        //outgoing stream redirect to socket
        OutputStream out = s.getOutputStream();

        PrintWriter output = new PrintWriter(out);
        output.println("Hello Android!");
        BufferedReader input = new BufferedReader(new InputStreamReader(s.getInputStream()));

        //read line(s)
        String st = input.readLine();
        . . .
        //Close connection
        s.close();


} catch (UnknownHostException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
} catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
}

提前谢谢你！！！

Answer 1

首先要注意协议，如果您的应用程序卡在String st = input.readLine();，这并不意味着服务器不发送数据，因为readLine() 方法需要一行（以CRLF 结尾），这是可能的该服务器只是发送一些没有换行的字符串，然后缓冲读取器仍然卡住线程（当前线程），因为它需要 CRLF。 接下来，您将有另一个接受 Socket 作为参数的类，然后等待一段时间，然后由于服务器没有响应而关闭套接字。像这样

class SocketMgr implements Runnable{
final private int timeout=5000;
private Socket s;
public SocketMgr(Socket s){this.s=s;new Thread(this).start();}
public void run(){
try{Thread.sleep(timeout);s.close();}catch(Exception ex){}
}
}

在你的代码中

 try {
        Socket s = new Socket("localhost",12345);

        //outgoing stream redirect to socket
        OutputStream out = s.getOutputStream();

        PrintWriter output = new PrintWriter(out);
        output.println("Hello Android!");
        output.flush();
        BufferedReader input = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //////////////////////////////////
        new SocketMgr(s);
        //////////////////////////////////
        //read line(s)
        String st = input.readLine();
        . . .
        //Close connection
        s.close();


} catch (UnknownHostException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
} catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
}

你也可以看看这个简单的[java threading tutorial] 再一次，了解属于您的服务器的协议很重要。 祝你好运，有一个不错的套接字程序:)。