myserver.java

基于socket的聊天室程序java源码

package homework.h20090412.IM02;

/*一个作为Server*/
import java.io.*;
import java.net.*;

public class MyServer{
	public static void main(String[] args) throws IOException{
		ServerSocket s=new ServerSocket(8000);
		System.out.println("开始："+s);
		try{
			Socket socket=s.accept();
			try{
				System.out.println("连接接受"+socket);
				BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
				PrintWriter out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
				while(true){
					String str=in.readLine();
					if(str.equals("q")) break;
					System.out.println("对方说："+str);
					BufferedReader is=new BufferedReader(new InputStreamReader(System.in));
					String input=new String();
					input=is.readLine().trim();
					out.println(input);
					System.out.print("我说：");
					out.flush();
				}
			}
			finally{
				System.out.println("关闭....");
				socket.close();
			}
		}
		finally{
			s.close();
		}
	}
}