백엔드 마이크로서비스 Webflux(Reactor-core)용 Java 라이브러리 소개
깃허브 링크: https://github.com/hoangtien2k3/reactify-core
1. 도서관 개요
이 라이브러리는 반응형 프로그래밍을 지원하는 두 가지 강력한 도구인 Spring WebFlux 및 Reactor-Core의 핵심 구성 요소를 기반으로 구축되었습니다. 이 라이브러리를 사용하면 비동기식 마이크로서비스 애플리케이션을 쉽게 구축하여 비선형 데이터 스트림을 효율적으로 처리할 수 있습니다.
주요 기능은 다음과 같습니다.
- 완전한 반응형 프로그래밍 지원: 스트림 기반 비동기 데이터 처리
- 고성능 최적화: 필요한 스레드 수를 최소화하고 CPU 리소스를 최대화합니다.
- 쉬운 확장성: 대량의 사용자 요청을 처리해야 하는 마이크로서비스 시스템에 적합합니다.
2. 도서관의 장점
뛰어난 성능과 우수한 반응성:
비차단 메커니즘을 사용하는 이 라이브러리는 너무 많은 스레드를 생성하지 않고도 수천 개의 동시 요청을 처리할 수 있으므로 리소스 로드가 줄어들고 응답 속도가 향상됩니다.간편한 스트림 처리:
Reactor-Core는 실시간 알림 시스템, 이벤트 처리, 빅데이터 처리 시스템 등 지속적인 데이터 처리가 필요한 애플리케이션에 적합한 스트림 처리를 위한 강력한 API를 제공합니다.Spring 생태계와의 손쉬운 통합:
이 라이브러리는 Spring Security, Spring Data R2DBC 등 Spring 생태계의 구성 요소와 잘 작동하도록 설계되어 적은 노력으로 완전한 애플리케이션을 구축하는 데 도움이 됩니다.
반응 코어 설정
1. @ComponentScan 주석을 사용하여 모든 라이브러리를 스캔합니다.
@ComponentScan(basePackages = { "com.reactify.*", // add default: com.reactify.* "com.example.myproject" // varies depending on your project }) @SpringBootApplication public class ExampleApplication { public static void main(String[] args) { SpringApplication.run(Example.class, args); } }
2. 프로젝트 파일 application.yml 또는 application.properties를 구성합니다.
# spring config spring: main: web-application-type: reactive allow-bean-definition-overriding: true messages: basename: i18n/messages #connect db R2DBC PostgreSQL r2dbc: url: r2dbc:postgresql://localhost:5434/auth username: admin password: admin pool: max-size: 10 initial-size: 5 # Config connect Keycloak security: oauth2: client: provider: oidc: token-uri: ${keycloak.serverUrl}/realms/${keycloak.realm}/protocol/openid-connect/token registration: oidc: client-id: ${keycloak.clientId} client-secret: ${keycloak.clientSecret} authorization-grant-type: ${keycloak.grantType} #password || #client_credentials resourceserver: jwt: jwk-set-uri: ${keycloak.serverUrl}/realms/${keycloak.realm}/protocol/openid-connect/certs keycloak: client-id: ${keycloak.clientId} # Web client config client: #keycloak keycloak: address: http://localhost:8080/realms/ezbuy-server/protocol/openid-connect name: keycloak auth: client-id: ezbuy-client client-secret: mI92QDfvi20tZgFtjpRAPWu8TR6eMHmw #notification notification: internal-oauth: true address: http://localhost:7777/v1/transmission name: notiServiceClient pool: max-size: 100 max-pending-acquire: 100 timeout: read: 60000 write: 1000 # Unauthenticated endpoints config application: http-logging: request: enable: true header: true param: true body: true response: enable: true body: true whiteList: - uri: /v1/auth/generate-otp methods: - POST - uri: /** methods: - OPTIONS - uri: /v1/auth/get-all methods: - GET data: sync-data: limit: 500 #keycloak client config keycloak: clientId: ezbuy-client clientSecret: mI92QDfvi20tZgFtjpRAPWu8TR6eMHmw realm: ezbuy-server serverUrl: http://localhost:8080 grantType: password host: localhost # minio server config minio: bucket: ezbuy-bucket enabled: true baseUrl: http://localhost:9000 publicUrl: http://localhost:9000/ezbuy-bucket accessKey: 4DoaZ0KdzpXdDlVK104t secretKey: nuRiQUIJNVygMOHhmtR4LT1etAa7F8PQOsRGP5oj private: bucket: ezbuy-private
3. 구성을 완료한 후 프로젝트 실행을 시작합니다.
# Using Maven mvn spring-boot:run # Using Gradle gradle bootRun
4. 다음 프로젝트를 참조하십시오.
webflux 마이크로서비스 프로젝트용 reactify-core 라이브러리: keycloak-auth-service
누구나 피드백을 제공하고 오류를 찾아내거나 이 라이브러리를 개선하여 커뮤니티를 더욱 강력하게 발전시킬 수 있습니다. 정말 감사합니다
좋은 하루 보내세요
위 내용은 백엔드 마이크로서비스 Webflux(Reactor-core)용 Java 라이브러리 소개의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

핫 AI 도구

Undress AI Tool
무료로 이미지를 벗다

Undresser.AI Undress
사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.

Clothoff.io
AI 옷 제거제

Video Face Swap
완전히 무료인 AI 얼굴 교환 도구를 사용하여 모든 비디오의 얼굴을 쉽게 바꾸세요!

인기 기사

뜨거운 도구

메모장++7.3.1
사용하기 쉬운 무료 코드 편집기

SublimeText3 중국어 버전
중국어 버전, 사용하기 매우 쉽습니다.

스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경

드림위버 CS6
시각적 웹 개발 도구

SublimeText3 Mac 버전
신 수준의 코드 편집 소프트웨어(SublimeText3)

해시 맵은 Java의 해시 테이블을 통해 키 값 쌍 스토리지를 구현하며, 그 핵심은 데이터 위치를 빠르게 배치하는 데 있습니다. 1. 먼저 키의 hashcode () 메소드를 사용하여 해시 값을 생성하고 비트 작업을 통해 배열 인덱스로 변환합니다. 2. 다른 객체가 동일한 해시 값을 생성하여 충돌을 일으킬 수 있습니다. 현재 노드는 링크 된 목록의 형태로 장착됩니다. JDK8 후 링크 된 목록이 너무 길고 (기본 길이 8) 효율을 향상시키기 위해 빨간색과 검은 색 트리로 변환됩니다. 3. 사용자 정의 클래스를 키로 사용하는 경우 equals () 및 hashcode () 메소드를 다시 작성해야합니다. 4. 해시 맵은 용량을 동적으로 확장합니다. 요소 수가 용량을 초과하고 하중 계수 (기본 0.75)를 곱하면 확장 및 재사용; 5. 해시 맵은 스레드 안전이 아니며 Multithreaded에서 Concu를 사용해야합니다.

TOSETJAVA_HOMEONWINDOWS, FIRSTLOCATETEJDKINSTALLATIONPATH (예 : C : \ ProgramFiles \ java \ jdk-17), thencreateasystemenvaria blenamedjava_homewiththatpath.next, updatePathVariableByadding%java \ _home%\ bin, andverifythesetupusingjava-versionandjavac-v

가상 스레드는 동시성과 IO 집약적 시나리오에서 상당한 성능 이점을 가지고 있지만 테스트 방법과 해당 시나리오에주의를 기울여야합니다. 1. 정확한 테스트는 실제 비즈니스, 특히 IO 차단 시나리오를 시뮬레이션하고 JMH 또는 Gatling과 같은 도구를 사용하여 플랫폼 스레드를 비교해야합니다. 2. 처리량 간격은 분명하며, 일정이 가볍고 효율적이기 때문에 10 만 동시 요청보다 여러 배에서 10 배나 높을 수 있습니다. 3. 테스트 중에, 높은 동시성 수치를 맹목적으로 추구하고, 비 차단 IO 모델에 적응하고, 대기 시간 및 GC와 같은 모니터링 지표에주의를 기울일 필요가있다. 4. 실제 애플리케이션에서는 웹 백엔드, 비동기 작업 처리 및 많은 동시 IO 시나리오에 적합하지만 CPU 집약적 작업은 플랫폼 스레드 또는 포크 플랫폼에 여전히 적합합니다.

JDBC 트랜잭션을 올바르게 처리하려면 먼저 자동 커밋 모드를 끄고 여러 작업을 수행 한 다음 결과에 따라 커밋 또는 롤백을 수행해야합니다. 1. 트랜잭션을 시작하려면 Conn.SetAutoCommit (False)에게 전화하십시오. 2. 인서트 및 업데이트와 같은 여러 SQL 작업을 실행합니다. 3. 모든 작업이 성공한 경우 Conn.commit ()에게 전화하여 데이터 일관성을 보장하기 위해 예외가 발생하면 Conn.Rollback ()에게 전화하십시오. 동시에, 재 시도는 리소스를 관리하고, 예외를 올바르게 처리하고, 연결 유출을 피하기 위해 긴밀한 연결을 사용하는 데 사용해야합니다. 또한 연결 풀을 사용하고 부분적으로 롤백을 달성하기 위해 저장 포인트를 설정하고 성능을 향상시키기 위해 거래를 가능한 한 짧게 유지하는 것이 좋습니다.

링크 된 목록을 구현하기위한 핵심은 노드 클래스를 정의하고 기본 작업을 구현하는 것입니다. first 데이터 및 다음 노드에 대한 참조를 포함하여 노드 클래스를 만듭니다. linkedlist 클래스를 생성하여 삽입, 삭제 및 인쇄 기능을 구현합니다. hepend 메소드는 꼬리에 노드를 추가하는 데 사용됩니다. printList 메소드는 링크 된 목록의 내용을 출력하는 데 사용됩니다. deletewithValue 메소드는 지정된 값으로 노드를 삭제하고 헤드 노드와 중간 노드의 다른 상황을 처리하는 데 사용됩니다.

Servicemesh는 Java Microservice Architecture의 진화를위한 불가피한 선택이며, 그 핵심은 네트워크 논리 및 비즈니스 코드를 분리하는 데 있습니다. 1. Servicemesh는 부하 밸런싱, 퓨즈, 모니터링 및 기타 기능을 부상 에이전트를 통해 처리하여 비즈니스에 중점을 둡니다. 2. Istio Envoy는 중간 및 대형 프로젝트에 적합하며 Linkerd는 가볍고 소규모 시험에 적합합니다. 3. Java 마이크로 서비스는 Feign, Ribbon 및 기타 구성 요소를 닫고 발견 및 의사 소통을 위해 Istiod로 넘겨야합니다. 4. 배치 중 사이드카의 자동 주입을 보장하고 트래픽 규칙 구성, 프로토콜 호환성 및 로그 추적 시스템 구성에주의를 기울이고 점진적인 마이그레이션 및 사전 제어 모니터링 계획을 채택하십시오.

SimpleDateFormat을 작성하고 사용하여 NewsImpleDateFormat ( "yyyy-mm-ddhh : mm : ss")와 같은 형식 문자열을 전달해야합니다. 2. 사례 민감도에주의를 기울이고 혼합 단일 레터 형식과 YYYY 및 DD의 오용을 피하십시오. 3. SimpledateFormat은 스레드 안전이 아닙니다. 멀티 스레드 환경에서는 새 인스턴스를 만들거나 매번 ThreadLocal을 사용해야합니다. 4. 구문 분석 방법을 사용하여 문자열을 구문 분석 할 때 ParseException을 잡아야하며 결과에는 시간대 정보가 포함되어 있지 않습니다. 5. DateTimeFormatter 및 Lo를 사용하는 것이 좋습니다

Java Collection Framework의 성능을 향상시키기 위해 다음 4 가지 점에서 최적화 할 수 있습니다. 1. Arraylist에 대한 자주 임의의 액세스, 해시 세트에 대한 빠른 검색 및 동의 환경에 대한 동의어 맵과 같은 시나리오에 따라 적절한 유형을 선택하십시오. 2. 용량 확장 오버 헤드를 줄이지 만 메모리 폐기물을 피하기 위해 초기화 중에 용량 및로드 계수를 합리적으로 설정하십시오. 3. 불변의 세트 (예 : List.of ())를 사용하여 보안 및 성능을 향상 시키며 일정한 또는 읽기 전용 데이터에 적합합니다. 4. 메모리 누출을 방지하고 약한 참조 또는 전문 캐시 라이브러리를 사용하여 장기 생존 세트를 관리합니다. 이러한 세부 사항은 프로그램 안정성과 효율성에 큰 영향을 미칩니다.
