WSO2 ESB并发线程vfs-worker

Question

我是WSO2和Apache Synapse的新手，我做了一个代理服务将一些文件路由到另一个文件夹，但是当我查看JConsole时，只有1个线程在工作。

我如何配置设置，使多个线程工作，并在同一时间处理同一个源文件夹?我这样配置线程池:

-Dsnd_t_core=3 
-Dsnd_t_max=5000 
-Dsnd_qlen=-1 

我的代理服务是这样的:

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://ws.apache.org/ns/synapse">
   <registry provider="org.wso2.carbon.mediation.registry.WSO2Registry">
      <parameter name="cachableDuration">15000</parameter>
   </registry>
   <proxy name="Service1"
          transports="vfs"
          startOnLoad="true"
          trace="enable"
          statistics="enable">
      <description/>
      <target>
         <inSequence>
            <log level="custom">
               <property name="Message" value="Routing start"/>
               <property name="filename"
                         expression="fn:concat(get-property('transport', 'FILE_NAME'), '.xml')"/>
            </log>
         </inSequence>
         <outSequence>
            <property name="OUT_ONLY" value="true"/>
         </outSequence>
      </target>
      <parameter name="transport.vfs.Streaming">false</parameter>
      <parameter name="transport.vfs.ActionAfterProcess">MOVE</parameter>
      <parameter name="transport.PollInterval">1</parameter>
      <parameter name="transport.vfs.FileURI">file:///home/user/test/target2</parameter>
      <parameter name="transport.vfs.MoveAfterProcess">file:///home/user/test/target</parameter>
      <parameter name="transport.vfs.MoveAfterFailure">file:///home/user/test/failure</parameter>
      <parameter name="transport.vfs.Locking">disable</parameter>
      <parameter name="transport.vfs.FileNamePattern">.*.*</parameter>
      <parameter name="transport.vfs.ContentType">text/plain</parameter>
      <parameter name="transport.vfs.ActionAfterFailure">MOVE</parameter>
   </proxy>
   <sequence name="fault">
      <log>
         <property name="MESSAGE" value="Executing default &#34;fault&#34; sequence"/>
         <property name="ERROR_CODE" expression="get-property('ERROR_CODE')"/>
         <property name="ERROR_MESSAGE" expression="get-property('ERROR_MESSAGE')"/>
      </log>
      <drop/>
   </sequence>
   <sequence name="main">
      <in>
         <filter source="get-property('To')" regex="http://localhost:9000.*">
            <send/>
         </filter>
      </in>
      <out>
         <send/>
      </out>
      <description>The main sequence for the message mediation</description>
   </sequence>
</definitions>

Answer 1

正如我从你的问题中理解的那样，你要做的是并行服务相同的消息，并将它们存储在并行执行的文件中。

如果是这样，实现这一点的方法是使用克隆中介。克隆中介将消息拆分为多个相同的消息，这些消息将并行处理

您可以通过[1]参考克隆中介文档。

根据您的场景，您可以使用迭代中介来按照父消息中的文件名进行迭代，迭代中介的样本可以在[2]中找到，并在[3]中找到样本

[1]。http://docs.wso2.org/wiki/display/ESB460/Clone +中介

[2] .北京://docs.wso2.org/wiki/display/ESB460/Sample + 400% +信息+ 3分+和+聚合+ +反应

[3] .北京://docs.wso2.org/wiki/display/ESB460/Iterate +中介

谢谢你,Dharshana .