mremedy.java

httptunnel.jar httptunnel java 源码

package net.jumperz.app.MRemedy;

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

public class MRemedy
{
private static final int THREAD_COUNT = 35;
//--------------------------------------------------------------------------------
public static void main( String[] args )
throws Exception
{
MRemedy instance = new MRemedy();
instance.start();
}
//--------------------------------------------------------------------------------
public void start()
throws Exception
{
MThreadPool threadPool1 = new MThreadPool( THREAD_COUNT );
MThreadPool threadPool2 = new MThreadPool( 70 );
threadPool1.addCommand( MResultWriter.getInstance() );

MResolver resolver = new MResolver( threadPool2 );

BufferedReader reader = new BufferedReader( new InputStreamReader( System.in ) );
String line = null;
for( int i = 0;; ++i )
	{
	line = reader.readLine();
	if( line == null )
		{
		break;
		}
	String ip = MRegEx.getMatch( "[0-9]{1,3}\\.[0-9]{1,3}\\.[0-9]{1,3}\\.[0-9]{1,3}", line );
	if( ip.equals( "" ) )
		{
		MResultWriter.getInstance().putResult( new Integer( i ), line );
		}
	else
		{
		MRemedyCommand remedyCommand = new MRemedyCommand( i, line, ip, resolver );
		while( true )
			{
			boolean result = threadPool1.forceCommand( remedyCommand );
			if( result )
				{
				break;
				}
			else
				{
				Thread.sleep( 1000 );
				}
			}
		}
	}
}
//--------------------------------------------------------------------------------
}