Не удается использовать REST API для служебной шины для Windows Server 1.1 (локально)

Я использую служебную шину Windows Server 1.1. Я могу сгенерировать токен OAuth из служебной шины Windows Server, используя следующий базовый адрес

  string baseAddressHttp = "https://" + ServerName + ":9355/" + Namespace + "/$STS/OAuth/";

Для Window Azure Service Bus для отправки сообщения в очередь я могу отправить запрос по следующему адресу очереди

        string serviceNamespace = "ServiceBusDefaultNamespace";
        string queueName = "SampleQueuName";
        string message ="This is my first message";
        string queueAddress = "https://" + serviceNamespace + ".servicebus.windows.net/"+ queueName + "/messages";
        WebClient webClient = new WebClient();
        webClient.Headers[HttpRequestHeader.Authorization] = token;
        webClient.UploadData(baseAddress, "POST", Encoding.UTF8.GetBytes(message));

Но для Windows Server Service Bus этот же метод не работает.

Поддерживает ли служебная шина Windows Server 1.1 REST API? Любая помощь будет действительно оценена.

Заранее спасибо!!


azure rest c# azureservicebus servicebus
person R J    schedule 10.02.2014    source источник
comment
была проблема с моим ответом?   -  person jonho    schedule 17.02.2014
comment
Это работает!!! Большое спасибо, Джонхо!!   -  person R J    schedule 18.02.2014

Ответы (1)


arrow_upward
5
arrow_downward

да поддерживает. Мы используем это.

  1. Я думаю, что ваша конечная точка пространства имен по умолчанию неверна - вам не нужен .servicebus.windows.net
  2. вам нужно сначала получить токен от sts, используя имя пользователя и пароль пользователя, у которого есть права прослушивания или отправки на служебной шине.
  3. имя пользователя и пароль пользователя служебной шины должны быть опубликованы в определенном формате.
  4. Затем вам нужно добавить возвращаемый токен в заголовок авторизации и сделать фактический запрос на отправку или прослушивание в конечную точку /messages.

  5. Этот код должен сделать это:

    private const string DefaultNamespace = "https://yoursbserver:9355/servicebusdefaultnamespace";
private const string QueueEndpoint = "https://yoursbserver:9355/servicebusdefaultnamespace/YourQueueNameOrTopicName/messages/?timeout=60";

private static void Main()
{
    var token = GetOAuthTokenFromSts(new Uri(DefaultNamespace), "usernamewithpermissiononServiceBus", "password", TimeSpan.FromMinutes(10));
    var messageXml = CreateXml();
    SendMessage(token, messageXml);

    Console.WriteLine("Successfully posted message!");
    Console.ReadLine();
}

private static string CreateMessage()
{
    return "<SomeMessage xmlns='MyNamespace'></SomeMessage>";
}

public static string GetOAuthTokenFromSts(Uri namespaceBaseAddress, string userName, string userPassword, TimeSpan timeout)
{
    const string stsPath = "$STS/OAuth/";

    var requestUri = new Uri(namespaceBaseAddress, stsPath);
    var requestContent = GetRequestContent(namespaceBaseAddress, userName, userPassword);
    var request = CreateRequest(timeout, requestUri, requestContent);
    return GetAccessToken(request, requestContent);
}

private static HttpWebRequest CreateRequest(TimeSpan timeout, Uri requestUri, byte[] requestContent)
{
    var request = WebRequest.Create(requestUri) as HttpWebRequest;
    request.ServicePoint.MaxIdleTime = 5000;
    request.AllowAutoRedirect = true;
    request.MaximumAutomaticRedirections = 1;
    request.Method = "POST";
    request.ContentType = "application/x-www-form-urlencoded";
    request.ContentLength = requestContent.Length;
    request.Timeout = Convert.ToInt32(timeout.TotalMilliseconds,
                                      CultureInfo.InvariantCulture);
    return request;
}

private static byte[] GetRequestContent(Uri namespaceBaseAddress, string userName, string userPassword)
{
    const string clientPasswordFormat = "grant_type=authorization_code&client_id={0}&client_secret={1}&scope={2}";
    var requestContent = string.Format(CultureInfo.InvariantCulture,
                                          clientPasswordFormat, HttpUtility.UrlEncode(userName),
                                          HttpUtility.UrlEncode(userPassword),
                                          HttpUtility.UrlEncode(namespaceBaseAddress.AbsoluteUri));
    return Encoding.UTF8.GetBytes(requestContent);
}

private static string GetAccessToken(HttpWebRequest request, byte[] requestContent)
{
    string accessToken;
    using (var requestStream = request.GetRequestStream())
    {
        requestStream.Write(requestContent, 0, requestContent.Length);
    }

    using (var response = request.GetResponse() as HttpWebResponse)
    using (var stream = response.GetResponseStream())
    using (var reader = new StreamReader(stream, Encoding.UTF8))
    {
        accessToken = reader.ReadToEnd();
    }

    return string.Format(CultureInfo.InvariantCulture, "WRAP access_token=\"{0}\"", accessToken);
}

private static void SendMessage(string token, string message)
{
    var webClient = new WebClient();
    webClient.Headers[HttpRequestHeader.Authorization] = token;
    webClient.UploadData(QueueEndpoint, "POST", Encoding.UTF8.GetBytes(message));
}
person jonho    schedule 13.02.2014