带有Express.js的SOAP服务器

Question

我使用节点肥皂创建了一个简单的SOAP服务器，该服务器当前正在处理来自SOAP客户端的请求。现在的要求是将来服务于来自不同客户端的传入REST和SOAP请求。我的问题是我可以通过使用一个Express应用程序（使用Express.js框架）来实现吗？我对此并不陌生，因此不胜感激。提前致谢！

Answer 1

我认为prasun已经给出了很好的例子，但想更详细地分享我的观点。我使用express和soap，但是使用http / https来创建服务器，而不是使用express

首先，下面是项目结构，我将RESTful端点路由器的模块化路由文件夹和Soap WebService端点的服务文件夹模块化

/config/index.js    
/routes/index.js
/services/wsdl/poservice.wsdl
/services/poservice.js
app.js
server.js

通过express创建路由器，并为根（'/'）上下文路径的GET请求构建端点

[routers / index.js]

var express = require('express');
var router = express.Router();

router.get('/', function(req, res, next) {
  res.setHeader('Content-Type', 'application/json');
  res.send(JSON.stringify({"data": "some data"}));
});

module.exports = router;

在app.js上构建主路由图

[app.js]

var express = require('express');
var bodyParser = require('body-parser');
var indexRouter = require('./routes/index');

var app = express();
app.use(bodyParser.raw({type: function(){return true;}, limit: '5mb'}));

app.use('/', indexRouter);
module.exports = app;

设置服务，端口和操作对象，并从文件路径（./services/wsdl/PurchaseOrderServiceV2.wsdl）发布wsdl

[services / poservice.js]

var fs = require('fs');
var path = require('path');
var poServiceXml = fs.readFileSync(path.join(path.join(__dirname, 'wsdl'), 'PurchaseOrderServiceV2.wsdl'), 'utf8');

var poService = {
  PurchaseOrderService: {
      PurchaseOrderServiceSoapHttpPort: {
          getPurchaseOrder: function(args) {
              console.log(args);
              return {
                  name: args.name
              };
          }
      }
   }
};

module.exports = {
  service: poService,
  xml: poServiceXml
};

此服务，端口和操作设置基于wsdl。下面是wsdl服务，端口和操作定义的摘要

[services / wsdl / PurchaseOrderServiceV2.wsdl]

<wsdl:operation name="getPurchaseOrder">
  <wsdl:input message="tns:PurchaseOrderService_getPurchaseOrder"/>
  <wsdl:output message="tns:PurchaseOrderService_getPurchaseOrderResponse"/>
  <wsdl:fault name="ServiceException" message="errors:ServiceException"/>
</wsdl:operation>
             :

<wsdl:service name="PurchaseOrderService">
  <wsdl:port name="PurchaseOrderServiceSoapHttpPort" binding="tns:PurchaseOrderServiceSoapHttp">
    <soap:address location="https://efqf-test.prc.us6.oraclecloud.com:443/prcPoEditDocumentOrder/PurchaseOrderServiceV2"/>
             :

现在创建服务器并运行RESTful和Soap端点

[server.js]

var fs = require('fs');
var config = require('./config');
var app = require('./app');
var debug = require('debug')('po-service:server');
var http = require('http');
var https = require('https');
var soap = require('soap');
const poService = require('./services/poservice');

/**
 * Get port from environment and store in Express.
 */

var port = normalizePort(process.env.PORT || config.get('app.port'));
app.set('port', port);

/**
 * Create HTTP server or HTTPS server
 */
var server = http.createServer(app);
if(config.get('app.https')) {
  server = https.createServer({
    key: fs.readFileSync(config.get('app.serverkey')),
    cert: fs.readFileSync(config.get('app.servercert'))
  }, app);
}

/**
 * Listen on provided port, on all network interfaces.
 */
function startServer() {
  server.listen(port);
  server.on('error', onError);
  server.on('listening', onListening);
  soap.listen(server, '/prcPoEditDocumentOrder/PurchaseOrderServiceV2', poService.service, poService.xml);
}

if(!module.parent) {
  // Start server if file is run directly
  startServer();
} else {
  // Export server, if file is referenced via cluster
  module.exports = startServer;
}

/**
 * Normalize a port into a number, string, or false.
 */
function normalizePort(val) {
  var port = parseInt(val, 10);

  if (isNaN(port)) {
    // named pipe
    return val;
  }
  if (port >= 0) {
    // port number
    return port;
  }
  return false;
}

/**
 * Event listener for HTTP server "error" event.
 */

function onError(error) {
  if (error.syscall !== 'listen') {
    throw error;
  }

  var bind = typeof port === 'string'
  ? 'Pipe ' + port
  : 'Port ' + port;

  // handle specific listen errors with friendly messages
  switch (error.code) {
    case 'EACCES':
      console.error(bind + ' requires elevated privileges');
      process.exit(1);
      break;
    case 'EADDRINUSE':
      console.error(bind + ' is already in use');
      process.exit(1);
      break;
    default:
      throw error;
  }
}

/**
 * Event listener for HTTP server "listening" event.
 */

function onListening() {
  var addr = server.address();
  var bind = typeof addr === 'string'
      ? 'pipe ' + addr
      : 'port ' + addr.port;
  debug('Listening on ' + bind);
}

对于配置，我有配置模块

[config / index.js]

var PropertiesReader = require('properties-reader');
var config = new PropertiesReader('app.properties');

module.exports = config;

下面是配置文件

[app.properties]

[app]
hostname = localhost
port = 8080
https = false
serverkey = /path/to/signed.key
servercert = /path/to/signed.crt

现在验证RESTful端点

$ curl http://localhost:8080/
{"data":"some data"}

通过高级REST客户端验证Soap端点

或通过SoapUI

可以通过浏览器检索发布的wsdl支票