[code="java"]
//得到socket及其它信息
private static SessionBean sessionBean = SessionBean.getInstance();
/**
* 报文处理及生成CSV文件流程
* @return void 无返回值
*/
public static void process(){
//从上层sessionBean中得到一个socket,socket负责接收实时消息
Socket s = sessionBean.getSocket();
new Runnable() {
public void run() {
try {
BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
String data = br.readLine();
//得到所需要的数据
String needData = getNeedMessage(data);
//处理所需要的数据
dataHandle(needData);
//生成CSV文件
writeCsvFile();
} catch (IOException e) {
logger.error("报文信息读取失败");
}
}
};
}
[/code]