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并不涉及编译时间依赖性，只需要直接利用消息正文构建URL即可。