apphttp.h

linux 上http email 协议分析程序 主要能够处理大数据量的主干网的应用

#ifndef _EMAILAPP_FILE_H
#define _EMAILAPP_FILE_H

#include <Mem.h>
#include <ShmApply.h>
#include <BaseConst.h>
#include <RtRadiusIP.h>

#include "Cnstream.h"
#include "Chv.h"
#include "Chtmlfile.h"
#include "AppWeb.h"
#include "Db.h"
#include "Hash.h"
#include "ungzip.h"
#include "DataInfo.h"
//#include "RtRadiusIP.h"
#include "Httpspadd.h"

class CAppHttp
{
public:
	CAppHttp(char *filename);
	
	~CAppHttp();
	void run();
	void timeOut(); 
	void reLoad();
private:
	int findHtml(struct ST_TCP_STREAM *m_theHead,char * m_pszinq);
	bool saveHtml(struct ST_TCP_STREAM *m_theHead,char *m_pszret,int m_iretlen);
	int retCode(Cmimestream *);

	void profHtml();
	//bool profoneInq();
	bool isavailfilename(char *filename);
	//bool CAppHttp::getBoudary(char *szbd)
	bool getBoudary(char *szbd);
	void profmultiform();
	bool profoneInqData();
	bool setinqHead();

	bool profoneRet();

	bool posUrl();
	//bool isMatchUrl();
	void checkKey();
	void checkspKey();
	
	void registerPage();
	void registerspPage(char *szdir,int isubmit=0);

	void registerContent();
	void registerspContent();
	
	int registerWatchedObj();
	int registerspWatchedObj();

	void saveNA(int idpt,int idna,char *);
	void setPageRecord(STRU_TR_T_SENPAGE &recpage);
	bool availContType();
	
	void setNullInq();
	void setNullRet(); 
	void https();
private:

	
	void initDir();
	
private:
	CShmApply *m_pshm;
	Chash_v *m_theHash;
	CMem *m_theMem;
	CHtmlFile *m_theHtmlFile;
	Cunzip *m_pUnzip;
	//CTbl	*m_pTbl;
	//TRecordHtml m_Html;
	 CTblEvent  *m_pEvent;	
	 CSeqEvent  *m_pSeqEvent;
	
	CTblNet *m_ptblnet;
	CSeqNet *m_pseqnet;
	
	CTblSsl *m_ptblssl;
	CSeqSsl *m_pseqssl;
	
	CTblSpWarm *m_pTblSpWarm;
	CSeqSpWarm *m_pSeqSpWarm;

	CTblWeb *m_ptblweb;
	CSeqWeb *m_pseqweb;

	CSpTblWeb *m_psptblweb;
	CSpSeqWeb *m_pspseqweb;
	//Cinfo *m_theInfo;
	Cmimestream *m_theinqStream;
	Cmimestream *m_theretStream;
	Chv		*m_prethv;//标头类
	Chv		*m_pinqhv;
	//敏感网页
	
	CAppWeb *m_pappweb;

	//CRtRdsIP *m_pshmInfo;
	CDataInfo *m_pInfo;
	HttpSpAdd *m_phpadd;

	CRtRdsIP	*m_prdsip;
private:
	time_t m_lcleartime;
	int m_iidletime;
	 unsigned long m_clientip;
private:
	struct ST_TCP_STREAM m_theHead;
	char *m_pszret;
	int m_iretlen;
	char *m_pszinq;
	int m_iinqlen;

private:
	char m_szmethod[16];
	
	char m_szurl[1024];
	char m_szinidir[32];
	char m_szdir[1024];
	char m_szhost[1024];
	char m_szpostpara[1024];
	char m_szline[2048];
	char m_szboudary[1024];
	char m_szfilename[1024];

	char *m_pszpostdata;
	int m_ilenpostdata;
	char *m_pszinqData;
	int m_iinqDataLen;
	char *m_pszretData;
	int m_iretDataLen;

private:
	char *m_szrcv;
	int m_ilenrcv;

	char *m_szsaved;
	int m_ilensaved;

	char *m_szbuf;
	char *m_szbuftmp;
private:
	TUnit_v *m_punit;
private:
	int m_idataflow;
		

};



#endif