Docs Menu
Docs Home
/
언어
/
Java
/
Java Reactive Streams 드라이버
/
시작하기

MongoDB에 연결

Java Reactive Streams 운전자 는 세 가지 구성 요소로 구성된 Reactive Streams API 의 구현 입니다.

  • Publisher

  • Subscriber

  • Subscription

Publisher 는 Subscriber 또는 Subscriber 의 여러 인스턴스에서 받은 수요에 따라 게시되는 시퀀스된 요소의 무제한 제공자 입니다. Subscription 는 Publisher 를 구독 하는 Subscriber 의 일대일 라이프사이클을 나타냅니다.

팁

리액티브 스트림에 학습 보려면 리액티브 스트림 문서를 참조하세요.

이 튜토리얼에서는 데이터베이스 를 쿼리 하기 위해 Java Reactive Streams Subscribers 를 구현 해야 합니다. 이 가이드 에서는 Reactive Streams 사양을 기반으로 하는 라이브러리인 Reactor 라이브러리의 메서드를 사용하여 Java Reactive Streams Subscribers 를 구현 합니다.

Reactor 라이브러리에 학습 보려면 시작하기 를 참조하세요. Project Reactor 문서에서 확인 가능합니다.

1

Java Reactive Streams 운전자 애플리케이션 만들기

You must use a project within an integrated development environment (IDE) to complete the following steps. 프로젝트 에서 Java 패키지 에 QueryDatabase 이라는 새 Java 파일 을 만듭니다. 다음 코드를 복사하여 QueryDatabase 파일 에 붙여넣습니다.

import com.mongodb.*;
import com.mongodb.reactivestreams.client.MongoCollection;
import org.bson.Document;
import reactor.core.publisher.Mono;
import com.mongodb.reactivestreams.client.MongoClient;
import com.mongodb.reactivestreams.client.MongoClients;
import com.mongodb.reactivestreams.client.MongoDatabase;
import static com.mongodb.client.model.Filters.eq;
public class QueryDatabase {
    public static void main(String[] args) {
        // Replace the placeholder with your Atlas connection string
        String uri = "<connection string>";
        // Construct a ServerApi instance using the ServerApi.builder() method
        ServerApi serverApi = ServerApi.builder()
                .version(ServerApiVersion.V1)
                .build();
        MongoClientSettings settings = MongoClientSettings.builder()
                .applyConnectionString(new ConnectionString(uri))
                .serverApi(serverApi)
                .build();
        // Create a new client and connect to the server
        try (MongoClient mongoClient = MongoClients.create(settings)) {
            MongoDatabase database = mongoClient.getDatabase("sample_mflix");
            MongoCollection<Document> movies = database.getCollection("movies");
            Mono.from(movies.find(eq("title", "Back to the Future")))                   
                    .doOnSuccess(i -> System.out.println(i))                            
                    .doOnError(err -> System.out.println("Error: " + err.getMessage())) 
                    .block();                                                           
        }
    }
}
2

연결 문자열 할당

<connection string> 자리 표시자를 string 이 가이드 의 연결 만들기 단계에서 복사한 연결 string 로 바꿉니다.

3

애플리케이션 실행하기

IDE 또는 shell 에서 애플리케이션 을 실행합니다. 출력은 MongoDB 에 연결하고 데이터베이스 를 쿼리했음을 보여줍니다.

{
   _id: ...,
   plot: 'A young man is accidentally sent 30 years into the past...',
   genres: [ 'Adventure', 'Comedy', 'Sci-Fi' ],
   ...
   title: 'Back to the Future',
   ...
 }

팁

오류가 발생하면 적절한 연결 string 을 지정했는지, 샘플 데이터를 로드했는지 확인하세요.

이 단계를 완료하면 운전자 를 사용하여 MongoDB deployment 에 연결하고, 데이터베이스 를 쿼리하고, 결과를 출력하는 애플리케이션 이 작동합니다.

참고

이 단계에서 문제가 발생하면 MongoDB Community 포럼에서 도움을 요청하거나 이 페이지 오른쪽 또는 하단의 Rate this page 탭을 사용하여 피드백을 제출하세요.

돌아가기

연결 문자열 만들기

다음

다음 단계