Наши проекты:
Журнал · Discuz!ML · Wiki · DRKB · Помощь проекту |
||
ПРАВИЛА | FAQ | Помощь | Поиск | Участники | Календарь | Избранное | RSS |
[3.133.144.217] |
|
Сообщ.
#1
,
|
|
|
Добрый день!
Вобщем не могу разобраться как отследить состояния соединения в клиенте Socket с сервер. При разрыве соединения (Плохой сигнал GSM и имитируя путем закрытия порта на роутере) клиент думает что он еще соединен, при этом даже от него можно пытаться отсылать сообщения и тоже ошибки нет, как будто чего-то не хватает для обработки, хотя catch есть. Делал по примеру NetworkDemo1. Чистый NetworkDemo1 тоже самая ситуация. package socket; import java.io.*; import javax.microedition.io.*; import javax.microedition.lcdui.*; import javax.microedition.midlet.*; public class Client implements Runnable, CommandListener { private SocketMIDlet parent; private Display display; private Form f; private StringItem si; private TextField tf; private boolean stop; private Command sendCommand = new Command("Send", Command.ITEM, 1); private Command exitCommand = new Command("Exit", Command.EXIT, 1); InputStream is; OutputStream os; SocketConnection sc; Sender sender; public Client(SocketMIDlet m) { parent = m; display = Display.getDisplay(parent); f = new Form("Socket Client"); si = new StringItem("Status:", " "); tf = new TextField("Send:", "", 30, TextField.ANY); f.append(si); f.append(tf); f.addCommand(exitCommand); f.addCommand(sendCommand); f.setCommandListener(this); display.setCurrent(f); } /** * Start the client thread */ public void start() { Thread t = new Thread(this); t.start(); } public void run() { try { sc = (SocketConnection)Connector.open("socket://krogal-home.dyndns.org:5000"); si.setText("Connected to server"); is = sc.openInputStream(); os = sc.openOutputStream(); // Start the thread for sending messages - see Sender's main // comment for explanation sender = new Sender(os); // Loop forever, receiving data while (true) { StringBuffer sb = new StringBuffer(); int c = 0; while (((c = is.read()) != '\n') && (c != -1)) { sb.append((char)c); } if (c == -1) { break; } // Display message to user si.setText("Message received - " + sb.toString()); } stop(); si.setText("Connection closed"); f.removeCommand(sendCommand); } catch (ConnectionNotFoundException cnfe) { Alert a = new Alert("Client", "Please run Server MIDlet first", null, AlertType.ERROR); a.setTimeout(Alert.FOREVER); a.setCommandListener(this); display.setCurrent(a); } catch (IOException ioe) { if (!stop) { ioe.printStackTrace(); } } catch (Exception e) { e.printStackTrace(); } } public void commandAction(Command c, Displayable s) { if ((c == sendCommand) && !parent.isPaused()) { sender.send(tf.getString()); } if ((c == Alert.DISMISS_COMMAND) || (c == exitCommand)) { parent.notifyDestroyed(); parent.destroyApp(true); } } /** * Close all open streams */ public void stop() { try { stop = true; if (sender != null) { sender.stop(); } if (is != null) { is.close(); } if (os != null) { os.close(); } if (sc != null) { sc.close(); } } catch (IOException ioe) { } } } package socket; import java.io.*; import javax.microedition.io.*; import javax.microedition.lcdui.*; import javax.microedition.midlet.*; public class Sender extends Thread { private OutputStream os; private String message; public Sender(OutputStream os) { this.os = os; start(); } public synchronized void send(String msg) { message = msg; notify(); } public synchronized void run() { while (true) { // If no client to deal, wait until one connects if (message == null) { try { wait(); } catch (InterruptedException e) { } } if (message == null) { break; } try { os.write(message.getBytes()); //os.write("\r\n".getBytes()); } catch (IOException ioe) { ioe.printStackTrace(); } // Completed client handling, return handler to pool and // mark for wait message = null; } } public synchronized void stop() { message = null; notify(); } } |