[Java] java基于C/S结构实现多线程聊天室

import java.io.bufferedreader;
import java.io.ioexception;
import java.io.inputstreamreader;
import java.io.printstream;
import java.net.socket;
import java.net.serversocket;
import java.util.arraylist;
import javax.swing.joptionpane;
 
public class myserver {
 
 public static arraylist<socket> socketlist = new arraylist<socket>();
 private static string port ;
 public static void main(string[] args) throws ioexception
 {
 //弹出一个对话框输入端口号
 port = joptionpane.showinputdialog("input the port number: ");
 int serverport = new integer(port).intvalue();
 
 serversocket ss = new serversocket(serverport);
 system.out.println("server is initializating...");
 while(true)
 {
 system.out.println("server is waiting...");
 
 //此处将阻塞监听
 socket s = ss.accept();
 system.out.println("listening from: " + s.getinetaddress());
 socketlist.add(s);
 new thread(new serverthread(s)).start();
 }
 }
 
}
class serverthread implements runnable
{
 socket s = null;
 bufferedreader br = null;
 public serverthread(socket s) throws ioexception
 {
 this.s = s;
 br = new bufferedreader(new inputstreamreader(s.getinputstream()));
 }
 public void run()
 {
 try
 {
 string content = null;
 while( (content = readfromclient()) != null )
 {
 //播报每个客户端数据
 for(socket s : myserver.socketlist)
 {
 printstream ps = new printstream(s.getoutputstream());
 ps.println(content);
 }
 }
 }
 catch (ioexception io) 
 {
 io.printstacktrace();
 }
 }
 private string readfromclient()
 {
 try
 {
 return br.readline();
 }
 catch (ioexception io)
 {
 myserver.socketlist.remove(s);
 system.out.println(s.getinetaddress() + " is disconnecting...");
 }
 return null;
 }
 
}

import java.net.socket;
import java.io.bufferedreader;
import java.io.ioexception;
import java.io.inputstreamreader;
import java.io.printstream;
 
public class myclient {
 
 public static void main(string[] args) throws exception
 {
 socket s = new socket("192.168.1.164", 30000);
 
 // new thread to read content from server.
 new thread(new clientthread(s)).start();
 
 printstream ps = new printstream(s.getoutputstream());
 string line = null;
 bufferedreader br = new bufferedreader(new inputstreamreader(system.in));
 while((line = br.readline()) != null)
 {
 ps.println(line);
 }
 }
}
class clientthread implements runnable
{
 private socket s = null;
 bufferedreader br = null;
 public clientthread(socket s) throws ioexception
 {
 this.s = s;
 br = new bufferedreader(new inputstreamreader(s.getinputstream()));
 }
 public void run()
 {
 try
 {
 string content = null;
 while( (content = br.readline()) != null)
 {
 system.out.println(content);
 }
 }
 catch (ioexception io)
 {
 io.printstacktrace();
 }
 }
}