NATS Aspire container #1175
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,20 @@ | ||
| <Project Sdk="Microsoft.NET.Sdk.Web"> | ||
|
|
||
| <PropertyGroup> | ||
| <TargetFramework>net8.0</TargetFramework> | ||
| <Nullable>enable</Nullable> | ||
| <ImplicitUsings>enable</ImplicitUsings> | ||
| <InvariantGlobalization>true</InvariantGlobalization> | ||
| </PropertyGroup> | ||
|
|
||
| <ItemGroup> | ||
| <PackageReference Include="Swashbuckle.AspNetCore" /> | ||
| </ItemGroup> | ||
|
|
||
| <ItemGroup> | ||
| <ProjectReference Include="..\..\..\src\Components\Aspire.NATS.Net\Aspire.NATS.Net.csproj" /> | ||
| <ProjectReference Include="..\..\Playground.ServiceDefaults\Playground.ServiceDefaults.csproj" /> | ||
| <ProjectReference Include="..\Nats.Common\Nats.Common.csproj" /> | ||
| </ItemGroup> | ||
|
|
||
| </Project> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,51 @@ | ||
| @HostAddress = http://localhost:5156 | ||
|
|
||
| POST {{HostAddress}}/ping/ | ||
|
|
||
| ### | ||
|
|
||
| POST {{HostAddress}}/stream/ | ||
| Content-Type: application/json | ||
|
|
||
| { | ||
| "name": "EVENTS", | ||
| "description": "Events Description", | ||
| "subjects": ["events.>"], | ||
| "max_msgs": 10 | ||
| } | ||
|
|
||
| ### | ||
|
|
||
| GET {{HostAddress}}/stream/EVENTS | ||
| Accept: application/json | ||
|
|
||
| ### | ||
|
|
||
| POST {{HostAddress}}/publish/ | ||
| Content-Type: application/json | ||
|
|
||
| { | ||
| "subject": "events.mouse.click", | ||
| "name": "Mouse Event", | ||
| "description": "Mouse Event Description", | ||
| "priority": 0.1 | ||
| } | ||
|
|
||
| ### | ||
|
|
||
| POST {{HostAddress}}/publish/ | ||
| Content-Type: application/json | ||
|
|
||
| { | ||
| "subject": "events.key.a", | ||
| "name": "Key Event", | ||
| "description": "Key Event Description", | ||
| "priority": 0.5 | ||
| } | ||
|
|
||
| ### | ||
|
|
||
| GET {{HostAddress}}/consume/EVENTS | ||
| Accept: application/json | ||
|
|
||
| ### |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,85 @@ | ||
| using NATS.Client.Core; | ||
| using NATS.Client.JetStream; | ||
| using NATS.Client.JetStream.Models; | ||
| using Nats.Common; | ||
|
|
||
| var builder = WebApplication.CreateBuilder(args); | ||
|
|
||
| // Add services to the container. | ||
| // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle | ||
| builder.Services.AddEndpointsApiExplorer(); | ||
| builder.Services.AddSwaggerGen(); | ||
|
|
||
| builder.AddServiceDefaults(); | ||
|
|
||
| builder.AddNatsClient("nats", configureOptions: opts => | ||
| { | ||
| var jsonRegistry = new NatsJsonContextSerializerRegistry(AppJsonContext.Default); | ||
| return opts with { SerializerRegistry = jsonRegistry }; | ||
|
Comment on lines
+17
to
+18
Collaborator
There was a problem hiding this comment. Is this required or optional?
Contributor
Author
There was a problem hiding this comment. it's optional. required for json serialization. Would you suggests to make it easier for ad hoc JSON serialization?
Collaborator
There was a problem hiding this comment. I think so, but I don't know enough about your API design to suggest something.
Contributor
Author
There was a problem hiding this comment. Challenge is our core NuGet packages are AOT ready and for ad-hoc JSON we have an extra package. I can bring NATS ad-hoc JSON package into Aspite.Nats.Client if AOT is not a concern (yet?). There was a problem hiding this comment. The Aspire component packages are intended to be AOT compatible if the associated client library is AOT compatible. For example, we are using the Configuration Binder source generator, so config binding works in native AOT. We have 2 service apps in https://github.com/dotnet/eShop that support being published to native AOT:
So, yes, AOT is a concern for Aspire.
Contributor
Author
There was a problem hiding this comment. Thanks for the comments. I'm going to leave this as it is for now since it looks like we're going to need some changes on NATS Client side as well (nats-io/nats.net#417) |
||
| }); | ||
|
|
||
| builder.AddNatsJetStream(); | ||
|
|
||
| var app = builder.Build(); | ||
|
|
||
| // Configure the HTTP request pipeline. | ||
| if (app.Environment.IsDevelopment()) | ||
| { | ||
| app.UseSwagger(); | ||
| app.UseSwaggerUI(); | ||
| } | ||
|
|
||
| app.MapGet("/ping", async (INatsConnection nats) => | ||
| { | ||
| var rtt = await nats.PingAsync(); | ||
| return Results.Json(new { rtt, nats.ServerInfo }); | ||
| }); | ||
|
|
||
| app.MapPost("/stream", async (StreamConfig config, INatsJSContext jetStream) => | ||
| { | ||
| var stream = await jetStream.CreateStreamAsync(config); | ||
| var name = stream.Info.Config.Name; | ||
| return Results.Created($"/stream/{name}", name); | ||
| }); | ||
|
|
||
| app.MapGet("/stream/{name}", async (string name, INatsJSContext jetStream) => | ||
| { | ||
| var stream = await jetStream.GetStreamAsync(name); | ||
| return Results.Ok(stream.Info); | ||
| }); | ||
|
|
||
| app.MapPost("/publish/", async (AppEvent @event, INatsJSContext jetStream) => | ||
| { | ||
| try | ||
| { | ||
| var ack = await jetStream.PublishAsync(@event.Subject, @event); | ||
| ack.EnsureSuccess(); | ||
| } | ||
| catch (NatsJSPublishNoResponseException) | ||
| { | ||
| return Results.Problem("Make sure the stream is created before publishing."); | ||
| } | ||
|
|
||
| return Results.Created(); | ||
| }); | ||
|
|
||
| app.MapGet("/consume/{name}", async (string name, INatsJSContext jetStream) => | ||
| { | ||
| var stream = await jetStream.GetStreamAsync(name); | ||
| var consumer = await stream.CreateOrderedConsumerAsync(); | ||
|
|
||
| var events = new List<AppEvent>(); | ||
| await foreach(var msg in consumer.ConsumeAsync<AppEvent>()) | ||
| { | ||
| events.Add(msg.Data!); | ||
|
|
||
| if (msg.Metadata?.NumPending == 0) | ||
| { | ||
| break; | ||
| } | ||
| } | ||
|
|
||
| return Results.Ok(events); | ||
| }); | ||
|
|
||
| app.Run(); | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,38 @@ | ||
| { | ||
| "$schema": "http://json.schemastore.org/launchsettings.json", | ||
| "iisSettings": { | ||
| "windowsAuthentication": false, | ||
| "anonymousAuthentication": true, | ||
| "iisExpress": { | ||
| "applicationUrl": "http://localhost:12538", | ||
| "sslPort": 44308 | ||
| } | ||
| }, | ||
| "profiles": { | ||
| "http": { | ||
| "commandName": "Project", | ||
| "dotnetRunMessages": true, | ||
| "launchBrowser": true, | ||
| "applicationUrl": "http://localhost:5156", | ||
| "environmentVariables": { | ||
| "ASPNETCORE_ENVIRONMENT": "Development" | ||
| } | ||
| }, | ||
| "https": { | ||
| "commandName": "Project", | ||
| "dotnetRunMessages": true, | ||
| "launchBrowser": true, | ||
| "applicationUrl": "https://localhost:7060;http://localhost:5156", | ||
| "environmentVariables": { | ||
| "ASPNETCORE_ENVIRONMENT": "Development" | ||
| } | ||
| }, | ||
| "IIS Express": { | ||
| "commandName": "IISExpress", | ||
| "launchBrowser": true, | ||
| "environmentVariables": { | ||
| "ASPNETCORE_ENVIRONMENT": "Development" | ||
| } | ||
| } | ||
| } | ||
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,8 @@ | ||
| { | ||
| "Logging": { | ||
| "LogLevel": { | ||
| "Default": "Information", | ||
| "Microsoft.AspNetCore": "Warning" | ||
| } | ||
| } | ||
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,9 @@ | ||
| { | ||
| "Logging": { | ||
| "LogLevel": { | ||
| "Default": "Information", | ||
| "Microsoft.AspNetCore": "Warning" | ||
| } | ||
| }, | ||
| "AllowedHosts": "*" | ||
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,8 @@ | ||
| <Project> | ||
|
|
||
| <Import Project="$([MSBuild]::GetPathOfFileAbove('Directory.Build.props', '$(MSBuildThisFileDirectory)../'))" /> | ||
|
|
||
| <!-- NOTE: This line is only required because we are using P2P references, not NuGet. It will not exist in real apps. --> | ||
| <Import Project="../../../src/Aspire.Hosting/build/Aspire.Hosting.props" /> | ||
|
|
||
| </Project> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,9 @@ | ||
| <Project> | ||
|
|
||
| <Import Project="$([MSBuild]::GetPathOfFileAbove('Directory.Build.targets', '$(MSBuildThisFileDirectory)../'))" /> | ||
|
|
||
| <!-- NOTE: These lines are only required because we are using P2P references, not NuGet. They will not exist in real apps. --> | ||
| <Import Project="..\..\..\src\Aspire.Hosting\build\Aspire.Hosting.targets" /> | ||
| <Import Project="..\..\..\src\Aspire.Hosting.Sdk\SDK\Sdk.targets" /> | ||
|
|
||
| </Project> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,24 @@ | ||
| <Project Sdk="Microsoft.NET.Sdk"> | ||
|
|
||
| <PropertyGroup> | ||
| <OutputType>Exe</OutputType> | ||
| <TargetFramework>net8.0</TargetFramework> | ||
| <ImplicitUsings>enable</ImplicitUsings> | ||
| <Nullable>enable</Nullable> | ||
| <IsAspireHost>true</IsAspireHost> | ||
| <RootNamespace>Nats.AppHosting</RootNamespace> | ||
| </PropertyGroup> | ||
|
|
||
| <ItemGroup> | ||
| <Compile Include="$(SharedDir)KnownResourceNames.cs" Link="KnownResourceNames.cs" /> | ||
| </ItemGroup> | ||
|
|
||
| <ItemGroup> | ||
| <ProjectReference Include="..\..\..\src\Aspire.Dashboard\Aspire.Dashboard.csproj" /> | ||
| <ProjectReference Include="..\..\..\src\Aspire.Hosting.Azure\Aspire.Hosting.Azure.csproj" IsAspireProjectResource="false" /> | ||
| <ProjectReference Include="..\..\..\src\Aspire.Hosting\Aspire.Hosting.csproj" IsAspireProjectResource="false" /> | ||
| <ProjectReference Include="..\Nats.ApiService\Nats.ApiService.csproj" /> | ||
| <ProjectReference Include="..\Nats.Backend\Nats.Backend.csproj" /> | ||
| </ItemGroup> | ||
|
|
||
| </Project> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,12 @@ | ||
| var builder = DistributedApplication.CreateBuilder(args); | ||
|
|
||
| var nats = builder.AddNats("nats") | ||
| .WithJetStream(); | ||
|
|
||
| builder.AddProject<Projects.Nats_ApiService>("api") | ||
| .WithReference(nats); | ||
|
|
||
| builder.AddProject<Projects.Nats_Backend>("backend") | ||
| .WithReference(nats); | ||
|
|
||
| builder.Build().Run(); |
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can we make this app a little more real? Can it use pubsub as well?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
sure, let me have a go!
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I created a simple JetStream example since it's easier demonstrate persisted messages using Web API. As for pubsub I suppose we'd need a frontend using SignalR or Blazor. Maybe a simple chat or something?