ServerSocket ss = new ServerSocket(100);

Socket s = ss.accept();
String ip = s.getInetAddress().getHostAddress();

Socket s = new Socket("localhost",100);

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.io.Reader;
import java.net.Socket;
import java.net.SocketException;
import java.util.Scanner;

public class ServerTask  implements Runnable{
	
	
	private Socket socket;

	
	public ServerTask(Socket socket) {
		// TODO 自動生成的構(gòu)造函數(shù)存根
		this.socket = socket;
	
	}
	
	@Override
	public void run() {
		// TODO 自動生成的方法存根
		
		//建立通信后所執(zhí)行的內(nèi)容
		
		System.out.println("歡迎【"+socket.getRemoteSocketAddress().toString()+"】進入聊天室");
		
		//構(gòu)建讀取緩沖
		BufferedReader br =null;
		//http響應寫入
		PrintWriter pw = null;
		
		try {
			
			//獲取客戶端輸入的信息 字節(jié)流緩沖成字符流
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			String msg;
			
			while((msg=br.readLine()) != null) {
				msg = "【"+socket.getRemoteSocketAddress().toString()+"】說"+msg;
				
				//輸出客戶端信息
				System.out.println(msg);
				
				//服務器接收到客戶端的消息發(fā)送消息給客戶端
				Scanner scanner = new Scanner(System.in);
				System.out.println("請輸入要發(fā)送的信息！");
				
				
				pw = new PrintWriter(socket.getOutputStream(),true);
				pw.println("服務器說："+scanner.nextLine());
				pw.flush();				
			}	
		}catch (SocketException e) {
			// TODO: handle exception
			System.out.println(socket.getRemoteSocketAddress().toString()+"退出聊天室！");
		}	
		catch (Exception e) {
			// TODO: handle exception
		}
		
	}

}

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.SocketException;
import java.util.Scanner;


public class ClientTask  implements Runnable{

	private Socket socket;
	
	
	
	public ClientTask(Socket socket) {
		// TODO 自動生成的構(gòu)造函數(shù)存根
		this.socket = socket;
	}
	
	
	@Override
	public void run() {
		// TODO 自動生成的方法存根
		
		try {
				while(true) {
					Scanner scanner = new Scanner(System.in);
					System.out.println("請輸入要發(fā)送的信息");
					//消息發(fā)送到服務器
					
					PrintWriter pw = new PrintWriter(socket.getOutputStream(),true);
					
					//br.readLine()讀取的消息發(fā)送到服務器
					pw.println(scanner.nextLine());

					
					//讀取服務器發(fā)送的消息
					BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
					System.out.println(br.readLine());

				}		
		}
		catch (Exception e) {
			// TODO: handle exception
		}
		
		
		
	}

	
}

import java.net.ServerSocket;
import java.net.Socket;

import com.qingsu.chat.Task.ServerTask;

public class ChatServer {

	
	public static void main(String[] args) {
		try {
			
			//創(chuàng)建服務端對象 監(jiān)聽一個窗口
			ServerSocket serverSocket = new ServerSocket(10622);
			System.out.println("服務器創(chuàng)建成功！端口號"+10622);
			
			//阻塞 直到有鏈接返回
			while(true) {
				Socket socket = serverSocket.accept();//獲取客戶端對象
				
				//啟動一個線程處理該鏈接
				
				Thread thread = new Thread(new ServerTask(socket));
				thread.start();
				
			}		
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}
}

import java.net.Socket;

import com.qingsu.chat.Task.ClientTask;

public class ChatClient {
	
	
	public static void main(String[] args) {
		try {
			
			//創(chuàng)建客戶端socket服務，把ip和端口作為地址傳進構(gòu)造函數(shù)
			Socket socket = new Socket("127.0.0.1",10622);
			
			//啟動客戶機線程處理
			Thread thread = new Thread(new ClientTask(socket));		
			thread.start();
		
			
		}catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}

}