//伺服器端程式碼 import java.io.*; import java.net.*; public class ServerTest3{ public static void main(String[] args){ try{ //設定sever端的連結 ServerSocket s = new ServerSocket(8888); Socket s1 = s.accept();//sever等待連結 //例項化輸出流 OutputStream os = s1.getOutputStream(); DataOutputStream dos = new DataOutputStream(os); //例項化輸入流 InputStream is = s1.getInputStream(); DataInputStream dis = new DataInputStream(is); //例項化兩個執行緒的物件 Thread msr = new MyServerReader(dis); Thread msw = new MyServerWriter(dos); //啟動執行緒 msr.start(); msw.start(); } //捕獲異常 catch(SocketException e){ System.out.println(e); }catch(IOException e){ System.out.println(e); } } } //建立一個程序用來進行接收讀取資料 class MyServerReader extends Thread{ private DataInputStream dis; public MyServerReader (DataInputStream dis){ this.dis = dis; } public void run(){ String msg; try{ while(true){ msg = dis.readUTF(); System.out.println("對方說:" + msg); if(msg.equals("bye")){ System.out.println("對方下線,程式退出"); System.exit(0); } } }catch(IOException e){ System.out.println(e); } } } //建立一個程序用來寫入併發送資料 class MyServerWriter extends Thread{ private DataOutputStream dos; public MyServerWriter(DataOutputStream dos){ this.dos = dos; } public void run(){ InputStreamReader isr = new InputStreamReader(System.in); BufferedReader br = new BufferedReader(isr); String msg; try{ while(true){ msg = br.readLine(); dos.writeUTF(msg); if(msg.equals("bye")){ System.out.println("自己下線,程式退出"); System.exit(0); } } }catch(IOException e){ System.out.println(e); } } }

//客戶端程式碼 import java.io.*; import java.net.*; public class ClientTest3{ public static void main(String[] args){ try{ //連結sever端 Socket s1 = new Socket("127.0.0.1",8888); //例項化輸入流 InputStream is = s1.getInputStream(); DataInputStream dis = new DataInputStream(is); //例項化輸出流 OutputStream os = s1.getOutputStream(); DataOutputStream dos = new DataOutputStream(os); //例項化兩個程序 Thread mcr = new MyClientReader(dis); Thread mcw = new MyClientWriter(dos); //啟動兩個程序 mcr.start(); mcw.start(); //捕獲異常 }catch(SocketException e){ System.out.println(e); }catch(IOException e){ System.out.println(e); } } } //建立一個程序用來進行接收讀取資料 class MyClientReader extends Thread{ private DataInputStream dis; public MyClientReader(DataInputStream dis){ this.dis = dis; } @Override public void run(){ String msg; try{ while(true){ msg = dis.readUTF(); System.out.println("對方說:"+msg); if(msg.equals("bye")){ System.out.println("對方下線,程式退出"); System.exit(0); } } }catch(IOException e){ System.out.println(e); } } } //建立一個程序用來寫入併發送資料 class MyClientWriter extends Thread{ private DataOutputStream dos; public MyClientWriter(DataOutputStream dos){ this.dos = dos; } @Override public void run(){ InputStreamReader isr = new InputStreamReader(System.in); BufferedReader br = new BufferedReader(isr); String msg; try{ while(true){ msg = br.readLine(); dos.writeUTF(msg); if(msg.equals("bye")){ System.out.println("自己下線,程式退出"); System.exit(0); } } }catch(IOException e){ System.out.println(e); } } }

開啟兩個控制檯,先執行伺服器端程式碼,再執行客戶端程式碼, 兩端可以自由聊天.