Threaded TCP connection - 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. Далее вы бы еще один класс, который принимает гнездо в качестве параметра, а затем ждет некоторое время, а затем закрыть сокет из-за отсутствия ответа от сервера., Что-то вроде этого

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] еще раз, это важно знать о протоколе, принадлежащем вашему серверу. Удачи, у вас хорошая программа сокетов :).