java實現多人聊天對話室
使用ServerSocket和Socket實現服務器端和客戶端的Socket通信。
瞭解完socket通信步驟後可以發現本實驗需要寫兩個類:Server和Client,並且要先運行Server再運行Client。
先構造服務器端
import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ExecutorService; import java.util.concurrent.ScheduledThreadPoolExecutor; /** * @author: Ren * @date: 2020-08-03 15:23 * @description: */ public class TcpserverC2 { public static void main(String[] args) throws IOException { // 定義多線程,讓多個用戶都可以參與到聊天室 ExecutorService pool = new ScheduledThreadPoolExecutor(10); // 綁定端口 ServerSocket serverSocket = new ServerSocket(8888); // 利用循環一直來讀取新的socket while (true) { // 開始serversocket偵聽請求,這方法會阻塞等待tcp請求的到來,一旦到來,就返回 Socket accept = serverSocket.accept(); pool.execute(new Runnable() { Socket socket = accept; // 定義字節數組來讀取輸入流 byte[] buf = new byte[1024]; @Override public void run() { // 定義輸入輸出流 InputStream in = null; OutputStream out = null; try { in = socket.getInputStream(); out = socket.getOutputStream(); while (true) { int len = in.read(buf); System.out.println("服務器收到:" + new String(buf, 0, len, ("utf-8"))); // 聊天室服務端一般不會參與對話,所以一般不加這個功能 // String xitongshuohua = scanner.nextLine(); // out.write("謝謝".getBytes(Charset.forName("utf-8"))); out.write("謝謝".getBytes(("utf-8"))); } } catch (IOException e) { e.printStackTrace(); } } }); } } }
再構建客戶端
import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; import java.util.Scanner; /** * @author: Ren * @date: 2020-08-03 15:23 * @description: */ public class TcpClientC2 { public static void main(String[] args) throws IOException { // 目標地址,目標端口 Socket socket = new Socket("127.0.0.1",8888); InputStream in = socket.getInputStream(); OutputStream out = socket.getOutputStream(); Scanner scanner = new Scanner(System.in); byte[] buf = new byte[1024]; while (true) { String word = scanner.nextLine(); out.write(word.getBytes(("utf-8"))); int lrn = in.read(buf); System.out.println("服務端回復:"+new String(buf,0,lrn,("utf-8"))); } } }
服務器端構建在一個主機上,然後在多臺電腦創建客戶端,並訪問服務器端所在的主機就可以構成聊天室的效果,當然前提是在同一個局域網下。
以上就是本文的全部內容,希望對大傢的學習有所幫助,也希望大傢多多支持WalkonNet。