6

根据 MSDN，代理消息可以通过 REST API 提交，并且该代理消息可以将属性键值对作为消息的一部分。我已经能够提交 Brokered 消息，但是当我收到它时，消息上的 Properties 字段未填充。我必须错误地编码属性 JSON。

这是代码片段

        WebClient webClient = new WebClient();
        webClient.Headers[HttpRequestHeader.Authorization] = _token;
        webClient.Headers["Content-Type"] = "application/atom+xml;type=entry;charset=utf-8";
        Guid messageId = Guid.NewGuid();
        webClient.Headers["BrokerProperties"] = @"{""MessageId"": ""{" + messageId.ToString("N") + @"}"", ""TimeToLive"" : 900, ""Properties"": [{""Key"" : ""ProjectId"", ""Value"" : """ + message.ProjectId + @"""}]}";

        // Serialize the message
        MemoryStream ms = new MemoryStream();
        DataContractSerializer ser = new DataContractSerializer(typeof(RespondentCommitMessage));
        ser.WriteObject(ms, message);
        byte[] array = ms.ToArray();
        ms.Close();

        byte[] response = webClient.UploadData(fullAddress, "POST", array);
        string responseStr = Encoding.UTF8.GetString(response);

有没有人有使用 BrokerProperties HTTP 标头提交 BrokeredMessage 的示例？

4

2 回答 2

3

看起来 servicebus 团队已经在http://servicebus.codeplex.com/上的 codeplex 上放置了一些 silverlight 和 windows phone 服务总线示例。我快速查看了 silverlight 聊天示例的代码，它似乎拥有通过 RESTFull API 发布代理消息所需的一切。

于 2011-10-18T20:46:52.763 回答
2

我自己必须对 Azure 服务总线的 REST API 进行一些调查/工作，我将为你们省去挖掘已接受答案中列出的 silverlight 聊天示例的麻烦，并为您提供实际的内幕。

你只需要知道两件事：

1) BrokerProperties HTTP Request Header 不等同于 BrokeredMessage.Properties 集合

BrokeredMessage 对象上的 Properties 字典是自定义属性的集合，而 BrokerProperties HTTP 请求标头是您指定通常与 BrokeredMessage 关联的内置属性的位置，例如标签、TimeToLive 等。

2) 所有自定义 HTTP 请求标头都被视为自定义属性

来自 MSDN：除了这些属性（参考 BrokerProperties）之外，您还可以指定自定义属性。如果发送或接收单个消息，则每个自定义属性都放置在其自己的 HTTP 标头中。如果发送了一批消息，则自定义属性是 JSON 编码的 HTTP 正文的一部分。

这意味着添加自定义属性所需要做的就是添加标题，例如：

    public static void SendMessageHTTP(string bodyContent, params KeyValuePair<string,object>[] properties)
    {
        //BrokeredMessage message = new BrokeredMessage(bodyContent);            
        //foreach(var prop in properties)
        //{
        //    message.Properties[prop.Key] = prop.Value;
        //}

        ...

        WebClient webClient = new WebClient();
        webClient.Headers[HttpRequestHeader.Authorization] = token;
        webClient.Headers[HttpRequestHeader.ContentType] = "application/atom+xml;type=entry;charset=utf-8";

        foreach (var prop in properties)
        {
            webClient.Headers[prop.Key] = prop.Value.ToString();
        }
        webClient.Headers["MyCustomProperty"] = "Value";

        webClient.UploadData(messageQueueURL, "POST", Encoding.UTF8.GetBytes(bodyContent));            
    }

非常值得一读的是关于发送消息 API 端点的 MSDN 参考和对 REST API 本身的介绍（这是它讨论自定义属性的地方）。Azure 网站文档中还有一篇包含示例代码的文章。

于 2015-10-28T18:44:21.397 回答