Azure ServiceBus Неверная подпись - PullRequest
Новая
       16

Azure ServiceBus Неверная подпись

0 голосов
/ 08 ноября 2018

Я создаю SAS TOKEN, сгенерированный с помощью модуля shared-access-signature npm. Когда я пытаюсь подключиться к сервисной шине с помощью Azure SDK, я получаю следующую ошибку. 

com.microsoft.azure.servicebus.primitives.ServiceBusException: 
Error{condition=com.microsoft:auth-failed, description='InvalidSignature:
The token has an invalid signature.', info=null}

Мой токен SAS выглядит следующим образом 

SharedAccessSignature sr=https%3A%2F%2Fmy-servicebus-dev.servicebus.windows.net%2F&sig=somesig%2idonotdisclose0e1g%3D&se=1541700607.155&skn=RootManageSharedAccessKey

Как использовать SAS TOKEN? Это должна быть вся строка или только часть, кроме SharedAccessSignature?

Пожалуйста, помогите. У меня заканчиваются подсказки.

1 Ответ

0 голосов
/ 09 ноября 2018

Как использовать SAS TOKEN? Должна ли это быть целая строка или только часть, кроме SharedAccessSignature?

На основании моего теста ответ - да. Вам нужно передать параметр как целую строку, включая SharedAccessSignature sr=.

Я генерирую токен sas с предоставленной вами библиотекой npm. 

var sas = require('shared-access-signature');

var url = 'https://******.servicebus.windows.net/BasicQueue';
var sharedAccessKeyName = 'RootManageSharedAccessKey';
var sharedAccessKey = '***';
var currentDate = new Date();
var expiry = currentDate.getTime() / 1000 + 3600; // We require expiry time in seconds since epoch.

var sas = require('shared-access-signature');
var signature = sas.generateServiceBusSignature(url, sharedAccessKeyName, sharedAccessKey, expiry);
console.log(signature);

Затем используйте его в приведенном ниже коде Java: 

import com.microsoft.azure.servicebus.Message;
import com.microsoft.azure.servicebus.QueueClient;
import com.microsoft.azure.servicebus.ReceiveMode;
import com.microsoft.azure.servicebus.primitives.ConnectionStringBuilder;
import com.microsoft.azure.servicebus.primitives.ServiceBusException;
public class SendMessages {
    private static String entityPath = "BasicQueue";

    private static String namespaceName = "***";

    private static String sharedAccessSingature = "SharedAccessSignature sr=https%3A%2F%2F***.servicebus.windows.net%2FBasicQueue&sig=ewu7ZwgPgDVSHBZiYB7paBp94KuMtby%2BiwK0fDJ5GLM%3D&se=1541735153.139&skn=RootManageSharedAccessKey";


    public static void main(String[] args) throws ServiceBusException, InterruptedException {

        QueueClient sendClient = new QueueClient(new ConnectionStringBuilder(namespaceName, entityPath, sharedAccessSingature), ReceiveMode.PEEKLOCK);

        String test = "test for 111";

        Message message = new Message(test);

        sendClient.sendAsync(message).thenRunAsync(() -> {
            System.out.printf("\n\tMessage acknowledged: Id = %s", message.getMessageId());
        });

        System.out.println("send success");
    }
}
...