javascript - Azure 服务总线队列发送消息速度缓慢

Question

因此，我尝试从 node.js 向 Azure 服务总线队列发送消息，我正在使用 Azure 文档中所述的样板代码。

var message = {
body: 'Test message',
customProperties: {
    testproperty: 'TestValue'
}};
serviceBusService.sendQueueMessage('myqueue', message, function(error){
if(!error){
    // message sent
}});

当我每隔几秒发送一条消息时，它工作正常，并且我能够在一秒钟左右看到我的工作人员拾取该消息，但是一旦我开始发送更多消息(每秒 5-10 条)看起来它开始令人窒息，我发现性能下降到每 5 - 8 秒才发送一条消息。有什么方法可以提高性能并保持 FIFO 顺序吗？由于我在本地运行 Node 代码和工作线程，这可能是延迟问题吗？

注意:我使用的是基本的非分区队列。

Answer 1

为了优化服务总线的发送性能，如果您的应用程序支持异步发送和完成操作，我们可以利用客户端批处理。详情可以查看官方文章https://azure.microsoft.com/en-us/documentation/articles/service-bus-performance-improvements/#client-side-batching .

但是，使用批量发送消息的客户端仅集成在.Net SDK中，在Node.js中我们应该通过REST API实现自定义请求https://msdn.microsoft.com/en-us/library/azure/dn798894.aspx .

要通过 REST API 实现自定义请求，我们需要首先在 Azure 门户上创建身份验证凭据:

• 转到Azure Managment Portal ，在左侧菜单中选择“服务总线”。
• 选择您创建的命名空间。
• 在顶部菜单中选择“队列”。
• 选择队列以转到详细信息屏幕
• 转到“配置”选项卡，然后转到“共享访问策略”部分
• 创建新政策，输入名称并选择用于发送消息的“发送”权限
• 按页面底部的“保存”按钮保存
• 转到“共享访问 key 生成器”部分
• 选择您的政策并复制主键
• 保存此 key ，稍后会用到

然后您可以利用此代码示例生成用于发送批量消息的 SAS token https://github.com/dx-ted-emea/azure-tessel/blob/master/labs/service-bus-queues/CreateSASToken.js

这是代码片段:

var https = require('https');
var crypto = require('crypto');
// ServiceBus parameters
var namespace = '<Your-ServiceBus-Namespace>';
var queue ='<Your-Queue>';
var AccessKeyName = '<Your-AccessKey-Name>';
var AccessKey = '<Your-AccessKey>';
// Full ServiceBus Queue publisher URI

var ServiceBusUri = 'https://' + namespace + '.servicebus.windows.net' + '/' + queue;
function createSASToken(uri, keyName, key) {
                var expiry = parseInt(Date.now()/1000)+3600;
                var signedString = encodeURIComponent(uri) + '\n' + expiry;
                var hmac = crypto.createHmac('sha256', key);
                hmac.update(signedString);
                var signature = hmac.digest('base64');
                var token = 'SharedAccessSignature sr=' + encodeURIComponent(uri) + '&sig=' + encodeURIComponent(signature) + '&se=' + expiry + '&skn=' + keyName;

                return token;
}

var createdSASToken = createSASToken(ServiceBusUri, AccessKeyName, AccessKey);
var options = {
                hostname: namespace + '.' + 'servicebus.Windows.net',
                port: 443,
                path: '/' + queue + '/messages',
                method: 'POST',
                headers: {
                                'Authorization': createdSASToken,
                                'Content-Type': 'application/vnd.microsoft.servicebus.json',
                }
};
var req = https.request(options, function(res) {
                console.log("SendMessageInQueue:statusCode: ", res.statusCode);
                res.setEncoding('utf8');
                res.on('data', function(d) {
                });
});
req.on('error', function(e) {
                console.error(e);
});
var messages = [{
                "Body": "This is the first message"
}, {
                "Body": "This is the second message"
}, {
                "Body": "This is the third message"
}];
req.write(JSON.stringify(messages));
req.end();

该解决方案基于https://github.com/dx-ted-emea/azure-tessel/tree/master/labs/service-bus-queues 。