Node.js を使用してスクラッチプロキシサーバーを構築する方法-jsチュートリアル-php.cn

Node.js を使用してスクラッチプロキシサーバーを構築する方法

WBOY

リリース： 2024-07-17 14:23:08

オリジナル

613 人が閲覧しました

プロキシサーバーがどのように動作し、インターネット上でデータをどのように提供するかについて興味があるかもしれません。このブログでは、コア NodeJs を使用してプロキシサーバーを実装します。これは、NodeJs に既に付属している net と呼ばれるコア NodeJs パッケージを使用して実現しました。

プロキシの仕組み

プロキシサーバーは、クライアントとサーバーの間のエージェントです。

のときクライアントがサーバーにリクエストを送信すると、ターゲットプロキシに転送されます
サーバ。ターゲットのプロキシサーバーがリクエストを処理して送信します
メインサーバーに送信され、メインサーバーはバックリクエストを
に送信します。プロキシサーバーとプロキシサーバーはリクエストをクライアントに送信します。

preview image

プロキシサーバーを設定する

プログラミングを始める前は、ソケットと NodeJ についてほとんど知りません。ソケットとは何か、そしてそれらがどのように機能するかは知っています。
NodeJs でプロキシサーバーを実装するには 2 つの方法があります。最初にカスタムメソッドを作成し、2 番目にインビルドを実行します。どちらもわかりやすいです

プロキシサーバーをテストするには、ローカルマシン上でローカル HTTP サーバーを実行し、ホストマシンをターゲットにすることができます。

次に、ネットパッケージを定義し、ターゲットサーバーとポート番号を記述します。

const net = require('net');

// Define the target host and port
const targetHost = 'localhost'; // Specify the hostname of the target server. For Ex: (12.568.45.25)
const targetPort = 80; // Specify the port of the target server

ログイン後にコピー

TCP サーバーを作成してリッスンしています。

const server = net.createServer((clientSocket) => {

});

// Start listening for incoming connections on the specified port
const proxyPort = 3000; // Specify the port for the proxy server
server.listen(proxyPort, () => {
    console.log(`Reverse proxy server is listening on port ${proxyPort}`);
});

ログイン後にコピー

net パッケージを使用してサーバーを作成しました。これは、proxyPort 変数を使用して定義したポート番号 3000 を実行している TCP サーバーです。サーバーが起動すると、コンソールに「リバースプロキシサーバーがポート 3000 でリッスンしている」というメッセージが表示されます。
クライアントがプロキシサーバーに接続しようとすると、createServer 内にあるコールバック関数が実行されます。
サーバー関数のコールバックには、clientSocket パラメーターが 1 つあります。これは、接続のために受信したユーザー接続です。
ユーザーからのデータを受け入れて受信します

const targetHost = 'localhost'; // Specify the hostname of the target server. For Ex: (12.568.45.25)
const targetPort = 80; // Specify the port of the target server

// Create a TCP server
const server = net.createServer((clientSocket) => {
    // Establish a connection to the target host
    net.createConnection({host: targetHost, port: targetPort}, () => {

        // When data is received from the client, write it to the target server
        clientSocket.on("data", (data) => {
            targetSocket.write(data);
        });

        // When data is received from the target server, write it back to the client
        targetSocket.on("data", (data) => {
            clientSocket.write(data);
        });
    });
});

ログイン後にコピー

クライアントがプロキシサーバーに接続しようとすると、create createConnection を使用してサーバーへの一時的な接続が作成されます。
createServerには2つの引数があります
- 接続したい最初のホストこの場合、targetHost 変数で定義されているサーバーホストに接続する必要があります。
- 接続する 2 番目のポートこの場合、targetPort 変数で定義されているサーバーポートに接続する必要があります。
ここで、ユーザーがデータを送信するときに、このデータをサーバーに渡します。このコードを使用して

 clientSocket.on("data", (data) => {
     targetSocket.write(data);
 });

ログイン後にコピー

その後、サーバーはデータを送信します。このコードを使用してこのデータをユーザーに送信します

  targetSocket.on("data", (data) => {
      clientSocket.write(data);
  });

ログイン後にコピー

おめでとうございます!プロキシサーバーが正常に作成されました。

エラー処理

プロキシサーバーの機能を調べるのは興味深いことですが、信頼性を確保するには、予期しない問題を適切に処理するための堅牢なエラー処理方法が必要です。このような種類のエラーを処理するために、エラーと呼ばれるイベントがあります。実装はとても簡単です。

    const server = net.createServer((clientSocket) => {
     // Establish a connection to the target host
     const targetSocket = net.createConnection({host: targetHost,port: targetPort}, () => {

       // Handle errors when connecting to the target server
       targetSocket.on('error', (err) => {
         console.error('Error connecting to target:', err);
         clientSocket.end(); // close connection
       });

       // Handle errors related to the client socket
       clientSocket.on('error', (err) => {
         console.error('Client socket error:', err);
         targetSocket.end(); // close connection
       });
     });
   });

ログイン後にコピー

エラーが発生すると、エラーをコンソールして接続を閉じます。

すべてのコード

ホスト名とポート番号は好みに応じて置き換えてください。

const net = require('net');

// Define the target host and port
const targetHost = 'localhost'; // Specify the hostname of the target server
const targetPort = 80; // Specify the port of the target server

// Create a TCP server
const server = net.createServer((clientSocket) => {
   // Establish a connection to the target host
   const targetSocket = net.createConnection({
      host: targetHost,
      port: targetPort
   }, () => {
      // When data is received from the target server, write it back to the client
      targetSocket.on("data", (data) => {
         clientSocket.write(data);
      });

      // When data is received from the client, write it to the target server
      clientSocket.on("data", (data) => {
         targetSocket.write(data);
      });
   });

   // Handle errors when connecting to the target server
   targetSocket.on('error', (err) => {
      console.error('Error connecting to target:', err);
      clientSocket.end();
   });

   // Handle errors related to the client socket
   clientSocket.on('error', (err) => {
      console.error('Client socket error:', err);
      targetSocket.end();
   });
});

// Start listening for incoming connections on the specified port
const proxyPort = 3000; // Specify the port for the proxy server
server.listen(proxyPort, () => {
   console.log(`Reverse proxy server is listening on port ${proxyPort}`);
});

ログイン後にコピー

構築されたメソッド

クライアントとサーバーの接続の複雑さを軽減するために、メソッドパイプが組み込まれています。この構文を置き換えます

// Handle errors when connecting to the target server
targetSocket.on("data", (data) => {
   clientSocket.write(data);
});

// When data is received from the client, write it to the target server
clientSocket.on("data", (data) => {
   targetSocket.write(data);
});

ログイン後にコピー

この構文へ

// Pipe data from the client to the target
clientSocket.pipe(targetSocket);

// When data is received from the client, write it to the target server
targetSocket.pipe(clientSocket);

ログイン後にコピー

ここにすべてのコードがあります

const net = require('net');

// Define the target host and port
const targetHost = 'localhost';
const targetPort = 80;

// Create a TCP server
const server = net.createServer((clientSocket) => {
   // Establish a connection to the target host
   const targetSocket = net.createConnection({
      host: targetHost,
      port: targetPort
   }, () => {
      // Pipe data from the client to the target
      clientSocket.pipe(targetSocket);

      // Pipe data from the target to the client
      targetSocket.pipe(clientSocket);
   });

   // Handle errors
   targetSocket.on('error', (err) => {
      console.error('Error connecting to target:', err);
      clientSocket.end();
   });

   clientSocket.on('error', (err) => {
      console.error('Client socket error:', err);
      targetSocket.end();
   });
});

// Start listening for incoming connections
const proxyPort = 3000;
server.listen(proxyPort, () => {
   console.log(`Reverse proxy server is listening on port ${proxyPort}`);
});

ログイン後にコピー