한빛출판네트워크

 
import java.io.*;
import java.net.*;
import java.util.*;

public class Server {
  public static void main(String[] args) throws IOException {
    String name = args[0];
    int port = Integer.parseInt(args[1]);
    new Server(name, port);
  }

  private List mClients;
  private String mName;

  public Server(String name, int port) throws IOException {
    mClients = new Vector();
    mName = name;
    ServerSocket serverSocket = new ServerSocket(port);
    while (true) addClient(serverSocket.accept());
  }

  public void addClient(Socket clientSocket) throws IOException {
    final PrintWriter out =
        new PrintWriter(clientSocket.getOutputStream(), true);
    mClients.add(out);
    
    out.println("[Welcome to " + mName + ".]");
    
    new Listener(clientSocket.getInputStream()) {
      public void processLine(String line) {
        if (line.length() == 0) mClients.remove(out);
        else sendToClients(line);
      }
    };
  }
  
  public void sendToClients(String line) {
    Iterator iterator = mClients.iterator();
    while(iterator.hasNext()) {
      PrintWriter out = (PrintWriter)iterator.next();
      out.println(line);
    }
  }
}

 
import java.io.*;

public abstract class Listener  {
  public abstract void processLine(String line);

  private BufferedReader mIn;
  
  public Listener(InputStream in) {
    mIn = new BufferedReader(new InputStreamReader(in));
    Thread t = new Thread() {
      public void run() {
        try {
          String line;
          while ((line = mIn.readLine()) != null) processLine(line);
        }
        catch (IOException ioe) {}
      }
    };
    t.start();
  }
}

 
import java.io.*;

import javax.microedition.io.*;

import com.sun.kjava.*;

public class Client
    extends Spotlet {
  private static Graphics sGraphics;

  public static void main(String[] args) throws IOException {
    // Clear off the KVM splash screen.
    sGraphics = Graphics.getGraphics();
    sGraphics.clearScreen();

    // Put up the login screen.
    Login l = new Login();
    l.register(NO_EVENT_OPTIONS);
  }

  private String mName;
  private String[] mDisplayLines;
  private TextField mInputField;
  private PrintStream mOut;

  public Client(final String name, StreamConnection s)
      throws IOException {
    mName = name;
    mDisplayLines = new String[12];
    for (int i = 0; i < mDisplayLines.length; i++)
      mDisplayLines[i] = "";
    createUI();
    wireNetwork(s);
  }
  
  public void shutDown() {
    mOut.println("");
    mOut.close();
  }

  protected void createUI() {
    // Create the Input field and give it focus.
    mInputField = new TextField("Send", 0, 0, 144, 12);
    mInputField.setText("");
    mInputField.setFocus();
  }
    
  protected void wireNetwork(StreamConnection s)
      throws IOException {
    mOut = new PrintStream(s.openOutputStream());

    new Listener(s.openInputStream()) {
      public void processLine(String line) {
        for (int i = 0; i < mDisplayLines.length - 1; i++)
          mDisplayLines[i] = mDisplayLines[i + 1];
        mDisplayLines[mDisplayLines.length - 1] = line;
        paint();
      }
    };
  }

  public void paint() {
    sGraphics.clearScreen();
    // Paint UI controls.
    mInputField.paint();
    // Draw the chat lines.
    for (int i = 0; i < mDisplayLines.length; i++)
      sGraphics.drawString(mDisplayLines[i], 0, 16 + 12 * i);
  }
  
  public void keyDown(int key) {
    if (mInputField.hasFocus()) {
      if (key == "￦n") sendLine();
      else mInputField.handleKeyDown(key);
    }
  }

  protected void sendLine() {
    // Send the stuff to the server.
    String line = mName + ": " + mInputField.getText();
    mOut.println(line);
    mInputField.setText("");
  }
}

 
import java.io.*;

import javax.microedition.io.*;

import com.sun.kjava.*;

public class Login
    extends Spotlet {
  private static Graphics sGraphics = Graphics.getGraphics();
  private TextField mNameField, mHostField, mPortField;
  private Button mLoginButton, mCancelButton;

  public Login() {
    mNameField = new TextField("Name", 30, 30, 100, 12);
    mNameField.setText("Palmer");
    mNameField.setFocus();
    mHostField = new TextField("Host", 30, 60, 100, 12);
    mHostField.setText("172.16.0.3");
    mPortField = new TextField("Port", 30, 90, 100, 12);
    mPortField.setText("7099");
    mLoginButton = new Button("Login", 30, 120);
    mCancelButton = new Button("Cancel", 90, 120);
    paint();
  }

  public void paint() {
    // Paint UI controls.
    mNameField.paint();
    mHostField.paint();
    mPortField.paint();
    mLoginButton.paint();
    mCancelButton.paint();
  }

  public void keyDown(int key) {
    if (mNameField.hasFocus()) mNameField.handleKeyDown(key);
    else if (mHostField.hasFocus()) mHostField.handleKeyDown(key);
    else if (mPortField.hasFocus()) mPortField.handleKeyDown(key);
  }
  
  public void penDown(int x, int y) {
    if (mLoginButton.pressed(x, y)) login();
    else if (mCancelButton.pressed(x, y)) System.exit(0);
    else if (mNameField.pressed(x, y)) setFocus(mNameField);
    else if (mHostField.pressed(x, y)) setFocus(mHostField);
    else if (mPortField.pressed(x, y)) setFocus(mPortField);
  }
  
  private void setFocus(TextField t) {
    killFocus();
    t.setFocus();
  }
  
  private void killFocus() {
    if (mNameField.hasFocus()) mNameField.loseFocus();
    if (mHostField.hasFocus()) mHostField.loseFocus();
    if (mPortField.hasFocus()) mPortField.loseFocus();
  }

  public void login() {
    killFocus();
    unregister();
    try {
      String name = mNameField.getText();
      String host = mHostField.getText();
      int port = Integer.parseInt(mPortField.getText());

      String url = "socket://" + host + ":" + port;
      
      StreamConnection s = (StreamConnection)
          Connector.open(url);
      Client c = new Client(name, s);
      c.register(NO_EVENT_OPTIONS);
    }
    catch (IOException ioe) {
      System.out.println(ioe);
      System.exit(0);
    }
  }
}

 
import java.io.*;

public class BufferedReader {
  private Reader mReader;
  private char[] mBuffer;
  
  public BufferedReader(Reader r) {
    mReader = r;
    mBuffer = new char[512];
  }

  public String readLine() throws IOException {
    boolean trucking = true;
    int index = 0;
    while (trucking) {
      int c = mReader.read();
      if (c == "￦n" || c == -1) trucking = false;
      else if (c != "￦r") mBuffer[index++] = (char)c;
    }
    if (index == 0) return null;
    String line = new String(mBuffer, 0, index);
    return line;
  }
}