0

ソケットを使用してJavaで単純なhttpプロキシサーバーを作成したいと思います。インターネットで見つけたいくつかのチュートリアルで構成されるテストプロトタイプを作成しました。長い間私はこれを持ってきました：

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class SimpleProxyServer
{
    public static final int portNumber = 55558;
    public static final int maxConnections = 100;

    public static void main( String[] args )
    {
        SimpleProxyServer proxyServer = new SimpleProxyServer();
        proxyServer.start();
    }

    public void start()
    {
        System.out.println("Starting the SimpleProxyServer ...");
        try
        {
            ServerSocket serverSocket = new ServerSocket( portNumber, maxConnections );
            byte[] buffer = new byte[10000];

            boolean run = true;
            while( run )
            {
                Socket clientSocket = serverSocket.accept();

                InputStream clientInputStream = clientSocket.getInputStream();

                // reading the request and put it into buffer
                final int readBytesCount = clientInputStream.read( buffer );
                if( readBytesCount < 0)
                    continue;

                String browserRequest = new String( buffer, 0, readBytesCount );
                System.out.println( browserRequest );

                // extract the host to connect to
                final int hostNameStart = browserRequest.indexOf( "Host: " ) + 6;
                final int hostNameEnd = browserRequest.indexOf( '\n', hostNameStart );
                final String hostName = browserRequest.substring( hostNameStart, hostNameEnd - 1 );
                System.out.println( "Connecting to host " + hostName );

                // forward the response from the proxy to the server
                Socket hostSocket = new Socket( hostName, 80 );
                OutputStream hostOutputStream = hostSocket.getOutputStream();
                System.out.println( "Forwarding request to server" );
                hostOutputStream.write( buffer, 0, readBytesCount );
                hostOutputStream.flush();

                ProxyThread thread1 = new ProxyThread( clientSocket, hostSocket );
                thread1.start();

                ProxyThread thread2 = new ProxyThread( hostSocket, clientSocket );
                thread2.start();
            }
            serverSocket.close();
        }
        catch( IOException e )
        {
            System.err.println( "IO Error: " + e.getMessage() );
            e.printStackTrace();
        }
    }
}

class ProxyThread extends Thread 
{
    private Socket incoming, outgoing;

    ProxyThread( Socket in, Socket out )
    {
        incoming = in;
        outgoing = out;
    }

    // Overwritten run() method of thread,
    // does the data transfers
    public void run()
    {
        System.out.println( "Starting proxy thread" );
        try
        {
            OutputStream toClient = outgoing.getOutputStream();
            InputStream fromClient = incoming.getInputStream();

            int numberRead = 0;
            byte[] buffer = new byte[10000];
            do
            {
                numberRead = fromClient.read( buffer );
                System.out.println( "Read " + numberRead + " bytes" );
                System.out.println( "Buffer: " + buffer );
                if( numberRead > 0 )
                {
                    toClient.write( buffer, 0, numberRead );
                    System.out.println( "Sent " + numberRead + " bytes" );
                }
            }
            while( numberRead > 0 );

            System.out.println( "Closing all streams and sockets" );
            toClient.flush();
            incoming.close();
            outgoing.close();
        }
        catch( IOException e ) 
        {
            System.err.println( "IO Error: " + e.getMessage() );
        }
        catch( ArrayIndexOutOfBoundsException e )
        {
            System.err.println( "Index error: " + e.getMessage() );
        }
    }
}

ブラウザ（Firefoxが役立つ場合）でテストしている間、fromClient.read(buffer)通話がハングしてフリーズし、-1が返されますが、ブラウザははるかに早く接続拒否を示します。その原因は何ですか？それはブロッキングが原因InputStream.read()ですか、それともちょっとしたレースですか？たぶん全体のアプローチは間違っていますか？それとも、スレッドの問題ですか？

PS私の「母国語」はC++です。私はJavaプログラミング言語について時々経験を積んでいますが、それでもそのライブラリ、特にソケットについては十分な経験がありません。

PPS httpプロキシサーバーのようなものにはインターネット上で複数のチュートリアルとハウツーがあると思いましたが、私が見つけたのはシングルスレッドであるか、宛先URLを読み取らず、次のプロキシにリクエストを送信するだけです。だから多分投稿は誰かが自分のものを書くのを助けるでしょう。修正されたら...

4

1 に答える 1

1

受け入れられた各ソケットを別々のスレッドで処理する必要があります。これには、CONNECTコマンドの読み取りも含まれます。それ以外の場合、それを読み取るホールドアップは、受け入れスレッドが新しい接続を受け入れるのをブロックします。

于 2013-02-04T22:17:53.167 に答える