simple realtime flow computation
simple_flow 是一个简单的实时流计算框架,由两部分组成,一个是agent,一个是flow_server, agent负责将数据实时传输给flow_server,flow_server负责对实时流的处理
make && make test # 此步骤会生成一个agent和一个测试用的flow_server
./bin/flow_server_test # start flow_server to receive flow
./bin/fileagent localhost 3491 /tmp/test.log # usage: ./bin/fileagent flow_server_ip flow_server_port file_path
#include <fstream>
#include "simple_log.h"
#include "flow_handler.h"
#include "flow_server.h"
class LogFlowHandler : public FlowHandler {
public:
int do_handle(char *flow_bytes, int size) {
std::string receive_flow = std::string(flow_bytes, size);
LOG_DEBUG("start handle the size:%d, flows %s", size, receive_flow.c_str());
return 0;
}
};
int main() {
FlowServer flow_server;
flow_server.start(3491, new LogFlowHandler());
return 1;
}
?
? 项目地址:?https://github.com/hongliuliao/simple_flow
?
?
原文:http://finallygo.iteye.com/blog/2149175