java 端口代理程序及源码

package com.ts.document; import java.io.*; import java.net.*; public class Proxy implements Runnable { Socket connectionSocket; String clientIPAddr=""; private static int threadCount=0; public Proxy(Socket connectionSocket) { this.connectionSocket = connectionSocket; } public void run() { //connect to biee server onThreadStart(); ServerConnection sc = new ServerConnection(connectionSocket); Socket serverSocket = sc.connectToServer(); System.out.println("Connect to DOCUMENT Server "+Config.DOC_HOST+", Socket:"+serverSocket); new Thread(sc).start(); // try { //analysis client IP clientIPAddr=connectionSocket.getRemoteSocketAddress().toString(); // /127.0.0.1:1585 if(clientIPAddr!=null){ clientIPAddr=clientIPAddr.substring(1); int p=clientIPAddr.indexOf(":"); if(p>0){ clientIPAddr=clientIPAddr.substring(0,p); } } else{ clientIPAddr=""; } //start read data from client socket System.out.println("Client Address : "+connectionSocket.getRemoteSocketAddress()); InputStream inFromClient = connectionSocket.getInputStream(); DataOutputStream outToServer = new DataOutputStream(serverSocket .getOutputStream()); byte[] buffer = new byte[1024*4]; int temp = 0; while(true){ temp = inFromClient.read(buffer); if(temp==-1)break; if(temp>0){ outToServer.write(buffer,0,temp); } } serverSocket.close(); connectionSocket.close(); } catch (Exception e) { System.out.println("Document-Proxy-Exception:" + e.getMessage()); //e.printStackTrace(); } System.out.println("Client thread exit..."); onThreadEnd(); } private void onThreadEnd() { // TODO Auto-generated method stub threadCount--; System.out.println("ClentConnection-Thread-Count:"+threadCount); } private void onThreadStart() { // TODO Auto-generated method stub threadCount++; System.out.println("ClentConnection-Thread-Count:"+threadCount); } public static void main(String[] args) throws Exception { for(int i=0;i<args.length;i++){ if(i==0){ Config.DOC_HOST=args[0]; } if(i==1){ Config.DOC_PORT=Integer.valueOf(args[1]); } if(i==0){ Config.PROXY_PORT=Integer.valueOf(args[2]); } } System.out.println("Document-Proxy-Server v1.0 Started(Listen Port:"+Config.PROXY_PORT+") (DocumentServer:"+Config.DOC_HOST+":"+Config.DOC_PORT+")"); // ServerSocket welcomeSocket = new ServerSocket(Config.PROXY_PORT); while (true) { Socket connectionSocket = welcomeSocket.accept(); new Thread(new Proxy(connectionSocket)).start(); } } }