servertoproxy.java

一个代理服务器的源码实现 本例中HTTP代理服务器默认于8000端口建立代理服务！

/*
 * Created on 2004-12-30
 *
 * To change the template for this generated file go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */

/**
 * @author mq
 *
 * To change the template for this generated type comment go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */

import java.io.*;
import java.net.*;

public class ServerToProxy extends Thread {
	Pair pair;
	ShareBuffer sharebuffer;
	byte [] buffer = new byte[1024*20];
	
	public ServerToProxy(Pair pair,ShareBuffer sharebuffer)
	{
		this.pair = pair;
		this.sharebuffer = sharebuffer;
	}
	
	public void run()
	{
		int len = 0;
		boolean status = true;
		
		while(pair.isConnectedToUserOK && pair.isConnectedToServerOk)
		{
			try
			{
				InputStream input = pair.ProxyToServer.getInputStream();
				len = input.read(buffer);
				
				if(len <= 0)
				{
					status = false;
					
					sharebuffer.len = len;
					sharebuffer.saveData(buffer);
				//	System.out.println("over!!!"); 
				}
				else
				{
					sharebuffer.len = len;
					sharebuffer.saveData(buffer);
					
					//Message.show("send buffer to user");
				}
			}
			catch (Exception e)
			{
				e.printStackTrace();
				status = false;
			}
			
			if(!status)
			{
				break;
			}
		}
		//Message.show("servertouser thread is ended."); 
	}
}