Banana-Coding.com - Java Knuddels Emulator

Quellcode

run:
BananaClient V0.1aaa
Socket[addr=localhost/127.0.0.1,port=2710,localport=50640]
java.io.IOException: InputStream is null!
	at mhclient.Protocol.decode(Protocol.java:9)
	at mhclient.ChatApplet.run(ChatApplet.java:111)
	at java.lang.Thread.run(Thread.java:722)
java.io.IOException: InputStream is null!
	at mhclient.Protocol.decode(Protocol.java:9)
	at mhclient.ChatApplet.run(ChatApplet.java:111)
	at java.lang.Thread.run(Thread.java:722)
java.io.IOException: InputStream is null!

PHP-Quelltext

// ChatApplet.java
public class ChatApplet extends javax.swing.JApplet implements ClientListener {
    private Client client;

    @Override
    public void init() {
         // initComponents();
         try {
            client = new Client("localhost", 2710);
            client.addListener(this);
        } catch (UnknownHostException ex) {
            Logger.getLogger(BananaChat.class.getName()).log(Level.SEVERE, null, ex);
        } catch (IOException ex) {
            Logger.getLogger(BananaChat.class.getName()).log(Level.SEVERE, null, ex);
        }
   }

  @Override
    public void OnButlerReceive(ButlerReceiveHandler e) {
        System.out.println(e.getName());
    }

}

// ClientListener.java
public interface ClientListener extends EventListener {
    public void OnButlerReceive(ButlerReceiveHandler e);
}

// MultiClientListener.java
public class MultiClientListener implements ClientListener {
    
    protected Vector listener = new Vector();

    public void add(ClientListener l) {
        listener.add(l);
    }

    public void remove(ClientListener l) {
        listener.remove(l);
    }

   @Override
    public void OnButlerReceive(ButlerReceiveHandler e) {
        for (int i = 0; i < listener.size(); i++) {
            ((ClientListener) listener.elementAt(i)).OnButlerReceive(e);
        }
    }
}

//ButlerReceiveHandler.java

public class ButlerReceiveHandler extends EventObject {

    protected String name;

    public String getName() {
        return name;
    }
    
    public ButlerReceiveHandler(Object source, String[] tokens) {
        super(source);
        this.name = tokens[1];
    }


//Client.java
public class Client implements Runnable {
    private Socket socket;
    private OutputStream out;
    protected MultiClientListener listener = null;

    public Client(String host, int port) throws UnknownHostException, IOException {
        this.socket = new Socket(host, port);
        out = socket.getOutputStream();
        listener = new MultiClientListener();
        new Thread(this).start();
    }

    public void addListener(ClientListener l) {
        listener.add(l);
    }

 @Override
    public void run() {
            //
            //...
            //
            while (true) {
                byte[] buffer = Protocol.decode(in);
                String packet = new String(buffer, "UTF8");
                String[] tokens = packet.split("\0");
                String opcode = tokens[0];
                if (opcode.equals(ReceiveOpcode.BUTLER.getValue())) { 
                    listener.OnButlerReceive(new ButlerReceiveHandler(this,tokens));
                } 
            }
    }
}