Server

Pre-requisites

• installed
• Initialized Dapr environment

1. Install the SDK with :

1. Import the libraries:

import { DaprServer, CommunicationProtocolEnum } from "dapr-client";
const daprHost = "127.0.0.1"; // Dapr Sidecar Host
const daprPort = "3500"; // Dapr Sidecar Port of this Example Server
const serverHost = "127.0.0.1"; // App Host of this Example Server
const serverPort = "50051"; // App Port of this Example Server 
// HTTP Example
const server = new DaprServer(serverHost, serverPort, daprHost, daprPort); 
// GRPC Example

Running

To run the examples, you can use two different protocols to interact with the Dapr sidecar: HTTP (default) or gRPC.

import { DaprServer } from "dapr-client";
const server= new DaprServer(appHost, appPort, daprHost, daprPort);
// initialize subscribtions, ... before server start
// the dapr sidecar relies on these
await server.start();

import { DaprServer, CommunicationProtocol } from "dapr-client";
const server = new DaprServer(appHost, appPort, daprHost, daprPort, CommunicationProtocol.GRPC);
// initialize subscribtions, ... before server start
// the dapr sidecar relies on these

# Using dapr run
dapr run --app-id example-sdk --app-port 50051 --app-protocol grpc -- npm run start
# or, using npm script
npm run start:dapr-grpc

The JavaScript Server SDK allows you to interface with all of the focusing on Sidecar to App features.

Listen to an Invocation

Subscribe to messages

import { DaprServer } from "dapr-client";
const daprHost = "127.0.0.1"; // Dapr Sidecar Host
const daprPort = "3500"; // Dapr Sidecar Port of this Example Server
const serverHost = "127.0.0.1"; // App Host of this Example Server
const serverPort = "50051"; // App Port of this Example Server "
async function start() {
  const server = new DaprServer(serverHost, serverPort, daprHost, daprPort);
  const pubSubName = "my-pubsub-name";
  const topic = "topic-a";
  await server.pubsub.subscribe(pubSubName, topic, async (data: any) => console.log(`Got Data: ${JSON.stringify(data)}`));
  await server.start();
}
start().catch((e) => {
  console.error(e);
  process.exit(1);
});

Receive an Input Binding

import { DaprServer } from "dapr-client";
const daprHost = "127.0.0.1"; 
const daprPort = "3500"; 
const serverHost = "127.0.0.1";
const serverPort = "5051";
async function start() {
  const server = new DaprServer(serverHost, serverPort, daprHost, daprPort);;
  const bindingName = "my-binding-name";
  const response = await server.binding.receive(bindingName, async (data: any) => console.log(`Got Data: ${JSON.stringify(data)}`));
  await server.start();
}
start().catch((e) => {
  console.error(e);
  process.exit(1);

Related links