java中SOCKET通訊源碼 內(nèi)容: //ServeOneSocket.java 服務(wù)端源程序import java.io.*;import java.net.*;public class ServeOneSocket extends Thread {private Socket socket;private BufferedReader in;private PrintWriter out;private String content;/*** Constructor*/public ServeOneSocket(Socket s,String c)throws IOException {socket=s;content=c;in=new BufferedReader(new InputStreamReader(socket.getInputStream()));//enable auto-flushout=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);start();//calls run()}public void run(){try{while (true){String str=in.readLine();if (str.equals('END'))break;System.out.println('Echoing:'+str);out.println(str);out.println(content);}System.out.println('Closing...');}catch(IOException e){}finally{try{socket.close();}catch(IOException e){}}}}//SocketClientThread.java 客戶端源程序import java.net.*;import java.io.*;class SocketClientThread extends Thread{private Socket socket;private BufferedReader in;private PrintWriter out;private static int counter=0;private int id=counter++;private static int threadcount=0;final int port=8110;public static int threadCount(){return threadcount;}public SocketClientThread(InetAddress addr){System.out.println('Making client:'+id);threadcount++;try{socket=new Socket(addr,port);}catch(IOException e){}try{in=new BufferedReader(new InputStreamReader(socket.getInputStream()));out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);start();}catch(IOException e){try{socket.close();}catch(IOException e2){}}}public void run(){try{for (int i=0;i