client.java

一个简单而精彩的java聊天室小程序

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
//import java.net.InetAddress;
import java.net.Socket;


public class client {
	public static Socket serverSocket = null; 

	public static void main(String[] args)throws Exception{ 
		serverSocket = new Socket("192.168.0.166",1234); 
		//BufferedReader in=new BufferedReader(new InputStreamReader(serverSocket.getInputStream())); 
		PrintWriter out=new PrintWriter(serverSocket.getOutputStream()); 
		//BufferedReader wt=new BufferedReader(new InputStreamReader(server.getInputStream()));//System.in)); 
		String str;
		
		recieve rec = new recieve();
		rec.start();
		
		while(true){ 
			//String str=wt.readLine();
			BufferedReader readBuf;
			readBuf = new BufferedReader(new InputStreamReader(System.in));
			str = readBuf.readLine();
			out.println(str); 
			out.flush(); 
			if(str.equals("end")){ 
				break; 
			}
			//str = in.readLine();
			//System.out.println(str);

			/*if (str.equals("wd")){
				break;
			}else{
				str = "wd";
			}*/
		} 
		
		//System.in.read();
		//out.println(str); 
		//out.flush(); 
		//server.close(); 
	}
}

class recieve extends Thread {
	String str;
	public void run() {
		try {
			while (true) {
				BufferedReader in=new BufferedReader(new InputStreamReader(client.serverSocket.getInputStream()));
				str = in.readLine();
				System.out.println(str);
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
}