Dapr - Publish/Subscibe - Using Web APIs

apiVersion: dapr.io/v1alpha1 kind: Component metadata: name: myapp-pubsub spec: type: pubsub.redis version: v1 metadata: - name: redisHost value: localhost:6379 - name: redisPassword value: "" scopes: - publisher - subscriber 

builder.Services.AddDaprClient(); 

var builder = WebApplication.CreateBuilder(args); // Add services to the container. builder.Services.AddControllers(); // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle builder.Services.AddEndpointsApiExplorer(); builder.Services.AddSwaggerGen(); builder.Services.AddDaprClient(); var app = builder.Build(); // Configure the HTTP request pipeline. if (app.Environment.IsDevelopment()) { app.UseSwagger(); app.UseSwaggerUI(); } app.UseHttpsRedirection(); app.UseAuthorization(); app.MapControllers(); app.Run(); 

using Dapr.Client; using Microsoft.AspNetCore.Mvc; using System; namespace Publisher.Controllers { [Route("api/[controller]")] [ApiController] public class PublishController : ControllerBase { private readonly DaprClient daprClient; private readonly ILogger<PublishController> logger; public PublishController(DaprClient daprClient, ILogger<PublishController> logger) { this.daprClient = daprClient; this.logger = logger; } [HttpPost] public async Task Post([FromBody] string value) { await daprClient.PublishEventAsync("myapp-pubsub", "test-dapr-topic", $"{DateTime.Now} - {value}"); logger.LogInformation($"Published data at {DateTime.Now} - {value}"); } } } 

apiVersion: dapr.io/v1alpha1 kind: Component metadata: name: myapp-pubsub spec: type: pubsub.redis version: v1 metadata: - name: redisHost value: localhost:6379 - name: redisPassword value: "" scopes: - publisher - subscriber 

/* The call to UseCloudEvents adds CloudEvents middleware into to the * ASP.NET Core middleware pipeline. * This middleware will unwrap requests that use the CloudEvents structured * format, so the receiving method can read the event payload directly. */ app.UseCloudEvents(); /* The call to MapSubscribeHandler in the endpoint routing configuration * will add a Dapr subscribe endpoint to the application. * * This endpoint will respond to requests on /dapr/subscribe. * When this endpoint is called, it will automatically find all WebAPI * action methods decorated with the Topic attribute and instruct * Dapr to create subscriptions for them. */ app.MapSubscribeHandler(); 

var builder = WebApplication.CreateBuilder(args); // Add services to the container. builder.Services.AddControllers(); // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle builder.Services.AddEndpointsApiExplorer(); builder.Services.AddSwaggerGen(); var app = builder.Build(); // Configure the HTTP request pipeline. if (app.Environment.IsDevelopment()) { app.UseSwagger(); app.UseSwaggerUI(); } app.UseHttpsRedirection(); app.UseAuthorization(); app.UseCloudEvents(); app.MapSubscribeHandler(); app.MapControllers(); app.Run(); 

using Dapr; using Microsoft.AspNetCore.Mvc; namespace Subscriber.Controllers { [ApiController] [Route("api/[controller]")] public class SubscriberController : ControllerBase { ILogger<SubscriberController> logger; public SubscriberController(ILogger<SubscriberController> logger) { this.logger = logger; } [Topic("myapp-pubsub", "test-dapr-topic")] [HttpPost("subscriber")] public IActionResult Post([FromBody] string value) { logger.LogInformation(value); return Ok(value); } } }