java - 如何在不保存 Excel 工作表的情况下从 Java 中的 Excel 工作表中读取动态变化的值

Question

我正在使用 Nest Trader 应用程序(与股票市场交易相关)，它在 Excel 工作表中提供值并在几毫秒内非常快速地更新单元格中的值。

我想读取这些值并将它们保存在数据库中。
我正在使用 apache poi-3.17 库。

Answer 1

How to read dynamically changing values from Excel sheet in Java, without saving Excel sheet ?

如果到目前为止还没有实现，可以求助于使用 JDDE-library，详情如下。

---

毫秒是足够的时间......

在普通交易环境中(即即使是低端的 HFT 仍然不谈)，所有纳秒级 [ns] 延迟都是精心策划的，最好避免，不要添加远超过几个 [us]，所以 [ms] 确实有足够的时间 - 然而，仍然值得卸载任何天真的实现主要是 distributed-system 的“远程”端，因为这既“导出”了这样的工作负载(而不是在您的平台部分花费关键时间)+它还避免了链式延迟，因为决策是在尽可能短的时间内做出的(并且接下来仅在某些情况下公布，与您的平台部分相关)。

---

可以重复使用这个:

JDDE 是基于JNI 的免费开源 Java 库，它允许 Java 应用程序与 Windows 平台上的 native 应用程序通信(如果这些仍然允许 - 在 Vista64 中有问题，但这超出了本文的范围)通过D动态D数据Exchange(又名DDE ) 协议(protocol)。

---

暴力 DDE 示例:

作为使用一种蛮力的示例，下面的代码将通过 Java 应用程序与正在运行的 Microsoft Excel 建立 DDE 连接。

如果 Excel-DDE 实现在 2018 年以后仍支持此功能，另一种更智能的方法是订阅“受监控”内容的所有更改(因为这更接近交易生态系统，并且REUTERS 系统早在 199x 就开始使用它，甚至在几天前，Windows 操作系统还没有配备基于 TCP/IP 的网络，那些日子已经使用 DDE 工作了:o)

naive-brute-DDE-force 示例执行:
- REQUEST 操作，用于从 A1-cell 中读取数据，这是本主题的主题
+ POKE 操作来更改 A1 单元格中的数据，以及
+ EXECUTE 操作以关闭 Excel 文档，如果其他用例需要的话。

 /*
 * Copyright 2009 www.pretty-tools.com. All rights reserved.
 */

import com.pretty_tools.dde.ClipboardFormat;
import com.pretty_tools.dde.DDEException;
import com.pretty_tools.dde.DDEMLException;
import com.pretty_tools.dde.client.DDEClientConversation;

/**
 * Excel Example.
 *
 * @author Alexander Kozlov
 */

public class ExcelExample
{
    public static void main( String[] args )
    {
        try
        {
                         //                                DDE client
            final DDEClientConversation conversation = new DDEClientConversation();
                         //                     We can use UNICODE format if server prefers it
         // conversation.setTextFormat( ClipboardFormat.CF_UNICODETEXT );

            conversation.setTimeout( 3000 );
                         //                     Establish conversation with opened and active workbook
            conversation.connect( "Excel", "Sheet1" );
                         //                     if you have several opened files,
                         //                        you can establish conversation using file path
         // conversation.connect( "Excel", "C:\\Book1.xlsx" );
                         //                     or you can also specify Sheet
         // conversation.connect( "Excel", "C:\\[Book1.xlsx]Sheet2" );
            try
            {
                             //                  Requesting A1 value
                System.out.println( "A1 value: " + conversation.request( "R1C1" ) );
                             //                  Changing cell A1 value to "We did it!"
                conversation.poke( "R1C1", "We did it!" );
                conversation.poke( "R2C2", "We did it again!".getBytes(), ClipboardFormat.CF_TEXT );
                             //                  Fill several cells of the same row,
                             //                       using \t as separator
                conversation.poke( "R4", "Fill\tthe\trow" );
                             //                  Fill several cells of the same column,
                             //                       using \n as separator
                conversation.poke( "C4", "Fill\nthe\ncolumn" );
                             //                  Fill several cells with matrix,
                             //                       using \t as column separator
                             //                         and \n as row separator
                conversation.poke( "R5C5:R7C7", "1\t2\t3\n4\t5\t6\n7\t8\t9" );
                             //                  Run macro with name Macro1
             // conversation.execute( "[run(\"Macro1\")]" );
                             //                  Sending "close()" command
                conversation.execute( "[close()]" );
                             //                  or we can use byte array to send command
             // conversation.execute( "[close()]\0".getBytes() );
            }
            finally
            {
                conversation.disconnect();
            }
        }
        catch ( DDEMLException e )
        {
            System.out.println( "DDEMLException: 0x"
                              +  Integer.toHexString( e.getErrorCode() )
                              + " "
                              +  e.getMessage()
                                 );
        }
        catch ( DDEException e )
        {
            System.out.println( "DDEClientException: "
                              +  e.getMessage()
                                 );
        }
        catch ( Exception e )
        {
            System.out.println( "Exception: "
                              +  e
                                 );
        }
    }
}

---

一种更聪明的方式
- 避免“手动”轮询
+ 卸载到 DDE-self-advertised change monitor/propagator :

以下示例监听 Excel 单元格中的更改。 .setEventListener() 方法用于设置异步事件处理程序(代理，在 distributed-system 中工作以监听远程事件并负责 - 一旦它接收任何此类 - 本地端对此类事件的响应 react )。

在这个简单的模型演示中，它只会将任何远程 A1-cell 更改打印到此 Java 应用程序的本地控制台(并处理断开连接事件，一个显然同样重要的步骤):

/*
 * Copyright 2009 www.pretty-tools.com. All rights reserved.
 */

import com.pretty_tools.dde.DDEException;
import com.pretty_tools.dde.client.DDEClientConversation;
import com.pretty_tools.dde.client.DDEClientEventListener;
import com.pretty_tools.dde.DDEMLException;

/**
 * Excel Advice Example.
 *
 * @author Alexander Kozlov
 */

public class ExcelAdviceExample
{
    public static void main( String[] args )
    {
        try
        {
                         //                                DDE client
            final DDEClientConversation conversation = new DDEClientConversation();
                         //                     We can use UNICODE format if server prefers it
         // conversation.setTextFormat( ClipboardFormat.CF_UNICODETEXT );

            conversation.setEventListener( new DDEClientEventListener()
            {
                public void onDisconnect()
                {
                    System.out.println( "onDisconnect()" );
                }

                public void onItemChanged( String topic, String item, String data )
                {
                    System.out.println( "onItemChanged( "
                                      +  topic
                                      + ","
                                      +  item
                                      + ","
                                      +  data.trim()
                                      + ")"
                                         );
                }
            } );

            System.out.println(            "Connecting..." );
            conversation.connect( "Excel", "Sheet1" );
            try
            {            // .startAdvice(-------------------------------
                conversation.startAdvice(  "R1C1" );

                System.out.println(        "Press Enter to quit" );
                System.in.read();

                conversation.stopAdvice(   "R1C1" );
            }            // .stopAdvice(--------------------------------
            finally
            {
                conversation.disconnect();
            }
        }
        catch ( DDEMLException e )
        {
            System.out.println( "DDEMLException: 0x"
                              +  Integer.toHexString( e.getErrorCode() )
                              + " "
                              +  e.getMessage()
                                 );
        }
        catch ( DDEException e )
        {
            System.out.println( "DDEClientException: "
                              +  e.getMessage()
                                 );
        }
        catch ( Exception e )
        {
            System.out.println( "Exception: "
                              +  e
                                 );
        }
    }
}

---

JDDE 是基于 JNI 的库，它需要本地代码库(Windows 的 DLL)。

因此，DLL(== JavaDDE.dll 文件)应该放在您运行示例的当前目录中，或者您应该指定 JVM java.library.path，参数指向一个文件夹，JavaDDE.dll文件存放在该文件夹中。

示例:

 java -Djava.library.path="C:\jdde" ExcelExample