使用Java/Spring连接Azure事件网格和服务总线

Question

我有一个场景，每当Azure Service bus的队列/主题中有消息时，Azure ServiceBus就会将事件发送到事件网格。那么，我如何在Java/Spring中建立连接，使用事件网格接收事件，并使用服务总线提取消息。要在Java/Spring中建立与事件网格和Azure服务总线的连接，需要进行哪些配置？另外，在应用程序端（application.yml或properties文件）必须进行哪些配置才能包括连接字符串等内容。？

Answer 1

Azure服务总线到事件网格集成

当队列中有消息时，服务总线现在可以向事件网格发出事件；当没有接收者时，服务总线可以向订阅发出事件。您可以创建对服务总线名称空间的事件网格订阅，侦听这些事件，然后通过启动接收器对事件作出反应。

要启用该功能，您需要以下项目：

• 具有至少一个服务总线队列的服务总线高级命名空间或具有至少一个订阅的服务总线主题。
• 参与者访问服务总线命名空间。导航到Azure门户中的服务总线命名空间，然后选择访问控制（IAM），然后选择角色分配选项卡。验证您是否拥有对命名空间的贡献者访问权限。
• 此外，需要为服务总线命名空间订阅事件网格。此订阅从事件网格接收通知，通知有消息要接收。典型的订阅者可以是Azure应用服务的逻辑应用功能、Azure功能或与Web应用联系的Web钩子。订户然后处理消息。

有关详细信息，请查看此Microsoft文档。

选中此项以使用Azure函数连接两者。

检查此文档以使用逻辑应用程序连接这两个。

Azure CLI：

namespaceid=$(az resource show --namespace Microsoft.ServiceBus --resource-type namespaces --name "<service bus namespace>" --resource-group "<resource group that contains the service bus namespace>" --query id --output tsv

az eventgrid event-subscription create --resource-id $namespaceid --name "<YOUR EVENT GRID SUBSCRIPTION NAME>" --endpoint "<your_endpoint_url>" --subject-ends-with "<YOUR SERVICE BUS SUBSCRIPTION NAME>"

PowerShell：

$namespaceID = (Get-AzServiceBusNamespace -ResourceGroupName "<YOUR RESOURCE GROUP NAME>" -NamespaceName "<YOUR NAMESPACE NAME>").Id

New-AzEVentGridSubscription -EventSubscriptionName "<YOUR EVENT GRID SUBSCRIPTION NAME>" -ResourceId $namespaceID -Endpoint "<YOUR ENDPOINT URL>” -SubjectEndsWith "<YOUR SERVICE BUS SUBSCRIPTION NAME>"

Answer 2

您的需求可以通过azure function app轻松实现。

将服务总线队列/主题设置为接收消息的函数的触发器。

并使用Azure SDKJava将事件发送到事件网格：

https://docs.microsoft.com/en-us/java/api/overview/azure/eventgrid/client?view=azure-java稳定

https://docs.microsoft.com/en-us/java/api/overview/azure/messaging-eventgrid-readme?view=azure-java稳定