15-10-17

请问在云引擎(Node.js)中如何向某个聊天室发送一条消息？我当前的代码是这样的：

/**
 * @return (AV.Promise) resolved when mesage is successfully sent
 */
function sendMessages(conversationId, messages) {  
  var promise = new AV.Promise();
  var realtimeObj = types.createRealtimeObject();
  realtimeObj.on('close', function() {
      console.log('[REALTIME] closed.');
  });
  realtimeObj.on('open', function() {
    console.log('[REALTIME] opened.');
    realtimeObj.conv(conversationId, function(convObj) {
      if(!convObj) {
        promise.reject('cannot construct convObj for ' + conversation.id);
        return;
      }
      convObj.join(function(convObjAgain) {
        if(!convObjAgain) {
          promise.reject('cannot join convObj for ' + conversation.id);
          return;
        }
        var list = [];
        messages.forEach(function(data) {
          var prom = new AV.Promise();
          list.push(prom);
          convObjAgain.send({
            text: JSON.stringify(data),
          }, function(data) {
            prom.resolve('successfully sent');
          });
        });
        AV.Promise.when(list).then(function() {
          promise.resolve('all ' + list.length + ' messages are successfully sent.');
        }, function() {
          promise.reject('unknown error when sending all messages');
        });
      })
    })
  })
  return promise;
}

types.js

var leancloudrealtime = require('leancloud-realtime')
exports.createRealtimeObject = function() {
    return leancloudrealtime({
      appId: process.env.LC_APP_ID,
      clientId: 'ADMINBOT',
      // 是否开启 HTML 转义，SDK 层面开启防御 XSS
      // encodeHTML: true,
  });
}

sendMessages这个函数会在_messageReceived这个hook被调用时调用。

然而后台日志却显示：

ERROR 2015-10-17 12:07:22 LeanEngine function uncaughtException url=/_messageReceived, msg=Error: connect ETIMEDOUT
ERROR 2015-10-17 12:07:22 at TCPConnectWrap.afterConnect as oncomplete
ERROR 2015-10-17 12:07:22 at TLSSocket.socketCloseListener (httpclient.js:247:23)
ERROR 2015-10-17 12:07:22 at TLSSocket.emit (events.js:129:20)
ERROR 2015-10-17 12:07:22 LeanEngine function uncaughtException url=/_messageReceived, msg=Error: socket hang up
ERROR 2015-10-17 12:07:22 at TCP.close (net.js:485:12)
ERROR 2015-10-17 12:07:22 at createHangUpError (httpclient.js:215:15)

请问如何在云引擎中给聊天室发送消息呢？