我们有多个 webapi（微服务）。为了在这些微服务之间进行通信，我们使用 Azure 服务总线 Topic\Subscription。 webapi 控制器如何获取消息订阅，以便 api 可以处理消息并插入数据库。我不想使用任何天蓝色的功能。我想在我的 webapi（直接微服务）中订阅消息。
【问题讨论】：
标签： azure asp.net-core-webapi azure-servicebus-topics
您可以为主题创建一个客户端来订阅消息并设置选项以在完成必要的过程后完成。 请找到以下示例代码，您可以在其中阅读某个主题的订阅消息。
您可以使用 WindowsAzure.ServiceBus -Nuget 包
示例代码：
using Microsoft.ServiceBus.Messaging;
using Microsoft.ServiceBus;
var con = "your connection string for the topic";
var topic = "your topic name";
var subclient = SubscriptionClient.CreateFromConnectionString(con, topic, "yourSubscriptionName");
OnMessageOptions options = new OnMessageOptions();
options.AutoComplete = false;
client.OnMessage(message =>
{
Console.WriteLine("Message:" + message.GetBody<string>());
message.Complete();
}, options);
您可以将它放在单独的方法中并根据需要使用。 要进行轮询，您可以创建一个 webjob，或者您可以放置触发 web api 的代码，以便它同时轮询消息。
【讨论】：