标签: azureservicebus

我对使用Azure Service Bus通知中心感兴趣.但是,我的第一个"客户端"将是一个基于websocket的连接到具有Knockout的ASP.NET MVC站点.目前,我正在尝试使用SignalR将通知推送给客户端.

但是,如果我可以使用SB通知中心,这看起来会容易得多.所有 示例都是Windows或iOS.

您可以将Azure Service Bus通知中心与基于WebSocket的HTML客户端一起使用吗？

我在监测和固定的消息编写功能dead letter queue的topic subscription在Azure上.

我可以得到一个_subscriptionClient.PeekBatch(10)用于显示的消息列表; 但是,当我们想要实际删除其中一条消息时,我们会陷入困境.

工作流程将是:

1. 获取所有邮件的列表
2. 将特定消息(例如集合中的第5个)发送回原始队列以进行重新处理
3. 将关联的死信消息标记为.Complete().

问题是,虽然我们有消息列表,但我们不能先.Complete()使用特定的消息.subscriptionClient.Receive().

由于你不能通过.Receive()MessageId发送消息,这是否意味着我们必须逐个遍历消息,如下所示？

public BrokeredMessage GetMessageById(string messageIdentifier)
{
    BrokeredMessage matchingMessage = null;
    var messageNotFound = true;

    var messagesToAbandon = new List<BrokeredMessage>();

    while (messageNotFound)
    {
        var message = _subscriptionClient.Receive();

        if (message == null)
        {
            throw new Exception("Could not find the message on the queue");
        }

        if (message.MessageId == messageIdentifier)
        {
            messageNotFound = false;
            matchingMessage = message;
        }
        else …

我知道(阅读msdn文档[此处])Windows Azure存储队列对邮件使用基于租约的独占访问策略,Azure Service Bus Queues使用基于锁的存储队列.在两者中我都可以设置锁定/租用的最大持续时间.那么,这两种方法之间最重要的区别是什么？有人可以提供明确/简短的例子吗？谢谢.

1 https://msdn.microsoft.com/en-us/library/azure/hh767287.aspx

有没有ServiceBus提供商这样的东西？作为我的应用程序的一部分,我想包括一个SB命名空间,主题和订阅.您是否期望使用ARM部署网站,并使用服务接口来编写其他支持功能的脚本？

我创建了一个Azure功能,只要将新邮件添加到Azure ServiceBus队列,就会触发该功能.使用此代码可以正常工作:

#r "Newtonsoft.Json"
#load "..\shared\person.csx"

using Newtonsoft.Json;
using Newtonsoft.Json.Serialization;

public static void Run(string message, TraceWriter log)
{
    var person = JsonConvert.DeserializeObject<Person>(message, 
            new JsonSerializerSettings() {ContractResolver = new CamelCasePropertyNamesContractResolver()});
    log.Verbose($"From DeserializeObject: {person.FirstName} {person.LastName}");
}

我已经看到我也可以将消息绑定到这样的POCO:

public static void Run(Person message, TraceWriter log)
{
    log.Verbose($"From DeserializeObject: {message.FirstName} {message.LastName}");
}

现在我想将消息绑定到a,BrokeredMessage因为我需要访问消息的属性.

我知道，由于SSL的影响，Azure Service Bus在传输过程中是安全的，但是我无法找到有关在静止状态下是否已加密的任何信息。

如果消息的内容本质上是敏感的，那么可以在Azure基础结构中依靠Azure来保持消息的私密性吗？还是我们应该实现消息安全性？

这是场景:

Publisher #1 ????             ???? Round Robin ??????? Subscriber #1 (Service 1)
                ?             ?                   ???? Subscriber #2 (Service 1)
                ???? Topic ????
                ?             ?                   ???? Subscriber #3 (Service 2)
Publisher #2 ????             ???? Round Robin ??????? Subscriber #4 (Service 2)

我有一条消息需要由多个订阅者处理,但每个服务只有一个(每个服务都会运行多个实例).

消息#1需要由订户#1和#3处理.消息#2需要由订户#2和#4处理.消息#3,订户#1和#3再次.基本上,每条消息应循环到订阅每条消息的每个负载均衡服务,按连接的每个服务进行分组.这可能不创建多个主题吗？

即使它不是循环法,我也会尽最大努力在多个服务之间实现负载均衡.这可能吗？

我正在使用Azure Service Bus主题机制.我已将消息发送到主题,并希望查看全部发送到azure门户中主题的消息.我可以看到消息计数但想要查看实际消息而不是计数.

我怎样才能做到这一点？

我有一些代码想要从Microsoft.Azure.ServiceBus迁移到Azure.Messaging.ServiceBus，考虑到前一个包已被视为已弃用。

我不知道如何使用这个新包的一件事是构建/操作连接字符串。具体来说，我使用ServiceBusConnectionStringBuilder从我的配置中解析连接字符串并获取EntityPath，以及此类提供的一些其他内容。

我是否忽略了某些内容，或者此功能已被完全删除？

我正在试验 Windows Azure 中继服务总线和 WCF...我有一个带有 3 个侦听器的服务总线，有没有办法找出有关这三个侦听器指向何处的任何信息？

因为我只启动了一个 WCF 服务，所以我看到 3 个听众有点奇怪，所以我想知道是什么......

谢谢！