Client

• installed
• Initialized Dapr environment

Import the libraries:

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
const server = new DaprServer(serverHost, serverPort, daprHost, daprPort); 
const client = new DaprClient(daprHost, daprPort);
// GRPC 
const server = new DaprServer(serverHost, serverPort, daprHost, daprPort, CommunicationProtocolEnum.GRPC);
const client = new DaprClient(daprHost, daprPort, CommunicationProtocolEnum.GRPC);

DaprClient Library

DaprServer Library

A library for how an application registers bindings / routes with Dapr. The startServer() method is used to start the server and bind the routes.

import { DaprClient, HttpMethod, CommunicationProtocolEnum } from "dapr-client"; 
const daprHost = "127.0.0.1"; 
const daprPort = "3500"; 
async function start() {
  const client = new DaprClient(daprHost, daprPort, CommunicationProtocolEnum.GRPC); 
  const serviceAppId = "my-app-id";
  // POST Request
  const response = await client.invoker.invoke(serviceAppId , serviceMethod , HttpMethod.POST, { hello: "world" });
  // GET Request
  const response = await client.invoker.invoke(serviceAppId , serviceMethod , HttpMethod.GET);
}

• For a full guide on service invocation visit How-To: Invoke a service.

• For a full list of state operations visit .

Publish messages

const daprHost = "127.0.0.1"; 
const daprPort = "3500"; 
async function start() {
  const client = new DaprClient(daprHost, daprPort, CommunicationProtocolEnum.GRPC); 
  const pubSubName = "my-pubsub-name";
  const topic = "topic-a";
  const message = { hello: "world" }
  // Publish Message to Topic
  const response = await client.pubsub.publish(pubSubName, topic, message);
}

Subscribe to messages

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 "
async function start() {
  const server = new DaprServer(serverHost, serverPort, daprHost, daprPort, CommunicationProtocolEnum.GRPC);
  const pubSubName = "my-pubsub-name";
  const topic = "topic-a";
  // Configure Subscriber for a Topic
  await server.pubsub.subscribe(pubSubName, topic, async (data: any) => console.log(`Got Data: ${JSON.stringify(data)}`));
  await server.startServer();

• For a full list of state operations visit How-To: Publish & subscribe.

Output Bindings

import { DaprServer, CommunicationProtocolEnum } 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, CommunicationProtocolEnum.GRPC);;
  const bindingName = "my-binding-name";
  const response = await server.binding.receive(bindingName, async (data: any) => console.log(`Got Data: ${JSON.stringify(data)}`));
  await server.startServer();
}

• For a full guide on output bindings visit .

import { DaprClient, CommunicationProtocolEnum } from "dapr-client"; 
const daprHost = "127.0.0.1"; 
const daprPort = "3500"; 
async function start() {
  const client = new DaprClient(daprHost, daprPort, CommunicationProtocolEnum.GRPC); 
  const secretStoreName = "my-secret-store";
  const secretKey = "secret-key";
  // Retrieve a single secret from secret store
  const response = await client.secret.get(secretStoreName, secretKey);
  // Retrieve all secrets from secret store
}

• For a full guide on secrets visit How-To: Retrieve secrets.