passThrough.js 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142
  1. // 透明传输
  2. // let logger = require('../util/log4js').logger('passThrough');
  3. let request = require('request'); // 发送http请求
  4. let Config = require('../conf/index');
  5. module.exports = {
  6. // k8s server
  7. server: function(req, res, next) {
  8. let path = req.path.slice(4); // 例 /api/v1/* => /v1/*
  9. request({
  10. url: Config.network.serverHost + path,
  11. method: req.method,
  12. json: true,
  13. body: req.body
  14. }, (error, response, data) => {
  15. }).pipe(res);
  16. },
  17. server2: function(req, res, next) {
  18. let path = req.path.slice(7); // 例 /api/s2/v1/* => /v1/*
  19. request({
  20. url: Config.network.serverHost2 + path,
  21. method: req.method,
  22. json: true,
  23. body: req.body
  24. }, (error, response, data) => {
  25. }).pipe(res);
  26. },
  27. server3: function(req, res, next) {
  28. let path = req.path.slice(7); // 例 /api/s3/v1/* => /v1/*
  29. request({
  30. url: Config.network.serverHost3 + path,
  31. method: req.method,
  32. json: true,
  33. body: req.body
  34. }, (error, response, data) => {
  35. }).pipe(res);
  36. },
  37. }