네트워크 (java / OSI 7계층)

package transport;
 
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
 
public class TcpServerSocketExample {
    public static void main(String[] args) {
        int port = 8080; // L4 계층의 포트 번호 지정
 
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("L4 Server가 포트 " + port + "에서 클라이언트 연결을 대기 중입니다.");
 
            while (true) {
                // 클라이언트와의 3-Way Handshake가 백그라운드(OS)에서 완료되면 연결 소켓을 반환받음
                try (Socket clientSocket = serverSocket.accept();
                     BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                     PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true)) {
 
                    System.out.println("클라이언트가 연결되었습니다: " + clientSocket.getRemoteSocketAddress());
 
                    // 스트림을 통한 데이터 읽기
                    String clientMessage = in.readLine();
                    System.out.println("수신된 메시지: " + clientMessage);
 
                    // 클라이언트에 응답 전송
                    out.println("서버에서 보내는 응답: " + clientMessage);
                } catch (Exception e) {
                    System.err.println("클라이언트 처리 중 오류 발생: " + e.getMessage());
                }
            }
        } catch (Exception e) {
            System.err.println("서버 소켓 오픈 실패: " + e.getMessage());
        }
    }
}

package presentation;
 
import com.fasterxml.jackson.databind.ObjectMapper;
 
public class SerializationExample {
 
    // 전송할 도메인 객체 정의
    public static class UserDto {
        private String name;
        private int age;
 
        public UserDto() {} // 기본 생성자 필수
 
        public UserDto(String name, int age) {
            this.name = name;
            this.age = age;
        }
 
        public String getName() { return name; }
        public int getAge() { return age; }
    }
 
    public static void main(String[] args) {
        ObjectMapper objectMapper = new ObjectMapper();
 
        try {
            UserDto user = new UserDto("홍길동", 30);
 
            // 1. Serialization (Java 객체 -> JSON 문자열) : 네트워크 송신을 위한 준비
            String jsonString = objectMapper.writeValueAsString(user);
            System.out.println("L6 직렬화 결과 (네트워크로 전송할 데이터 포맷):");
            System.out.println(jsonString);
 
            // 2. Deserialization (JSON 문자열 -> Java 객체) : 수신한 데이터 해석
            UserDto deserializedUser = objectMapper.readValue(jsonString, UserDto.class);
            System.out.println("\nL6 역직렬화 결과 (애플리케이션이 이해할 수 있는 객체 포맷):");
            System.out.println("이름: " + deserializedUser.getName() + ", 나이: " + deserializedUser.getAge());
 
        } catch (Exception e) {
            System.err.println("직렬화/역직렬화 실패: " + e.getMessage());
        }
    }
}

package application;
 
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.time.duration.Duration;
 
public class HttpClientExample {
    public static void main(String[] args) {
        // HTTP 통신을 수행할 클라이언트 인스턴스 생성
        HttpClient httpClient = HttpClient.newBuilder()
                .connectTimeout(Duration.ofSeconds(5))
                .build();
 
        // HTTP GET 요청 명세 작성 (URI, Method 등 애플리케이션 규약 정의)
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create("[https://jsonplaceholder.typicode.com/posts/1](https://jsonplaceholder.typicode.com/posts/1)"))
                .header("Accept", "application/json")
                .GET()
                .build();
 
        try {
            System.out.println("L7 HTTP GET 요청을 전송합니다.");
 
            // 내부적으로 L4 소켓이 생성되고, L6 수준의 헤더/바디 포맷팅을 거쳐 비동기/동기 통신이 수행됨
            HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
 
            System.out.println("응답 상태 코드: " + response.statusCode());
            System.out.println("응답 바디 데이터:");
            System.out.println(response.body());
 
        } catch (Exception e) {
            System.err.println("HTTP 통신 오류 발생: " + e.getMessage());
        }
    }
}