{"id":38524,"date":"2020-03-04T06:00:43","date_gmt":"2020-03-04T13:00:43","guid":{"rendered":"http:\/\/devblogs.microsoft.com\/premier-developer\/?p=38524"},"modified":"2020-03-03T14:13:30","modified_gmt":"2020-03-03T21:13:30","slug":"dapr-in-a-microservices-architecture","status":"publish","type":"post","link":"https:\/\/devblogs.microsoft.com\/premier-developer\/dapr-in-a-microservices-architecture\/","title":{"rendered":"Dapr in a microservices architecture"},"content":{"rendered":"

Application Development Manager Erick Ramirez<\/a> introduces dapr and provides a walkthrough of using it to create an ASP.NET Core web application.<\/p>\n

\n

Dapr is an event driven runtime that helps to build stateless and stateful microservice applications, with a diversity of languages and frameworks. It is still in alpha version, which is not yet recommended for production environments but this will be very helpful for developers in the near feature.<\/p>\n

One of the main patterns you should consider when designing a microservices architecture is publisher \u2013 subscriber, and Dapr provides support for this pattern. This pattern consists of a message broker where event consumers and producers are decoupled from one another and communicate by sending and receiving messages associated with a namespace. Using dapr we are going to have an \u201cAt-least-Once messaging guarantee\u201d. This means that a message is delivered at least once to any subscriber when the response status code is 200 or returns no error. Dapr will deliver the message to only one instance, if more than one exists.<\/p>\n

To install and configure Dapr, you can use the following guide Getting Started \u2013 Environment Setup<\/a>. Standalone mode was used for this article, but a guide to install it in a Kubernetes cluster is also available.<\/p>\n

To demonstrate this, we described the following scenario:<\/p>\n

<\/p>\n

<\/p>\n

Before we start typing code, we need to reference the Nuget package Dapr.AspNetCore (this is preview only \u2013 v0.4.0-preview01)<\/p>\n

<\/p>\n

Next, we initialize the subscriber Handler that will create an endpoint to dapr\/subscribe that returns the topics. Following this, we must register the CloudEvents<\/em> middleware to receive every incoming request with the content type of \u201capplication\/cloudevents+json\u201d<\/p>\n

public void Configure(IApplicationBuilder app, IWebHostEnvironment env)\r\n{\r\n   if (env.IsDevelopment())\r\n   {\r\n      app.UseDeveloperExceptionPage();\r\n   }\r\n   app.UseCloudEvents();\r\n   app.UseRouting();\r\n   app.UseAuthorization();\r\n   app.UseEndpoints(endpoints =>\r\n   {\r\n      endpoints.MapSubscribeHandler();\r\n      endpoints.MapControllers();\r\n      }\r\n   );\r\n}<\/pre>\n
Once that we have created the project, we need to add the first <\/span>MessageController<\/em>, where we initialize the logger in the constructor, and add a new method that will receive all messages from the queue, as you can see in the code snippet:<\/span><\/p>\n
[ApiController]\r\npublic class MessageController : ControllerBase\r\n{\r\n   private readonly ILogger<MessageController> _logger;\r\n   public MessageController(ILogger<MessageController> logger)\r\n   {\r\n      _logger = logger;\r\n   }\r\n\r\n   [HttpPost]\r\n   [Route(\"api\/message\")]\r\n   public async Task<IActionResult> ReceiveMessage([FromBody]Message message)\r\n   {\r\n      _logger.LogInformation($\"Message with id {message.Id.ToString()} received!\");\r\n\r\n      \/\/Validate message received\r\n      using (var httpClient = new HttpClient())\r\n      {\r\n         var result = await httpClient.PostAsync(\r\n            \"http:\/\/localhost:3500\/v1.0\/publish\/messagetopic\",\r\n            new StringContent(JsonConvert.SerializeObject(message), Encoding.UTF8, \"application\/json\")\r\n            );\r\n\r\n         _logger.LogInformation($\"Message with id {message.Id.ToString()} published with status {result.StatusCode}!\");\r\n      }\r\n\r\n      return Ok();\r\n   }<\/pre>\n
Next, we add a new operation named \u201cProcessMessage\u201d to process all the messages that will be receiving.<\/span><\/p>\n
   [Topic(\"messagetopic\")]\r\n   [HttpPost]\r\n   [Route(\"messagetopic\")]\r\n   public async Task<IActionResult> ProcessOrder([FromBody]Message message)\r\n   {\r\n      \/\/Process message placeholder\r\n      _logger.LogInformation($\"Message with id {message.Id.ToString()} processed!\");\r\n      return Ok();\r\n   }<\/pre>\n
Finally, we create a new POCO to store the Message<\/em> properties, as it shown in the following code snippet:<\/p>\n
   public class Message\r\n   {\r\n      public Guid Id { get; set; }\r\n      public string Content { get; set; }\r\n      public string Subject { get; set; }\r\n   }\r\n}<\/pre>\n
Once everything is in place, we need to initialize dapr with the following command:<\/span><\/p>\n
dapr init<\/pre>\n
<\/p>\n
Next, we start the ASP.NET Core application, listening on HTTP port 5000, and dapr on port 3500:<\/p>\n
dapr run --app-id pubsub --app-port 5000 --port 3500 dotnet run<\/pre>\n
<\/p>\n
Now that our application is running, let\u2019s see how this works. First, we will open a new Postman window and create a request. We will perform a new HTTP GET operation to the following URL http:\/\/localhost:5000\/dapr\/subscribe<\/a><\/p>\n
<\/p>\n
We receive the topics that we are subscribed to as a result. Then, we will create a new request with HTTP POST to invoke the ProcessMessage<\/em> method with the following payload:<\/p>\n
<\/p>\n
Analyzing the command window output, we can see that the message was received, published, and processed successfully.<\/p>\n
<\/p>\n
You can select a broker like Redis, RabitMQ, Azure Service Bus, etc. to establish the pub\/sub component.<\/p>\n
Dapr also supports following features through HTTP\/gRPC to implement the sidecar pattern:<\/p>\n