KafkaProducer 기본 구성 요소

목표 client에서 KafkaProducer가 메시지지를 produce하는 과정을 이해한다. Spring 에서 KafkaTemplate 호출시 동작 KafkaTemplate.doSend() 메서드 호출시 KafkaProducer.send() 메서드를 내부에서 호출하고 있다. send() 메서드 호출 시 파라미터로 전송할 ProducerRecord와 Callback 파라미터를 넘겨준다. KafkaProducer의 기본 구성 요소 KafkaProducer: 사용자가 직접 사용하는 클래스. send() 메서드를 호출하면 Record를 전송한다. RecordAccumulator: 사용자가 KafkaProducer::send() 메서드를 호출하면 Record가 바로 전송되는 것이 아니라 RecordAccumulator에 저장된다. 그리고 실제로 Broker에 저장되는 것은 이후에 비동기적으로 이루어진다. Sender: KafkaProducer는 별도의 Sender Thread를 생성한다. Sender Thread는 RecordAccumulator에 저장된 Record들을 Broker로 전송하는 역할을 한다....

2024-09-15 · 1 min · 103 words

K6 시작하기

설치 https://k6.io/docs/getting-started/installation/ 위 링크를 참고하면 내가 원하는 환경의 설치 방법을 확인할 수 있다. 나 같은 경우는 도커 환경에서 성능 테스트를 진행할 예정이라 아래와 같은 명령어를 입력했다. $ docker pull loadimpact/k6 실행 하기 K6의 테스트 작성은 매우 간단했다. JavaScript 파일을 하나 만들어두고 아래와 같이 function 안에 시나리오를 작성하면 된다. import http from 'k6/http'; import { sleep } from 'k6'; export default function () { http.get('https://test.k6.io'); sleep(1); } 도커에서 실행해야되므로 아래와 같이 실행했다....

2024-09-15 · 1 min · 171 words

JUnit 5 Extensions

목표 @ExtendWith 애노테이션의 역할을 알아본다. JUnit 5 Extension JUnit 5에서는 테스트 클래스나 메소드의 동작을 확장하기 위해서 extension을 제공해주고 있다. extension points: 테스트 실행에서 발생할 수 있는 이벤트 지점. 이 지점에서 등록된 extension을 호출할 수 있따. extension point의 5가지 종류: 괄호 안은 구현해야되는 인터페이스 테스트 인스턴스 후처리(TestInstancePostProcessor): 일반적으로 의존성 주입할 때 사용한다. 조건부 테스트 실행( ExecutionCondition): 조건에 따라 테스트 실행 여부를 설정할 수 있다. 라이프사이클 콜백: 테스트 라이프사이클에 행동을 추가할 수 있다....

2024-09-15 · 1 min · 145 words

JSP에서 SpEL 사용 시 null 인 경우 예외 발생

배경 Spring Framework에서는 view가 JSP 인 경우에 대한 여러 가지 기능을 tag 기능으로 제공해주고 있다. 그 중 eval 태그를 사용하면 JSP에서 변수를 할당하거나 출력할 수 있다. <spring:eval expression="someVariable" /> 위 예시에서 someVariable이 null 인 경우에 SpelEvaluationException 가 발생한다. 해결 방법 이를 해결하기 위해서는 사용할 변수의 scope를 명확하게 명시해야 된다고 한다. <spring:eval expression="requestScope['someVariable']?.bytes"/> 참고 자료 https://github.com/spring-projects/spring-framework/issues/13211 https://stackoverflow.com/questions/16289341/how-to-pass-a-null-variable-into-a-spring-expression-in-jsp https://docs.spring.io/spring-framework/docs/4.2.x/spring-framework-reference/html/spring-tld.html#spring.tld.eval

2024-09-15 · 1 min · 57 words

Jsoup Java를 이용해서 크롤링 하기

특정 URL의 문서 가져오기 Document doc = Jsoup.connect("http://example.com/").get(); selector 문법으로 원하는 위치의 엘리먼트 가져오기 Elements links = doc.select("a[href]"); // a with href Elements 는 ArrayList 를 상속하고 있다. 엘리먼트의 속성값 가져오기 String relHref = link.attr("href"); 참고 자료 https://jsoup.org/cookbook/extracting-data/working-with-urls

2024-09-15 · 1 min · 38 words

JpaRepository에서 SQL 작성하기

@Query 어노테이션에 nativeQuery 필드를 true로 설정하면 JPQL이 아닌 SQL 문을 작성할 수 있다. @Query( value = "SELECT * FROM USERS u WHERE u.status = 1", nativeQuery = true) Collection<User> findAllActiveUsersNative(); 참고 자료 https://www.baeldung.com/spring-data-jpa-query

2024-09-15 · 1 min · 33 words

JobParameters

목표 JobParameters가 무엇인지 이해한다. JobParameters 배치 작업에서 런타임 매개변수를 던져주기 위한 VO다. 이를 사용하기 위해서는 Job이나 Step의 late binding이 가능하도록 설정해야된다. late binding으로 동작하고자 하는 Step은 아래와 같이 step scope를 지정하면 된다. 이는 Job을 실제로 실행하기 전까지 인스턴스화 하지 않는다. 또한 Step을 실행할 때 마다가 각자 다른 인스턴스가 실행되어서 병렬 처리시에 충돌이 발생하지 않는다. @StepScope @Bean public FlatFileItemReader flatFileItemReader(@Value("#{jobParameters['input.file.name']}") String name) { return new FlatFileItemReaderBuilder<Foo>() .name("flatFileItemReader") .resource(new FileSystemResource(name)) ... } 참고 자료 https://docs....

2024-09-15 · 1 min · 76 words

JDK 라이센스 문제

Java 애플리케이션을 컴파일하기 위한 JDK는 크게 Oracle JDK와 OpenJDK로 나뉜다. Oracle JDK의 경우 일반적인 목적(General Purpose Computing)이 아닌 경우 라이센스 비를 지불해야된다. 따라서, 여러 회사에서는 이 애매한 표현 때문에 대부분 오픈소스인 OpenJDK를 사용한다. Java SE7부터 모든 JDK는 OpenJDK 레퍼런스 코드를 기반으로 제작된다. Oracle JDK 또한 마찬가지다. OpenJDK 운영 주체 또한 Oracle이다. 오라클이 아닌 서드파티 업체가 OpenJDK를 기반으로 공인된 JDK를 제작하여 배포하려면 오라클의 유료 라이센스인 OCTLA에 가입해야 한다. 현재 전세계에 19개 업체가 가입되어 있다....

2024-09-15 · 1 min · 103 words

JDBC의 SQL Injection 대응

정확히는 JDBC 내부적으로 SQL Injection에 대응하고 있다. PreparedStatement 클래스를 예로 들면 setString() 메서드에 내부적으로 SQL Injection에 대응하고 있기 때문에 안전하게 사용할 수 있다. https://www.baeldung.com/sql-injection 따라서 아래와 같은 코드를 작성하지 않도록 조심하자. String sql = "select " + "customer_id,acc_number,branch_id,balance " + "from Accounts where customer_id = '" + customerId + "'"; Connection c = dataSource.getConnection(); ResultSet rs = c.createStatement().executeQuery(sql); select count(1) from user where id = ? and password = ?

2024-09-15 · 1 min · 70 words

JDBC에서 모든 테이블 이름 찾기

Rest Assured를 통한 E2E 테스트 진행시, 모든 테스트를 독립적으로 만들기 위해 각 테스트마다 모든 테이블을 TRUNCATE 할 필요가 있었다. 그래서 모든 테이블의 이름을 찾는 과정이 필요했다. DatabaseMetaData 를 통해 찾을 수 있다고 한다. DatabaseMetaData는 Connection을 통해 얻을 수 있다. 나같은 경우 Spring을 사용하고 있어서 JdbcTemplate를 통해서 구할 수 있었다. private void truncateAllTables() throws SQLException { JdbcTestUtils.deleteFromTables(jdbcTemplate, getAllTables().toArray(new String[0])); } private List<String> getAllTables() throws SQLException { DatabaseMetaData metaData = jdbcTemplate.getDataSource().getConnection().getMetaData(); List<String> tables = new ArrayList<>(); try (ResultSet resultSet = metaData....

2024-09-15 · 1 min · 104 words

JDBC에서 MySQL의 COUNT 함수 리턴 타입

배경 MyBatis를 이용해 특정 id별 COUNT 결과를 Pair<Long, Int> 로 리턴했더니, 타입 캐스팅 예외가 발생했다. java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer 문제 상황 예시 코드 @Select("...") fun countByIds(ids: List<Long>): List<Pair<Long, Int>> 원인 MySQL의 COUNT 함수의 리턴 타입은 BIGINT 이다. MySQL JDBC Driver 에서 BIGINT는 기본적으로 Java의 Long 타입으로 변환되므로 타입 캐스팅 예외가 발생한다. 참고 자료 https://dev.mysql.com/doc/refman/8.0/en/aggregate-functions.html#function_count https://dev.mysql.com/doc/connector-j/en/connector-j-reference-type-conversions.html

2024-09-15 · 1 min · 58 words

JdbcTemplate와 템플릿 콜백 패턴

템플릿/콜백 패턴: 전략 패턴의 기본 구조에 익명 내부 클래스를 활용한 방식이다. 템플릿/콜백 패턴은 DI 방식의 전략 패턴 구조다. 클라이언트가 템플릿 메소드를 호출하면서 콜백 오브젝트를 전달하는 방식으로 메소드 레벨에서 일어나는 DI다. 템플릿: 어떤 목적을 위해 미리 만들어둔 모양이 있는 틀을 가리킨다. 템플릿 메소드 패턴은 고정된 틀의 로직을 가진 템플릿 메소드를 슈퍼클래스에 두고, 바뀌는 부분을 서브 클래스의 메소드에 두는 구조로 이루어진다. 콜백: 실행되는 것을 목적으로 다른 오브젝트의 메소드에 전달되는 오브젝트를 말한다. 자바에선 메소드 자체를 파라미터로 넘기지 못하기 때문에 메소드가 담긴 오브젝트를 넘긴다....

2024-09-15 · 1 min · 136 words

JdbcPreparedStatement의 setObject

PreparedStatement의 setObject메소드로 파라미터 매핑을 했을 때 어떻게 자동으로 타입을 찾는지 궁금해서 조금 찾아봤다. // JdbcPreparedStatement @Override public void setObject(int parameterIndex, Object x) throws SQLException { try { if (isDebugEnabled()) { debugCode("setObject(" + parameterIndex + ", x);"); } if (x == null) { setParameter(parameterIndex, ValueNull.INSTANCE); } else { setParameter(parameterIndex, DataType.convertToValue(session, x, Value.UNKNOWN)); } } catch (Exception e) { throw logAndConvert(e); } } JdbcPreparedStatement의 setObject를 보면 다음과같이 DataType.convertToValue 메서드로 타입을 변환한다. https://github.com/chris-martin/h2/blob/a639abcdfd5928ea23b7dd3827cb8567e162a0a1/h2/src/main/org/h2/value/DataType.java#L882...

2024-09-15 · 1 min · 82 words

JDBC execute vs executeQuery vs executeUpdate

execute: 일반적인 sql 실행. 리턴 타입이 ResultSet이면 TRUE, 아니면 false다. executeQuery: 특정 데이터를 탐색할 때 사용하는 메소드. 리턴타입이 ResultSet이다. executeUpdate: DML, DDL 등을 입려할 때 사용하는 메소드. 리턴타입이 int로 영향받은 행의 개수를 반환한다. 참고 자료 https://javaconceptoftheday.com/difference-between-executequery-executeupdate-execute-in-jdbc/

2024-09-15 · 1 min · 36 words

Java의 Comparator와 Comparable

Java에서 커스텀 클래스를 PriorityQueue에 담기 위해서, 정렬 기준을 구현할 필요가 있다. Java에서 정렬을 구현하는 방법에는 두 가지가 있다. Comparable 인터페이스 구현 Comparator 인터페이스 구현 위 두 인턴페이스 모두 함수형 인터페이스로 람다식으로 표현도 가능하다. Comparable 하나의 객체가 다른 객체를 비교할 수 있음을 나타내는 인터페이스다. public int compareTo(T o) 메서드를 구현하면 된다. 정렬 순서를 정할 때, 비교할 대상의 객체보다 앞에 오게 하려면 음수를 반환, 뒤에 오게 하려면 양수를 반환, 같으면 0을 반환하면 된다....

2024-09-15 · 2 min · 254 words

Java에서 String이 불변 객체인 이유

Java에서 String a, b 를 더했을 때 나오는 결과는 새로운 주소값을 가지는 것을 확인할 수 있다. 이렇게 Java에서는 왜 String을 불변 객체로 관리가 되는지 정리해본다. 1. String Pool로 인한 메모리 절약 Java에서는 String 리터럴 값을 사용하면 String Pool에 값을 캐싱하게 된다. 같은 String이라면 새로 인스턴스를 생성하지 않고 String Pool에서 재사용하기 때문에 힙 메모리 영역을 절약할 수 있다. 2. 보안 String은 사용자 이름, 비밀번호 등 민감한 정보를 저장하기 위해 주로 사용된다. 만약 String이 불변이 아니라면, 문자열을 사용하는 중간에 값이 바뀔 수도 있어서 안전하지 않다....

2024-09-15 · 1 min · 148 words

JavaScript로 POST 요청 보내기

fetch 함수를 사용한다. await fetch('http://localhost:8080/api/games', { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify({ "alternativeNames": ["롤"], "images": ["img1", "img2", "img3"], "name": "League Of Legends" }) });

2024-09-15 · 1 min · 27 words

Java 스레드

기본 소개 Java에서는 경합 상태일 때 데이터의 정합성을 보장하기 위해 스레드 동기화로 한 번에 하나의 스레드만 공유 자원에 접근할 수 있도록 한다. 이를 구현하기위해 Java에서는 각 인스턴스들이 자신의 Monitor를 가지게하고, 스레드가 이 인스턴스를 사용할 때 Monitor를 점유하도록 한다. 이 Monitor는 하나의 스레드만 점유할 수 있기때문에, 다른 스레드들은 Wait Queue에서 기다리게 된다. (synchronized 키워드를 사용하면 점유하게된다) Java 스레드에는 ‘데몬 스레드(daemon thread)’와 ‘일반 스레드(non-daemon thread)’가 있다. 데몬 스레드: 백그라운드로 실행되고, 일반 스레드가 모두 종료되면 데몬 스레드의 의미가 사라지기 때문에 강제적으로 자동 종료된다....

2024-09-15 · 2 min · 249 words

Java 버전 명시

sourceCompatibility 와 targetCompatibility 를 사용하면된다. sourceCompatibility: .java 파일을 컴파일 할 때 사용할 Java 프로그래밍 언어의 버전. targetCompatibility: 생성 될 클래스파일이 호환되어야 하는 VM의 버전. 기본적으로 source와 같은 값이 되므로 같다면 명시해줄 필요가 없다. 참고 자료 https://docs.gradle.org/3.3/userguide/java_plugin.html#sec:java_convention_properties https://www.cloudhadoop.com/gradle-configure-java-version/

2024-09-15 · 1 min · 37 words

Java 메서드 파라미터의 final 자동으로 붙이기

2024-09-15 · 0 min · 0 words