NodeJs - Http请求

Get请求

//Get请求
const http = require('http');
// var qs = require('querystring');
//这是需要提交的数据
// var data = {
//   a: 123,
//   time: new Date().getTime()
// };
// var content = qs.stringify(data);

// path: '/import/v1/grooming-salons/38' + content,
const options = {
  hostname: '127.0.0.1',
  port: 7001,
  path: '/import/v1/grooming-salons/38',
  method: 'GET'
};
const req = http.request(options, function (res) {
  res.stat
  console.log('STATUS: ' + res.statusCode);
  console.log('HEADERS: ' + JSON.stringify(res.headers));
  res.setEncoding('utf8');
  res.on('data', function (chunk) {
    console.log('BODY: ' + chunk);
  });
});

req.on('error', function (e) {
  console.log('problem with request: ' + e.message);
});
req.end();

 

Post请求Http

          //Post请求
          const http = require('http');
          const qs = require('querystring');
          const content = qs.stringify(shop);
          const options = {
            hostname: '127.0.0.1',
            port: 7001,
            path: '/import/v1/grooming-salons',
            method: 'POST',
            headers: {
              'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8'
            }
          };

          let req = http.request(options, function (res) {
            // console.log('STATUS: ' + res.statusCode);
            // console.log('HEADERS: ' + JSON.stringify(res.headers));
            res.setEncoding('utf8');
            res.on('data', function (chunk) {
              // console.log('BODY: ' + chunk);
              if (res.statusCode != 200) {
                console.log('STATUS: ' + res.statusCode);
                console.log('BODY: ' + chunk);
                console.log('brandId: ' + shop.brandId);
              }
            });

            if (res.statusCode == 200) {
              successCount++;
            } else {
              failCount++;
            }

            console.log(`total - successCount: ${successCount}, failCount: ${failCount}, brandId: ${shop.brandId}`);
            console.log("--------");
          });

          req.on('error', function (e) {
            failCount++;
            console.log(`total - err - successCount: ${successCount}, failCount: ${failCount}`);
            console.log('problem with request: ' + e.message);
          });

          // write data to request body
          req.write(content);
          req.end();
        });

 

 

POST请求HTTPS

//Post请求
          const http = require('https');
          const qs = require('querystring');
          const content = qs.stringify(shop);
          const options = {
            hostname: 'api-dev.nga-x.com',
            port: 443,
            path: '/pet-service/import/v1/grooming-salons/',
            method: 'POST',
            headers: {
              "Accept": "*/*",
              'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',
              'import-key': 'hY*<t/D<khbW~'
            }
          };

          let req = http.request(options, function (res) {
            console.log('STATUS: ' + res.statusCode);
            // console.log('HEADERS: ' + JSON.stringify(res.headers));
            res.setEncoding('utf8');
            res.on('data', function (chunk) {
              // console.log('BODY: ' + chunk);
              if (res.statusCode != 200) {
                console.log('STATUS: ' + res.statusCode);
                console.log('BODY: ' + chunk);
                console.log('brandId: ' + shop.brandId);
              }
            });

            if (res.statusCode == 200) {
              successCount++;
            } else {
              failCount++;
            }

            console.log(`total - successCount: ${successCount}, failCount: ${failCount}, brandId: ${shop.brandId}`);
            console.log("--------");
          });

          req.on('error', function (e) {
            failCount++;
            console.log(`total - err - successCount: ${successCount}, failCount: ${failCount}`);
            console.log('problem with request: ' + e.message);
          });

          // write data to request body
          req.write(content);
          req.end();

 

 

 

循环内调用Http请求

try {

        data.map(d => {
          const obj: ShopData = JSON.parse(d);
          const shop = new CreateAdminGroomingSalonRequest;
          shop.storeType = 1;
          shop.name = obj.info.shopInfo.shopName;
          shop.cover = obj.info.petImageList.length == 0 ? ["http://nga.com", "http://nga.com"] : obj.info.petImageList;
          shop.score = 0;
          shop.perCapita = 0;
          if (obj.info.shopInfo.area) {
            shop.areaLevel1 = obj.info.shopInfo.area.split(' ＞ ')[0];
            shop.areaLevel2 = obj.info.shopInfo.area.split(' ＞ ')[0] + " ＞ " + obj.info.shopInfo.area.split(' ')[1];
            shop.address = obj.info.shopInfo.area;
          } else {
            if (obj.info.shopInfo.address) {
              shop.areaLevel1 = obj.info.shopInfo.address.split(' ')[0];
              shop.areaLevel2 = obj.info.shopInfo.address.split(' ')[0] + " ＞ " + obj.info.shopInfo.address.split(' ')[1];
              shop.address = obj.info.shopInfo.address;
            } else {
              shop.areaLevel1 = "0"
              shop.areaLevel2 = "0"
              shop.address = "0";
            }
          }
          shop.workday = [1, 2, 3, 4, 5, 6, 7];
          if (obj.info.openTimeInfo.openTime) {
            shop.openingTime = obj.info.openTimeInfo.openTime.split(' ~ ')[0];
            shop.closingTime = obj.info.openTimeInfo.openTime.split(' ~ ')[1];
          } else {
            shop.openingTime = "00:00:00"
            shop.closingTime = "24:00:00";
          }
          shop.certificatePerson = obj.info.registerInfo.registerName ? obj.info.registerInfo.registerName : "0";
          shop.openingDate = obj.info.registerInfo.registeDate ? obj.info.registerInfo.registeDate.replace('年', '-').replace('月', '-').replace('日', '') : "1970-01-01";
          shop.areaSize = 0;
          shop.telephone = "0";
          shop.state = "open";
          shop.brandId = obj.id;

          //Post请求
          const http = require('https');
          const qs = require('querystring');
          const content = qs.stringify(shop);
          const options = {
            hostname: 'api-dev.nga-x.com',
            port: 443,
            path: '/pet-service/import/v1/grooming-salons/',
            method: 'POST',
            headers: {
              "Accept": "*/*",
              'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',
              'import-key': 'hY*<t/D<khbW~'
            }
          };

          let req = http.request(options, function (res) {
            console.log('STATUS: ' + res.statusCode);
            // console.log('HEADERS: ' + JSON.stringify(res.headers));
            res.setEncoding('utf8');
            res.on('data', function (chunk) {
              // console.log('BODY: ' + chunk);
              if (res.statusCode != 200) {
                console.log('STATUS: ' + res.statusCode);
                console.log('BODY: ' + chunk);
                console.log('brandId: ' + shop.brandId);
              }
            });

            if (res.statusCode == 200) {
              successCount++;
            } else {
              failCount++;
            }

            console.log(`total - successCount: ${successCount}, failCount: ${failCount}, brandId: ${shop.brandId}`);
            console.log("--------");
          });

          req.on('error', function (e) {
            failCount++;
            console.log(`total - err - successCount: ${successCount}, failCount: ${failCount}`);
            console.log('problem with request: ' + e.message);
          });

          // write data to request body
          req.write(content);
          req.end();