rants

KO | EN

gitlite — search

#javascript #python #hacktoberfest #go #linux #java #nodejs #awesome #cli #kubernetes #awesome-list #security #mcp #open-source

(★ 83)

An async NATS client library for the Rust programming language.

rants Latest Version Download

Download Latest Version (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# Rants

[![build status](https://img.shields.io/github/workflow/status/davidMcneil/rants/Rust)](https://github.com/davidMcneil/rants/actions)
[![crates.io](https://img.shields.io/crates/v/rants.svg)](https://crates.io/crates/rants)
[![docs](https://docs.rs/rants/badge.svg)](https://docs.rs/rants)
![License](https://img.shields.io/badge/license-MIT-blue.svg)
![License](https://img.shields.io/badge/license-APACHE-blue.svg)

An async [NATS](https://nats.io/) client library for the Rust programming language.

The client aims to be an ergonomic, yet thin, wrapper over the NATS client protocol. The easiest way to learn to use the client is by reading the [NATS client protocol documentation](https://docs.nats.io/nats-protocol/nats-protocol). The main entry point into the library's API is the [`Client`](https://docs.rs/rants/latest/rants/struct.Client.html) struct.

TLS support can be powered by the [`native-tls` crate](https://github.com/sfackler/rust-native-tls) enabled with the `native-tls` feature, or TLS support can be powered by the [`rustls` crate](https://github.com/ctz/rustls) enabled with the `rustls-tls` feature.

# Example

```rust
use futures::stream::StreamExt;
use rants::Client;

#[tokio::main]
async fn main() {
   // A NATS server must be running on `127.0.0.1:4222`
   let address = "127.0.0.1:4222".parse().unwrap();
   let client = Client::new(vec![address]);

// Configure the client to receive messages even if it sent the message
   client.connect_mut().await.echo(true);

// Connect to the server
   client.connect().await;

// Create a new subject called "test"
   let subject = "test".parse().unwrap();

// Subscribe to the "test" subject
   let (_, mut subscription) = client.subscribe(&subject, 1024).await.unwrap();

// Publish a message to the "test" subject
   client
       .publish(&subject, b"This is a message!")
       .await
       .unwrap();

// Read a message from the subscription
   let message = subscription.next().await.unwrap();
   let message = String::from_utf8(message.into_payload()).unwrap();
   println!("Received '{}'", message);

// Disconnect from the server
   client.disconnect().await;
}
```

## Development

The integration test suite requires the `NATS_PATH` environment variable point to the [NATS server executable](https://nats.io/download/nats-io/nats-server/):

> cargo test

The [`env_logger`](https://github.com/sebasmagri/env_logger/) crate is used in integration tests. To enable it and run a single test run:

> RUST_LOG=rants=trace cargo test ping_pong

## Alternatives
- [`nats.rs`](https://github.com/nats-io/nats.rs)
- [`natsclient`](https://github.com/encabulators/natsclient)
- [`nitox`](https://github.com/YellowInnovation/nitox)
- [`ratsio`](https://github.com/mnetship/ratsio)
- [`rust-nats`](https://github.com/jedisct1/rust-nats)

rants

rants Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

rants

rants Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

Download README