接收键盘输入然后向对方发送消息的线程
1 package cn.com.chat; 2 3 import java.io.BufferedReader; 4 import java.io.BufferedWriter; 5 import java.io.IOException; 6 import java.io.InputStreamReader; 7 import java.io.OutputStreamWriter; 8 import java.net.Socket; 9 10 /** 11 * 12 * @author Xiaofei 13 * 14 */ 15 public class SendMsgThread extends Thread{ 16 /** 17 * 用来接收键盘输入然后向对方发送消息的线程 18 */ 19 Socket ss = null; 20 BufferedWriter bw = null; 21 BufferedReader br = null; 22 public SendMsgThread(Socket ss){ 23 this.ss = ss; 24 try { 25 bw = new BufferedWriter(new OutputStreamWriter(ss.getOutputStream())); 26 br = new BufferedReader(new InputStreamReader(System.in)); 27 } catch (IOException e) { 28 // TODO 自动生成的 catch 块 29 e.printStackTrace(); 30 } 31 } 32 public void run(){ 33 try { 34 while(true){ 35 String str; 36 str = br.readLine(); 37 if(str.equals("exit")){ 38 System.exit(0); 39 }else{ 40 bw.write(str+" "); 41 bw.flush(); 42 } 43 } 44 } catch (IOException e) { 45 // TODO 自动生成的 catch 块 46 e.printStackTrace(); 47 }finally{ 48 try { 49 bw.close(); 50 br.close(); 51 } catch (IOException e) { 52 // TODO 自动生成的 catch 块 53 e.printStackTrace(); 54 } 55 } 56 } 57 }
服务端:Server
package cn.com.chat; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; public class Server { public static void main(String[] args) { ServerSocket server = null; Socket socket = null; BufferedReader br= null; try { server = new ServerSocket(88); socket = server.accept(); new SendMsgThread(socket).start(); br = new BufferedReader(new InputStreamReader(socket.getInputStream())); while(true){ String str = br.readLine(); System.out.println("客户端: "+str); } } catch (IOException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); }finally{ try { br.close(); server.close(); } catch (IOException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } } }
客户端:Client
1 package cn.com.chat; 2 3 import java.io.BufferedReader; 4 import java.io.IOException; 5 import java.io.InputStreamReader; 6 import java.net.Socket; 7 8 public class Client { 9 public static void main(String[] args) { 10 Socket socket = null; 11 BufferedReader br = null; 12 try { 13 socket = new Socket("192.168.16.111", 88); 14 System.out.println("请输入您的消息:"); 15 new SendMsgThread(socket).start(); 16 br = new BufferedReader(new InputStreamReader( 17 socket.getInputStream())); 18 while (true) { 19 String str = br.readLine(); 20 System.out.println("客户端: " + str); 21 } 22 } catch (IOException e) { 23 e.printStackTrace(); 24 } finally { 25 try { 26 br.close(); 27 socket.close(); 28 } catch (IOException e) { 29 // TODO 自动生成的 catch 块 30 e.printStackTrace(); 31 } 32 } 33 } 34 35 }
特别提醒一点:注意启动的顺序,现实启动服务端,再启动客户端。现有接收的服务器,客户端才能够获得服务端的端口和IP。