httptunnelingoutcomingdatahandler.java

java实现的代理程序 socket 编程实现的http 和socket 代理程序

package javatunnel;

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

import sun.net.www.protocol.http.HttpURLConnection;

/**
 *
 *JavaTunnel
 *
 *Copyright (C) 2002 Andr閟 Ederra
 *
 *This program is free software; you can redistribute it and/or
 *modify it under the terms of the GNU General Public License
 *as published by the Free Software Foundation; either version 2
 *of the License, or (at your option) any later version.
 *
 *This program is distributed in the hope that it will be useful,
 *but WITHOUT ANY WARRANTY; without even the implied warranty of
 *MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *GNU General Public License for more details.
 *
 *You should have received a copy of the GNU General Public License
 *along with this program; if not, write to the Free Software
 *Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
*/
public class HTTPTunnelingOutcomingDataHandler
	extends Thread
	implements DataHandler {
	private static final int BUFFERSIZE = 1024 * 10;
	private static final int WAITCYCLE = 200;
	private static final int FIRSTWAITCYCLE = 1000;

	private Socket in;
	private HttpURLConnection POSTconn;
	private String destinationURL;
	private int destinationPort;
	private String serverURL;
	private int serverPort;
	private String ticket;

	public HTTPTunnelingOutcomingDataHandler(
		Socket local,
		String destinationURL,
		int destinationPort,
		String serverURL,
		int serverPort,
		String ticket) {
		this.in = local;
		this.destinationURL = destinationURL;
		this.destinationPort = destinationPort;
		this.serverURL = serverURL;
		this.serverPort = serverPort;
		this.ticket = ticket;
	}
	public void run() {

		InputStream inStream;
		DataOutputStream outStream;

		try {

			byte[] buffer = new byte[BUFFERSIZE];

			
				try {
					Thread.sleep(FIRSTWAITCYCLE);
				} catch (InterruptedException ie) {
					ie.printStackTrace();
				}
			
			inStream = in.getInputStream();
			int n = 0;
			n = inStream.read(buffer);
			while (n != -1) {
				URL url =
					new URL(
						"http"
							+ "://"
							+ serverURL
							+ ":"
							+ serverPort
							+ "/JavaTunnel/server");
				POSTconn = (HttpURLConnection) url.openConnection();
				POSTconn.setDoInput(true);
				POSTconn.setDoOutput(true);
				POSTconn.setUseCaches(false);
				POSTconn.setRequestProperty(
					"Content-Type",
					"application/octet-stream");
				POSTconn.setRequestProperty("TunnelControl", "OUT " + ticket);

				outStream = new DataOutputStream(POSTconn.getOutputStream());

				/*System.out.println(
					"POST: escribiendo "
						+ n
						+ " bytes\r\n"
						+ new String(buffer));*/
				outStream.write(buffer, 0, n);
				outStream.flush();
				outStream.close();

				InputStream responseStream = POSTconn.getInputStream();

				while (responseStream.skip(1000) != 0) {

				}
					try {
					Thread.sleep(WAITCYCLE);
				} catch (InterruptedException ie) {
					ie.printStackTrace();
				}

				n = inStream.read(buffer);

			}
			System.out.println("Saliendo");
		} catch (IOException ioe) {
			ioe.printStackTrace();
			System.out.println(
				"Error de conexi髇 en sockets\nExcepcion: " + ioe);
			System.exit(1);
		}
	}
	public void stopHandler(){}
}