聊天室---BS架构jsp版.rar

package DD; import java.io.*; import java.net.*; import java.awt.*; public class Server extends Frame implements Runnable { ServerSocket server; Socket connection; OutputStream output; InputStream input; Thread outThread; TextArea display; TextField text1; Button startButton; public static void main(String args[]) { Server s = new Server(); } public Server() { super("Server"); startButton = new Button("Start the server"); text1 = new TextField(20); display = new TextArea(7, 30); display.setEditable(false); add("North", startButton); add("Center", display); add("South", text1); resize(300, 600); show(); } public boolean action(Event e, Object o) { if (e.target == startButton) { display.setText("启动服务器...\n"); startButton.setEnabled(false); try { server = new ServerSocket(5000, 100); connection = server.accept(); output = connection.getOutputStream(); input = connection.getInputStream(); outThread = new Thread(this); outThread.start(); } catch (IOException ee) {} } else if (e.target == text1) { byte writeBytes[] = new byte[50]; String s = "Server: " + text1.getText() + "\n"; text1.setText(""); writeBytes = s.getBytes(); display.append(s); try { output.write(writeBytes); } catch (IOException ee) {} if (s.trim().equals("Server: exit")) { outThread.stop(); quit(); } } return true; } public void run() { while (true) { byte readBytes[] = new byte[50]; try { input.read(readBytes); } catch (IOException e) {} String s = new String(readBytes); display.append(s); if (s.trim().equals("Client: exit")) break; } quit(); } public void quit() { try { output.close(); input.close(); connection.close(); } catch (IOException e) {} startButton.setEnabled(true); } public boolean handleEvent(Event e) { if (e.id == Event.WINDOW_DESTROY) System.exit(0); return super.handleEvent(e); } }