proxytouser.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 ProxyToUser extends Thread {
	Pair pair;
	ShareBuffer sharebuffer;
	byte [] buffer = new byte[1024*20];
	
	public ProxyToUser(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
			{
				sharebuffer.fetchData(buffer);
				len = sharebuffer.len;
				
				if(len <= 0)
				{
					status = false;
					
				//	System.out.println("over!!!"); 
				}
				else
				{
					OutputStream output = pair.ProxyToUser.getOutputStream();
					output.write(buffer);
					output.flush();
					
					//Message.show("send buffer to user");
				}
			}
			catch (Exception e)
			{
				e.printStackTrace();
				status = false;
			}
			
			if(!status)
			{
				break;
			}
		}
		//Message.show("servertouser thread is ended."); 
	}
}