小编Jaz*_*lli的帖子

直截了当的问题,希望有一个直截了当的答案.我正在尝试使用请求通过Node.js实现客户端凭据流.这是我的代码

var request = require('request');
var payload = config.spotify.clientID + ":" + config.spotify.clientSecret;
var encodedPayload = new Buffer(payload).toString("base64");

var opts = {
    url: "https://accounts.spotify.com/api/token",
    method: "POST",
    headers: {
        "Content-Type": "application/x-www-form-urlencoded",
        "Authorization": "Bearer " + encodedPayload
    },
    body: "grant_type=client_credentials&scope=playlist-modify-public playlist-modify-private"
};

request(opts, function (err, res, body) {
    console.log('error', err);
    console.log('status', res.statusCode);
    console.log('body', body);
});

无论我做什么,反应机构总是如此

{"error":"invalid_client"}

我尝试使用curl发出请求,结果相同.

$ curl -X POST -H 'Authorization: Bearer <base64encoded client_id:client_secret>' -d 'grant_type=client_credentials&scope=playlist-modify-public playlist-modify-private' https://accounts.spotify.com/api/token

这意味着它是凭证的问题.我肯定在我的应用程序中使用正确的clientID和clientSecret,这让我相信它是导致问题的编码.

我正在编码吗？如果是这样,还有什么可能是原因？

我正在编写一个模块,作为amqplib的包装器.我们的动机是,我们已经建立了一个现有的,定义良好的交换/队列/绑定,我只想公开使用消费方法以允许消费传入数据.

为此,我的模块采用了表单的回调参数callback(channel, msg).在模块中,在设置了交换和队列以及绑定之后,我有以下内容

module.exports = function (options, callback) {

  /* connection, exchange and queue set up here */

  // consume messages from primary queue
  ok = ok.then(function() {
    var q = opts.pq;
    console.log('Subscribing to', q);
    return ch.consume(q, function (message) {
      callback(ch, message);
    });
  });

  return ok;

};

在回调中,我正在处理消息,并在成功时调用channel.ack(msg).

一切都运行正常,因为没有错误,但是RabbitMQ管理控制台将所有已处理的消息显示为Unacked.如果我然后杀了我的应用程序,Unacked消息将返回队列(谢天谢地).

为什么我的消息没有被删除？我在ack'ing做错了吗？我应该allUpTo在调用中将参数提供为true ack吗？

环境详情

node -v
v0.8.26

npm ls
...
amqplib@0.1.1