基于j2me的手机聊天软件

import javax.microedition.midlet.*; import javax.microedition.io.*; import java.io.*; import java.util.*; public class Server extends MIDlet { private ServerSocketConnection ssc=null; private SocketConnection sc=null; private Vector threadVector=new Vector(); public void startApp() { try { ssc=(ServerSocketConnection)Connector.open("socket://:9999"); } catch(Exception ex){} ReceiveThread rt=new ReceiveThread(); rt.start(); } public void pauseApp() { } public void destroyApp(boolean unconditional) { } class ReceiveThread extends Thread { public void run() { while(true) { try { sc=(SocketConnection)ssc.acceptAndOpen(); ChatThread ct=new ChatThread(sc); ct.start(); threadVector.addElement(ct); } catch(Exception ex){} } } } class ChatThread extends Thread { private SocketConnection sc=null; private DataInputStream dis=null; private DataOutputStream dos=null; public ChatThread(SocketConnection sc) { try { this.sc=sc; dis=sc.openDataInputStream(); dos=sc.openDataOutputStream(); } catch(Exception ex){} } public void run() { while(true) { try { String msg=dis.readUTF(); for(int i=0;i<threadVector.size();i++) { ChatThread tmp_chat_thread=(ChatThread)threadVector.elementAt(i); tmp_chat_thread.dos.writeUTF(msg); } } catch(Exception ex){} } } } }