chatroomserver.java

用java socket技术实现多人聊天室

package chatserver2;
	import java.awt.*;
	import java.awt.event.*;
	import java.io.*;
	import java.net.*;

	public class ChatRoomServer extends Frame implements Runnable{
	 Panel panel;
	 ScrollPane sPanel;
	 TextArea textArea;
	 Button button1;
	 ServerSocket serverSock;
	 public final static int DEFAULT_PORT=6666;//默认端口号
	 Thread chatAcceptThread;//启动接受连接的线程
	 BroadcastThread broadcastThread;//广播thread; run when server is listening 
	 java.util.Vector clients;//记录连接的线程
	 java.util.Vector clientsInfor;//记录连接线程的信息
	 public static int index=0;
	 
	 public ChatRoomServer(){
	  try{
	   jbInit();
	  }catch(Exception e){
	   e.printStackTrace();
	  }
	  serverListen();//服务器开始监听
	 }
	 
	 private void jbInit(){//初始化界面
	  panel=new Panel();
	  sPanel=new ScrollPane();
	  textArea=new TextArea("server information:\n");
	  button1=new Button("退出");
	  
	  sPanel.add(textArea);
	  
	  button1.addActionListener(new java.awt.event.ActionListener(){//退出按钮注册
	   public void actionPerformed(ActionEvent e){
	    button1_actionPerformed(e);
	   }
	  });
	  panel.add(button1);
	  
	  this.addWindowListener(new ChatFrame_WindowAdapter(this));//注册到继承了窗口适配器的类
	  this.setSize(600,600);
	  this.setLayout(new BorderLayout());
	  this.add(sPanel,BorderLayout.CENTER);
	  this.add(panel,BorderLayout.SOUTH);
	  this.show();
	  
	 }
	 
	 private void button1_actionPerformed(ActionEvent e){
	  exit();
	 }
	 
	 public void processMsg(String str){//
	  textArea.append(str);
	 }
	 
	 private void serverListen(){
	  try{
	   serverSock=new ServerSocket(DEFAULT_PORT);
	  }catch(IOException e){
	   processMsg(e.toString());
	   processMsg("server failed!\n");
	  }
	  processMsg("server listening on port:"+DEFAULT_PORT);
	  clients=new java.util.Vector();
	  clientsInfor=new java.util.Vector();
	  
	  chatAcceptThread=new Thread(this);//启动接受连接的线程
	  chatAcceptThread.start();
	  
	  broadcastThread=new BroadcastThread(this);//广播线程
	  broadcastThread.start();
	  
	  //还有一个回收无用连接thread 的线程
	 }
	  
	 public void run(){//接受连接并记录线程信息
	  int i=0;
	  try{
	   while(true){
	    Socket clientSock=serverSock.accept();
	    CommunicateThread ct=new CommunicateThread(clientSock,this,index);//创建线程保持连接
	    clients.add(ct);//record Communicate Thread;
	    i++;
	    index++;//version2
	    clientsInfor.add("Thread-"+i);
	    processMsg("Thread-"+i+"join in\n");
	    
	   }
	  }catch(IOException e){
	   processMsg(e.toString());
	  } 
	 }
	 
	 public void exit(){
	  broadcastThread.broadcast("Server exit!");
	  try{
	   serverSock.close();
	  }catch(IOException ioe){}
	  finally{
	   System.exit(0);
	  }
	 }
	 
	 public static void main(String[] args){
	  ChatRoomServer chat=new ChatRoomServer();
	 }
	}