/* * @(#)Server.java	1.4 03/03/02 * * Copyright (c) 2004 Sun Microsystems, Inc.  All rights reserved. * Use is subject to license terms */package example.socket;import javax.microedition.io.*;import javax.microedition.lcdui.*;import java.io.InputStream;import java.io.OutputStream;import java.io.IOException;public class Server 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);    InputStream is;    OutputStream os;    SocketConnection sc;    Sender sender;    public Server(SocketMIDlet m) {        parent = m;        display = Display.getDisplay(parent);        f = new Form("Socket Server");        si = new StringItem("Status:" , " ");        tf = new TextField("Send:", "", 30, TextField.ANY);        f.append(si);        f.append(tf);        display.setCurrent(f);    }    public void start() {        Thread t = new Thread(this);        t.start();    }    public void run() {        try {            si.setText("Waiting for connection");            ServerSocketConnection scn = (ServerSocketConnection)                  Connector.open("socket://:5000");            // Wait for a connection.            sc = (SocketConnection) scn.acceptAndOpen();            si.setText("Connection accepted");            is  = sc.openInputStream();            os = sc.openOutputStream();            sender = new Sender(os);            // Allow sending of messages only after Sender is created            f.addCommand(sendCommand);            f.setCommandListener(this);            while (true) {                StringBuffer sb = new StringBuffer();                int c = 0;                while (((c = is.read()) != '\n') && (c != -1)) {                    sb.append((char) c);                }                si.setText("Message received - " + sb.toString());            }        } catch (IOException ioe) {            if (ioe.getMessage().equals("ServerSocket Open")) {                Alert a = new Alert("Server", "Port 5000 is already taken.",                                    null, AlertType.ERROR);                a.setTimeout(Alert.FOREVER);                a.setCommandListener(this);                display.setCurrent(a);            } else {                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) {            parent.notifyDestroyed();            parent.destroyApp(true);        }    }    /**     * Close all open streams     */    public void stop() {        try {            stop = true;            if (is != null) {                is.close();            }            if (os != null) {                os.close();            }            if (sc != null) {                sc.close();            }        }        catch (IOException ioe) {        }    }}