java 에서 실시간으로 데이터를 입력하는 내용을 만들기 위해 알아보았습니다만... 방법을 잘 몰라서 ; 질문을 드리고자 합니다.

1.실시간 이벤트를 사용 하는 방법은 spark streaming, Esper 이 있는 것으로 알고 있는데요. 이 이외에 다른 쉬운 방법이 있나요?

2.Esper 에서 실시간 이벤트 사용 방법을 모르겠습니다.

설명 사이트

gitHub 적용 사이트

EPL 실험 해볼 수 있는 사이트

를 참조해서 만들어 보았습니다.

public void EesperExample2(UserInfoDto udto) {

Configuration config = new Configuration();

config.addEventType("SearchYoutubeVo", SearchYoutubeVo.class.getName());

EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider(config);

String epl = "select * , count(*) from SearchYoutubeVo.win:time(5 minutes)";

List<SearchYoutubeVo> vo;

EPStatement statement = epService.getEPAdministrator().createEPL(epl);

ExampleListener example = new ExampleListener();

statement.addListener(example);

int EventCreateNum = 5;

//for(int i = 0; i < EventCreateNum; i++ ){

try {

vo = youtubeSearchService.searchYoutube(udto);

} catch (Exception e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}

try { Thread.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); }

//}

}

public class ExampleListener implements UpdateListener {

public void update(EventBean[] newEvents, EventBean[] oldEvents) {

EventBean event = newEvents[0];

System.out.println("Avg Rating of NFM = " + event.get("viewCount") + " Total Count: " + event.get("videoId"));

System.out.println(event.get("count(*)"));

}

}

'vo = youtubeSearchService.searchYoutube(udto);' 는 youtube 키워드를 입력해서 이를 가지고오는 내용입니다.

'UserInfoDto udto' 유저의 관련된 정보를 가지고 오는 것입니다.

그런데 제가 하고 싶은 것은 처음에 youtubeSearchService.searchYoutube(udto); 사용해서 데이터를 가조고온 후, 5분 간격으로 데이터를 가지고 오고 싶은 것인데.... 방법을 전혀 모르겠습니다.

그런데 ExampleListener 는 전혀 실행되지 않고 있습니다.

#esper

질문실시간 이벤트 처리 방법(Esper 사용법)