KRX(한국거래소) 시세 정보는 보통 코스콤(Koscom)의 KOSMOS 시스템을 통해 UDP Multicast 방식 수신방법

# 네트워크 인터페이스 리스트 확인 (예: eth0, enp0s3 등)
ip addr

# 멀티캐스트 라우팅 경로 확인
route -n
# 만약 멀티캐스트 대역(224.0.0.0/4)에 대한 경로가 없다면 추가 (필요 시)
sudo route add -net 224.0.0.0 netmask 240.0.0.0 dev eth0

# 특정 포트(예: 12345)로 들어오는 UDP 패킷 확인
sudo tcpdump -i eth0 udp port 12345 -X -nn

# 특정 멀티캐스트 IP와 포트를 지정하여 확인
sudo tcpdump -i eth0 host 239.XXX.XXX.XXX and udp port 12345 -vv

# 멀티캐스트 그룹에 가입하여 데이터를 표준 출력으로 확인
# IP: 239.1.1.1, PORT: 12345 가정
socat UDP4-RECVFROM:12345,ip-add-membership=239.1.1.1:eth0,fork -

# 패킷을 캡처하여 파일로 저장 (나중에 Wireshark GUI에서 분석 가능)
sudo tshark -i eth0 -f "udp port 12345" -w krx_test.pcap

# 실시간으로 페이로드(데이터)만 추출해서 보기
sudo tshark -i eth0 -f "udp port 12345" -T fields -e data

import socket
import struct

MCAST_GRP = '239.1.1.1' # 코스콤에서 제공한 그룹 IP
MCAST_PORT = 12345      # 코스콤에서 제공한 포트

sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

# 포트 바인딩
sock.bind(('', MCAST_PORT))

# 멀티캐스트 그룹 가입 설정
mreq = struct.pack("4sl", socket.inet_aton(MCAST_GRP), socket.INADDR_ANY)
sock.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq)

print(f"Listening for KRX data on {MCAST_GRP}:{MCAST_PORT}...")

while True:
    data, addr = sock.recvfrom(2048) # 보통 시세 패킷은 1500바이트 이하
    print(f"Received {len(data)} bytes from {addr}")
    print(data) # 데이터 전문 출력

# ufw 사용 시
sudo ufw allow 12345/udp

# iptables 사용 시
sudo iptables -A INPUT -p udp --dport 12345 -j ACCEPT