import java.io.BufferedReader;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.PrintWriter;

import java.net.Socket;

public class Client {

public static void main(String[] args) {

	try {

		Socket socket = new Socket("localhost", 8080);//1.创建客户端Socket，指定服务器地址和端口

		//2.获取输出流，向服务器端发送信息

		OutputStream os = socket.getOutputStream();//字节输出流

		PrintWriter pw = new PrintWriter(os);//将输出流包装为打印流

		pw.write("用户名：whf;密码：789");

		pw.flush();

		socket.shutdownOutput();//关闭输出流

		//3.获取输入流，并读取服务器端的响应信息

		InputStream is = socket.getInputStream();

		BufferedReader br = new BufferedReader(new InputStreamReader(is));

		String info = null;

		while ((info = br.readLine()) != null) {

			System.out.println("我是客户端，服务器说：" + info);

		}

		//4.关闭资源

		br.close();

		is.close();

		pw.close();

		os.close();

		socket.close();

	} catch (Exception e) {

		// TODO: handle exception

	}

}

}

import java.net.InetAddress;

import java.net.ServerSocket;

import java.net.Socket;

public class Server {

public static void main(String[] args) {

	try {

		//1.创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口

		ServerSocket serverSocket = new ServerSocket(8080);

		Socket socket = null;

		int count = 0;//记录客户端的数量

		System.out.println("***服务器即将启动，等待客户端的连接***");

		while (true) {

			socket = serverSocket.accept();//调用accept()方法开始监听，等待客户端的连接

			//创建一个新的线程

			ServerThread serverThread = new ServerThread(socket);

			serverThread.start();//启动线程

			count++;

			System.out.println("客户端的数量：" + count);

			InetAddress address = socket.getInetAddress();

			System.out.println("当前客户端的IP：" + address.getHostAddress());

		}

	} catch (Exception e) {

		e.printStackTrace();

	}

}

}

import java.io.BufferedReader;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.io.PrintWriter;

import java.net.Socket;

/**

 *

 * @ClassName: ServerThread

 * @Description:  服务器线程处理类

 * @author: xfzhong

 * @date:

 */

public class ServerThread extends Thread{

	Socket socket=null;// 和本线程相关的Socket

	public ServerThread(Socket socket) {

		this.socket=socket;

	}

	//线程执行的操作，响应客户端的请求

public void run() {

	InputStream is=null;

	InputStreamReader isr=null;

	BufferedReader br=null;

	OutputStream os=null;

	PrintWriter pw=null;

	try {

		//获取输入流，并读取客户端信息

		is = socket.getInputStream();

		isr = new InputStreamReader(is);

		br = new BufferedReader(isr);

		String info = null;

		while ((info = br.readLine()) != null) {

			System.out.println("我是服务器，客户端说：" + info);

		}

		socket.shutdownInput();//关闭输入流

		//获取输出流，响应客户端的请求

		os = socket.getOutputStream();

		pw = new PrintWriter(os);

		pw.write("欢迎您！");

		pw.flush();//调用flush()方法将缓冲输出

	} catch (Exception e) {

		e.printStackTrace();

	}finally{

		try {

			//关闭资源

			if (pw != null)

				pw.close();

			if (os != null)

				os.close();

			if (br != null)

				br.close();

			if (isr != null)

				isr.close();

			if (is != null)

				is.close();

			if (socket != null)

				socket.close();

		} catch (Exception e2) {

			e2.printStackTrace();

		}

	}

}

}