北大青鸟Y2新语聊天

import java.applet.*; import java.awt.*; import java.io.*; import java.net.*; import java.awt.event.*; public class ChatClient extends Applet{ protected boolean loggedIn;//登入状态 protected Frame cp;//聊天室框架 protected static int PORTNUM=7777; //缺省端口号7777 protected int port;//实际端口号 protected Socket sock; protected BufferedReader is;//用于从sock读取数据的BufferedReader protected PrintWriter pw;//用于向sock写入数据的PrintWriter protected TextField tf;//用于输入的TextField protected TextArea ta;//用于显示对话的TextArea protected Button lib;//登入按钮 protected Button lob;//登出的按钮 final static String TITLE ="Chatroom applet>>>>>>>>>>>>>>>>>>>>>>>>"; protected String paintMessage;//发表的消息 public ChatParameter Chat; public void init(){ paintMessage="正在生成聊天窗口"; repaint(); cp=new Frame(TITLE); cp.setLayout(new BorderLayout()); String portNum=getParameter("port");//呢个参数勿太明 port=PORTNUM; if (portNum!=null) //书上是portNum==null,十分有问题 port=Integer.parseInt(portNum); //CGI ta=new TextArea(14,80); ta.setEditable(false);//read only attribute ta.setFont(new Font("Monospaced",Font.PLAIN,11)); cp.add(BorderLayout.NORTH,ta); Panel p=new Panel(); Button b; //for login button p.add(lib=new Button("Login")); lib.setEnabled(true); lib.requestFocus(); lib.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e){ login(); lib.setEnabled(false); lob.setEnabled(true); tf.requestFocus();//将键盘输入锁定再右边的文本框中 } }); //for logout button p.add(lob=new Button ("Logout")); lob.setEnabled(false); lob.addActionListener(new ActionListener(){ public void actionPerformed(ActionEvent e){ logout(); lib.setEnabled(true); lob.setEnabled(false); lib.requestFocus(); } }); p.add(new Label ("输入消息:")); tf=new TextField(40); tf.addActionListener(new ActionListener(){ public void actionPerformed(ActionEvent e){ if(loggedIn){ //pw.println(Chat.CMD_BCAST+tf.getText());//Chat.CMD....是咩野来? int j=tf.getText().indexOf(":"); if(j>0) pw.println(Chat.CMD_MESG+tf.getText()); else pw.println(Chat.CMD_BCAST+tf.getText()); tf.setText("");//勿使用flush()? } } }); p.add(tf); cp.add(BorderLayout.SOUTH,p); cp.addWindowListener(new WindowAdapter(){ public void windowClosing(WindowEvent e){ //如果执行了setVisible或者dispose,关闭窗口 ChatClient.this.cp.setVisible(false); ChatClient.this.cp.dispose(); logout(); } }); cp.pack();//勿明白有咩用? //将Frame cp放在中间 Dimension us=cp.getSize(), them=Toolkit.getDefaultToolkit().getScreenSize(); int newX=(them.width-us.width)/2; int newY=(them.height-us.height)/2; cp.setLocation(newX,newY); cp.setVisible(true); paintMessage="Window should now be visible"; repaint(); } //登录聊天室 public void login(){ if(loggedIn) return; try{ sock=new Socket(getCodeBase().getHost(),port); is=new BufferedReader(new InputStreamReader(sock.getInputStream())); pw=new PrintWriter(sock.getOutputStream(),true); }catch(IOException e){ showStatus("Can't get socket: "+e); cp.add(new Label("Can't get socket: "+e)); return;} //构造并且启动读入器,从服务器读取数据,输出到文本框中 //这里,长成一个线程来避免锁住资源(lockups) new Thread (new Runnable(){ public void run(){ String line; try{ while(loggedIn &&((line=is.readLine())!=null)) ta.appendText(line+"\n"); }catch(IOException e){ showStatus("我的天啊,掉线了也!!!!"); return; } } }).start(); //假定登录(其实只是打印相关信息,并没有真正登录) // pw.println(Chat.CMD_LOGIN+"AppletUser"); pw.println(Chat.CMD_LOGIN+"AppletUser"); loggedIn =true; } //模仿退出的代码 public void logout(){ if(!loggedIn) return; loggedIn=false; try{ if(sock!=null) sock.close(); }catch(IOException ign){ // 异常处理哦 } } //没有设置stop的方法,即使从浏览器跳到另外一个网页的时候 //聊天程序还可以继续运行 public void paint(Graphics g){ Dimension d=getSize(); int h=d.height; int w=d.width; g.fillRect(0,0,w,2); g.setColor(Color.black); g.drawString(paintMessage,10,(h/2)-5); } } 聊天室服务器端 import java.net.*; import java.io.*; import java.util.*; public class ChatServer{ //聊天室管理员ID protected final static String CHATMASTER_ID="ChatMaster"; //系统信息的分隔符 protected final static String SEP=": "; //服务器的Socket protected ServerSocket servSock; //当前客户端列表 protected ArrayList clients; //调试标记 protected boolean DEBUG=false; public ChatParameter Chat; //主方法构造一个ChatServer,没有返回值 public static void main(String[] argv){ System.out.println("Chat server0.1 starting>>>>>>>>>>>>>>>>"); ChatServer w=new ChatServer(); w.runServer(); System.out.println("***ERROR*** Chat server0.1 quitting"); } //构造和运行一个聊天服务 ChatServer(){ Chat=new ChatParameter(); clients=new ArrayList(); try{ servSock=new ServerSocket(7777);//实有问题拉,不过可能是他自己定义既一个class. System.out.println("Chat Server0.1 listening on port:"+7777); }catch(Exception e){ log("IO Exception in ChatServer.<init>"); System.exit(0); } } public void runServer(){ try{ while(true){ Socket us=servSock.accept(); String hostName=us.getInetAddress().getHostName(); System.out.println("Accpeted from "+hostName); //一个处理的线程 ChatHandler cl=new ChatHandler(us,hostName); synchronized(clients){ clients.add(cl); cl.start(); if(clients.size()==1) cl.send(CHATMASTER_ID,"Welcome!You are the first one here"); else{ cl.send(CHATMASTER_ID,"Welcome!You are the latest of"+ clients.size()+" users."); } } } }catch(Exception e){ log("IO Exception in runServer:"+e); System.exit(0); } } protected void log(String s){ System.out.println(s); } //处理会话的内部的类 protected class ChatHandler extends Thread { //客户端scoket protected Socket clientSock; //读取socket的BufferedReader protected BufferedReader is ; //在socket 上发送信息行的PrintWriter protected PrintWriter pw; //客户端出主机 protected String clientIP; //句柄 protected String login; public ChatHandler (Socket sock,String clnt)throws IOException { clientSock=sock; clientIP=clnt; is=new BufferedReader( new InputStreamReader(sock.getInputStream())); pw=new PrintWriter (sock.getOutputStream(),true); } //每一个ChatHandler是一个线程,下面的是他的run()方法 //用于处理会话 public void run(){ String line; try{ while((line=is.readLine())!=null){ char c=line.charAt(0);//我顶你老母啊 ,果只Chat.CMD咩xx冇定义 扑啊///!!! line=line.substring(1); switch(c){ //case Chat.CMD_LOGIN: case 'l': if(!Chat.isValidLoginName(line)){ send(CHATMASTER_ID,"LOGIN"+line+"invalid"); log("LOGIN INVALID from:"+clientIP); continue; } login=line; broadcast(CHATMASTER_ID,login+" joins us,for a total of"+ clients.size()+" users"); break; // case Chat.CMD_MESG: case 'm': if(login==null){ send(CHATMASTER_ID,"please login first"); continue; } int where =line.indexOf(Chat.SEPARATOR); String recip=line.substring(0,where); String mesg=line.substring (where+1); log("MESG: "+login+"--->"+recip+": "+mesg); ChatHandler cl=lookup(recip); if(cl==null) psend(CHATMASTER_ID,recip+"not logged in."); else cl.psend(login,mesg); break; //case Chat.CMD_QUIT: case 'q': broadcast(CHATMASTER_ID,"Goodbye to "+login+"@"+clientIP); close(); return;//ChatHandler结束 // case Chat.CMD_BCAST: case 'b': if(login!=null) broadcast(login,line); else log("B<L FROM"+clientIP); break; default: log("Unknow cmd"+c+"from"+login+"@"+clientIP); } } }catch(IOException e){ log("IO Exception :"+e); }finally{ //sock 结束,我们完成了 //还不能发送再见的消息 //得有简单的基于命令的协议才行 System.out.println(login+SEP+"All Done"); synchronized(clients){ clients.