mtunnelrequestsender.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.httptunnel.MLEYE;

import java.io.*;
import java.net.*;
import net.jumperz.util.*;
import net.jumperz.app.httptunnel.*;

public final class MTunnelRequestSender
implements MCommand, MSubject1
{
private MHTunnelRequest request;
private int state;
private Socket socket;
private MSubject1 subject = new MSubject1Impl();

public static final int SUCCESS	= 0;
public static final int ERROR	= 1;
//------------------------------------------------------------------------------------
public MTunnelRequestSender( MHTunnelRequest IN_request )
{
request = IN_request;
}
//------------------------------------------------------------------------------------
public final void execute()
{
try
	{
	socket = new Socket( MHTunnelRequest.httpProxyHost, MHTunnelRequest.httpProxyPort );
	OutputStream outputStream = socket.getOutputStream();
	outputStream.write( request.toByteArray() );
	state = SUCCESS;
	}
catch( Exception e )
	{
	e.printStackTrace();
	state = ERROR;
	}
notify1();
}
//------------------------------------------------------------------------------------
public final void breakCommand()
{
try
	{
	if( socket != null )
		{
		socket.close();
		}
	}
catch( IOException e )
	{
	}
}
//------------------------------------------------------------------------------------
public final int getState()
{
return state;
}
//------------------------------------------------------------------------------------
public final Socket getSocket()
{
return socket;
}
//------------------------------------------------------------------------------------
public final MHTunnelRequest getRequest()
{
return request;
}
//------------------------------------------------------------------------------------
public void notify1()
{
subject.notify1();
}
//----------------------------------------------------------------
public void register1( MObserver1 observer )
{
subject.register1( observer );
}
//----------------------------------------------------------------
public void removeObservers1()
{
subject.removeObservers1();
}
//----------------------------------------------------------------
public void removeObserver1( MObserver1 observer )
{
subject.removeObserver1( observer );
}
//----------------------------------------------------------------
}