java - 我可以使用 Flex 中的远程对象来轮询服务器上的 Java 类(Blazeds)吗？我想将实时信息返回到我的数据网格中

Question

这是我到目前为止的代码:

弹性代码

<?xml version="1.0" encoding="utf-8"?>

<fx:Declarations>


    <s:RemoteObject id="getStockPrices" result="result(event)" destination="blazeDsService"
                    endpoint="http://localhost:8400/flexspring/messagebroker/streamingamf"/>

</fx:Declarations>


<mx:DataGrid  x="10" y="295" width="910" height="211" creationComplete="getStockPrices.getQuotes();"
             dataProvider="{getStockPrices.getQuotes.lastResult}" >
    <mx:columns>
        <mx:DataGridColumn headerText="Stock Ticker" dataField="name" />
        <mx:DataGridColumn headerText="Price" dataField="price"/>
        <mx:DataGridColumn headerText="Hi" dataField="col3"/>
        <mx:DataGridColumn headerText="Low" dataField="col4"/>
        <!--<mx:DataGridColumn headerText="Adverage" dataField="col5"/>
        <mx:DataGridColumn headerText="Graph" dataField="col6"/>-->
    </mx:columns>
</mx:DataGrid>


<mx:Button label="Retrieve Stocks" click="retrieveStocks()"/>

这是 java 类文件。这将返回数组列表:

package flex;

导入java.util.ArrayList;导入java.util.List；导入 java.util.Random;

导入org.springframework.flex.remoting.RemotingDestination;导入 org.springframework.flex.remoting.RemotingIninclude;导入 org.springframework.stereotype.Service;

导入supportingClasses.StockQuote;

@服务

@RemotingDestination

公共(public)类 BlazeDsService {

private static final String[] MASTER_LIST = {"C", "FNM", "FRE", "F", "GOOG", "AIG", "CSCO", "MSFT", "AAPL", "YHOO", "BSX", "PORT","F", "TNT", "ESP", "RET", "VBN", "EES"};


@RemotingInclude
public List<StockQuote> getQuotes(){
    List<StockQuote> list = new ArrayList<StockQuote>();
    Random r = new Random();
    for (String s:MASTER_LIST){
        StockQuote sq = new StockQuote();
        sq.setName(s);
        sq.setPrice(r.nextInt(50));
        list.add(sq);
    }
    return list;
}

}

此时需要按下按钮来刷新数据。我想摆脱这个并每隔 x 秒轮询一次信息。这可以吗？

我需要更改我的设置吗？创建一些发布-订阅模式并使用流媒体 channel ？

谢谢

Answer 1

如果您只想每 X 秒调用一次 getQuotes 方法，您可以在 Flex 中使用计时器，无需消息传递。如果您想在股票值(value)发生变化时收到通知，您可以在 Flex 端使用消费者，该消费者订阅了服务器添加消息的同一目的地。您可以在 traderdesktop 文件夹下的 BlazeDS 示例文件夹中找到执行此操作的示例。