Skip to content

Commit

Permalink
reorder functions, update Python code, etc.
Browse files Browse the repository at this point in the history
  • Loading branch information
@ktabe
ktabe committed Nov 24, 2022
1 parent 3566af6 commit 72f8b3a
Show file tree
Hide file tree
Showing 5 changed files with 339 additions and 316 deletions.
238 changes: 122 additions & 116 deletions C/webserver.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,37 +16,62 @@
#include <arpa/inet.h> // inet_ntop()
#include <unistd.h> // close()

/*
* GET要求を処理する
*/
void handle_get(FILE *fp, const char *path)
// プロトタイプ宣言
void handle_get(FILE *fp, const char *path);
void handle_client(int client_fd, struct sockaddr_in *client_addr);

int main(int argc, char **argv)
{
if (strcmp(path, "/") == 0) { // http://localhost:8000/ へのアクセスの場合
// C言語では連続した文字列は自動的に連結される
fprintf(fp,
"HTTP/1.0 200 OK\r\n" // ステータス行
"Content-Type: text/html\r\n" // 本体がHTMLであることを伝える
"\r\n" // ヘッダの終了を表す空行
"<!DOCTYPE html>\r\n" // 以下はHTML (HTML5)
"<html>\r\n"
"<head><title>Sample</title></head>\r\n"
"<body>This server is implemented with C!</body>\r\n"
"</html>\r\n"
);
} else { // 他のパス (http://localhost:8000/abc.html) などへのアクセスの場合，404エラー
fprintf(fp,
"HTTP/1.0 404 Not Found\r\n" // 404はNot Foundを表す
"Content-Type: text/html\r\n"
"\r\n"
"<!DOCTYPE html>\r\n"
"<html>\r\n"
"<head><title>404 Not Found</title></head>\r\n"
"<body>%s is not found</body>\r\n"
"</html>\r\n",
path
);
// socket()はソケットを生成し，ファイル記述子(ソケットに割り当てられた整数値)を返す
// - AF_INETはIPv4
// - SOCK_STREAMは信頼性の高い全2重バイトストリームの指定
// - IPPROTO_TCPはTCPの指定
int server_fd;
if ((server_fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) {
// socket()はエラーのとき負の値を返す
perror("socket");
exit(1);
}

// プログラム再実行時に，サーバのポートをすぐに再利用できるようにする
int yes = 1;
setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes));

// bind()で自ノード側のアドレスを設定
struct sockaddr_in server_addr; // sockaddr_inはIPアドレスとポート番号を保持する構造体
memset(&server_addr, 0, sizeof(server_addr)); // 構造体をいったんゼロクリア
server_addr.sin_family = AF_INET; // IPv4アドレス
// サーバ側のIPアドレスはANY(指定しない)．htonlは4バイトをネットワークバイトオーダに変換
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
server_addr.sin_port = htons(8000); // サーバ側のポート番号の指定．htonsは2バイトをネットワークバイトオーダに変換
if (bind(server_fd, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0) {
perror("bind");
exit(1);
}

// ソケットをサーバ用に設定．5はコネクション要求を貯めておくキューの長さ
// - コネクション要求はaccept()で受け取る必要があるが，それをどのくらい溜めておけるか
if (listen(server_fd, 5) < 0) {
perror("listen");
exit(1);
}

printf("open http://localhost:8000/ with your browser!\n");

// クライアントからのコネクションを処理するためのループ
while (1) {
// accept()はクライアントとのコネクションが確立するのを待ってブロックする（待つ）．
// 確立すると当該コネクションで通信するためのファイル記述子を返す．
// - client_addrはクライアントのIPアドレスとポート番号を受け取るための構造体
int client_fd;
struct sockaddr_in client_addr;
socklen_t addr_length = sizeof client_addr;
if ((client_fd = accept(server_fd, (struct sockaddr*)&client_addr, &addr_length)) < 0) {
perror("accept");
exit(1);
}
handle_client(client_fd, &client_addr); // クライアントとのやりとりを行う
}
fflush(fp); // 溜まっているバッファをフラッシュ(送信)
}

/*
Expand All @@ -59,9 +84,9 @@ void handle_client(int client_fd, struct sockaddr_in *client_addr)
char ipstr[128];
if (inet_ntop(AF_INET, &client_addr->sin_addr, ipstr, sizeof ipstr) == NULL) {
perror("inet_ntop");
exit(1);
return;
}
printf("connected: %s\n", ipstr);
printf("Connection from %s has been established!\n", ipstr);

// ファイル記述子を直接扱うとバイト列で読み書きすることしかできない
// 行単位で読み書きするために，fdopen()を使ってfgetsやfprintfを使えるようにする
Expand All @@ -77,17 +102,17 @@ void handle_client(int client_fd, struct sockaddr_in *client_addr)
const int MAX_HEADER_LINES = 256;
char *headers[MAX_HEADER_LINES];
int header_index = 0;
// クライアントからの要求を読み出すループ
// HTTPヘッダを読むための繰り返し
while (1) {
if (header_index >= MAX_HEADER_LINES) {
printf("too many HTTP headers!");
break;
puts("too many HTTP headers!");
goto bailout;
}
// 1行読み込み
char line[1024];
if (fgets(line, sizeof line, fp) == NULL) {
printf("connection closed!");
break;
puts("connection closed!");
goto bailout;
}
// fgetsは改行を削除しないので，行中の最初の\rか\nを\0に書き換えて切り詰める
char *eol = strpbrk(line, "\r\n");
Expand All @@ -98,96 +123,77 @@ void handle_client(int client_fd, struct sockaddr_in *client_addr)
// headersに代入．strdup()は文字列をmallocした領域にコピーする関数
headers[header_index++] = strdup(line);

// 空行かどうかの判定
// 空行判定
if (strcmp(line, "") == 0) {
// 最初の行は "GET / HTTP/1.0" のような形式になっている．これを取り出す．
char *request_line = headers[0];
char *req[] = { NULL, NULL, NULL }; // method, path, versionの3つの要素を入れる配列
// strtok()で空白で分割する
for (int i = 0; i < 3; i++) {
char *word = strtok(request_line, " "); // " " で区切られた最初のトークンを返す
request_line = NULL; // strtok()の2回目以降の呼び出しでは第1引数をNULLにする約束
req[i] = word;
if (word == NULL) {
break;
}
}
// 念のため，3つめの要素があるかを確認
if (req[2] == NULL) {
printf("wrong format\n");
break;
}
const char *method = req[0];
const char *path = req[1];
const char *http_version = req[2];
printf("method=%s, path=%s, http_version=%s\n", method, path, http_version);
// 要求を処理
if (strcmp(method, "GET") == 0) {
handle_get(fp, path);
} else {
// GET要求以外の場合，クライアントに 501 Not Implemented エラーを返す
printf("unsupported method: %s\n", method);
fprintf(fp, "HTTP/1.0 501 Not Implemented\r\n");
}
break;
}
}

// 最初の行は "GET / HTTP/1.0" のような形式になっている．これを取り出す．
char *req_line = headers[0];
char *req[] = { NULL, NULL, NULL }; // method, path, versionの3つの要素を入れる配列
// strtok()で空白で分割する
for (int i = 0; i < 3; i++) {
char *word = strtok(req_line, " "); // " " で区切られた最初のトークンを返す
req_line = NULL; // strtok()の2回目以降の呼び出しでは第1引数をNULLにする約束
req[i] = word;
if (word == NULL) {
break;
}
}
// 念のため，3つめの要素があるかを確認
if (req[2] == NULL) {
printf("wrong format: %s\n", headers[0]);
goto bailout;
}
const char *method = req[0];
const char *path = req[1];
const char *http_version = req[2];
printf("method=%s, path=%s, http_version=%s\n", method, path, http_version);
// 要求を処理
if (strcmp(method, "GET") == 0) {
handle_get(fp, path);
} else {
// GET要求以外の場合，クライアントに 501 Not Implemented エラーを返す
printf("unsupported method: %s\n", method);
fprintf(fp, "HTTP/1.0 501 Not Implemented\r\n");
}
bailout:
fclose(fp); // fcloseは内部でcloseを呼ぶので，クライアントとのコネクションが切断される
for (int i = 0; i < header_index; i++) {
free(headers[i]); // strdup()でmallocした領域を開放
}
}

int main(int argc, char **argv)
/*
* GET要求を処理する
*/
void handle_get(FILE *fp, const char *path)
{
// socket()はソケットを生成し，ファイル記述子(ソケットに割り当てられた整数値)を返す
// - AF_INETはIPv4
// - SOCK_STREAMは信頼性の高い全2重バイトストリームの指定
// - IPPROTO_TCPはTCPの指定
int server_fd;
if ((server_fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) {
// socket()はエラーのとき負の値を返す
perror("socket");
exit(1);
}

// プログラム再実行時に，サーバのポートをすぐに再利用できるようにする
int yes = 1;
setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes));

// bind()で自ノード側のアドレスを設定
struct sockaddr_in server_addr; // sockaddr_inはIPアドレスとポート番号を保持する構造体
memset(&server_addr, 0, sizeof(server_addr)); // 構造体をいったんゼロクリア
server_addr.sin_family = AF_INET; // IPv4アドレス
// サーバ側のIPアドレスはANY(指定しない)．htonlは4バイトをネットワークバイトオーダに変換
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
server_addr.sin_port = htons(8000); // サーバ側のポート番号の指定．htonsは2バイトをネットワークバイトオーダに変換
if (bind(server_fd, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0) {
perror("bind");
exit(1);
}

// ソケットをサーバ用に設定．5はコネクション要求を貯めておくキューの長さ
// - コネクション要求はaccept()で受け取る必要があるが，それをどのくらい溜めておけるか
if (listen(server_fd, 5) < 0) {
perror("listen");
exit(1);
}

printf("open http://localhost:8000/ with your browser!\n");

// クライアントからのコネクションを処理するためのループ
while (1) {
// accept()はクライアントとのコネクションが確立するのを待ってブロックする（待つ）．
// 確立すると当該コネクションで通信するためのファイル記述子を返す．
// - client_addrはクライアントのIPアドレスとポート番号を受け取るための構造体
int client_fd;
struct sockaddr_in client_addr;
socklen_t addr_length = sizeof client_addr;
if ((client_fd = accept(server_fd, (struct sockaddr*)&client_addr, &addr_length)) < 0) {
perror("accept");
exit(1);
}
handle_client(client_fd, &client_addr); // クライアントとのやりとりを行う
if (strcmp(path, "/") == 0) { // http://localhost:8000/ へのアクセスの場合
// C言語では連続した文字列は自動的に連結される
fprintf(fp,
"HTTP/1.0 200 OK\r\n" // ステータス行
"Content-Type: text/html\r\n" // 本体がHTMLであることを伝える
"\r\n" // ヘッダの終了を表す空行
"<!DOCTYPE html>\r\n" // 以下はHTML (HTML5)
"<html>\r\n"
"<head><title>Sample</title></head>\r\n"
"<body>This server is implemented with C!</body>\r\n"
"</html>\r\n"
);
} else { // 他のパス (http://localhost:8000/abc.html) などへのアクセスの場合，404エラー
fprintf(fp,
"HTTP/1.0 404 Not Found\r\n" // 404はNot Foundを表す
"Content-Type: text/html\r\n"
"\r\n"
"<!DOCTYPE html>\r\n"
"<html>\r\n"
"<head><title>404 Not Found</title></head>\r\n"
"<body>%s is not found</body>\r\n"
"</html>\r\n",
path
);
}
fflush(fp); // 溜まっているバッファをフラッシュ(送信)
}
Loading

0 comments on commit 72f8b3a

Please sign in to comment.