1

我想使用 WSO2 ESB 从网站下载 XML 文件。为简单起见,假设 URL 是静态的。

我尝试过将 VFS 作为代理服务和单独的序列都没有成功,并且在 Internet 上找不到任何相关材料。

这是序列 XML:

<sequence xmlns="http://ws.apache.org/ns/synapse" name="download">
   <in>
      <log level="headers">
         <property name="?" value="[download] in: started"/>
      </log>
      <property name="OUT_ONLY" value="true" scope="default" type="STRING"/>
      <property name="transport.vfs.ContentType" value="text/xml" scope="transport" type="STRING"/>
      <property name="transport.vfs.FileURI" value="http://static.nvd.nist.gov/feeds/xml/cve/nvdcve-2.0-2013.xml" scope="transport" type="STRING"/>
      <log level="headers">
         <property name="?" value="[download] in: sending over vfs"/>
      </log>
      <send>
         <endpoint>
            <address uri="http://static.nvd.nist.gov/feeds/xml/cve/nvdcve-2.0-2013.xml"/>
         </endpoint>
      </send>
      <log level="headers">
         <property name="?" value="[download] in: ended"/>
      </log>
   </in>
   <out>
      <log level="headers">
         <property name="?" value="[download] out: started"/>
      </log>
      <send/>
      <log level="headers">
         <property name="?" value="[download] out: ended"/>
      </log>
   </out>
</sequence>

那么,如何使用 WSO2 ESB 通过 HTTP下载大文件?

4

2 回答 2

2

我有一个类似的问题,现在我已经用 API 和这段代码解决了它:

<api xmlns="http://ws.apache.org/ns/synapse" name="EcoRest" context="/services/ecorest">
   <resource methods="GET" uri-template="/{idFile}">
      <inSequence>
         <send>
            <endpoint>
               <http method="get" uri-template="http://slx00012001:8888/repositoryfiles/{uri.var.idFile}">
                  <suspendOnFailure>
                     <errorCodes>101500,101510,101001,101000</errorCodes>
                     <initialDuration>10</initialDuration>
                     <progressionFactor>1.0</progressionFactor>
                     <maximumDuration>10</maximumDuration>
                  </suspendOnFailure>
               </http>
            </endpoint>
         </send>
         <property name="enableSwA" value="true" scope="axis2"></property>
      </inSequence>
      <faultSequence>
         <log level="custom">
            <property name="FAULT GETTING FILE" expression="get-property('uri.var.idFile')"></property>
         </log>
         <payloadFactory media-type="json">
            <format>           {"descError":"$1", "error": "true"}           </format>
            <args>
               <arg evaluator="json" expression="$.descError"></arg>
            </args>
         </payloadFactory>
         <property name="HTTP_SC" value="500" scope="axis2" type="STRING"></property>
         <respond></respond>
      </faultSequence>
   </resource>
</api>

这个 API 可以完美运行,并且可以对文件进行直通。但是如果我发送一个不存在的id_file,后端服务返回一个带有json-message的http 400,进程进入faultsequence,但是faultsequence中的payloadFactory不起作用,我不知道为什么: (

于 2015-06-23T14:42:05.457 回答
0

试试这个配置:

<proxy xmlns="http://ws.apache.org/ns/synapse" name="download" transports="https,http,vfs" statistics="disable" trace="disable" startOnLoad="true">
   <target>
      <inSequence>
         <property name="OUT_ONLY" value="true" scope="default" type="STRING"/>
         <property name="ClientApiNonBlocking" value="true" scope="axis2" action="remove"/>
         <send>
            <endpoint>
               <address uri="vfs:file://home/secondary/file.xml"/>
            </endpoint>
         </send>
      </inSequence>
   </target>
   <parameter name="transport.vfs.Streaming">true</parameter>
   <parameter name="transport.vfs.FileURI">http://static.nvd.nist.gov/feeds/xml/cve/nvdcve-2.0-2013.xml</parameter>
   <parameter name="transport.vfs.Locking">disable</parameter>
   <description></description>
</proxy>

您可以使用以下方式启动下载:

curl -v http://localhost:8280/services/download

您可以在此处找到有关 VFS 传输特定参数的更多信息:http: //docs.wso2.org/wiki/display/ESB460/VFS+Transport。您还可以在此处找到另一个 VFS 示例:http: //docs.wso2.org/wiki/pages/viewpage.action?pageId= 16846489。希望这可以帮助。

于 2013-04-29T17:16:44.097 回答