2

我听说 java 服务比使用流服务运行得更快。但是当我尝试将我的流服务更改为 java 服务时，我只得到了相同的处理时间。这是捕获：

Java 服务之前

使用 Java 服务后

这是我的java服务代码

try{

String dateTime = "";
String SCDataFound = "";
String  startDate = "";
String  endDate = "";
IData output = null;
IDataCursor outputCursor = null;
IData input = IDataFactory.create();
IDataCursor inputCursor = input.getCursor();
// pipeline
IDataCursor pipelineCursor = pipeline.getCursor();
        startDate = IDataUtil.getString( pipelineCursor, "startDate" );
        endDate = IDataUtil.getString( pipelineCursor, "endDate" );
pipelineCursor.destroy();

if(startDate==null&&endDate==null){
    DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
    Date date = new Date();
    String theDate = dateFormat.format(date);
    SCDataFound = "";
    dateTime = "and b.document_date ='" +theDate+"'";
}else{
    String startTimeClause = "and b.create_date>=to_date('"+startDate+"' 00:00:00','yyyyMMdd HH24:MI:SS')";
    String endTimeClause = "and b.create_date<=to_date('"+endDate+"' 23:59:59','yyyyMMdd HH24:MI:SS')";
    dateTime = startTimeClause.concat(endTimeClause); 
}

IDataUtil.put( inputCursor,  "dateTime", dateTime);
IDataUtil.put( inputCursor,  "procStatus", "('4', '1', '5')");
IDataUtil.put( inputCursor,  "providerCd", "c.provider_code='SPN02' and B.TRXTYPE='1' and");
IDataUtil.put( inputCursor,  "legStatus", "SC");
IDataUtil.put( inputCursor,  "tableResponse", "SPAN_HOST_SC_RESPONSE");
IDataUtil.put( inputCursor,  "addClause", "and b.BATCHID=d.BATCHID");
inputCursor.destroy();
output = wmDoInvoke("mandiri.span.db.service", "getSPANSummaries", input);

outputCursor = output.getCursor();
IData[] summariesDatas = IDataUtil.getIDataArray( outputCursor, "SPANSummaries" );
IData[] newSummariesDatas = new IData[summariesDatas.length];
outputCursor.destroy(); 
if ( summariesDatas != null)
    {
        for ( int i = 0; i < summariesDatas.length; i++ )
        {
            newSummariesDatas [i] = IDataFactory.create();
            IDataCursor newSummariesDatasCursor = newSummariesDatas[i].getCursor();
            IDataCursor summariesDatasCursor  = summariesDatas[i].getCursor();
            IDataUtil.put( newSummariesDatasCursor, "FILE_NAME",IDataUtil.getString( summariesDatasCursor, "FILE_NAME" ));
            IDataUtil.put( newSummariesDatasCursor, "RETRY_STATUS_L1", IDataUtil.getString( summariesDatasCursor, "RETRY_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor, "RETUR_STATUS", IDataUtil.getString( summariesDatasCursor, "RETUR_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor, "SUCCESS_STATUS_L1", IDataUtil.getString( summariesDatasCursor, "SUCCESS_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor, "TOTAL_AMOUNT", IDataUtil.getString( summariesDatasCursor, "TOTAL_AMOUNT" ) );
            IDataUtil.put( newSummariesDatasCursor, "TOTAL_RECORD", IDataUtil.getString( summariesDatasCursor, "TOTAL_RECORD" ) );
            IDataUtil.put( newSummariesDatasCursor, "PROC_STATUS", IDataUtil.getString( summariesDatasCursor, "PROC_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor, "BATCHID", IDataUtil.getString( summariesDatasCursor, "BATCHID" ) );
            IDataUtil.put( newSummariesDatasCursor, "UPDATE_DATE", IDataUtil.getString( summariesDatasCursor, "UPDATE_DATE" ) );
            IDataUtil.put( newSummariesDatasCursor, "CREATE_DATE", IDataUtil.getString( summariesDatasCursor, "CREATE_DATE" ) );
            IDataUtil.put( newSummariesDatasCursor, "TOTAL_PROCESS", IDataUtil.getString( summariesDatasCursor, "TOTAL_PROCESS" ) );
            IDataUtil.put( newSummariesDatasCursor, "FORCED_ACK", IDataUtil.getString( summariesDatasCursor, "FORCED_ACK" ) );
            IDataUtil.put( newSummariesDatasCursor, "LEGSTATUS", IDataUtil.getString( summariesDatasCursor, "LEGSTATUS" ) );
            IDataUtil.put( newSummariesDatasCursor, "DOCUMENT_DATE", IDataUtil.getString( summariesDatasCursor, "DOCUMENT_DATE" ) );
        }
}

IDataUtil.put( inputCursor,  "dateTime", dateTime);
IDataUtil.put( inputCursor,  "procStatus", "('4', '1', '5')");
IDataUtil.put( inputCursor,  "providerCd", "c.provider_code='SPN02' and B.TRXTYPE='1' and");
IDataUtil.put( inputCursor,  "legStatus", "SC");
IDataUtil.put( inputCursor,  "tableResponse", "SPAN_HOST_RESPONSE");
IDataUtil.put( inputCursor,  "addClause", "");
inputCursor.destroy();
output = wmDoInvoke("mandiri.span.db.service", "getSPANSummaries", input);
outputCursor = output.getCursor();
IData[] summariesDatas1 = IDataUtil.getIDataArray( outputCursor, "SPANSummaries" );
IData[] newSummariesDatas1 = new IData[summariesDatas1.length];
outputCursor.destroy(); 
if ( summariesDatas1 != null)
    {
        for ( int i = 0; i < summariesDatas1.length; i++ )
        {
            newSummariesDatas1 [i] = IDataFactory.create();
            IDataCursor newSummariesDatasCursor1 = newSummariesDatas1[i].getCursor();
            IDataCursor summariesDatasCursor1  = summariesDatas1[i].getCursor();
            IDataUtil.put( newSummariesDatasCursor1, "FILE_NAME",IDataUtil.getString( summariesDatasCursor1, "FILE_NAME" ));
            IDataUtil.put( newSummariesDatasCursor1, "RETRY_STATUS_L1", IDataUtil.getString( summariesDatasCursor1, "RETRY_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor1, "RETUR_STATUS", IDataUtil.getString( summariesDatasCursor1, "RETUR_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor1, "SUCCESS_STATUS_L1", IDataUtil.getString( summariesDatasCursor1, "SUCCESS_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor1, "TOTAL_AMOUNT", IDataUtil.getString( summariesDatasCursor1, "TOTAL_AMOUNT" ) );
            IDataUtil.put( newSummariesDatasCursor1, "TOTAL_RECORD", IDataUtil.getString( summariesDatasCursor1, "TOTAL_RECORD" ) );
            IDataUtil.put( newSummariesDatasCursor1, "PROC_STATUS", IDataUtil.getString( summariesDatasCursor1, "PROC_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor1, "BATCHID", IDataUtil.getString( summariesDatasCursor1, "BATCHID" ) );
            IDataUtil.put( newSummariesDatasCursor1, "UPDATE_DATE", IDataUtil.getString( summariesDatasCursor1, "UPDATE_DATE" ) );
            IDataUtil.put( newSummariesDatasCursor1, "CREATE_DATE", IDataUtil.getString( summariesDatasCursor1, "CREATE_DATE" ) );
            IDataUtil.put( newSummariesDatasCursor1, "TOTAL_PROCESS", IDataUtil.getString( summariesDatasCursor1, "TOTAL_PROCESS" ) );
            IDataUtil.put( newSummariesDatasCursor1, "FORCED_ACK", IDataUtil.getString( summariesDatasCursor1, "FORCED_ACK" ) );
            IDataUtil.put( newSummariesDatasCursor1, "LEGSTATUS", IDataUtil.getString( summariesDatasCursor1, "LEGSTATUS" ) );
            IDataUtil.put( newSummariesDatasCursor1, "DOCUMENT_DATE", IDataUtil.getString( summariesDatasCursor1, "DOCUMENT_DATE" ) );
        }
}

IDataUtil.put( inputCursor,  "dateTime", dateTime);
IDataUtil.put( inputCursor,  "procStatus", "('4', '1', '5')");
IDataUtil.put( inputCursor,  "providerCd", "c.provider_code='SPN02' and B.TRXTYPE='1' and");
IDataUtil.put( inputCursor,  "legStatus", "L2");
IDataUtil.put( inputCursor,  "tableResponse", "SPAN_HOST_RESPONSE");
IDataUtil.put( inputCursor,  "addClause", "");
inputCursor.destroy();
output = wmDoInvoke("mandiri.span.db.service", "getSPANSummaries", input);
outputCursor = output.getCursor();
IData[] summariesDatas2 = IDataUtil.getIDataArray( outputCursor, "SPANSummaries" );
IData[] newSummariesDatas2 = new IData[summariesDatas2.length];
outputCursor.destroy(); 
if ( summariesDatas2 != null)
    {
        for ( int i = 0; i < summariesDatas2.length; i++ )
        {
            newSummariesDatas2 [i] = IDataFactory.create();
            IDataCursor newSummariesDatasCursor2 = newSummariesDatas2[i].getCursor();
            IDataCursor summariesDatasCursor2  = summariesDatas2[i].getCursor();
            IDataUtil.put( newSummariesDatasCursor2, "FILE_NAME",IDataUtil.getString( summariesDatasCursor2, "FILE_NAME" ));
            IDataUtil.put( newSummariesDatasCursor2, "RETRY_STATUS_L2", IDataUtil.getString( summariesDatasCursor2, "RETRY_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor2, "RETUR_STATUS", IDataUtil.getString( summariesDatasCursor2, "RETUR_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor2, "SUCCESS_STATUS_L2", IDataUtil.getString( summariesDatasCursor2, "SUCCESS_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor2, "TOTAL_AMOUNT", IDataUtil.getString( summariesDatasCursor2, "TOTAL_AMOUNT" ) );
            IDataUtil.put( newSummariesDatasCursor2, "TOTAL_RECORD", IDataUtil.getString( summariesDatasCursor2, "TOTAL_RECORD" ) );
            IDataUtil.put( newSummariesDatasCursor2, "PROC_STATUS", IDataUtil.getString( summariesDatasCursor2, "PROC_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor2, "BATCHID", IDataUtil.getString( summariesDatasCursor2, "BATCHID" ) );
            IDataUtil.put( newSummariesDatasCursor2, "UPDATE_DATE", IDataUtil.getString( summariesDatasCursor2, "UPDATE_DATE" ) );
            IDataUtil.put( newSummariesDatasCursor2, "CREATE_DATE", IDataUtil.getString( summariesDatasCursor2, "CREATE_DATE" ) );
            IDataUtil.put( newSummariesDatasCursor2, "TOTAL_PROCESS", IDataUtil.getString( summariesDatasCursor2, "TOTAL_PROCESS" ) );
            IDataUtil.put( newSummariesDatasCursor2, "FORCED_ACK", IDataUtil.getString( summariesDatasCursor2, "FORCED_ACK" ) );
            IDataUtil.put( newSummariesDatasCursor2, "LEGSTATUS", IDataUtil.getString( summariesDatasCursor2, "LEGSTATUS" ) );
            IDataUtil.put( newSummariesDatasCursor2, "DOCUMENT_DATE", IDataUtil.getString( summariesDatasCursor2, "DOCUMENT_DATE" ) );
        }
}

IDataUtil.put( inputCursor,  "dateTime", dateTime);
IDataUtil.put( inputCursor,  "procStatus", "('4', '1', '5')");
IDataUtil.put( inputCursor,  "providerCd", "c.provider_code='SPN02' and B.TRXTYPE='1' and");
IDataUtil.put( inputCursor,  "legStatus", "L1");
IDataUtil.put( inputCursor,  "tableResponse", "SPAN_HOST_RESPONSE");
IDataUtil.put( inputCursor,  "addClause", "");
inputCursor.destroy();
output = wmDoInvoke("mandiri.span.db.service", "getSPANSummaries", input);
outputCursor = output.getCursor();
IData[] summariesDatas3 = IDataUtil.getIDataArray( outputCursor, "SPANSummaries" );
IData[] newSummariesDatas3 = new IData[summariesDatas3.length];
outputCursor.destroy(); 
if ( summariesDatas3 != null)
    {
        for ( int i = 0; i < summariesDatas3.length; i++ )
        {
            newSummariesDatas3 [i] = IDataFactory.create();
            IDataCursor newSummariesDatasCursor3 = newSummariesDatas3[i].getCursor();
            IDataCursor summariesDatasCursor3  = summariesDatas3[i].getCursor();
            IDataUtil.put( newSummariesDatasCursor3, "FILE_NAME",IDataUtil.getString( summariesDatasCursor3, "FILE_NAME" ));
            IDataUtil.put( newSummariesDatasCursor3, "RETRY_STATUS_L1", IDataUtil.getString( summariesDatasCursor3, "RETRY_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor3, "RETUR_STATUS", IDataUtil.getString( summariesDatasCursor3, "RETUR_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor3, "SUCCESS_STATUS_L1", IDataUtil.getString( summariesDatasCursor3, "SUCCESS_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor3, "TOTAL_AMOUNT", IDataUtil.getString( summariesDatasCursor3, "TOTAL_AMOUNT" ) );
            IDataUtil.put( newSummariesDatasCursor3, "TOTAL_RECORD", IDataUtil.getString( summariesDatasCursor3, "TOTAL_RECORD" ) );
            IDataUtil.put( newSummariesDatasCursor3, "PROC_STATUS", IDataUtil.getString( summariesDatasCursor3, "PROC_STATUS" ) );
            IDataUtil.put( newSummariesDatasCursor3, "BATCHID", IDataUtil.getString( summariesDatasCursor3, "BATCHID" ) );
            IDataUtil.put( newSummariesDatasCursor3, "UPDATE_DATE", IDataUtil.getString( summariesDatasCursor3, "UPDATE_DATE" ) );
            IDataUtil.put( newSummariesDatasCursor3, "CREATE_DATE", IDataUtil.getString( summariesDatasCursor3, "CREATE_DATE" ) );
            IDataUtil.put( newSummariesDatasCursor3, "TOTAL_PROCESS", IDataUtil.getString( summariesDatasCursor3, "TOTAL_PROCESS" ) );
            IDataUtil.put( newSummariesDatasCursor3, "FORCED_ACK", IDataUtil.getString( summariesDatasCursor3, "FORCED_ACK" ) );
            IDataUtil.put( newSummariesDatasCursor3, "LEGSTATUS", IDataUtil.getString( summariesDatasCursor3, "LEGSTATUS" ) );
            IDataUtil.put( newSummariesDatasCursor3, "DOCUMENT_DATE", IDataUtil.getString( summariesDatasCursor3, "DOCUMENT_DATE" ) );
        }
}



//

/*IData[] mergedArray1= (IData[]) ArrayUtils.addAll(newSummariesDatas,newSummariesDatas1); 
IData[] mergedArray2 = (IData[]) ArrayUtils.addAll(mergedArray1,newSummariesDatas2);
IData[] mergedArray3 = (IData[]) ArrayUtils.addAll(mergedArray2,newSummariesDatas3);
*/

IData[] mergedArray1= combine(newSummariesDatas,newSummariesDatas1); 
IData[] mergedArray2 = combine(mergedArray1,newSummariesDatas2);
IData[] mergedArray3 = combine(mergedArray2,newSummariesDatas3);


IDataCursor pipelineCursor_1 = pipeline.getCursor();
IDataUtil.put( pipelineCursor_1, "SPANSummaries", mergedArray3 );
pipelineCursor_1.destroy();


//

}catch(Exception e){
e.printStackTrace();
}

如何获得更快的流量服务？

4

2 回答 2

2

我冒昧地建议所有实际工作都在 mandiri.span.db.service:getSPANSummaries 服务中完成（因此花费了时间）。您的流服务和等效的 Java 服务只是在一些简单的映射步骤之间编排调用。如果您需要更快的速度，我会考虑该服务。

此外，除了调用 getSPANSummaries 之外，您的 Java 服务所做的大部分工作都涉及通过 IDataUtil 从/向管道检索和存储值，这几乎是 Flow 所做的，因此将使用相同的时间。

WM 应用程序通常受 I/O 限制——通常是通过网络调用 JDBC 或 HTTP ——在这些情况下，Flow 和 Java 之间的差异可能太小而无法衡量，或者太微不足道而无需担心。但是 Flow 是由运行在另一个解释器 (JVM) 之上的解释器执行的。它还具有更多受限的操作方式，例如所有管道/变量/文档访问都涉及潜在的嵌套 IData/Hashmap/ArrayList 访问，并且它可能需要几个 Flow 步骤来完成可以在单个 Java 语句中完成的操作。因此，对于不受 I/O 限制的问题，纯 Java 可以更快。但我怀疑，在这个特定的服务中不是。

于 2015-03-23T04:14:55.920 回答
2

我认为您已经通过生成当前流服务的代码来创建 Java 服务。在有更多处理步骤（例如嵌套循环）的情况下，Java 服务的运行速度比 Flow 服务快得多。

于 2015-03-25T14:11:07.867 回答