데이터 처리를위한 Java 스트림 API에 대한 실용 가이드

Java Streams API는 컬렉션, 어레이 또는 공장에서 스트림을 만들고 필터, 맵 및 플랫 맵과 같은 중간 작업을 적용하여 데이터가 게으르게 변환하기 위해 중간 작업을 적용한 다음, 수집, 카운트 또는 FindFirst와 같은 터미널 작업을 사용하여 결과를 피하고, 스트림 재사용을 피하고, 그룹화를위한 수집 또는 요약을 포함하여 유사한 스트림을 사용하여 유사한 스트림을 사용하여 유사한 스트림을 사용합니다. 필터링.

Java Streams API는 Java 8에 도입 된 강력한 도구로 개발자가 데이터 시퀀스를 처리하는 방법에 혁명을 일으킨다. 컬렉션, 어레이 및 기타 데이터 소스에서 기능 스타일 작업을 수행하여 코드를보다 읽기 쉽고 간결하며 종종 병렬화하기 쉽습니다. 사용자 목록을 필터링하거나 데이터 변환 또는 값을 집계하든 스트림은 작업을 완료 할 수있는 깨끗하고 효율적인 방법을 제공합니다.

다음은 실제 데이터 처리 시나리오에서 Streams API를 효과적으로 사용하는 데 도움이되는 실용 가이드입니다.

1. 스트림 생성 및 이해

스트림은 데이터 구조가 아니며 요소를 저장하지 않습니다. 대신, 운영 파이프 라인을 통해 소스 (수집 또는 배열과 같은)의 데이터를 전달합니다.

여러 가지 방법으로 스트림을 만들 수 있습니다.

 // 컬렉션에서
list <string> names = arrays.aslist ( "Alice", "Bob", "Charlie");
스트림 <string> namestream = names.stream ();

// 배열에서
int [] 숫자 = {1, 2, 3, 4, 5};
intstream numberstream = arrays.stream (숫자);

// 정적 공장 방법에서
스트림 <string> staticstream = stream.of ( "Apple", "Banana", "Cherry");

// 무한 스트림 (주의해서 사용)
스트림 <integer> infinitestream = stream.iterate (0, n-> n 2);

중요 : 사용 후 스트림이 소비됩니다. collect() 또는 forEach() 와 같은 작업이 호출되면 스트림을 재사용 할 수 없습니다.

2. 일반적인 중간 작업

중간 작업은 새 스트림을 반환하여 메소드 체인을 허용합니다. 그들은 게으르다 - 터미널 작동이 호출 될 때까지 실행되지 않는다.

• filter(Predicate) - 조건과 일치하는 요소를 선택합니다
• map(Function) - 각 요소를 변환합니다
• flatMap(Function) - 평평한 중첩 구조
• distinct() - 복제를 제거합니다
• sorted() - 정렬 요소
• limit(n) / skip(n) - 제어 크기

예 : 사용자 이름을 필터링 및 매핑합니다

 <string> longnamesuppercase = user.stream ()
    .filter (user-> user.getName (). longth ()> 5)
    .map (user :: getName)
    .map (String :: ToupperCase)
    .별개의()
    .collect (collectors.tolist ());

이 체인은 사용자에게 긴 이름, 추출 및 이름을 대문자로 변환하고 중복을 제거합니다.

flatMap 사용하여 중첩 된 데이터를 평평하게하십시오.

 List <list <string >> listofLists = arrays.aslist (
    Arrays.aslist ( "A", "B"),
    Arrays.aslist ( "C", "D")
);

list <string> flatlist = listofLists.stream ()
    .flatmap (list :: stream)
    .collect (collectors.tolist ()); // [ "a", "b", "c", "d"]]]

3. 터미널 작동 : 결과를 얻습니다

터미널 작업은 실제 처리를 트리거하고 결과 또는 부작용을 생성합니다. 그 후 스트림이 닫힙니다.

일반적인 터미널 작업 :

• collect(Collector) - 결과를 목록,지도 등으로 수집하십시오.
• forEach(Consumer) - 각 요소에 대한 작업을 수행합니다
• count() - 요소 수를 얻습니다
• anyMatch() , allMatch() , noneMatch() - 부울 점검
• findFirst() , findAny() - 선택적 결과를 얻습니다
• reduce() - 요소를 단일 값으로 결합하십시오

예 :

 // 활성 사용자를 계산하십시오
long activecount = user.stream ()
    .filter (user :: isactive)
    .세다();

// 사용자가 관리자인지 확인하십시오
부울 hasadmin = user.stream ()
    .AnyMatch (user-> user.getRole (). Equals ( "admin");

// 총 급여로 줄입니다
Double TotalSalary = Employees.stream ()
    .maptodouble (직원 :: getsalary)
    .reduce (0.0, double :: sum);

nulls를 피하려면 findFirst() 와 함께 Optional 사용하십시오.

 옵션 <user> firstAdmin = user.stream ()
    .filter (u-> u.getRole (). Equals ( "admin"))
    .findFirst ();

4. 수집가와의 결과 수집

Collectors 유틸리티 클래스는 스트림 출력을 수집하는 강력한 방법을 제공합니다.

• toList() , toSet() , toMap()
• groupingBy() - 분류기 별 그룹 요소
• partitioningBy() - True/False 그룹으로 나뉩니다
• summarizingInt/Long/Double() - 요약 통계를 얻으십시오

역할 별 그룹 사용자 :

 Map <String, List <User>> userSyRole = user.stream ()
    .collect (Collectors.groupingby (user :: getrole));

성인과 미성년자로의 분할 :

 Map <boolean, list <user>> partitionedByage = user.stream ()
    .Collect (Collectors.PartitioningBy (u-> u.getage ()> = 18);

요약 통계 받기 :

 intsummarystatistics agestats = user.stream ()
    .collect (Collectors.summarizingInt (user :: getage));

System.out.println ( "Avg Age :"agestats.getaverage ());
System.out.println ( "Max Age :"agestats.getmax ());

5. 성능 팁 및 모범 사례

• 평행 스트림을 현명하게 사용하십시오 : parallelStream() 은 대형 데이터 세트 속도를 높일 수 있지만 부작용과 스레드 안전성을 조심하십시오.

   List <string> result = largelist.parallelstream ()
      .map (this :: 값 비싼 점)
      .filter (Objects :: Nonnull)
      .collect (collectors.tolist ());

• 돌연변이 가능한 감소를 피하십시오 : Collectors.toList() 와 같은 불변 forEach 수집가를 선호합니다.

• limit() 및 anyMatch() 와 같은 단락 작업은 대형 또는 무한 스트림의 성능을 향상시킬 수 있습니다.

• 체인 작업 효율적으로 : map() 와 같은 고가의 작업 전에 데이터 크기를 줄이기 위해 filter() 조기에 배치하십시오.

6. 피하는 일반적인 함정

• 스트림을 재사용하려고 :

   스트림 <string> stream = list.stream ();
  stream.foreach (System.out :: println); // 좋아요
  stream.foreach (System.out :: println); // INLEGALSTATEException!

• Optional 반품 무시 : findFirst() 또는 findAny() 항상 확인하거나 안전하게 풀립니다.

• 간단한 루프에 스트림 사용 : 스트림을 과도하게 사용하지 마십시오. 사소한 작업에는 간단한 for 가 더 명확합니다.

• 과도한 체인 : 변수 또는 도우미 방법으로 복잡한 파이프 라인을 읽을 수있는 단계로 나눕니다.

---

Streams API는 Java의 데이터 처리를보다 표현적이고 기능적으로 만듭니다. 필터링, 변환 및 감소 작업을 결합하여 특히 컬렉션을 다룰 때 클리너,보다 관리 가능한 코드를 작성할 수 있습니다.

그냥 기억하십시오 : 스트림은 어떻게 해야하는지 에 관한 것입니다. 불변성을 받아들이고 부작용을 피하고 API가 반복을 처리하게하십시오.

기본적으로, 일단 중간 대 터미널 작업을 수행하고 결과를 효과적으로 수집하는 방법을 얻으면 대부분의 일상 데이터 작업이 훨씬 부드럽습니다.

위 내용은 데이터 처리를위한 Java 스트림 API에 대한 실용 가이드의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!