NATS Transporter - The NATS client for NestJS

[!IMPORTANT]

This project reorganizes the NATS Base Client library (originally part of nats.deno), into multiple modules, and on-boards the supported transports (Deno, Node/Bun, and WebSocket).

Welcome to the new NATS.js repository! Beginning with the v3 release of the JavaScript clients, the NATS.js repository reorganizes the NATS JavaScript client libraries into a formal mono-repo.

Overview

NATS is a simple, secure and high performance open source messaging system for cloud native applications, IoT messaging, and microservices architectures. The NATS server is written in the Go programming language, but client libraries to interact with the server are available for dozens of major programming languages. NATS supports both At Most Once and At Least Once delivery. It can run anywhere, from large servers and cloud instances, through edge gateways and even Internet of Things devices.

Installation

To start building microservice with nats transporter, first install required packages:

1$ npm i --save nestjs-nats-transporter nats

Getting started

To instantiate a microservice, use the createMicroservice() method of the NestFactory class:

1import { NestFactory } from '@nestjs/core';
2import { AppModule } from './modules/app/app.module';
3import { NatsTransporter } from 'nestjs-nats-transporter';
4
5async function bootstrap() {
6  const app = await NestFactory.createMicroservice(AppModule, {
7    strategy: new NatsTransporter({
8      servers: ['nats://0.0.0.0:4222'],
9      user: 'nats_user',
10      pass: 'nats_password',
11    }),
12  });
13  await app.listen();
14}
15bootstrap();

Patterns

Microservices recognize both messages and events by patterns. A pattern is a plain value, for example, a literal object or a string. Patterns are automatically serialized and sent over the network along with the data portion of a message. In this way, message senders and consumers can coordinate which requests are consumed by which handlers.

Client Proxy

1import { Module } from '@nestjs/common';
2import { ClientsModule } from '@nestjs/microservices';
3import { NatsClientProxy } from 'nestjs-nats-transporter';
4import { ConnectionOptions } from 'nats';
5
6@Module({
7  imports: [
8    ClientsModule.register([
9      {
10        name: 'NATS_CLIENT',
11        customClass: NatsClientProxy,
12        options: {
13          servers: ['nats://0.0.0.0:4222'],
14          user: 'nats_user',
15          pass: 'nats_password',
16        },
17      },
18    ]),
19  ],
20  controllers: [ExampleController],
21  providers: [ExampleService],
22})
23export class ExampleModule {}

Injection

1import { Inject, Injectable } from '@nestjs/common';
2import { NatsClientProxy } from 'nestjs-nats-transporter';
3
4@Injectable()
5export class ExampleService {
6  
7  @Inject('NATS_CLIENT')
8  private client: NatsClientProxy
9}

Sending messages

RxJs

1@Injectable()
2export class ExampleService {
3
4  getHelloWorld(): Observable<number> {
5    const payload = [1, 2, 3];
6    return this.client.send<number>('subject', payload); 
7  }
8}

Promise

1@Injectable()
2export class ExampleService {
3
4  async getHelloWorld(): Promise<string> {
5    const payload = [1, 2, 3];
6    const result = await lastValueFrom(
7      this.client.send<string>('subject', payload)
8    );
9    console.log(result) //should be "Hello World!"
10    return result;
11  }
12}

Publishing events