我已经在IBM Blockchain平台上部署了示例fabcar网络,并且正在使用此repository中的代码与之交互。当我分别调用每个函数时,交互效果很好。

当我开发 Node 服务器并公开用于调用链码的API时,就会出现问题。一旦这样做,我就会开始收到错误消息



奇怪的是,当我同时向POST调用发送3个请求时,出现此错误。但是记录被插入到IBM云中。

当我同时发送100个请求时,只有大约20个被插入云中,其余的显示此错误以及类似的其他错误



在某些情况下



我不明白为什么会显示这些错误。我必须开发一个可以处理负载的高性能应用程序,我们将不胜感激任何帮助和指导。

这是我的app.js代码:

'use strict';

//get libraries
const express = require('express');
const bodyParser = require('body-parser');
const request = require('request');
const path = require('path');

//create express web-app
const app = express();
const router = express.Router();
app.use(bodyParser.json());
const invoke = require('./invokeNetwork.js');

//declare port
var port = process.env.PORT || 8000;
if (process.env.VCAP_APPLICATION) {
  port = process.env.PORT;
}

//run app on port
app.listen(port, function() {
  console.log('app running on port: %d', port);
});

app.post('/api/post', async function(req,res){
    var carID = req.body.carID;
    var make = req.body.make;
    var model = req.body.model;
    var color = req.body.color;
    var owner = req.body.owner;

  await invoke.invokeCreate(carID, make, model, color, owner).then((response) => {
    //return error if error in response
    if (response.status == 500) {
      res.status(500).send({ error: response.message });
    } else {
      //else return success
      res.status(200).send({ message: response.message });
    }
  }).catch(err => {
    console.log(err);
  });

});

这是invokeNetwork.js代码
'use strict';

var Fabric_Client = require('fabric-client');
var path = require('path');
var util = require('util');
var os = require('os');
var fs = require('fs');

var isError = false;
var throwError = "";

//make sure we have the profiles we need
var networkConfig = path.join(__dirname, './config/network-profile.json')
var clientConfig = path.join(__dirname, './config/client-profile.json');

module.exports = {

invokeCreate: async function(carID, make, model, color, owner) {

  isError = false;

//try {

  checkProfilesExist(networkConfig, clientConfig); //terminates early if they are not found

// load the base network profile
var fabric_client = Fabric_Client.loadFromConfig(path.join(__dirname, './config/network-profile.json'));

// overlay the client profile over the network profile
fabric_client.loadFromConfig(path.join(__dirname, './config/client-profile.json'));

// setup the fabric network - get the channel that was loaded from the network profile
var channel = fabric_client.getChannel('defaultchannel');
var tx_id = null;

//load the user who is going to unteract with the network
fabric_client.initCredentialStores().then(() => {
  // get the enrolled user from persistence, this user will sign all requests
  return fabric_client.getUserContext('user1', true);
}).then((user_from_store) => {
  if (user_from_store && user_from_store.isEnrolled()) {
    console.log('Successfully loaded user1 from persistence');

  } else {
    throw new Error('Failed to get user1.... run registerUserNetwork.js');
  }

  // get a transaction id object based on the current user assigned to fabric client
  tx_id = fabric_client.newTransactionID();
  console.log("Assigning transaction_id: ", tx_id._transaction_id);

  // createCar chaincode function - requires 5 args, ex: args: ['CAR11', 'Honda', 'Accord', 'Black', 'Dave'],
  // changeCarOwner chaincode function - requires 2 args , ex: args: ['CAR11', 'MGK'],
    var request = {
        chaincodeId: 'fabcar',
        fcn: 'createCar',
        args: [carID, make, model, color, owner],
        txId: tx_id
  };

  // send the transaction proposal to the endorsing peers
  return channel.sendTransactionProposal(request);
}).then((results) => {
  var proposalResponses = results[0];
  var proposal = results[1];
  let isProposalGood = false;
  if (proposalResponses && proposalResponses[0].response &&
    proposalResponses[0].response.status === 200) {
    isProposalGood = true;
    console.log('Transaction proposal was good');
  } else {
    console.error('Transaction proposal was bad');

  }
  if (isProposalGood) {
    console.log(util.format(
      'Successfully sent Proposal and received ProposalResponse: Status - %s, message - "%s"',
      proposalResponses[0].response.status, proposalResponses[0].response.message));

    // build up the request for the orderer to have the transaction committed
    var request = {
      proposalResponses: proposalResponses,
      proposal: proposal
    };

    // set the transaction listener and set a timeout of 30 sec
    // if the transaction did not get committed within the timeout period,
    // report a TIMEOUT status
    var transaction_id_string = tx_id.getTransactionID(); //Get the transaction ID string to be used by the event processing
    var promises = [];

    var sendPromise = channel.sendTransaction(request);
    promises.push(sendPromise); //we want the send transaction first, so that we know where to check status

    // get an eventhub once the fabric client has a user assigned. The user
    // is required bacause the event registration must be signed
    console.error('Getting event hub');
    let event_hub = fabric_client.getEventHub('org1-peer1');

    // using resolve the promise so that result status may be processed
    // under the then clause rather than having the catch clause process
    // the status
    let txPromise = new Promise((resolve, reject) => {
      let handle = setTimeout(() => {
        event_hub.disconnect();
        resolve({ event_status: 'TIMEOUT' }); //we could use reject(new Error('Trnasaction did not complete within 30 seconds'));
      }, 3000);
      event_hub.connect();
      event_hub.registerTxEvent(transaction_id_string, (tx, code) => {
        // this is the callback for transaction event status
        // first some clean up of event listener
        clearTimeout(handle);
        event_hub.unregisterTxEvent(transaction_id_string);
        event_hub.disconnect();

        // now let the application know what happened
        var return_status = { event_status: code, tx_id: transaction_id_string };
        if (code !== 'VALID') {
          console.error('The transaction was invalid, code = ' + code);
          resolve(return_status); // we could use reject(new Error('Problem with the tranaction, event status ::'+code));
        } else {
          console.log('The transaction has been committed on peer ' + event_hub._ep._endpoint.addr);
          resolve(return_status);
        }
      }, (err) => {
        //this is the callback if something goes wrong with the event registration or processing
        reject(new Error('There was a problem with the eventhub ::' + err));
        throwError += err;
      });
    });
    promises.push(txPromise);

    return Promise.all(promises);
  } else {
    console.error('Failed to send Proposal or receive valid response. Response null or status is not 200. exiting...');
    throw new Error('Failed to send Proposal or receive valid response. Response null or status is not 200. exiting...');
  }
}).then((results) => {
  console.log('Send transaction promise and event listener promise have completed');
  // check the results in the order the promises were added to the promise all list
  if (results && results[0] && results[0].status === 'SUCCESS') {
    console.log('Successfully sent transaction to the orderer.');
  } else {
    console.error('Failed to order the transaction. Error code: ' + response.status);
    throw new exception("Transaction");
  }

  if (results && results[1] && results[1].event_status === 'VALID') {
    console.log('Successfully committed the change to the ledger by the peer');
    return true;
  } else {
    console.log('Transaction failed to be committed to the ledger due to ::' + results[1].event_status);
  }
}).catch((err) => {
  console.error('Failed to invoke successfully :: ' + err);
  isError = true;
  throwError += err;
});

console.log(isError);

return {
  message: (isError) ? throwError : 'Success Transaction'
}

function checkProfilesExist(networkConfig, clientConfig) {
  if (!fs.existsSync(networkConfig)) {
    console.log("Error: config file 'network-profile.json' not found.");
    console.log("Make sure 'network-profile.json' is copied into the './config' folder.");
    process.exit()
  }

  //make sure we have the client profile we need

  if (!fs.existsSync(clientConfig)) {
    console.log("Error: config file 'client-profile.json' not found.");
    console.log("Make sure 'client-profile.json' is copied into the './config' folder.");
    process.exit()
  }
}

}

}
//throw new exception("Exceoption thrown");
//return true;
// }
//   catch(err) {
//     //print and return error
//     console.log(err);
//     var error = {};
//     error.error = err.message;
//     return error;
//     }
//   }
// }

最佳答案

因此,我们一直在研究 Fabric ,并尝试测试一些性能。我遇到过与您处理的所有相同问题,因此将解释我们的问题,并希望它们能为您提供帮助。
Eventhub关闭Error: There was a problem with the eventhub ::Error: EventHub has been shutdown问题
请注意,这在我们发送大量交易时会出现,在我们使用狡猾的Internet连接时也会出现。 fabric docs state:

我认为问题是eventhub尝试连接到我们的API,但是在连接方面存在问题。然后,这会导致eventhub超时(因为它没有收到响应),这将导致eventhub关闭。
解决方案
同样,fabric docs建议:

  • 在块级别上进行监听,因此,即使您错过了一个块,也可以获取旧块(更多信息,请参见上方的fabs链接)
  • 建立自己的队列

  • 查看此pastebin以获取基本的块监听器-> https://pastebin.com/wCd6Ni46
    错误:14无法使用
    问题
    我们注意到,当我们开始发送大量交易时,我们还会遇到一个错误:14 Unavailable,但这确实是在大量交易淹没网络之后。
    我认为我们可以批量使用20个,但是当我们连续快速发送50个或更多时,它就无法处理。
    请记住,至少在IBP启动程序添加时,块限制为每个块10个事务,因此在处理下一组事务之前,它需要等待其被挖掘。在此过程中,我认为缓冲区已满,然后您无法发送太多。
    因此,您的两个错误是订购者被淹没或同行被太多事务淹没。
    解决方案
    将交易分批处理,然后等待确认交易,然后再发送其他交易。这为您的同辈和订购者提供了一些喘息的空间。
    希望这会有所帮助!

    关于node.js - Hyperledger Fabric Nodejs SDK Eventhub已关闭,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/52773529/

    10-09 07:07