ChenGen

一切歸零，重新開(kāi)始

隨筆 - 13, 文章 - 10, 評(píng)論 - 21, 引用 - 0

數(shù)據(jù)加載中……

使用Sandstorm

/**

?*?

? */

package ?p2hp.datapool.main;

import ?p2hp.datapool.handler.ReceiveStageHandler;

import ?p2hp.datapool.message.HelloWorldMsg;

import ?winseda.sandStorm.api.EventHandlerIF;

import ?winseda.sandStorm.api.ManagerIF;

import ?winseda.sandStorm.api.SinkIF;

import ?winseda.sandStorm.api.StageIF;

import ?winseda.sandStorm.main.Sandstorm;

/**

?*? @author ?chengen

? */

public ? class ?SandStormTest? {

???? /**

?????*? @param ?args

????? */

???? public ? static ? void ?main(String[]?args)? {

???????? try ? {

???????????? // ?create?an?instance?of?SandStorm

????????????Sandstorm?ss? = ? new ?Sandstorm();

???????????? // ?get?the?managerIF?through?which?we?create?stages

????????????ManagerIF?mgr? = ?ss.getManager();

???????????? // ?create?an?instance?of?a?EventHandlerIF?which?can?then?receive?and

???????????? // ?process?messages

????????????EventHandlerIF?handler1? = ? new ?ReceiveStageHandler();

???????????? // ?create?a?stage?use?ManagerIF

????????????mgr.createStage( " receivestage " ,?handler1,? null );

???????????? // ?get?the?StageIF?of?the?stage?we?created?just?now?whose?name?is

???????????? // ?'receiverstage'

????????????StageIF?receiveStage? = ?mgr.getStage( " receivestage " );

???????????? // ?get?the?SinkIF?of?the?stage?we?created?just?now?and?then?we?use

???????????? // ?this?SinkIF?to?send?messages?to?the?stage

????????????SinkIF?nextStageSink? = ?receiveStage.getSink();

???????????? // ?send?1000?messages?to?the?stage?'receivestage'

???????????? for ?( int ?i? = ? 0 ;?i? < ? 1000 ;?i ++ )? {

???????????????? // ?create?an?instance?of?the?message

????????????????HelloWorldMsg?msg? = ? new ?HelloWorldMsg( " message " ? + ?i);

????????????????System.out.println( " #send?message# " ? + ?msg);

????????????????Thread.sleep( 500 );

???????????????? // ?send?the?message?through?the?SinkIF

????????????????nextStageSink.enqueue(msg);

????????????}

????????} ? catch ?(Exception?e)? {

???????????? // ?TODO:?handle?exception

????????????e.printStackTrace();

????????}

????}

}

/**

?*?

? */

package ?p2hp.datapool.handler;

import ?p2hp.datapool.message.HelloWorldMsg;

import ?winseda.sandStorm.api.ConfigDataIF;

import ?winseda.sandStorm.api.EventHandlerException;

import ?winseda.sandStorm.api.EventHandlerIF;

import ?winseda.sandStorm.api.QueueElementIF;

import ?winseda.sandStorm.api.SinkIF;

import ?winseda.sandStorm.api.StagesInitializedSignal;

/**

?*? @author ?chengen

? */

public ? class ?ReceiveStageHandler? implements ?EventHandlerIF? {

???? private ?ConfigDataIF?config;

???? /*

?????*?(non-Javadoc)

?????*?

?????*?@see?winseda.sandStorm.api.EventHandlerIF#destroy()

????? */

???? public ? void ?destroy()? throws ?Exception? {

???????? // ?TODO?Auto-generated?method?stub

????}

???? /*

?????*?(non-Javadoc)

?????*?

?????*?@see?winseda.sandStorm.api.EventHandlerIF#handleEvent(winseda.sandStorm.api.QueueElementIF)

????? */

???? public ? void ?handleEvent(QueueElementIF?elem)? throws ?EventHandlerException? {

???????? // ?TODO?Auto-generated?method?stub

???????? if ?(elem? instanceof ?HelloWorldMsg)? {

????????????System.out.println( this .getClass()? + ? " ::get?message:: " ? + ?elem);

????????}

????}

???? /*

?????*?(non-Javadoc)

?????*?

?????*?@see?winseda.sandStorm.api.EventHandlerIF#handleEvents(winseda.sandStorm.api.QueueElementIF[])

????? */

???? public ? void ?handleEvents(QueueElementIF[]?elemarr)

???????????? throws ?EventHandlerException? {

???????? // ?TODO?Auto-generated?method?stub

???????? for ?( int ?i? = ? 0 ;?i? < ?elemarr.length;?i ++ )? {

????????????handleEvent(elemarr[i]);

????????}

????}

???? /*

?????*?(non-Javadoc)

?????*?

?????*?@see?winseda.sandStorm.api.EventHandlerIF#init(winseda.sandStorm.api.ConfigDataIF)

????? */

???? public ? void ?init(ConfigDataIF?config)? throws ?Exception? {

???????? // ?TODO?Auto-generated?method?stub

???????? this .config? = ?config;

????????System.out.println( " ######receive?stage?initialized###### " );

????}

}

posted on 2006-10-12 11:28 ChenGen 閱讀(457) 評(píng)論(0) 編輯收藏所屬分類(lèi): SEDA

新用戶(hù)注冊(cè) 刷新評(píng)論列表


只有注冊(cè)用戶(hù)登錄后才能發(fā)表評(píng)論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問(wèn) 管理
相關(guān)文章: 使用Sandstorm SEDA簡(jiǎn)介我和SEDA

ChenGen

使用Sandstorm

導(dǎo)航

常用鏈接

留言簿(5)

隨筆分類(lèi)

隨筆檔案

文章分類(lèi)

文章檔案

收藏夾

Good BLogs

搜索

最新評(píng)論

閱讀排行榜

評(píng)論排行榜