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;// 和本线程相关的Socketpublic 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();}}}
}