KRX(한국거래소) 시세 데이터는 보통 UDP Multicast 방식 수신샘플(JAVA)

import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.MulticastSocket;
import java.net.NetworkInterface;
import java.net.StandardSocketOptions;
import java.util.Enumeration;

public class KrxUdpReceiver {

    public static void main(String[] args) {
        // 1. 코스콤/KRX에서 제공한 설정 정보 (예시)
        String mcastIp = "239.1.1.1"; // 멀티캐스트 그룹 IP
        int port = 12345;             // 포트 번호
        String interfaceName = "eth0"; // 데이터가 들어오는 랜카드 이름 (ip addr로 확인)

        try {
            // 2. 멀티캐스트 소켓 생성 및 포트 바인딩
            MulticastSocket socket = new MulticastSocket(port);
            
            // 소켓 옵션 설정 (포트 재사용)
            socket.setReuseAddress(true);

            // 3. 네트워크 인터페이스 설정
            // 서버에 랜카드가 여러 개인 경우, 데이터를 받을 랜카드를 명확히 지정해야 함
            NetworkInterface networkInterface = NetworkInterface.getByName(interfaceName);
            if (networkInterface == null) {
                // 인터페이스 이름을 모를 경우 첫 번째 유효한 인터페이스 선택 (주의 필요)
                networkInterface = NetworkInterface.getByInetAddress(InetAddress.getLocalHost());
            }

            // 4. 멀티캐스트 그룹 가입 (IGMP Join)
            InetAddress group = InetAddress.getByName(mcastIp);
            InetSocketAddress groupAddress = new InetSocketAddress(group, port);
            socket.joinGroup(groupAddress, networkInterface);

            System.out.println(String.format("Listening KRX UDP on %s:%d (Interface: %s)...", 
                                mcastIp, port, networkInterface.getName()));

            // 5. 수신 버퍼 설정 (KRX 패킷은 보통 MTU 사이즈인 1500바이트 이하)
            byte[] buffer = new byte[2048];
            
            while (true) {
                DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
                
                // 데이터 수신 (패킷이 들어올 때까지 블로킹)
                socket.receive(packet);

                // 6. 데이터 처리
                byte[] receivedData = new byte[packet.getLength()];
                System.arraycopy(packet.getData(), 0, receivedData, 0, packet.getLength());

                processPacket(receivedData);
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 수신된 바이너리 데이터를 처리하는 메서드
     */
    private static void processPacket(byte[] data) {
        // 실무에서는 여기서 전문 가이드(Spec)에 따라 바이트를 잘라 파싱합니다.
        // 예: 종목코드(최초 12바이트), 현재가, 거래량 등
        
        System.out.println("--------------------------------------------------");
        System.out.println("Received Packet Length: " + data.length);
        
        // 헥사(Hex) 출력 (디버깅용)
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < Math.min(data.length, 50); i++) { // 앞 50바이트만 출력
            sb.append(String.format("%02X ", data[i]));
        }
        System.out.println("Hex Data (First 50b): " + sb.toString());
        
        // ASCII 변환 출력 (문자열 데이터 확인용)
        // KRX 데이터는 보통 EUC-KR(CP949)을 사용합니다.
        try {
            String rawString = new String(data, "EUC-KR");
            System.out.println("Raw String: " + rawString.substring(0, Math.min(rawString.length(), 100)));
        } catch (Exception e) {
            System.out.println("ASCII Conversion Error");
        }
    }
}