java - 使用java服务真的比流服务快吗？-6ren

java - 使用java服务真的比流服务快吗？

转载作者：行者123 更新时间：2023-11-30 07:02:39

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

Before Java Service

After using Java Service

这是我的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();
}

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

最佳答案

我冒昧地建议所有真正的工作都在 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 可以更快。但我怀疑，在这项特定服务中并非如此。

关于java - 使用java服务真的比流服务快吗？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/28983651/

文章推荐： javascript - 计算javascript中的元音

文章推荐： java - 规则的 Sonar 名称 [repository=xxx key=yyy] 为空

文章推荐： javascript - setTimeout(callback) 后跟 while 循环从不触发

文章推荐： java - 如何更有效地处理错误？

css transition in 快，out 快
这看起来很基础，但我想不通。是否有一种简单的 CSS 唯一方法可以使 cssa 真正快速淡入并缓慢淡出。这是为了改变多个 div 的颜色。大约 0.5 秒的缓入和 2 秒的缓出。谢谢! 最佳答案你
Python+C 比纯 C 快(稍微)快
我一直在用各种语言和实现实现相同的代码(在 Blackjack 中发牌而不爆牌的方法的数量)。我注意到的一个奇怪之处是，Python 在 C 中调用分区函数的实现实际上比用 C 编写的整个程序快一点。
XPath:/比//快？
如果我没看错，/ 意味着它右边的节点必须是左边节点的直接子节点，例如/ul/li 返回 li 项，它们是作为文档根的 ul 项的直接子项。 //ul//li 返回 li 项，它们是文档中某处任何 ul
php - mysql随机更新一列(快)
如何随机更新一个表。所以你给一列一个随机值。并且该列(例如“顶部”)是唯一的。如果您在数字 10 到 20 之间进行选择，并且您有 10 行，那么您就不能有未使用的数字。如果你有 Test table
android - 位图创建和绘制速度慢...快
这在一小部分是一个问题(因为我不明白为什么它会有所不同)，在很大程度上是一篇希望能帮助其他一些可怜的程序员的帖子。我有一个代码库，是我大约 5-7 年前第一次开始 Android 编程时编写的，它具
sql - 为什么自连接比 or 快？
我正在尝试过滤关系表以获得满足两个条件的表子集(即:我想要 color_ids 为 1 或 2 的条目的所有 ID)。这是一张结实的 table ，所以我正在尝试尽可能多地进行优化。我想知道是否有人
聊聊PHP中的 === 运算符为什么比 == 快
在上一篇《聊聊PHP中require_once()函数为什么不好用》中给大家介绍了PHP中require_once()为什么不好用的原因，感兴趣的朋友可以去阅读了解一下~ 那么本文将给大家介绍PH
perl - 为什么 FastCGI 快？
很难说出这里问的是什么。这个问题模棱两可、含糊不清、不完整、过于宽泛或言辞激烈，无法以目前的形式合理回答。如需帮助澄清此问题以便可以重新打开，visit the help center . 10年前关
OpenGL 读取像素的速度比 glReadPixels 快
有没有办法提高glReadPixels的速度?目前我做: Gdx.gl.glReadPixels(0, 0, Gdx.graphics.getWidth(), Gdx.graphics.getHeig
r - 为什么:=比`:=`()快？
通常，我以函数形式`:=`()来计算data.table中的多列，认为这是最有效的方法。但是我最近发现它比简单地重复使用:=慢。至少在我的电脑上。我猜想:=的功能形式可能会产生一些开销，但这是它变慢
.net - 为什么三个线程比 10+ 快
我的问题是针对 Windows 环境中多线程的性能问题。在测试我的代码后，我得到的结果是增加线程数不会提高并行计算的性能，并且在经过一些计数后变得更少。到底是怎么回事？是否可以找出最佳线程数的公式:
C: free() 下一个尺寸无效(快)
我看到很少有相同问题的主题，但我仍然无法解决我的问题。这是我的代码 - 使用 XOR 加密的 C 套接字编程当服务器和客户端连接时:- 用户发送消息，例如:你好- 服务器响应，例如:(服务器):你好
c# - 鼠标移动比重绘 wpf 快
我正在定义继承自 Shape 类并实现“几何”属性的形状。这是一个例子: public class Landmark : Shape { public override bool IsInB
Android 执行代码的速度比 PC 快
相同代码在 Android(1Ghz Snapdragon)上的执行速度比我在 3.3 Ghz Core 2 Duo 的 PC(在桌面应用程序中)快 2 倍(PC 的类被复制到 Android 项目)
php - 比 in_array 快？
我需要将一个值与一组数组进行比较。但是，我需要比较 foreach 中的多个值。如果使用 in_array，它可能会很慢，真的很慢。有没有更快的选择？我当前的代码是 foreach($a as $b)
Java 比 C 快
这个问题在这里已经有了答案: How do I write a correct micro-benchmark in Java? (11 个答案) 关闭 9 年前。今天我做了一个简单的测试来比较
Python 实现比 C 快
如果比较不应该以这种方式进行，我深表歉意。我是编程新手，只是很好奇为什么会这样。我有一个包含词嵌入的大型二进制文件 (4.5gb)。每行都有一个单词，后面跟着它的嵌入，它由 300 个浮点值组成。我
c++ - 为什么我的直接四元数乘法比 SSE 快？
我经历了几个不同的四元数乘法实现，但我很惊讶地发现引用实现是迄今为止我最快的实现。这是有问题的实现: inline static quat multiply(const quat& lhs, cons
c++ - 为什么虚函数调用比 dynamic_cast 快？
我写了一个简单的例子，估计调用虚函数的平均时间，使用基类接口(interface)和dynamic_cast和调用非虚函数。这是它: #include #include #include #in
c++ - 比 Stackwalk 快
有没有人知道比“StackWalk”更好/更快的获取调用堆栈的方法？我还认为 stackwalk 在有很多变量的方法上也会变慢......(我想知道商业分析员是做什么的？)我在 Windows 上使用

行者123

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

java - 使用java服务真的比流服务快吗？