[Network Study] 02-4. HTTP/1.1

Connection: keep-alive # keep-alive 사용 Connection: Close # 해제 요청 # curl은 복수의 요청으로 keep-alive 활용가능 curl -v http://www.google.com http://www.google.com

# 1. JSONPlaceholder(가짜 데이터 제공하는 무료 REST API) curl --http1.1 -i https://jsonplaceholder.typicode.com/posts/1 # 2. 응답 HTTP/1.1 200 OK Cache-Control: max-age=43200 Etag: W/"124-yiKdLzqO5gfBrJFrcdJ8Yq0LGnU" Age: 12368 # 3. Etag값이 변경되지 않았다면 304 코드반환 curl --http1.1 -i \ -H 'If-None-Match: "124-yiKdLzqO5gfBrJFrcdJ8Yq0LGnU"' \ https://jsonplaceholder.typicode.com/posts/1 # 4. 304 반환 HTTP/1.1 304 Not Modified Cache-Control: max-age=43200

HTTP/1.1 200 OK Expires: Wed, 21 Oct 2021 07:28:00 GMT

HTTP/1.1 200 OK Cache-Control: max-age=3600, must-revalidate

server { listen 80; server_name www.example.com example.com; # 도메인 1 root /www/example; index index.html; } server { listen 80; server_name www.anotherexample.com; # 도메인 2 root /www/anotherexample; index index.html; }

package main import ( "fmt" "net" "os" ) func main() { // 9999포트 열기 listener, err := net.Listen("tcp", "localhost:9999") if err != nil { fmt.Println("Error creating listener:", err) os.Exit(1) } defer listener.Close() fmt.Println("Server is listening on localhost:9999") // 연결 성공여부 및 동작 for { conn, err := listener.Accept() if err != nil { fmt.Println("Error accepting connection:", err) continue } go handleConnection(conn) } } // 전송 데이터 func handleConnection(conn net.Conn) { defer conn.Close() // 전송할 전체 데이터 msg := "Hello from server. This data will be sent in chunks. Each chunk has its own part of the whole message." data := []byte(msg) // 청크 사이즈 정의 chunkSize := 5 // 데이터를 청크로 나누어 전송 for i := 0; i < len(data); i += chunkSize { end := i + chunkSize if end > len(data) { end = len(data) } _, err := conn.Write(data[i:end]) if err != nil { fmt.Println("Error writing to connection:", err) return } } }

package main import ( "fmt" "io" "net" "os" ) func main() { conn, err := net.Dial("tcp", "localhost:9999") if err != nil { fmt.Println("Error connecting to server:", err) os.Exit(1) } defer conn.Close() var receivedData []byte buf := make([]byte, 1024) // 1024 바이트 크기의 버퍼 for { n, err := conn.Read(buf) if err != nil { if err != io.EOF { fmt.Println("Error reading from connection:", err) } break } receivedData = append(receivedData, buf[:n]...) // 수신된 청크 출력 fmt.Printf("Received chunk: %s\n", string(buf[:n])) } fmt.Println("Received message:", string(receivedData)) }

Received chunk: Hello Received chunk: from server. This data will be sen Received chunk: t in chunks. Each ch Received chunk: unk has its own Received chunk: part of the wh Received chunk: ole messag Received chunk: e. Received message: Hello from server. This data will be sent in chunks. Each chunk has its own part of the whole message.

// 파일 보존해더 : Content-Disposition // filename.xlsx 다운로드 Content-Disposition: attachment; filename=filename.xlsx

# --remote-name(-O): Content-Disposition 헤더에 지정된 파일이름 저장 curl --remote-name https://downloads.apache.org/httpd/httpd-2.4.46.tar.gz

package main import ( "io" "log" "net/http" "os" "strconv" ) func main() { url := "https://dlcdn.apache.org/httpd/httpd-2.4.59.tar.bz2" // 대용량 파일 URL outputFile := "complete_largefile.zip" // 완성될 파일 이름 partSize := 1024 * 1024 // 다운로드할 각 파트의 크기 (1MB) client := &http.Client{} outFile, err := os.Create(outputFile) if err != nil { log.Fatalf("Error creating file: %v", err) } defer outFile.Close() // 파일 나눠서 순차 다운로드 for i := 0; ; i++ { start := i * partSize end := start + partSize - 1 // Range 헤더 설정 rangeHeader := "bytes=" + strconv.Itoa(start) + "-" + strconv.Itoa(end) log.Printf("Requesting bytes from %d to %d", start, end) req, err := http.NewRequest("GET", url, nil) if err != nil { log.Fatalf("Error creating request: %v", err) } req.Header.Add("Range", rangeHeader) req.Header.Set("User-Agent", "curl/7.64.1") // 요청 실행 resp, err := client.Do(req) if err != nil { log.Fatalf("Error executing request: %v", err) } defer resp.Body.Close() // 응답 상태 로그 log.Printf("Received status code: %d for range %d-%d", resp.StatusCode, start, end) if resp.StatusCode == http.StatusRequestedRangeNotSatisfiable { log.Println("Reached the end of the file.") break } // 파일의 일부분 쓰기 written, err := io.Copy(outFile, resp.Body) if err != nil { log.Fatalf("Error writing to file: %v", err) } log.Printf("Written %d bytes for range %d-%d", written, start, end) // 206 Partial Content 이외의 응답 처리 if resp.StatusCode != http.StatusPartialContent { log.Fatalf("Expected status 206, got %d", resp.StatusCode) } } log.Println("Download completed successfully!") }

2024/05/13 09:15:15 Requesting bytes from 0 to 1048575 2024/05/13 09:15:15 Received status code: 206 for range 0-1048575 2024/05/13 09:15:15 Written 1048576 bytes for range 0-1048575 2024/05/13 09:15:15 Requesting bytes from 1048576 to 2097151 2024/05/13 09:15:15 Received status code: 206 for range 1048576-2097151 # ... 2024/05/13 09:15:16 Reached the end of the file. 2024/05/13 09:15:16 Download completed successfully!

var xhr = new XMLHttpRequest(); xht.open("GET", "/json", true); xht.onload = function() { // 응답이 들어왔을 때 호출되는 메서드 if (xhr.status == 200) { // JSON 파싱해서 표시 console.log(JSON.parse(xhr.responseText)); } }; xhr.setRequestHeader("MyHeader", "HeaderValue"); xhr.send(); // curl -H "MyHeader=HaderValue" /json 과 동일한 의미

POST /Reservations HTTP/1.1 Host: travelcompany.example.org Content-Type: application/soap+xml; charset="utf-8" Content-Length: nnnn <?xml version='1.0' ?> <env:Envelope xmlns:env="http://www.w3.org/2003/05/soap-envelope" > <env:Header> <t:transaction xmlns:t="http://thirdparty.example.org/transaction" env:encodingStyle="http://example.com/encoding" env:mustUnderstand="true" >5</t:transaction> </env:Header> <env:Body> <m:chargeReservation env:encodingStyle="http://www.w3.org/2003/05/soap-encoding" xmlns:m="http://travelcompany.example.org/"> <m:reservation xmlns:m="http://travelcompany.example.org/reservation"> <m:code>FT35ZBQ</m:code> </m:reservation> <o:creditCard xmlns:o="http://mycompany.example.com/financial"> <n:name xmlns:n="http://mycompany.example.com/employees"> Åke Jógvan Øyvind </n:name> <o:number>123456789099999</o:number> <o:expiration>2005-02</o:expiration> </o:creditCard> </m:chargeReservation </env:Body> </env:Envelope>

POST /jsonrpc HTTP/1.1 Host: api.example.com Content-Type: application/json Content-Length: 94 Accept: application/json { "jsonrpc": "2.0", "method": "subtract", "params": {"subtrahend": 23, "minuend": 42}, "id": 3 }

HTTP/1.1 200 OK Content-Type: application/json Content-Length: 41 { "jsonrpc": "2.0", "result": 19, "id": 3 }

package main import ( "log" "net" "net/http" "net/rpc" "net/rpc/jsonrpc" ) // Calculator 타입 정의, 이를 통해 메서드 제공 type Calculator int // Multiply 메서드 정의, Args 인수를 받아 결과를 result에 저장 func (c *Calculator) Multiply(args Args, result *int) error { // 곱하기 연산 로그 출력 log.Printf("곱하기 연산: %d, %d\n", args.A, args.B) // 곱셈 결과를 result 포인터에 저장 *result = args.A * args.B return nil } // Args 구조체 정의, 두 개의 정수 인수 A와 B 포함 type Args struct { A, B int } func main() { // Calculator 인스턴스 생성 calculator := new(Calculator) // 새로운 RPC 서버 생성 server := rpc.NewServer() // Calculator 타입의 인스턴스를 서버에 등록 server.Register(calculator) // 기본 RPC 경로에 서버 핸들러 설정 http.Handle(rpc.DefaultRPCPath, server) // 서버 시작 로그 출력 log.Println("start http listening : 18888") // TCP 리스너 생성, 포트 18888에서 수신 대기 listener, err := net.Listen("tcp", ":18888") if err != nil { panic(err) } // 클라이언트 연결 수락을 위한 루프 for { // 클라이언트 연결 수락 conn, err := listener.Accept() if err != nil { panic(err) } // 새로운 고루틴에서 연결 처리 go server.ServeCodec(jsonrpc.NewServerCodec(conn)) } }

package main import ( "log" "net/rpc/jsonrpc" ) // Args 구조체 정의, 두 개의 정수 인수 A와 B 포함 type Args struct { A, B int } func main() { // JSON-RPC 클라이언트 생성, localhost:18888에 연결 client, err := jsonrpc.Dial("tcp", "localhost:18888") if err != nil { panic(err) } // 결과를 저장할 변수 선언 var result int // Args 구조체 인스턴스 생성, 값 4와 5 설정 args := &Args{4, 5} // Calculator.Multiply 메서드 호출, 결과를 result에 저장 err = client.Call("Calculator.Multiply", args, &result) if err != nil { panic(err) } // 곱셈 결과 로그 출력 log.Printf("4 x 5 = %d\n", result) }