Proxy 구현
#include <stdio.h>
#include "csapp.h"
/* 과제 조건: HTTP/1.0 GET 요청을 처리하는 기본 시퀀셜 프록시
클라이언트가 프록시에게 다음 HTTP 요청 보내면
GET http://www.google.com:80/index.html HTTP/1.1
프록시는 이 요청을 파싱해야한다 ! 호스트네임, www.google.com, /index.html
이렇게 프록시는 서버에게 다음 HTTP 요청으로 보내야함.
GET /index.html HTTP/1.0
즉, proxy는 HTTP/1.1로 받더라도 server에는 HTTP/1.0으로 요청해야함
*/
/* Recommended max cache and object sizes */
#define MAX_CACHE_SIZE 1049000
#define MAX_OBJECT_SIZE 102400
/* You won't lose style points for including this long line in your code */
static const char *user_agent_hdr =
"User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:10.0.3) Gecko/20120305 "
"Firefox/10.0.3\r\n";
static const char *new_version = "HTTP/1.0";
/* Function prototyps => 함수 순서 상관이 없게됨 */
void do_it(int fd);
void do_request(int clientfd, char *method, char *uri_ptos, char *host);
void do_response(int connfd, int clientfd);
int parse_uri(char *uri, char *uri_ptos, char *host, char *port);
void *thread(void *vargp);
int main(int argc, char **argv) {
int listenfd, *connfdp;
char hostname[MAXLINE], port[MAXLINE];
socklen_t clientlen;
struct sockaddr_storage clientaddr;
pthread_t tid;
/* Check command line args */
if (argc != 2) {
fprintf(stderr, "usage: %s <port>\n", argv[0]);
exit(1); // exit(0) => exit(1) 수정
}
// Review from PGJ
// exit 함수의 경우 통상적으로 정상적인 종료를 했을 경우 0 값을 반환하고, 오류로 인해 종료를 해야할 경우 0이 아닌 값들을 매게변수로 주는 것으로 알고 있습니다.
// 코드 문맥을 봤을 때 비정상적인 종료로 인해 exit를 사용하므로 매게변수로 1을 넣어주는게 좋을 것 같습니다.
/* 해당 포트 번호에 해당하는 듣기 소켓 식별자를 열어준다. */
listenfd = Open_listenfd(argv[1]);
/* 클라이언트의 요청이 올 때마다 새로 연결 소켓을 만들어 doit()호출 */
while(1) {
clientlen = sizeof(clientaddr);
/* 클라이언트에게서 받은 연결 요청을 accept한다. connfd = proxy의 connfd*/
connfdp = Malloc(sizeof(int));
*connfdp = Accept(listenfd, (SA *)&clientaddr, &clientlen);
/* 연결이 성공했다는 메세지를 위해. Getnameinfo를 호출하면서 hostname과 port가 채워진다.*/
Getnameinfo((SA *)&clientaddr, clientlen, hostname, MAXLINE, port, MAXLINE, 0);
printf("Accepted connection from (%s, %s)\n", hostname, port);
Pthread_create(&tid, NULL, thread, connfdp);
}
}
void *thread(void *vargp){
int connfd = *((int *)vargp);
Pthread_detach(pthread_self());
Free(vargp);
do_it(connfd);
Close(connfd);
return NULL;
}
void do_it(int connfd){
int clientfd;
char buf[MAXLINE], host[MAXLINE], port[MAXLINE], method[MAXLINE], uri[MAXLINE], version[MAXLINE];
char uri_ptos[MAXLINE];
rio_t rio;
/* Read request line and headers from Client */
Rio_readinitb(&rio, connfd); // rio 버퍼와 fd(proxy의 connfd)를 연결시켜준다.
Rio_readlineb(&rio, buf, MAXLINE); // 그리고 rio(==proxy의 connfd)에 있는 한 줄(응답 라인)을 모두 buf로 옮긴다.
printf("Request headers to proxy:\n");
printf("%s", buf);
sscanf(buf, "%s %s %s", method, uri, version); // buf에서 문자열 3개를 읽어와 각각 method, uri, version이라는 문자열에 저장
/* Parse URI from GET request */
// if (!(parse_uri(uri, uri_ptos, host, port)))
// return -1;
parse_uri(uri, uri_ptos, host, port);
clientfd = Open_clientfd(host, port); // clientfd = proxy의 clientfd (연결됨)
do_request(clientfd, method, uri_ptos, host); // clientfd에 Request headers 저장과 동시에 server의 connfd에 쓰여짐
do_response(connfd, clientfd);
Close(clientfd); // clientfd 역할 끝
}
/* do_request: proxy => server */
void do_request(int clientfd, char *method, char *uri_ptos, char *host){
char buf[MAXLINE];
printf("Request headers to server: \n");
printf("%s %s %s\n", method, uri_ptos, new_version);
/* Read request headers */
sprintf(buf, "GET %s %s\r\n", uri_ptos, new_version); // GET /index.html HTTP/1.0
sprintf(buf, "%sHost: %s\r\n", buf, host); // Host: www.google.com
sprintf(buf, "%s%s", buf, user_agent_hdr); // User-Agent: ~(bla bla)
sprintf(buf, "%sConnections: close\r\n", buf); // Connections: close
sprintf(buf, "%sProxy-Connection: close\r\n\r\n", buf); // Proxy-Connection: close
/* Rio_writen: buf에서 clientfd로 strlen(buf) 바이트로 전송*/
Rio_writen(clientfd, buf, (size_t)strlen(buf)); // => 적어주는 행위 자체가 요청하는거야~@!@!
}
/* do_response: server => proxy */
void do_response(int connfd, int clientfd){
char buf[MAX_CACHE_SIZE];
ssize_t n;
rio_t rio;
Rio_readinitb(&rio, clientfd);
n = Rio_readnb(&rio, buf, MAX_CACHE_SIZE);
Rio_writen(connfd, buf, n);
}
/* parse_uri: Parse URI, Proxy에서 Server로의 GET request를 하기 위해 필요 */
int parse_uri(char *uri, char *uri_ptos, char *host, char *port){
char *ptr;
/* 필요없는 http:// 부분 잘라서 host 추출 */
if (!(ptr = strstr(uri, "://")))
return -1; // ://가 없으면 unvalid uri
ptr += 3;
strcpy(host, ptr); // host = www.google.com:80/index.html
/* uri_ptos(proxy => server로 보낼 uri) 추출 */
if((ptr = strchr(host, '/'))){
*ptr = '\0'; // host = www.google.com:80
ptr += 1;
strcpy(uri_ptos, "/"); // uri_ptos = /
strcat(uri_ptos, ptr); // uri_ptos = /index.html
}
else strcpy(uri_ptos, "/");
/* port 추출 */
if ((ptr = strchr(host, ':'))){ // host = www.google.com:80
*ptr = '\0'; // host = www.google.com
ptr += 1;
strcpy(port, ptr); // port = 80
}
else strcpy(port, "80"); // port가 없을 경우 "80"을 넣어줌
/*
Before Parsing (Client로부터 받은 Request Line)
=> GET http://www.google.com:80/index.html HTTP/1.1
Result Parsing (순차적으로 host, uri_ptos, port으로 파싱됨)
=> host = www.google.com
=> uri_ptos = /index.html
=> port = 80
After Parsing (Server로 보낼 Request Line)
=> GET /index.html HTTP/11.
*/
return 0; // function int return => for valid check
}프록시 서버를 구현하는 과정에서 어려웠던 점은 몇 가지가 있습니다. 먼저, 프록시 서버는 클라이언트와 서버 사이에서 중개자 역할을 수행하기 때문에 네트워크 통신에 대한 이해와 관련된 개념들을 익히는 것이 중요합니다. 네트워크 프로토콜, 포트, IP 주소 등과 같은 개념들을 이해해야 효과적인 프록시 서버를 구현할 수 있습니다. 이러한 개념들을 이해하기 어렵다면, 관련 자료나 가이드를 참조하며 천천히 학습하는 것이 도움이 될 것입니다.
또한, 프록시 서버는 클라이언트의 요청을 중개하고 필터링하는 기능을 수행하기 때문에 웹 프로토콜에 대한 이해도 필요합니다. HTTP 요청과 응답의 구조, 헤더 필드, 캐싱 등과 같은 웹 프로토콜의 기능을 이해해야 프록시 서버에서 원하는 동작을 구현할 수 있습니다. 이러한 부분은 웹 개발이나 네트워크 관련 공부를 통해 익히는 것이 도움이 될 것입니다.
또한, 프록시 서버를 구현하는 동안 실제로 서버와 클라이언트 간의 통신을 가로채고 수정해야 하는데, 이 과정에서 프록시 서버의 동작을 디버깅하고 테스트하는 것이 어려울 수 있습니다. 디버깅 도구나 로그 기록을 활용하여 프록시 서버의 동작을 분석하고 문제를 해결해 나갈 필요가 있습니다. 또한, 다양한 테스트 케이스를 고려하며 프록시 서버를 검증하는 것도 중요한 과정입니다.
프록시 서버를 구현하면서 느낀 점은 네트워크 통신과 웹 프로토콜에 대한 이해가 중요하다는 것입니다. 또한, 실제로 프록시 서버를 구현하면서 발생하는 문제들은 다양하고 예측하기 어려울 수 있습니다. 따라서 문제에 직면했을 때 차분하게 분석하고, 관련 자료나 도움을 찾아가며 해결해 나가는 능력이 필요합니다. 프록시 서버를 구현하는 과정은 도전적이지만, 이를 통해 네트워크와 웹 프로토콜에 대한 이해도를 향상시킬 수 있다는 점에서 의미있는 경험이 될 것입니다
^^