multijabberserver.java

这是我自己写的一个聊天程序

import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

import javax.swing.JOptionPane;
import javax.swing.JWindow;

public class MultiJabberServer extends Thread
{
 public static final int PORT=5555;
 public String [] user;
 public static int num;
 ServerSocket ss;
// TotalClient client;
 public MultiJabberServer()throws Exception
 {
	 user=new String[100];
//	 client=new TotalClient();
	 ss=new ServerSocket(PORT); 
 }
 public void run()
 {
	 JOptionPane.showMessageDialog(new JWindow(),"服务器已启动!"+ss,"系统消息",JOptionPane.INFORMATION_MESSAGE);
	 System.out.println("Server started:"+ss);
	 try
	 {
		 while(true)
		 {
			 Socket s=ss.accept();
			 Client.client.add(s);
//			 client.elementCount++;
//			 ServeroneJabber soj=new ServeoneJabber(s,Client,user,num++);
			 System.out.println("Connection accepted:"+s);
		 }
	 }
	 catch(Exception e)
	 {
		 e.printStackTrace();
	 }
 }

 public String castMessage(String mess) throws Exception
 {
	 boolean isSend=false;
	 int i;
	 for(i=0;i<Client.client.size();i++)
	 {
		 Socket sss=(Socket)Client.client.get(i);
		 System.out.println(sss);
		 PrintWriter everyout=new PrintWriter(new BufferedWriter(new OutputStreamWriter(sss.getOutputStream())),true);
		 everyout.println(">>>>系统广播:"+mess);
		 System.out.println("Send ok!");
	 }
	 if(i==Client.client.size()+1)
	 {
		 isSend=true;
	 }
	 if(isSend=true)
	 {
		 return(mess);
	 }
     return "";
 }
 
}