mbenjamintcpcommand.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.MBenjamin.command;

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

public final class MBenjaminTcpCommand
extends MBenjaminCommand
{
private String host;
private int port;
private String specialString;
//--------------------------------------------------------------------------------------
public MBenjaminTcpCommand( String in_host, int in_port, String in_specialString )
{
host = in_host;
port = in_port;
specialString = in_specialString;
}
//--------------------------------------------------------------------------------------
protected void executeBenjamin()
throws IOException
{
socket = new Socket( host, port );
BufferedReader reader = new BufferedReader( new InputStreamReader( socket.getInputStream(), MCharset.CS_ISO_8859_1 ) );
String line = reader.readLine();
if( line.indexOf( specialString ) == 0 )
	{
	System.out.println( "OK! " + this.toString() );
	notify1();
	socket.close();
	}
}
//--------------------------------------------------------------------------------------
public String toString()
{
StringBuffer strBuf = new StringBuffer();
strBuf.append( "MBenjaminTcpCommand:" );
strBuf.append( host );strBuf.append( ":" );
strBuf.append( port );strBuf.append( ":" );
strBuf.append( specialString );
if( exception != null )
	{
	strBuf.append( ":" );
	strBuf.append( exception );
	}
return strBuf.toString();
}
//--------------------------------------------------------------------------------------
}