VC网络数据库开发

1、VC网络数据库开发(2006-6-30 16:10:00)【收藏】 【评论】 【打印】 【关闭】 标签:vc  典型网络数据库系统软件设计一、概述1. 本系统为内部系统，帐户由管理员添加、管理； 2. 分为两个组，User组和Boss组。Boss组的帐户可以发广播通知； 3. 任意两个用户间可以互相通信； 4. 数据库接口用DAO，网络通信用 CSocket+CSocketFile； 二、详细设计 1、数据库设计本系统只是一个消息通信模型，这里的数据库设计比较简单。ER图：把ER模型转为关系模型，共两个表： User (No , Name ,Password ,G#) 候选键：No

2、外键：G#Group (G# , GroupName ,Demo ) 主键 ：G#2、消息格式设计<1>、传送的消息共有5类-登录消息，验证返回消息，普通消息，用户列表消息，通知消息。定义一个枚举类型：enum MSGTYPE LOGIN , LOGINResponse , CHATTING , USERList , NOTICE;<2>、定义消息类 class CMsg : public CObject public: int m_eType; /枚举类型，记录消息类型 CString m_strMsg; /消息 CMsg(); virtual CMsg(); voi

3、d Serialize(CArchive &ar); /消息类系列化函数，发送和接受消息时用。; <3>、m_strMsg 为消息类中存放消息的成员，它的具体格式随着消息类型m_eType不同而不同。 m_eTypem_strMsgLOGIN呢称|密码LOGINResponseGOOD|欢迎!（BOSS） 或 FAILED|验证失败!CHATTING发给（来自）的用户名|消息内容USERList呢称1|呢称2|呢称n|ENDNOTICEALL|消息内容 或 来自的用户|消息内容m_strMsg中个内容用“|”隔开，用函数Decode(int n,CString strMsg

4、) 获的相应的内容。CString Decode(int n,CString strMsg) int pos; CString str; for(int i=1;i<=n;i+) pos=strMsg.Find ("|",0); if(pos<0) str=strMsg; else str=strMsg.Left (pos); strMsg=strMsg.Right(strMsg.GetLength ()-pos-1); return str; <4>、消息发送接收的序列化函数void CMsg:Serialize (CArchive &ar

5、) if(ar.IsStoring() ar<<m_strMsg<<m_eType; else ar>>m_strMsg>>m_eType; 3、通信协议设计 · 验证。客户端发送LOGIN消息，服务器回应 LOGINResponse消息； · 通信。客户端发送CHATTING 或 NOTICE 消息，服务器端根据接收到的消息，发送CHATTING，NOTICE或 USERList 消息。 4、服务器设计<1>、建立工程· 、用MFC AppWizard(exe) 新建一个“单个文档”的工程； ·

6、; 、在Step 2 of 6中，选 “查看数据库不使用文件支持”，点击“Data Source.”按钮，然后在弹出的对话框中选 “DAO”类型，再浏览选择数据库文件Data.mdb. 按确定，再在弹出的窗口选User表； · 、点击Next到Step 4 of 6,选“windows Sockets”。网络功能支持； · 、按“NEXT“，最后点击 “完成”； <2>、在CSuperServerView中添加下列成员： int m_iPort;/服务器端口CSocketListen * m_pSocket; /监听套接字。CSocketClient m_Soc

7、ketClientMax; /跟客户端通信的套接字。CArchive * m_pArOut; /发送消息时的序列化文档对象指针。CArchive * m_pArIn; /接收消息时的序列化化文档对象指针。CSocketFile * m_pSF; /套接字文件对象指针。CMsg msg;/消息类对象CString Decode(int n,CString strMsg); /消息的解码函数void SendUserList();bool CheckLogin(CSocketClient *pClient);void MyReceive(CSocketClient *pClient);void M

8、yClose(CSocketClient *pClient);void MyAccept(); <3>、CSuperServerView类的关键成员函数：void CSuperServerView:MyReceive(CSocketClient *pClient) m_pSF=new CSocketFile(pClient); m_pArIn=new CArchive(m_pSF,CArchive:load); msg.Serialize (*m_pArIn); int i; bool bOK=false; switch(msg.m_eType ) case LOGIN: /处理用

9、户登录。 m_pSF=new CSocketFile(pClient); m_pArOut=new CArchive(m_pSF,CArchive:store); msg.m_eType =LOGINResponse; if(CheckLogin(pClient) if(!pClient->m_bBoss) msg.m_strMsg="GOOD|欢迎!" bOK=true; else msg.m_strMsg="GOOD|BOSS" bOK=true; else msg.m_strMsg="FAILED|验证失败!" msg.S

10、erialize (*m_pArOut); m_pArOut->Flush (); if(bOK) SendUserList(); break; case CHATTING: /处理普通消息 for(i=0;i<Max;i+) if(m_SocketClienti.m_bBusy) if(m_SocketClienti.m_strName =Decode(1,msg.m_strMsg) m_pSF=new CSocketFile(&m_SocketClienti); m_pArOut=new CArchive(m_pSF,CArchive:store); msg.m_str

11、Msg=pClient->m_strName+"|"+Decode(2,msg.m_strMsg); msg.Serialize (*m_pArOut); m_pArOut->Flush (); break; break; case NOTICE: /处理广播消息。 msg.m_strMsg=pClient->m_strName+"|"+Decode(2,msg.m_strMsg); for(i=0;i<Max;i+) if(m_SocketClienti.m_bBusy && m_SocketClienti.m_

12、strName != pClient->m_strName) m_pSF=new CSocketFile(&m_SocketClienti); m_pArOut=new CArchive(m_pSF,CArchive:store); msg.Serialize (*m_pArOut); m_pArOut->Flush (); break; void CSuperServerView:MyAccept()for(int i=0;i<Max;i+)if(!m_SocketClienti.m_bBusy)m_pSocket->Accept (m_SocketClien

13、ti);m_SocketClienti.GetView (this);break;void CSuperServerView:OnStartServer() /开始服务m_pSocket=new CSocketListen(this);m_pSocket->Create (m_iPort,SOCK_STREAM);m_pSocket->Listen ();m_staState.SetWindowText("正在监听.");void CSuperServerView:OnStopServer() /关闭服务if(m_pSocket) m_pSocket->C

14、lose ();for(int i=0;i<Max;i+)if(m_SocketClienti.m_bBusy)m_SocketClienti.Close();m_SocketClienti.m_bBusy=false; m_staState.SetWindowText("服务关闭"); 数据库维护操作函数： void CSuperServerView:OnButtonAdd() /添加帐户 CAddDlg dlg; if(dlg.DoModal()=IDOK) if(dlg.m_strName!="") m_pSet->AddNew ();

15、 m_pSet->m_Name=dlg.m_strName; m_pSet->m_Password=dlg.m_strPwd; m_pSet->m_G_=dlg.m_iG; m_pSet->Update (); UpdateData(FALSE); void CSuperServerView:OnButtonDel() /删除帐户 m_pSet->Delete (); m_pSet->MoveNext (); if(m_pSet->IsEOF () m_pSet->MoveFirst(); UpdateData(FALSE);void CSupe

16、rServerView:OnButtonModify() /修改帐户信息 CAddDlg dlg; dlg.m_strName=m_pSet->m_Name; dlg.m_strPwd=m_pSet->m_Password; dlg.m_iG=m_pSet->m_G_; if(dlg.DoModal()=IDOK) if(dlg.m_strName!="") m_pSet->Edit (); m_pSet->m_Name=dlg.m_strName; m_pSet->m_Password=dlg.m_strPwd; m_pSet->

17、m_G_=dlg.m_iG; m_pSet->Update (); UpdateData(FALSE); void CSuperServerView:OnButtonFind() / 查找帐户 CFindDLG dlg; if(dlg.DoModal()=IDOK) if(dlg.m_strKey!="") CString m_strName; UpdateData(TRUE); m_strName=dlg.m_strKey ; if(m_pSet->IsOpen () m_pSet->Close (); m_pSet->Open(AFX_DAO_U

18、SE_DEFAULT_TYPE,"SELECT * FROM user where Name=''"+m_strName+"''"); UpdateData(FALSE); CSocketListen类中的接受事件函数OnAccept(int nErrorCode)。void CSocketListen:OnAccept(int nErrorCode) m_pView->MyAccept (); CSocket:OnAccept(nErrorCode);CSocketClient类中的接收消息函数。void CSoc

19、ketClient:OnClose(int nErrorCode) / TODO: Add your specialized code here and/or call the base class m_pView->MyClose(this); CSocket:OnClose(nErrorCode);CSocketClient类传递主窗口指针函数：void CSocketClient:GetView(CSuperServerView *pView) m_pView=pView;<4>、程序界面5、客户端设计。<1>、建立一个名为Client,基与对话框的应用程序

20、，在Step 2 of 6中选Windows Sockts支持,<2>、在CClientDlg中添加成员。 CString Decode(int n,CString strMsg); CMsg msg; CMySocket * m_pSocket; CArchive * m_pArOut; CArchive * m_pArIn; CSocketFile * m_pSF; void MyReceive();在CMySocket类中添加成员。 CClientDlg * m_pDlg; CMySocket(CClientDlg *pDlg); 构造函数实现，获得指向主对话框的指针 CMy

21、Socket:CMySocket(CClientDlg *pDlg) m_pDlg=pDlg;<3>、关键函数 BOOL CClientDlg:OnInitDialog() . m_strHost="192.168.1.126" m_iPort=1234; UpdateData(FALSE); GetDlgItem(IDC_BUTTON_SEND)->EnableWindow(false); Expand(0); return TRUE; / return TRUE unless you set the focus to a controlvoid CCl

22、ientDlg:OnLogin() /登录函数 UpdateData(TRUE); GetDlgItem(IDC_BUTTON1)->SetWindowText("Wait"); m_pSocket=new CMySocket(this); m_pSocket->Create(); int nTry=3,n; do n=m_pSocket->Connect (m_strHost,m_iPort); while(n!=1 && nTry-); if(n=1) Sleep(2000); m_pSF=new CSocketFile(m_pSock

23、et); m_pArOut=new CArchive(m_pSF,CArchive:store); m_pArIn=new CArchive(m_pSF,CArchive:load); msg.m_eType =LOGIN; msg.m_strMsg =m_strName+"|"+m_strPwd; msg.Serialize (*m_pArOut); m_pArOut->Flush(); else GetDlgItem(IDC_BUTTON1)->SetWindowText("Login"); GetDlgItem(IDC_BUTTON1)

24、->EnableWindow(true); AfxMessageBox("网络原因，没连上服务器!"); void CClientDlg:MyReceive() /接收消息函数 msg.Serialize (*m_pArIn); int i=0; CString str; switch(msg.m_eType ) case LOGINResponse: str=Decode(1,msg.m_strMsg); if(str="FAILED") str=Decode(2,msg.m_strMsg); m_pSocket->Close(); AfxMessageBox(str); else Expand(true); GetDlgItem(IDC_BUTTON1)->SetWindowText("L