重磅！微软开源微服务构建软件Dapr

const express = require('express');
const bodyParser = require('body-parser');
const app = express();
app.use(bodyParser.json());
const port = 3000;
app.get( '/dajgr/subscribe', (_req, res) => {
    res.json([
        'A',
        'B'
    ]);
});
app.post('/A', (req, res) => {
    console.log("A:", req.body);
    res.sendStatus(200);
});
app.post('/B', (req, res) => {
    console.log("B:", req.body);
    res.sendStatus(200);
});
app.listen(port, () => console.log('Node App listening on port ${port}!'))

using System.Collections.Generic;
using System.Text.Json;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Dependencylnjection;
using Microsoft.Extensions.Hosting;
using System.IO;
namespace DaprPubSub
{
    public class Startup
    {
        // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
        public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
        {
            app.UseRouting();
            app.UseEndpoints(endpoints =>
            {
                // Route called by Dapr runtime to get topics this app subscribes to.
                endpoints.MapGet("dagr/subscribe", async context =>
                {
                    // Returns list of topics to subscribe to as json in response.
                    var topicsToSubscribe = new List<string>() { "TopicA", "TopicB" >;
                    await JsonSerializer.SerializeAsync(context.Response.Body, topicsToSubscribe);
                });
                
                // Route to handle events published to TopicA
                endpoints.MapPost("A", async context =>
                {
                    // Read the event form request body.
                    using (var streamReader = new StreamReader(context.Request.Body))
                    {
                        var json = await streamReader.ReadToEndAsync();
                        Console.WriteLine("Received event for TopicA.");
                        Console.WriteLine($"Event Data: {json}');
                    }
                });
                // Route to handle events published to TopicB
                endpoints.MapPost("B", async context =>
                {
                    // Read the event form request body.
                    using (var streamReader = new StreamReader(context.Request.Body))
                    {
                        var json = await streamReader.ReadToEndAsync();
                        Console.WriteLine("Received event for TopicB.");
                        Console.WriteLine($"Event Data: {json}");
                    }
                });
            });
        }
    }
}

curl -X POST http://localhost:3500/vl.0/publish/A \ -H "Content-Type: application/json" \ -d '{"status": "completed"}'

const express = require('express'’);
const path = require('path');
const request = require('request');
const bodyParser = require('body-parser');
const app = express();
app.use(bodyParser.json());
const port = 8080;
const daprllrl = 'http://localhost:${process.env.DAPR_HTTP_PORT || 3500}/vl.0';
app.post('/publish', (req, res) => {
    console.log("Publishing: ", req.body);
    const publishUrl = '${daprUrl}/publish/${req.body.messageType}';
    request( { uri: publishUrl, method: ’POST', json: req.body } );
    res.sendStatus(200);
});
app.listen(process.env.PORT || port, () => console.log('Listening on port ${port}!'));

dapr init                                 (for local deployment)
dapr init --kubernetes              (for Kubernetes deployment)