urlopen 模块

var urlopen = require('urlopen');

var options = {
            target: 'http://example.com/mydoc.json',
            method: 'post',
           headers: { 'X-My-Header1' : 'value1' , 'X-My-Header2' : 'value2' },
       contentType: 'text/plain',
           timeout: 60,
  sslClientProfile: 'aliceProxyForwardTrusted',
              data: "Hello DataPower GatewayScript"};

urlopen.open(options, function(error, response) {
  if (error) {
    // an error occurred during the request sending or response header parsing
    session.output.write("urlopen error: "+JSON.stringify(error));
  } else {
    // get the response status code
    var responseStatusCode = response.statusCode;
    var responseReasonPhrase = response.reasonPhrase;
    console.log("Response status code: " + responseStatusCode);
    console.log("Response reason phrase: " + responseReasonPhrase);
    // reading response data
    response.readAsBuffer(function(error, responseData){
      if (error){
        throw error ;
      } else {
        session.output.write(responseData) ;
      }
    });
  }
});

var urlopen = require(’urlopen’);
// define the http-specific user agent properties
var ua_options = {    
    'persistentConnection': true,
    'allowCompression': false,
    'followRedirect': true,
    'maxRedirects': 8,
    'http10Only': false,
    'rewriteHost': false
};
var HttpUserAgent = new urlopen.HttpUserAgent(ua_options);
// define the urlopen options
var options = {
    target: 'http://127.0.0.1:42410/echo',
    //If the target is HTTPS like 'https://127.0.0.1:42409/echo', supply a TLS client profile
    //sslClientProfile: 'aliceClientProfile'
    method: 'post',    
    headers: { 'X-My-Header1' : 'value1', 'X-My-Header2': 'value2' },
    contentType: 'application/json',
    timeout: 60,    
    data: "Hello DataPower GatewayScript",
    agent: HttpUserAgent
};
urlopen.open(options, function(error, response) {
  if (error) {
    // an error occurred during the request sending or response header parsing
    session.output.write("urlopen error: "+JSON.stringify(error));
  } else {
    // get the response status code
    var responseStatusCode = response.statusCode;
    var responseReasonPhrase = response.reasonPhrase;
    console.log("Response status code: " + responseStatusCode);
    console.log("Response reason phrase: " + responseReasonPhrase);
    // reading response data
    response.readAsBuffer(function(error, responseData){
      if (error){
        throw error ;
      } else {
        session.output.write(responseData) ;
      }
    });
  }
});

var urlopen = require('urlopen');
urlopen.open("local:///mylocal_directory/mylocal_file.xml", function (error, response) {
  if (error) {
    session.output.write("openCallback error: " + error.errorMessage+"\n");
  }
  else {
    if (response.statusCode == 200) {
      // You have a 200, so you can read the file
      response.readAsBuffer (function (error, data) {
        session.output.write(data);
      });
    }
  }
});

var urlopen = require('urlopen');
urlopen.open("local:///nonexisting.txt", function (error, response) {
  if (error) {
    session.output.write("openCallback error: " + error.errorMessage+"\n");
  }
  else {
    if (response.statusCode != 200) {
      // in this case, a non-200 statusCode indicates a problem reading the file
      session.output.write("Unable to open the file, statusCode: " +
                            response.statusCode + ", reasonPhrase: " +
                            response.reasonPhrase);
      response.disconnect();   // Optional: You can call response.disconnect()
                               // to do an explicit disconnection. Without this
                               // call, urlopen does an implicit disconnection
    }
    else {
      response.readAsBuffer(function(readError, data) {
        if (readError) {
          session.output.write("read file error: " + readError.toString());
        }
        else {
          session.output.write(data);
        }
      });
    }
  }
});

var urlopen = require('urlopen');
var open_options = {
  // the target URL
  target: 'local:///mylocal_directory/mylocal_file.xml',
  // method is optional, default is GET
  method: 'GET'
};

urlopen.open(open_options, function (error, response) {
  if (error) {
    session.output.write("openCallback error: " + error.errorMessage+"\n");
  }
  else {
    if (response.statusCode != 200) {
      // in this case, a non-200 statusCode indicates a problem reading the file
      session.output.write("Unable to open the file, statusCode: " +
                            response.statusCode + ", reasonPhrase: " +
                            response.reasonPhrase);
      response.disconnect(); // optional, urlopen will do an implicit disconnect()
    }
    else {
      response.readAsBuffer(function(readError, data) {
        if (readError) {
          session.output.write("read file error: " + readError.toString());
        }
        else {
          session.output.write(data);
        }
      });
    }
  }
});

var urlopen = require ('urlopen');
var putData = '<MQRequest>Hello World</MQRequest>'; 

var options =
{
    target: 'mq://192.0.2.0:1414?QueueManager=QM1;UserName=mqm;Channel=QM1.SVRCONN;ChannelTimeout=10;'
              + 'channelLimit=100;Size=1024000;RequestQueue=queue1;ReplyQueue=queue2',
  
     data : putData,
  headers : { MQMD   : { // JSON object for specified header_name
                            MQMD: { // JSON object for the MQMD header
                                   StructId : { $ : 'MD' } ,
                                    Version : { $ : '1'} ,
                                  }
                        } 
              }
};

urlopen.open (options, function (error, response) {} );

var urlopen = require('urlopen');
var putData = '<MQRequest>Hello World</MQRequest>'; 

var urlopenHeaders = {
        // supply an MQMD header
        MQMD : {     // This MQMD is the header name.
                MQMD: {  // JSON object for the MQMD header
              StructId : { $ : 'MD' },
               Version : { $ : '1' },
                Format : { $ : 'MQHRF2' },
                MsgType : { $ : '1' },
           ReplyToQMgr : { $ : session.parameters.qm },
              ReplyToQ : { $ : session.parameters.replyQ },
                Expiry : { $ : '10000' },
           Persistence : { $ : '1' },
              Priority : { $ : '10' },
           PutApplType : { $ : '6' },
           PutApplName : { $ : 'My Datapower IBM MQClient' }, 
        ApplOriginData : { $ : 'testUrlOpenMPGW' },
      ApplIdentityData : { $ : 'mqUrlOpenDemo.js' } }
               },
         // supply an MQRFH2 header
         MQRFH2 : { 
           MQRFH2: {
                 Format: { $ : 'MQSTR' },
          NameValueData: {
                   NameValue: [
                                { mcd : { property1 : { $ : '1111' } } },
                                { jms : { property2 : { '@dt': 'string', $ : 'value2'} } },
                                { usr : { group : {
                                             property3 : { $ : 'value3' },
                                             property4 : { $ : 'value4'} } } }
                              ] }
               }
         }
 };

  var options = {
                     target : 'idgmq://' + session.parameters.qm + '/?RequestQueue='
                         + session.parameters.requestQ,
                   headers : urlopenHeaders,
                    data : putData,
           replyQueue : session.parameters.replyQ,
                  pmo : 2052  // MQPMO_NO_SYNCPOINT (4) + MQPMO_SET_ALL_CONTEXT (2048) };

 try {
       urlopen.open(options, function(connectError, response) {
             if (connectError) {    
                   var errorMessage = connectError + 'errorCode='
                                        + connectError.errorCode.toString(16);
                   console.error(errorMessage);
                   session.output.write(errorMessage);

              } else {
                   var responseCode = response.statusCode; 
                   if (responseCode == 0) {
                         console.info('Received MQ ' + response.statusCode
                                       + ' for target ' + options.target); 
                         response.readAsXML(function(readAsXMLError, xmlDom) {
                              if (readAsXMLError) {
                                  var errorMessage = 'Error on readAsXML: ' + readAsXMLError;
                                  console.error(errorMessage);
                                  response.readAsBuffer(function(readAsBufferError, buffer) {
                                       if (readAsBufferError) { 
                                             var errorMessage = 'Error on readAsBuffer: '
                                                                 + readAsBufferError;
                                             console.error(errorMessage);
                                             session.output.write(errorMessage);
                                       } else {
                                             console.info('MQ Response headers: ' + response.headers);
                                             session.output.write(buffer);
                                       }
                            });
                    } else { 
                        console.info('MQ Response headers: ' + response.headers);
                        session.output.write(xmlDom);
                    }
               });
           } else {
              var errorMessage = 'Received MQ ' + response.statusCode
                                + ' for target ' + options.target;
              session.reject(errorMessage);
           }
        }
    }); 
} catch (err) {
     var errorMessage = 'Thrown error on urlopen.open for target ' + options.target + ': '
                         + err.message + ', error object errorCode=' + err.errorCode.toString(16);
     session.reject(errorMessage);}

var urlopenMQMPHeaders = {
        // supply an MQMD header
        MQMD : {    // The property name 'MQMD' is the header name.
                MQMD: {   // This 'MQMD' represents the root property.
                          StructId : { $ : 'MD' },
                           Version : { $ : '2' },
                            Format : { $ : 'MQSTR' },
                           MsgType : { $ : '1' },
                       ReplyToQMgr : { $ : session.parameters.qm },
                          ReplyToQ : { $ : session.parameters.replyQ },
                            Expiry : { $ : '10000' },
                       Persistence : { $ : '1' },
                          Priority : { $ : '10' },
                       PutApplType : { $ : '6' },
                       PutApplName : { $ : 'My Datapower IBM MQClient' },
                    ApplOriginData : { $ : 'testUrlOpenMPGW' },
                  ApplIdentityData : { $ : 'testUrlOpen.js' }
                      }
               },
        // supply an MQMP header
        MQMP : {   // The property name 'MQMP' is the header name.
                   MQMP: { // This 'MQMP' represents the root property.
                                 Property : [ // an array of property
                                         { '@name' : 'car.brand', '@type':'string', $ : 'DataPower'},
                                         { '@name' : 'car.color', '@type':'string', $ : 'GREEN'},
                                         { '@name' : 'car.year', '@type':'int32', $ : '2005' }
                                            ]
                         }
               }
};
options = {
    target: 'idgmq://' + session.parameters.qm + '/?RequestQueue=GATEWAYSCRIPT.PROPERTIES.REQUEST' 
                      + ';ReplyQueue=' + session.parameters.replyQ,
   headers: urlopenMQMPHeaders,
      data: putData,
       pmo: 2052  // MQPMO_NO_SYNCPOINT (4) + MQPMO_SET_ALL_CONTEXT (2048)};
};