基于TCP/IP的網絡聊天室實現

開發工具:eclipse
開發環境:jdk1.8

發送端

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

import com.softeem.lesson39.talking.hard.comm.Tools;

/**
 * Freedom內網通
 * @author Freedom
 */
public class SQServer {
	
	/**對外提供服務端口號*/
	private int port;
	/**用于記錄所有產生Socket對象*/
	public volatile static List<Socket> clients = new ArrayList<>();
	
	public SQServer(int port) {
		super();
		this.port = port;
	}

	public void startServer() {
		try {
			//創建服務
			ServerSocket server = new ServerSocket(port);
			Tools.tips("服務已開啟，等待連接...");
			while(true) {
				//監聽客戶端連接
				Socket s = server.accept();
				//將獲取的Socket存儲到集合中
				clients.add(s);
				Tools.tips("客戶端已連接:"+Tools.ip(s));
				//啟動聊天服務線程
				new TalkingServer(s).start();
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	public static void main(String[] args) {
		//啟動服務
		new SQServer(8090).startServer();
		
	}
}

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

import com.softeem.lesson39.talking.hard.comm.Tools;

/**
 * 消息接收轉發線程
 * @author Freedom
 *
 */
public class MsgServer extends Thread{

	private Socket s;
	
	public MsgServer(Socket s) {
		this.s = s;
	}

	@Override
	public void run() {
		try {
			//讀取接收到的來自Socket消息
			//獲取socket的輸入流
			InputStream is = s.getInputStream();
			//將字節輸入流轉換為字符輸入流
			InputStreamReader isr = new InputStreamReader(is);
			//將低級流轉換為緩沖流
			BufferedReader br = new BufferedReader(isr);
			//臨時變量用于接收每一次讀取的文本消息
			String msg = null;
			while((msg = br.readLine()) != null) {
				//遍歷每一個Socket對象
				for(Socket c:SQServer.clients) {
					
					//格式化消息內容（時間+發送人主機名+消息內容）
					String content = Tools.time(System.currentTimeMillis()) + Tools.host(s)+":"+msg;
					
					Tools.sendMsg(c.getOutputStream(), content); 
				}
			}
		} catch (Exception e) {
			//e.printStackTrace();
			Tools.tips("客戶端斷開連接:"+Tools.ip(s));
			//從集合中移除該對象
			SQServer.clients.remove(s);
		}
	}
}

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

import com.softeem.lesson39.talking.hard.comm.Tools;

/**
 * 消息接收的線程
 * @author Freedom
 *
 */
public class MsgReceiver extends Thread{

	private Socket s;
	
	public MsgReceiver(Socket s) {
		this.s = s;
	}
	
	@Override
	public void run() {
		BufferedReader br = null;
		try {
			//獲取socket中的字節輸入流
			InputStream is = s.getInputStream();
			InputStreamReader isr = new InputStreamReader(is);
			br = new BufferedReader(isr);
			String msg = null;
			//循環讀取
			while((msg = br.readLine()) != null) {
				Tools.tips(msg);
			}
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			try {
				if(br != null)br.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}

接收端

import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
import com.softeem.lesson39.talking.hard.comm.Tools;
/**
 * 聊天服務的客戶端
 * @author Freedom
 *
 */
public class SQClient {

	/**遠程服務器的ip地址*/
	private String ip;
	/**遠程服務端應用的端口*/
	private int port;
	
	public SQClient(String ip, int port) {
		super();
		this.ip = ip;
		this.port = port;
	}

	public void startChats() {
		try {
			Socket s = new Socket(ip,port);
			//啟動消息接收線程
			MsgReceiver mr = new MsgReceiver(s);
			//設置消息接收線程為守護線程
			mr.setDaemon(true);
			mr.start();
			//獲取文本掃描對象
			Scanner sc = new Scanner(System.in);
			OutputStream os = s.getOutputStream();
			String msg = "";
			while(!"quit".equals(msg)) {
				msg = sc.nextLine();
				Tools.sendMsg(os, msg);
			}
			System.out.println("結束聊天!");
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	public static void main(String[] args) {
		SQClient client = new SQClient("192.168.7.141", 8090);
		client.startChats();
	}

}

import java.io.IOException;
import java.net.Socket;

import com.softeem.lesson39.talking.hard.comm.Tools;

/**
 * 聊天服務線程
 * @author Freedom
 */
public class TalkingServer extends Thread{

	private Socket s;
	
	public TalkingServer(Socket s) {
		this.s = s;
	}

	@Override
	public void run() {
		try {
			//發送歡迎消息給客戶端
			Tools.sendMsg(s.getOutputStream(), "歡迎使用Freedom內網通，聊得愉快!");
			//啟動消息接收和轉發線程
			new MsgServer(s).start();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
}

工具類

import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Date;

public class Tools {

	/**
	 * 封裝消息提示
	 * @param msg
	 */
	public static void tips(String msg) {
		System.out.println(msg); 
	}
	
	/**
	 * 封裝ip轉換
	 * @param s
	 * @return
	 */
	public static String ip(Socket s) {
		return s.getInetAddress().getHostAddress();
	}
	
	/**
	 * 封裝主機名轉換
	 * @param s
	 * @return
	 */
	public static String host(Socket s) {
		return s.getInetAddress().getHostName();
	}
	
	/***
	 * 
	 * 根據提供的毫秒時間轉換為固定格式的時間
	 * HH:mm:ss
	 * @param t
	 * @return
	 */
	public static String time(long t) {
		//根據提供的時間毫秒數構建日期對象
		Date d = new Date(t);
		SimpleDateFormat sdf = new SimpleDateFormat("[HH:mm:ss]");
		return sdf.format(d);
	}
	
	/**
	 * 通過輸出流發送文本消息
	 * @param os
	 * @param msg
	 */
	public static void sendMsg(OutputStream os,String msg) {
		PrintWriter pw = new PrintWriter(os);
		pw.println(msg);
		pw.flush();
	}
}

運行截圖