ci2u.com

패킷을 UDP로 수신하여 Kafka의 특정 토픽(Topic)으로 전송하는 구조로 수정해 드리겠습니다. 이 코드를 실행하려면 프로젝트에 Kafka Client 라이브러리가 포함되어야 합니다. (Maven 또는 Gradle 설정 필요) 1. Maven 의존성 추가 (pom.xml) <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>3.5.0</version> </dependency> 2. Kafka 연동 Java 샘플 (KrxUdpToKafka.java) import org.apache.kafka.clients.producer.*; import org.apache.kafka.common.serialization.ByteArraySerializer; import org.apache.kafka.common.serialization.StringSerializer; import java.net.*; import java.util.Properties; public class KrxUdpToKafka { public static … 더 읽기

JDK 1.8 환경에서 동작하는 UDP 멀티캐스트 수신 프로그램 예제입니다. 자바 8에서는 java.net.MulticastSocket 클래스를 사용하여 멀티캐스트 데이터를 손쉽게 수신할 수 있습니다. UDP 멀티캐스트 수신 예제 코드 codeJava import java.io.IOException; import java.net.DatagramPacket; import java.net.InetAddress; import java.net.MulticastSocket; public class MulticastReceiver { public static void main(String[] args) { // 1. 멀티캐스트 IP와 포트 설정 // 멀티캐스트 IP 범위: 224.0.0.0 ~ 239.255.255.255 … 더 읽기

KRX 시세 데이터를 TCP로 받는 방식은 보통 **시세 중계 서버(Relay Server)**에 접속하여 스트림 데이터를 받아오는 형태입니다. TCP는 UDP와 달리 데이터의 경계가 없으므로, 전문 헤더에 정의된 길이만큼 정확하게 잘라서 읽는 로직이 핵심입니다. Java의 Socket과 BufferedInputStream을 이용한 실무형 샘플 코드를 작성해 드립니다. KRX 시세 TCP 수신 Java 샘플 codeJava import java.io.BufferedInputStream; import java.io.IOException; import java.io.InputStream; import java.net.InetSocketAddress; import java.net.Socket; import … 더 읽기

KRX(한국거래소) 시세 데이터는 보통 UDP Multicast 방식으로 전송됩니다. Java에서 이를 수신하려면 MulticastSocket을 사용해야 하며, 특히 리눅스 서버 환경에서는 **네트워크 인터페이스(Network Interface)**를 명확하게 지정해주는 것이 중요합니다. 가장 최신 방식인 Java 7 이후의 NIO와 MulticastSocket을 이용한 샘플 코드를 작성해 드립니다. KRX 시세 UDP 수신 Java 샘플 codeJava 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 … 더 읽기

KRX 시세 데이터는 기본적으로 UDP Multicast로 송출되지만, 개발 환경이나 특정 솔루션(VND, 시세 분배 서버 등)을 거칠 때는 TCP Relay 방식을 사용하는 경우가 많습니다. TCP는 UDP와 달리 1:1 연결(Connection-oriented) 방식이므로, 멀티캐스트 그룹 가입 과정이 필요 없고 서버의 IP와 포트로 직접 접속해야 합니다. 관련 커맨드를 정리해 드립니다. 1. 연결 상태 확인 (Connectivity Test) 가장 먼저 개발 서버에서 시세 제공 서버(Gateway)의 포트가 열려 있는지 … 더 읽기

KRX(한국거래소) 시세 정보는 보통 코스콤(Koscom)의 KOSMOS 시스템을 통해 UDP Multicast 방식으로 전송됩니다. 개발 서버에서 이 데이터를 확인하기 위해서는 단순히 포트를 여는 것을 넘어, **Multicast Group에 가입(Join)**하고 패킷을 캡처하는 과정이 필요합니다. 주요 상황별 커맨드를 정리해 드립니다. 1. 네트워크 환경 확인 Multicast 패킷이 들어오는 인터페이스를 먼저 확인해야 합니다. codeBash # 네트워크 인터페이스 리스트 확인 (예: eth0, enp0s3 등) ip addr # … 더 읽기

먼저 중요한 점을 명확히 해야 합니다. Google의 Gemini(Pro, Flash 등) 모델은 클라우드 기반 API로 작동하기 때문에, 순수하게 오프라인 상태에서는 사용할 수 없습니다. 하지만, 두 가지 대안을 통해 원하는 환경을 구축할 수 있습니다. Gemini CLI 설치 (온라인 상태 필요): 터미널에서 Gemini API를 호출하여 사용하는 방법. Gemma 설치 (완전 오프라인 가능): Google에서 공개한 오픈 모델인 Gemma를 내 컴퓨터에 직접 설치하여 인터넷 없이 사용하는 방법. … 더 읽기

와탭(WhaTap)에서 로그 모니터링 기능을 효율적으로 활용하기 위해서는 **정형화된 로그 포맷(Structured Logging)**을 사용하는 것이 가장 중요합니다. 와탭은 기본적으로 텍스트 로그를 수집하지만, 분석과 알림 설정을 용이하게 하려면 JSON 포맷이나 일정한 패턴의 텍스트 포맷을 권장합니다. 와탭 모니터링에 최적화된 로그 포맷 구성 요소를 정리해 드립니다. 1. 권장 로그 포맷: JSON (가장 추천) JSON 포맷은 와탭의 로그 검색 및 통계 분석 기능을 … 더 읽기

Tuxedo 서비스를 Java에서 호출하기 위해서는 일반적으로 Oracle Jolt 라이브러리를 사용합니다. Jolt는 Java 애플리케이션이 Tuxedo 서비스와 통신할 수 있게 해주는 인터페이스입니다. 아래는 Jolt를 사용하여 Tuxedo 서비스를 호출(TR)하는 기본적인 Java 샘플 코드입니다. 1. 사전 준비사항 라이브러리: jolt.jar, joltremote.jar 파일이 프로젝트 클래스패스(Classpath)에 추가되어 있어야 합니다. Tuxedo 설정: Tuxedo 서버 쪽에 JSL(Jolt Server Listener)이 설정되어 있어야 하며, 호출하려는 서비스가 Jolt Repository에 등록되어 있어야 합니다. 2. … 더 읽기

오라클 21c XE 설치 중 발생하는 [DBT-06103] 포트(5,500) 사용 중 오류는 주로 이전 설치의 잔재가 남아 있거나, 다른 프로세스가 해당 포트(Oracle Enterprise Manager Express용)를 점유하고 있을 때 발생합니다. 재설치를 위해 아래 단계별 해결 방법을 시도해 보세요. 1. 포트 5500을 점유 중인 프로세스 확인 및 종료 먼저 실제로 어떤 프로그램이 5500 포트를 쓰고 있는지 확인해야 합니다. **명령 프롬프트(CMD)**를 관리자 권한으로 … 더 읽기