comclient.java

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

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

public class comClient {
	//public PrintStream ops;
	//public DataInputStream ips;
	public PrintWriter ops;
	public BufferedReader ips;
	
	public String cltRequest;
	public String svrResponse;
	
	public comClient(String serverName, int port) {
		try {
			//Socket clientSocket = new Socket(serverName, port);
			Socket clientSocket = new Socket(InetAddress.getLocalHost(), port);
			ops = new PrintWriter(clientSocket.getOutputStream());
			ips = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
		}catch(Exception e) {
			System.out.println("Unable to connect to server!");
		}
	}
	
	public void sendRequest(String request) {
		ops.println(request);
		ops.flush();
	}
	
	@SuppressWarnings("deprecation")
	public String getResponse() {
		String str = new String();
		try {
			str = ips.readLine();
			System.out.println(str);
		}catch(IOException e) {
			System.out.println("read error");
		}
		
		return str;
	}
	
	public static void main(String[] args) {
		//comClient cli = new comClient("127.0.0.1",5678);
		String msg = "Hello world";
		String msg1 = "I am wd";
		
		Socket clientSocket;
		try {
			clientSocket = new Socket(InetAddress.getLocalHost(), 5678);
			BufferedReader ips = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
			PrintWriter ops = new PrintWriter(clientSocket.getOutputStream());
			while (true) {
				ops.println(msg);
				ops.flush();
				
				System.out.println(ips.readLine());
				
				if (msg.equals(msg1)){
					msg = "end";
					break;
				}else{
					msg = msg1;
				}
			}
			
			System.in.read();
			ops.println(msg);
			ops.flush();
			clientSocket.close();
		} catch (UnknownHostException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		} catch (IOException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		
		
		
		//cli.sendRequest("Hello world");
		//cli.getResponse();
		//cli.sendRequest("I am wd");
		
		
	}
}