實現步驟：

伺服器端：

1、建立ServerSocket物件，繫結監聽埠

2、通過accept()方法監聽客戶端請求（迴圈監聽）

3、server與socket建立專線連線，兩個socket在一個單獨的執行緒上對話、通過輸入流讀取客戶端傳送的請求資訊

4、通過輸出流向客戶端傳送響應資訊

5、server繼續等待新的連線

6、關閉相應資源

客戶端：

1、建立Socket物件，指明需要連線的伺服器的地址和埠號

2、連線建立後，通過輸出流向伺服器端傳送請求資訊

3、通過輸入流獲取伺服器響應的資訊

4、關閉相應的資源

Server

package com.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

import javax.swing.text.AbstractDocument.BranchElement;

/*
 * 基於TCP協議的Socket通訊，實現使用者登入
 * 伺服器端
 */
public class Server {
	public static void main(String[] args) {
		try {
			
			//1.建立一個伺服器端的Socket，即ServerSocket，指定繫結的埠，並監聽此埠
			ServerSocket serverSocket=new ServerSocket(8888);
			//2.呼叫accept方法開始監聽，等待客戶端的連線
			Socket socket=null;
			int count=0;
			System.out.println("***伺服器即將啟動，等待客戶端的連線***");
			while(true) {
				socket=serverSocket.accept();
				ServerThread serverThread = new ServerThread(socket);
				serverThread.start();
				//統計客戶端的數量
				count++;
				System.out.println("客戶端的數量為："+count);
				InetAddress address = socket.getInetAddress();
				System.out.println("客戶端的ip為："+address.getHostAddress());
			}
			
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}
 

Client

package com.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

/*
 * 客戶端
 */
public class Client {
	public static void main(String[] args) {
		try {
			//1.建立客戶端socket,指定伺服器地址和埠
			Socket socket=new Socket("localhost", 8888);
			//2.獲取輸出流，向伺服器端傳送訊息
			OutputStream os=socket.getOutputStream(); //位元組輸出流
			PrintWriter pw=new PrintWriter(os);		//將位元組流包裝成列印流
			pw.write("使用者名稱：xiaolu;密碼：233");
			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);
			}
			br.close();
			is.close();
			pw.close();
			os.close();
			socket.close();
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {              
			e.printStackTrace();
		}
		
	}
}
 

ServerThread

package com.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

/*
 * 伺服器執行緒處理類
 */

public class ServerThread extends Thread{
	//和本執行緒相關的Socket
	Socket socket = null;
	
	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 {
			//3. 獲取輸入流，並讀取客戶端資訊
			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();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			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 (IOException e) {
				e.printStackTrace();
			}
		}
		
	}
}