?? server.java
字號(hào):
/* * @(#)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) { } }}
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -