最近，自己仿照网上写了个多客户端，网络通信（socket）用例：
1. Server2.java--服务端
2. Client2.java--客户端
3. Main2.java--启动测试
现在基本运行起来了，就是使用 inputstream时，使用BufferedInputStream bis 。。总是阻塞程序继续运行。。。
package com.automic.hxb.socketTest.test2; import java.io.*; import java.net.*; public class Server2 extends Thread { private int port = 5678; private ServerSocket server; private int onLine = 0;// connect client numbers /** * dispatcher start work */ public void startWork() { this.start(); } /* * (non-Javadoc) * * @see java.lang.Thread#run() */ @Override public void run() { // TODO Auto-generated method stub try {// get server socket server = new ServerSocket(port); while (true) { this.getConn(); System.out.println("Server2 -44- onLine = " + onLine); try { sleep(3000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally { ; } } } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } finally { try{ if(server != null){ server.close(); } }catch(Exception e){ e.printStackTrace(); }finally{;} } } /** * connect client socket */ private void getConn() { try { System.out.println("server start work....."); Socket client = server.accept(); System.out.println("client port : " + client.getPort()); ClientThread ct = new ClientThread(client); onLine++; ct.start(); } catch (Exception e) { e.printStackTrace(); } finally { ; } } /** * handle per client`s connection * * @author hxb * */ public class ClientThread extends Thread { private Socket client; private BufferedReader in; private PrintWriter out; public ClientThread(Socket client) { this.client = client; } /* * (non-Javadoc) * * @see java.lang.Thread#run() */ @Override public void run() { // TODO Auto-generated method stub try { /** * read message from client********/ String str = this.read(); /** *write message to client *********/ this.send(str); } catch (Exception e) { e.printStackTrace(); } finally { /** *close object********************/ this.closeObjs(); } } /** * read message from client connection * * @return */ private String read() { try { in = new BufferedReader(new InputStreamReader(client .getInputStream())); StringBuffer sb = new StringBuffer(); String str = in.readLine(); sb.append(str); System.out.println("Server2 -69- 客户端输入：" + sb.toString()); return sb.toString(); } catch (Exception e) { e.printStackTrace(); } finally { ; } return null; } /** * write message to client connection * * @param bakMess */ private void send(String bakMess) { try { out = new PrintWriter(client.getOutputStream()); bakMess = "服务器端已收到！\n mess:" + bakMess; out.println(bakMess); out.flush(); } catch (Exception e) { e.printStackTrace(); } finally { ; } } /** * close all object */ private void closeObjs() { try { if (out != null) { out.close(); } if (in != null) { in.close(); } if (client != null) { client.close(); onLine--; } } catch (Exception e) { e.printStackTrace(); } finally { ; } } } }
package com.automic.hxb.socketTest.test2; import java.io.*; import java.net.*; public class Client2 extends Thread{ private String ip = "192.168.0.131"; private int port = 5678; private Socket server; private BufferedReader in; private PrintWriter out; private int clientNum = 10; public void startWork(){ this.start(); } /* (non-Javadoc) * @see java.lang.Thread#run() */ @Override public void run() { // TODO Auto-generated method stub int i = 1; while(i < clientNum){ this.connServer(i); i++; try { sleep(3000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } private void connServer(int i){ try { System.out.println("client -" + i + "- start work...."); server = new Socket(ip, port); /***send mess to server******/ String str = "服务器你好,I am client -" + i + "- ..... helllllllll"; this.send("client -" + i + "- say:" + str); /***read bakMess from server*********/ this.read(); /***close object ******/ this.closeObjs(); } catch (Exception e) { e.printStackTrace(); } finally { ; } } /** * send message to server * @param sender */ private void send(String sender){ try{ PrintWriter out = new PrintWriter(server.getOutputStream()); out.println(sender); out.flush(); }catch(Exception e){ e.printStackTrace(); }finally{;} } /** * read back message from server */ private void read(){ try{ BufferedReader in = new BufferedReader(new InputStreamReader(server .getInputStream())); StringBuffer sb = new StringBuffer(); String rl = in.readLine(); while (rl != null) { sb.append(rl); rl = in.readLine(); } System.out.println("Client2 -30-" + sb.toString()); }catch(Exception e){ e.printStackTrace(); }finally{;} } /** * close all objets */ private void closeObjs(){ try{ if(out != null){ out.close(); } if(in != null){ in.close(); } if(server != null){ server.close(); } }catch(Exception e){ e.printStackTrace(); }finally{;} } }
/** * */ package com.automic.hxb.socketTest.test2; /** * @author hxb * */ public class Main2 { /** * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub Server2 s2 = new Server2(); s2.startWork(); Client2 c2 = new Client2(); c2.startWork(); } }
