KRX 시세 데이터를 TCP로 받는 방식은 보통 **시세 중계 서버(Relay Server)**에 접속하여 스트림 데이터를 받아오는 형태

import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketSocketType;

public class KrxTcpReceiver {

    public static void main(String[] args) {
        // 1. 접속 정보 설정 (중계 서버 IP 및 포트)
        String serverIp = "123.123.123.123"; 
        int port = 20001;
        int connectTimeout = 5000; // 5초

        // 2. TCP 소켓 연결
        try (Socket socket = new Socket()) {
            System.out.println("Connecting to KRX Relay Server... " + serverIp + ":" + port);
            socket.connect(new InetSocketAddress(serverIp, port), connectTimeout);
            socket.setKeepAlive(true); // 연결 유지 옵션
            
            System.out.println("Connected successfully.");

            InputStream is = socket.getInputStream();
            BufferedInputStream bis = new BufferedInputStream(is);

            // 3. 데이터 수신 루프
            while (true) {
                // 예시: KRX 공통 헤더가 40바이트이고, 그 중 데이터 길이를 나타내는 부분이 있다고 가정
                // 실제 규격서의 Header 길이를 사용하세요.
                int headerLength = 40; 
                byte[] headerBuffer = new byte[headerLength];

                // 헤더 읽기 (헤더가 다 들어올 때까지 읽음)
                if (!readExactly(bis, headerBuffer, headerLength)) {
                    System.out.println("Connection closed by server.");
                    break;
                }

                // 4. 데이터 길이 파싱 
                // 예: 헤더의 30~34번째 바이트가 바디 길이를 의미하는 ASCII 숫자라고 가정
                // 실제 규격서(Fixed Length)에 따라 이 부분을 수정해야 합니다.
                int bodyLength = parseBodyLength(headerBuffer); 

                // 5. 바디(데이터 본문) 읽기
                byte[] bodyBuffer = new byte[bodyLength];
                if (!readExactly(bis, bodyBuffer, bodyLength)) {
                    break;
                }

                // 6. 데이터 처리 (파싱)
                processMessage(headerBuffer, bodyBuffer);
            }

        } catch (IOException e) {
            System.err.println("Network Error: " + e.getMessage());
            e.printStackTrace();
        }
    }

    /**
     * TCP 스트림에서 지정한 길이만큼 데이터를 완전히 읽을 때까지 대기하는 유틸리티
     */
    private static boolean readExactly(InputStream is, byte[] buffer, int length) throws IOException {
        int totalRead = 0;
        while (totalRead < length) {
            int read = is.read(buffer, totalRead, length - totalRead);
            if (read == -1) return false; // 스트림 종료
            totalRead += read;
        }
        return true;
    }

    /**
     * 전문 헤더에서 바디 길이를 추출 (규격에 따라 구현 필요)
     */
    private static int parseBodyLength(byte[] header) {
        // 예시: 헤더 특정 위치의 문자열을 숫자로 변환
        // String lenStr = new String(header, 30, 4).trim(); 
        // return Integer.parseInt(lenStr);
        return 120; // 테스트를 위한 가상 길이
    }

    /**
     * 수신된 전문 출력 및 처리
     */
    private static void processMessage(byte[] header, byte[] body) {
        try {
            // KRX 시세는 보통 EUC-KR(또는 CP949) 인코딩을 사용함
            String headerStr = new String(header, "EUC-KR");
            String bodyStr = new String(body, "EUC-KR");

            System.out.println("[Recv] Header: " + headerStr);
            System.out.println("[Recv] Body: " + bodyStr);
            System.out.println("--------------------------------------------------");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}