azureservicebus相关内容

提供的锁无效.锁已过期,或消息已从队列中删除

我正在使用 Microsoft azure 服务总线队列来处理计算,并且我的程序可以正常运行几个小时,但随后我开始为我处理的每条消息收到此异常.我不知道从哪里开始,因为前几个小时一切正常.我的代码似乎也很准确.我会贴出我处理azure服务总线消息的方法. public static async Task processCalculations(BrokeredMessage 消息){尝试{如果( ..
发布时间:2021-12-06 18:02:18 C#/.NET

获取“amqp:内部错误"使用 AMQP、rhea 和 Node 从 Azure 服务总线队列查看消息时

几天前我问了同样的问题:无法“窥视";使用 AMQP 和 Node 来自 Azure 服务总线队列的消息.我再次问同样的问题,但有一些不同(因此,请不要将此问题标记为另一个问题的重复): 在上一个问题中,我使用了 nodeamqp10 库,但是根据 Github 页面上针对该库的一些评论,我最终使用了 rhea 而不是 nodeamqp10 库. 在 Azure 服务总线团队的帮助下,我取 ..

轨道交通.使用在不同命名空间中定义的相同对象

首先,请原谅我的英语很糟糕.我将 MassTransit 与 Azure 服务总线一起用于微服务之间的异步通信.根据它们自己的定义,为了避免它们之间产生依赖关系,不同微服务之间发送的消息被定义在每个微服务中,即它们属于不同的命名空间.MassTransit 的自动管理导致队列和主题按对象类型进行管理,从而阻止消费消息的微服务接收微服务发布者发送的消息.同样的事情发生在同一个命名空间中具有相同属性但 ..
发布时间:2021-11-24 17:58:37 C#

使用 .NET Core SDK 创建过滤的服务总线订阅

我想从 .NET Core 2.1 应用程序内部使用 Azure 服务总线.我熟悉 Nuget 包 Microsoft.Azure.ServiceBus 附带的 SDK,我目前正在使用它编写主题并从那里接收消息. 我现在想要的是为每个客户创建关于这个主题的订阅.关键是我想使用 SqlFilter 创建一个过滤订阅.这意味着,我必须通过代码创建订阅. 顺便说一句:据我所知,除此之外,在代 ..
发布时间:2021-11-24 17:53:50 C#

在 Azure ServiceBus 上从 .NET Core 发件人向 .NET 4.6 处理程序发送消息

我想从 .NET Core 控制台应用程序通过 Azure 服务总线发送消息,并在 .NET 4.6 控制台应用程序中接收它.在 .NET Core 中,我将 Azure 的新服务总线客户端用于尚未用于生产的发件人(根据他们的自述文件). https://github.com/Azure/azure-service-bus-dotnet 我可以使用示例轻松地从 .NET Core 发送 ..
发布时间:2021-11-24 17:07:16 C#/.NET

Azure ServiceBus 消息序列化/反序列化

我正在使用 .NET Core 应用程序通过 Azure 服务总线队列发送对象,并让 Web 作业(.NET Core 也是如此)接收它. 我的问题是如何序列化/反序列化来发送/接收对象? 我发现许多对旧 BroakerMessage.GetBody() 的引用以接收消息,但没有引用新的 .NET Core 方法.请指教,谢谢. 发件人代码: 使用 Microsoft.Azur ..
发布时间:2021-11-24 13:07:04 C#/.NET

Azure 服务总线 - 使用 BrokeredMessage.GetBody 读取 .NET Core 2 发送的消息

我将 .NET Core 2 用于需要在服务总线上放置消息并由旧版 .NET 4.6 接收器读取的应用程序.接收方也会监听来自其他遗留应用程序的消息. 旧发件人: UserData obj = new UserData(){id = 1,名称 = "阿丽莎"};BrokeredMessage 消息 = 新 BrokeredMessage(consentInstated);_client.S ..
发布时间:2021-11-24 12:51:54 C#

Azure Apns Hub 不适用于生产证书

我已经在沙盒模式下成功测试了一个 azure apns hub.现在,当我尝试切换到生产时,没有任何效果.我已阅读教程,并且我确定我正确生成了生产证书.有谁知道问题是什么?在某些时候,我想我已经读过,当我使用 Iphone 测试沙箱 apns 时,它可能在切换到生产后无法工作. 解决方案 在调试了一些之后,我找到了问题所在.我必须使用生产证书运行我的应用程序.这意味着,我无法通过 Xcod ..
发布时间:2021-11-16 21:21:20 其他开发

轨道交通.使用不同命名空间中定义的相同对象

首先,请原谅我的英语很糟糕.我将 MassTransit 与 Azure 服务总线一起用于微服务之间的异步通信.根据它们自己的定义,为了避免它们之间产生依赖关系,不同微服务之间发送的消息被定义在每个微服务中,即它们是不同命名空间的一部分.MassTransit 的自动管理导致队列和主题按对象类型进行管理,从而阻止使用消息的微服务接收微服务发布者发送的消息.同样的事情发生在同一个命名空间中具有相同属 ..
发布时间:2021-10-26 16:02:29 其他开发

如何在 Azure Function 中使用 Azure 托管标识通过触发器访问服务总线?

我在 Azure 中创建了一个 ServiceBus 命名空间,以及一个主题和一个订阅.我还有一个简单的 Azure 版本 1 函数,它触发 ServiceBus 中接收到的主题,如下所示: [FunctionName("MyServiceBusTriggerFunction")]public static void Run([ServiceBusTrigger("myTopic", "mySu ..

服务总线主题订阅过滤器

我正在从事一个将消息发布到服务总线主题的项目.我的主题有两个订阅.有没有办法过滤我的订户将收听的消息? 假设这是我的留言文字. {“数据" : {“名称":“约翰尼·克鲁兹"“性别":“男"}} 我只想听一条具有男性性别的消息.这是可以在Topic中配置的东西吗? 解决方案 用户可以定义他们希望从某个主题接收哪些消息.您可以参考主题过滤器和操作 服务总线支持三种过滤条件 ..
发布时间:2021-04-14 18:42:25 其他开发

结合使用SAS令牌和Azure ServiceBus

我正在使用新的Azure ServiceBus SDK,它是.NET Standard 2.0,并且发现使用SAS令牌很困难.以前,它以前是MessagingFactory,但在新的SDK中不存在.ServiceBusConnectionStringBuilder具有SAS令牌,但也需要connectionString. 基本上,我想使用SAS策略(用于发送和接收规则的发送规则)和从这些策略 ..
发布时间:2021-04-14 18:42:22 其他开发

如何在Spring Boot Java中将故障消息推送到Azure服务总线Dead Letter Queue?

我正在使用JMS侦听器从Azure主题中读取消息并处理该消息,一旦过程完成,我将推回另一个主题.我在spring文档的帮助下成功完成了功能.现在,我需要处理失败消息-错误处理程序.如果我们在阅读或处理消息时遇到异常,这意味着我需要将其推送到“死信队列"中. 我根据Spring文档尝试过的示例代码. @Component公共类接收器{@JmsListener(目的地="mailbox",c ..