Java网络通信代码总结.doc

Java网络通信代码总结 //建立服务器类，并令端口为2000 ServerSocket server = new ServerSocket(2000); //使用accept阻塞方法监听客户端请求 Socket incoming = server.accept(); BuffeReader in = new BufferReader(new InputStreamReader(incoming.getInputStream())); PrintWriter out = new PrintWriter(incoming.getOutputStream(),true); in.close(); out.close(); incoming.close(); //建立客户端请求 Socket socket() = new Socket(192.168.1.1,2000); in = new BufferReader(new InputStreamReader(socket.getInputStream())); out = new PrintWriter(socket.getOutputStream(),true); //建立用户界面 try{ ServerSocket server = new ServerSocket(2000); int i = 1; for(;;) { Socket incoming = server.accept(); new ServerThread(incoming,i).start(); i++; } }catch(IOExcetion ex){ ex.printStackTrace(); } //客户端 import java.io.*; import java.net.*; public class MultiTalkClient{ public static void main(String args[]){ try{ Socket socket = new Socket(127.0.0.1,2000); BufferReader sin = new BufferReader(new InputStreamReader(System.in)); PrintWriter os = new PrintWriter(socket.getOutputStream()); BufferReader is = new BufferReader(new InputStreamReader(socket.getInputStream())); String readline; readline = sin.readLine(); while(!readline.equals(bye)){ os.println(readline); os.flush(); System.out.println(Client:+readline); System.out.println(Server:+is.readLine()); readline = sin.readLine(); } os.close(); is.close(); socket.close(); }catch(Exception e){ System.out.println(Error+e); } } } //服务器端 import java.io.*; import java.net.*; import ServerThread; public class MultiTalkServer{ static int clientnum = 0; public static void main(String args[]){ ServerSocket serverSocket = null; boolean listening = true; try{ serverSocket = new ServerSocket (2000); }catch(IOExcetion e){ System.out.println(Could not listen on port:2000.); System.exit(-1); } while(listening){ new ServerThread(serverSocket.accept(),clientnum).start(); clientnum++; }