Node.jsでhttpサーバーを立ち上げる。
サーバーが同時に処理することができる最大接続数を変更する。
最大接続数を1つに設定しておく。
これにより1台目のPCでアクセスして2代目のPCでアクセスすると繋がらなくなる。
server.maxConnectionsで設定可能である。
環境
Windows10(64bit)
nvm(Node Version Manager)を使用する。
nvmはnodeとnpmのバージョンの切り替えができる。
node.jsはアップデートが頻繁に行われるため、バージョン管理ツールを使うと都合が良いことが多い。
「特定のプロジェクトに必要なNode.jsのバージョンを簡単にインストールして使用することができる。」や「プロジェクト毎にNode.jsのバージョンの切り替えが簡単になる。」等のメリットがある。
nvm 1.1.10
node v18.15.0
npm 9.5.0
httpサーバーを立ち上げるコード「http.js」を次に示す。
現地時間を取得するために自作モジュールLocalTime.jsを使用している。
(function() {
// 自作モジュールLocalTime.jsをrequireを使ってインポートして、定数localTimeに格納する。
const localTime = require("./LocalTime.js");
// LocalTimeの言語を日本語に設定
localTime.SetLang("JP");
// LocalTimeのタイムゾーンを東京(TYO)に設定
localTime.SetTimeZone("TYO");
// Node.jsのhttpモジュールをrequireを使ってインポートして、定数httpに格納する。
const http = require("http");
const port = 3000; //port番号
//const hostname = "localhost"; // ホスト名またはドメイン名
const hostname = "192.168.2.100"; // ホスト名またはドメイン名
// httpオブジェクトからcreateServerメソッドを実行する。
// createServerメソッドは、引数としてリクエストを処理するコールバック関数を受け取る。
// このコールバック関数は、リクエストが発生した際に実行され、リクエストオブジェクト(req)とレスポンスオブジェクト(res)を受け取る
// つまり、このコールバック関数は、http://localhost:3000にアクセスしたときに実行される。
// このコールバック関数内で、適切なレスポンス(res)を生成してクライアントに送信する処理を実装する。
// リクエストオブジェクト(req)は、http.IncomingMessageオブジェクトのインスタンスである。
// レスポンスオブジェクト(res)は、http.ServerResponseオブジェクトのインスタンスである。
// レスポンスオブジェクト(res)は、Writableストリームとして機能する。
// レスポンスオブジェクト(res)は、クライアントに対してデータを送信するためのストリームとして扱われる。
// reqはhttp.IncomingMessageオブジェクトのインスタンスであり、HTTPリクエストのデータを読み取るための
// Readableストリームです。リクエストヘッダーやボディなどのデータを読み取るために使用します。
// resはhttp.ServerResponseオブジェクトのインスタンスであり、HTTPレスポンスを生成および送信するための
// Writableストリームです。resに対して書き込まれたデータはクライアントに送信されます。
// writeメソッドやendメソッドを使用してレスポンスボディを書き込むことができます。
// レスポンスオブジェクト(res)のボディに書き込むにはwriteメソッドを使う。
// レスポンスオブジェクト(res)の送信を完了するためにはendメソッドを使う。
const server = http.createServer((req, res) => {
// この部分のコード req.connection.remoteAddress は、HTTPリクエストの接続情報に含まれるクライアントのIPアドレスを取得するためのものです。
// reqはリクエストオブジェクトであり、connectionプロパティは接続情報を表すオブジェクトを取得する。そして、remoteAddressプロパティは
// その接続元のIPアドレスを取得します。
// なお、remoteAddressは一般的にはクライアントの実際のIPアドレスを表す。
// しかし、プロキシサーバやロードバランサを経由している場合には、そのサーバのIPアドレスが取得されることがありえる。
// この点は注意すること。
//取得したクライアントのIPアドレスをclientIPに格納する。
const clientIP = req.connection.remoteAddress;
console.log(
`Executed. \n` +
`${localTime.GetLocalTimeString()} \n` +
`クライアントのIPアドレス:${clientIP}\n` +
`${req.method} \n` +
`${req.url} \n` +
`${req.headers["user-agent"]}`
);
const url = `http://${req.headers.host}`;
// URL解析
// req.urlは相対URLが入る。
// urlはベースurl(相対URLを解決するための基準となるURL)が入る。
const myURL = new URL(req.url, url);
const whitespace = 2;
const result = [];
const names = [];
let stringLengthMax = 0;
let buf = " ";
let blanks = "";
console.log("");
result.push(myURL.href);
result.push(myURL.origin);
result.push(myURL.protocol);
result.push(myURL.username);
result.push(myURL.password);
result.push(myURL.host);
result.push(myURL.port);
result.push(myURL.hostname);
result.push(myURL.pathname);
result.push(myURL.hash);
result.push(myURL.search);
names.push("href");
names.push("origin");
names.push("protocol");
names.push("username");
names.push("password");
names.push("host");
names.push("port");
names.push("hostname");
names.push("pathname");
names.push("hash");
names.push("search");
// names配列の中の文字列で最大長をstringLengthMaxに格納する。
names.forEach(t => {
if (t.length > stringLengthMax) stringLengthMax = t.length;
});
// bufに格納した空の文字列を「stringLengthMax + whitespace」回数分のコピーを含む新しい文字列blanksを作る。
blanks = buf.repeat(stringLengthMax + whitespace);
// URLの解析結果を出す。
names.forEach((t, u) => (console.log(t + ":" + blanks.slice(t.length) + result[u])));
console.log("");
console.log("req.headers = ");
console.log(req.headers);
console.log("");
let str = [];
str.push("method:");
str.push(req.method);
str.push("\n");
str.push("req.url:");
str.push(req.url);
str.push("\n");
if (myURL.pathname === "/") {
// ドキュメントルート（/）がリクエストさた場合
res.writeHead(200, {
"Content-Type": "text/plain;charset=utf-8"
});
if (req.method === "POST") {
let i = 0
// data受信イベントの発生時に断片データ(chunk)を取得する。
req.on("data", chunk => {
console.log(localTime.GetLocalTimeString() + " i = " + i + ", chunk = " + chunk + "");
i += 1;
str.push(chunk);
});
// 受信完了(end)イベント発生時
//「end」イベントは、レスポンスのデータの読み取りが完了した場合に発生する。
req.on("end", function() {
str.push("\n");
//レスポンスデータをchunk分割する。
res.write(str.join(""));
res.end("Hello World! " + req.method + "\n");
});
} else if (req.method === "GET") {
// URLSearchParamsに含まれる値はforEach()メソッドで取り出し可能である。
myURL.searchParams.forEach(function(value, key) {
str.push(key + " = " + value + "\n");
console.log(localTime.GetLocalTimeString() + ", " + key + " = " + value);
});
// レスポンスデータをchunk分割する。
res.write(str.join(""));
res.end("Hello World! " + req.method + "\n");
} else {
let i = 0
// data受信イベントの発生時に断片データ(chunk)を取得する。
req.on("data", chunk => {
console.log(localTime.GetLocalTimeString() + " i = " + i + ", chunk = " + chunk + "");
i += 1;
str.push(chunk);
});
// 受信完了(end)イベント発生時
// 「end」イベントは、レスポンスのデータの読み取りが完了した場合に発生する。
req.on("end", function() {
str.push("\n");
//レスポンスデータをchunk分割する。
res.write(str.join(""));
res.end("Hi! " + req.method);
});
}
} else {
// ドキュメントルート(/)がリクエストされない場合はメソッドに関係なくここを通る。
res.writeHead(404, {
"Content-Type": "text/plain;charset=utf-8"
});
// レスポンスデータをchunk分割する。
res.write(str.join(""));
res.end("404 Not Found");
}
});
// Keep-Aliveを無効にする。
// しかし、タイムアウトのcloseとブラウザの切断のcloseの2つが実行される。
// 効いていないな。
// server.keepAliveTimeout = 0;
// connectionイベントが発生した際に実行されるコールバック関数を設定する。
// このイベントは、クライアントとのTCP接続が確立された時に発生する。
server.on('connection', (socket) => {
// socket.remoteAddressは、クライアントのIPアドレスを取得するためのプロパティである。
// socketは、TCP接続のためのソケットオブジェクトを表しており、そのremoteAddressプロパティを使用することで、
// クライアントのIPアドレスを取得することができる。
const clientIP = socket.remoteAddress;
console.log(`${localTime.GetLocalTimeString()} TCP connection established. クライアントのIPアドレス:${clientIP}`);
// タイムアウトの設定
// 2秒のタイムアウト値を設定
socket.setTimeout(2000);
// タイムアウトの値を取得
const timeout = socket.timeout;
console.log('タイムアウト:' + timeout);
//closeイベントは、クライアントとのTCP接続が閉じられた時に発生する。
socket.on('close', () => {
console.log(`${localTime.GetLocalTimeString()} TCP connection closed. クライアントのIPアドレス:${clientIP}\n`);
});
});
// server.maxConnectionsプロパティを設定することで、サーバーが同時に処理することができる最大接続数を制限できる。
// 未設定の場合は無制限である。
// server.maxConnections = 100
// この場合、サーバーは同時に最大100の接続を処理することができます。101番目の接続が試行された場合は、接続が拒否される。
// 最大コネクション数を5に制限する
//server.maxConnections = 1;
// 最大コネクション数を取得
//console.log('最大コネクション数:' + server.maxConnections);
// serverインスタンスオブジェクトからlistenメソッドを実行する。
// httpサーバーが指定されたポート(3000)でリクエストを受け付けるようになる。
server.listen(port, hostname, () => {
console.log(localTime.GetLocalTimeString() + ` Server running at http://${hostname}:${port}`);
});
})();
http://192.168.100:3000に1台目PCでアクセス後に、2代目のPCでにアクセスすると「接続がリセットされました」と表示される。
