성능 고려 사항

개요

이 가이드에서는 Rust 드라이버의 성능을 최적화하는 방법을 배울 수 있습니다. MongoDB에 연결하려면 Client 인스턴스를 만들어야 합니다. Client 인스턴스는 서버 토폴로지 검색, 연결 모니터링, 내부 연결 풀 유지 관리 등 대부분의 연결 측면을 자동으로 처리합니다. 이 가이드에서는 Client 인스턴스를 구성하고 사용하기 위한 권장사항을 설명합니다.

이 가이드에는 다음 섹션이 포함되어 있습니다.

• 클라이언트 수명 주기 는 Client 인스턴스 생성 및 관리에 대한 권장사항을 설명합니다.

• 연결 풀 은 드라이버에서 연결 풀링이 작동하는 방식을 설명합니다.

• 병렬 처리는 병렬 비동기 작업을 실행하기 위한 샘플 코드를 제공합니다.

• 런타임 은 tokio 및 async_std 크레이트의 기능을 사용하여 런타임을 관리하는 방법을 설명합니다.

• 추가 정보에서 이 가이드에 언급된 유형 및 메소드에 대한 리소스 및 API 문서 링크를 찾을 수 있습니다.

클라이언트 라이프사이클

세션 및 작업 전반에서 클라이언트를 재사용하는 것이 좋습니다. 유형은 여러 스레드에서 동시에 사용하기에 안전하므로 동일한 인스턴스를 사용하여 Client 여러 작업을 수행할 수 있습니다.Client 각 요청에 대해 새 Client 인스턴스를 만들면 성능이 느려집니다.

다음 코드는 동일한 클라이언트를 사용하여 많은 요청을 수행할 수 있도록 하는 기존 Client 인스턴스에 대한 포인터를 허용하는 메서드를 만듭니다.

// ... Create a client earlier in your code
async fn make_request(client: &Client) -> Result<(), Box<dyn Error>> {
    // Use the client to perform operations
    Ok(())
}

연결 풀

모든 Client 인스턴스에는 MongoDB 토폴로지의 각 서버에 대한 기본 연결 풀이 제공됩니다. 연결 풀은 요청 시 소켓을 열어 애플리케이션에서 MongoDB에 대한 동시 요청을 지원합니다.

Client 의 기본 구성은 대부분의 애플리케이션에서 작동합니다. 다음 코드는 기본 연결 설정을 사용하여 클라이언트를 만드는 방법을 보여줍니다.

let client = Client::with_uri_str("<connection string>").await?;

또는 애플리케이션의 요구 사항에 가장 적합하도록 연결 풀을 조정하고 성능을 최적화할 수 있습니다. 연결 설정을 사용자 지정하는 방법에 대한 자세한 내용은 이 가이드의 다음 하위 섹션을 참조하세요.

• 최대 풀 크기 구성

• 동시 연결 옵션 구성

• 최대 유휴 시간 구성

let mut client_options = ClientOptions::parse_async("<connection string>").await?;
client_options.max_pool_size = Some(20);
let client = Client::with_options(client_options)?;

let mut client_options = ClientOptions::parse_async("<connection string>").await?;
client_options.max_connecting = Some(3);
client_options.min_pool_size = Some(1);
let client = Client::with_options(client_options)?;

let mut client_options = ClientOptions::parse_async("<connection string>").await?;
client_options.max_idle_time = Some(Duration::new(90, 0));
let client = Client::with_options(client_options)?;

병렬 처리

병렬 데이터 작업을 실행할 수 있는 경우 비동기 동시 작업을 실행하여 성능을 최적화할 수 있습니다. 다음 코드는 tokio::task 모듈의 spawn() 메서드를 사용하여 삽입 작업을 수행하기 위한 별도의 동시 작업을 만듭니다.

let client = Client::with_uri_str("<connection string>").await?;
let data = doc! { "title": "1984", "author": "George Orwell" };
for i in 0..5 {
    let client_ref = client.clone();
    let data_ref = data.clone();
    task::spawn(async move {
        let collection = client_ref
            .database("items")
            .collection::<Document>(&format!("coll{}", i));
        collection.insert_one(data_ref).await
    });
}

런타임

Client 인스턴스는 이를 생성한 tokio 또는 async-std 런타임의 인스턴스에 바인딩됩니다. Client 인스턴스를 사용하여 다른 런타임에서 작업을 수행하는 경우 예기치 않은 동작이나 오류가 발생할 수 있습니다.

tokio 또는 async_std 크레이트의 test 헬퍼 매크로를 사용하여 애플리케이션을 테스트하는 경우, 실수로 의도하지 않은 다른 런타임에서 작업을 실행할 수 있습니다. 이는 이러한 헬퍼 매크로가 각 테스트에 대해 새 런타임을 생성하기 때문입니다. 그러나 다음 전략 중 하나를 사용하여 이 문제를 방지할 수 있습니다.

• test 헬퍼 매크로를 사용하지 않고 런타임을 Client 인스턴스에 연결합니다.

• 모든 async 테스트에 대해 새 Client 인스턴스를 만듭니다.

이 예제에서는 첫 번째 전략을 따르며 테스트용으로만 사용되는 글로벌 런타임을 만듭니다. 다음 코드에서 test_list_dbs() 메서드는 이 런타임에 수동으로 연결하는 클라이언트를 사용하여 배포서버의 데이터베이스를 나열합니다.

use tokio::runtime::Runtime;
use once_cell::sync::Lazy;
static CLIENT_RUNTIME: Lazy<(Client, Runtime)> = Lazy::new(|| {
    let rt = Runtime::new().unwrap();
    let client = rt.block_on(async {
        Client::with_uri_str("<connection string>").await.unwrap()
    });
    (client, rt)
});
#[test]
fn test_list_dbs() -> Result<(), Box<dyn Error>> {
    let (client, rt) = &*CLIENT_RUNTIME;
    rt.block_on(async {
        client.list_database_names().await
    })?;
    Ok(())
}

두 번째 전략을 구현하는 다음 코드는 을 사용하여 Client 각 테스트 실행에 대해 새 인스턴스를 생성하여 tokio::test 런타임 간에 의도하지 않은 상호 작용이 없도록 합니다.

#[tokio::test]
async fn test_list_dbs() -> Result<(), Box<dyn Error>> {
    let client = Client::with_uri_str("<connection string>").await?;
    client.list_database_names().await?;
    Ok(())
}

추가 정보

MongoDB에 연결하는 방법에 대해 자세히 알아보려면 연결 가이드를 참조하세요.

Rust 드라이버의 사용 가능한 런타임에 대해 자세히 알아보려면 비동기 및 동기 API 가이드를 참조하세요.