服务器与客户机互传消息

服务器与客户机互传消息

一、服务器程序

创建一个名为“server" 的项目, 单文档界面。

在serverview.h 中加入代码：

           ＃include “winsock.h"

      添 加 变 量：

            CSize       sizeTotal;// 控 制 滚 动 条

            int   count;// 信 息 条 数

            CString m_data[1000];// 信 息 存 放

            char    Hostname[260];

            char  Hostaddress[20];// 主 机IP 地 址

            SOCKET      m_sock;

            HANDLE      m_hListenThread;// 线 程

            BOOL  m_bInitialized;// 是 否 初 始 化

            WSADATA     WSAData;

            BOOL  flag;

            SOCKADDR_IN saClnt;

            int   saClntLen;

            BOOL  Isconnect;// 是 否 连 接

在serverview.cpp 中重载CServerView() 构造器, 创建并绑定嵌套字：

      CServerView::CServerView()

{     // TODO: add construction code here

      Isconnect=FALSE;

      flag=FALSE;

      sizeTotal.cy=350;

      sizeTotal.cx=300;

      m_hListenThread;

      count=5;

      int status;

      WSADATA wsaData;

   m_data[0]=“initializing Windows Sockets DLL....";

      if((status=WSAStartup(0x0101, ＆wsaData))==0)

      {     m_data[0] ＋=“Succeeded";

            m_bInitialized=TRUE;

      }

      else

      {     m_bInitialized=FALSE;

      }

      m_sock=socket(AF_INET,SOCK_DGRAM,0);

      m_data[1]=“Creating socket....";

      if(m_sock==INVALID_SOCKET)

      {     m_data[1] ＋=“Failed";

      }

      m_data[1] ＋=“Succeeded";

      m_data[2]=“Binding socket....";

      sockaddr_in sa;

      sa.sin_family=AF_INET;

      sa.sin_addr.S_un.S_addr=htonl(INADDR_ANY);

      sa.sin_port=htons(5050);

      if(bind(m_sock,(PSOCKADDR) 

     ＆sa,sizeof(sa))==SOCKET_ERROR)

      {     m_data[2] ＋=“Failed";

            closesocket(m_sock);

      }

      m_data[2] ＋=“Succeeded";

      m_data[3]=“Creating listener thread....";

      unsigned long idThread;

 m_hListenThread=CreateThread(NULL,0,

(LPTHREAD_START_ROUTINE)Listen,

(void        if(m_hListenThread)

      {     m_data[3] ＋=“Succeeded";

            m_data[4] ＋=“Listening....";

      }

      else

            m_data[4] ＋=“Failed";

}

在析构函数中完成必需的清除操作:

      CServerView:: ～CServerView()

{     if(m_bInitialized)

      WSACleanup();

      closesocket(m_sock);

      if(m_hListenThread)

      ::TerminateThread(m_hListenThread,0);

}

定义接收和处理消息的线程:

      long WINAPI Listen(CServerView ＊pView)

{     char msg[2000]=“";

      int   nchar;

      SOCKADDR_IN saClnt;

      int saClntLen;

      while(1)

      { saClntLen=sizeof(saClnt);

        nchar=recvfrom(pView －>m_sock,msg,1024,0, 

(PSOCKADDR) ＆saClnt, ＆saClntLen);

        if(nchar<0)

        {     pView －>m_data[pView －>count ＋ ＋] ＋

             =“Error in recvfrom\n";

        pView －>InvalidateRect(NULL);

        }

        else

        {switch(msg[0])

        {

        case  ‘A':

        wsprintf(msg,“A:Client from ％s attached\n",

               inet_ntoa(saClnt.sin_addr));

        pView －>m_data[pView －>count ＋ ＋]=msg;

        pView －>flag=TRUE;

        pView －>InvalidateRect(NULL);

        pView －>Isconnect=TRUE;

        pView －>saClnt=saClnt;

        pView －>saClntLen=saClntLen;

        sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR) 

        ＆saClnt,saClntLen);

        break;

                  

        case ‘D':

        wsprintf(msg,“D: Client form ％s detached\n",

                inet_ntoa(saClnt.sin_addr));

        pView －>m_data[pView －>count ＋ ＋]=msg;

        pView －>flag=TRUE;

        pView －>InvalidateRect(NULL);

        pView －>Isconnect=FALSE;

       sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR) 

       ＆saClnt,saClntLen);

        break;



        case ‘R':

        saClntLen=sizeof(saClnt);

        pView －>m_data[pView －>count ＋ ＋]=msg;

        pView －>flag=TRUE;

        pView －>InvalidateRect(NULL);

        break;



        default:

        break;

        }

        }

            

      }

      return(0);

}

在程序菜单项中添加“ 本机IP 地址":

 　 　void CServerView::OnIp() 

{int WSAReturn;

 WSAReturn=WSAStartup( 0x0101, ＆WSAData );

 if( WSAReturn == 0 ){

 gethostname( Hostname, 260 );

 struct hostent ＊pHostEnt;

 pHostEnt = gethostbyname( Hostname);

 if( pHostEnt != NULL ){

 wsprintf( Hostaddress, “ ％d. ％d. ％d. ％d",

( pHostEnt －>h_addr_list[0][0] ＆ 0x00ff ),

( pHostEnt －>h_addr_list[0][1] ＆ 0x00ff ),

( pHostEnt －>h_addr_list[0][2] ＆ 0x00ff ),

( pHostEnt －>h_addr_list[0][3] ＆ 0x00ff ) );

 　 　CString out;      

 　 　out.Format(Hostaddress);

 　 　AfxMessageBox(out);

 　 　}

      }

}

在程序菜单中添加“ 发送消息"：

 　 　void CServerView::OnSendmessage() 

{// TODO: Add your command handler code here

      char msg[2000];

      Csend Sendmessage;

      if(Sendmessage.DoModal()==IDOK 

    ＆ ＆!Sendmessage.m_Message.IsEmpty())

 　 　{ wsprintf(msg,“R: " ＋Sendmessage.m_Message);

 　 　sendto(m_sock,msg,1024,0,(PSOCKADDR) 

      ＆saClnt,saClntLen);

 　 　m_data[count ＋ ＋]=Sendmessage.m_Message;

 　 　flag=TRUE;

 　 　InvalidateRect(NULL);

 　 　}

}

为发送消息项添加一个对话框的类, 名为send, 有一个文本框, 用来发送消息，并为文本框添加CString m_Message 变量, 在ServerView.cpp 中添加＃include “send.h"

为发送消息项添加一个判断函数:

     void CServerView::OnUpdateSendmessage(CCmdUI ＊ 

pCmdUI) 

{// TODO: Add your command update UI handler code here

      pCmdUI －>Enable(FALSE);

      if(Isconnect)

      pCmdUI －>Enable(TRUE);

}

再窗口显示消息:

      void CServerView::OnDraw(CDC ＊ pDC)

{     if(flag)

      {sizeTotal.cy ＋=20;

       for(int j=65;j

TextOut(10,y,m_data[i]);

            y ＋=20；}

      // TODO: add draw code for native data here

}

在Project 中点击Settings 中选择Link 项添加wsock32.lib。

----最后编译程序, 就可以得到Server.exe 程序。

二、客户机程序

创建一个名为“client" 的项目, 单文档界面。

在clientview.h 中加入代码：

            ＃include “winsock.h"

    添 加 变 量:

            CString m_data[1000];

            HANDLE      m_hListenThread;

            SOCKET      m_sock;

            SOCKADDR_IN m_saSrvr;

            BOOL  Isconnect;

            int   count;

            CSize       sizeTotal;

            BOOL  flag;

在构造函数中初始化变量:

      CClientView::CClientView()

{     // TODO: add construction code here

      Isconnect=FALSE;

      sizeTotal.cy=350;

      sizeTotal.cx=300;

      flag=FALSE;

}

在析构函数中完成清除操作，代码如上。

在菜单中添加“ 拨号" 项:

      void CClientView::OnDial() 

{// TODO: Add your command handler code here

      count=5;

      if(m_bInitialized)

      {     AfxMessageBox(“Already dialing");

            return;}

      Cdial dial;

    if(dial.DoModal()==IDOK 

    ＆ ＆!dial.m_HostAddress.IsEmpty())

      {m_saSrvr.sin_family=AF_INET;

       m_saSrvr.sin_addr.S_un.S_addr=htonl

(INADDR_ANY);

       m_saSrvr.sin_addr.S_un.S_addr=inet_addr

(dial.m_HostAddress);

       m_saSrvr.sin_port=htons(5050);

       int status;

       WSADATA wsaData;

       m_data[0]=“initializing Windows Sockets DLL....";

       if((status=WSAStartup(0x0101, ＆wsaData))==0)

      {     m_data[0] ＋=“Succeeded";

            m_bInitialized=TRUE;}

      else

      {     m_bInitialized=FALSE;}

      m_sock=socket(AF_INET,SOCK_DGRAM,0);

      m_data[1]=“Creating socket....";

      if(m_sock==INVALID_SOCKET)

      {     m_data[1] ＋=“Failed";}

      m_data[1] ＋=“Succeeded";

      m_data[2]=“Binding socket....";

      sockaddr_in sa;

      sa.sin_family=AF_INET;

      sa.sin_addr.S_un.S_addr=htonl(INADDR_ANY);

      sa.sin_port=htons(0);

      if(bind(m_sock,(PSOCKADDR) 

     ＆sa,sizeof(sa))==SOCKET_ERROR)

      {     m_data[2] ＋=“Failed";

            closesocket(m_sock)；}

      m_data[2] ＋=“Succeeded";

      m_data[3]=“Creating listener thread....";

      unsigned long idThread;

      m_hListenThread=CreateThread(NULL 0,

(LPTHREAD_START_ROUTINE)Listen,

(void ＊)this,0, ＆idThread);

      if(m_hListenThread)

      {     m_data[3] ＋=“Succeeded";

            m_data[4] ＋=“Waiting....";}

      else

      m_data[4] ＋=“Failed";

      InvalidateRect(NULL);

      }

}

添加一个拨号对话框, 名为dial, 有一个文本框用来写IP 地址. 并在clientview.cpp 中添加代码:
```
      ＃include dial.h
```

在拨号项添加一个判断函数:

    void CClientView::OnUpdateDial(CCmdUI ＊ 

pCmdUI) 

{// TODO: Add your command update UI handler code here

      pCmdUI －>Enable(TRUE);

      if(Isconnect)

      pCmdUI －>Enable(FALSE);

}

添加接收与发送消息的线程:

      long WINAPI Listen(CClientView ＊pView)

{     char msg[2000];

      pView －>m_data[5]=“Sending ATTACH command";

      pView －>InvalidateRect(NULL);

      wsprintf(msg,“A: ");

     sendto(pView －>m_sock,msg,1024,0,(PSOCKADDR)

     ＆pView －>m_saSrvr,sizeof(pView －>m_saSrvr));

      int saSrvrLen ,nchar;

      while(1)

      {saSrvrLen=sizeof(pView －>m_saSrvr);

      nchar=recvfrom(pView －>m_sock,msg,1024,0,

   (PSOCKADDR) ＆pView －>m_saSrvr, ＆saSrvrLen);

      if(nchar<0)

     {    pView －>m_data[pView －>count ＋ ＋]=

             “Error in recvform";

      pView －>InvalidateRect(NULL);}

      else

     { pView －>m_data[pView －>count ＋ ＋]=msg;

                  pView －>Isconnect=TRUE;

                  pView －>flag=TRUE;

                  pView －>InvalidateRect(NULL);

            }

      }

      return(0);

}

同主程序一样做一个发送消息项, 代码如上。
显示程序也与主程序一样, 代码如上。
在Project 中点击Settings 中选择Link 项添加wsock32.lib。
编译程序便可得到client.exe 程序。

----server.exe 和 client.exe 做完后, 就可以在具有 TCP/IP 协议下的网络中执行。

一、 服 务 器 程 序

二、 客 户 机 程 序

一、服务器程序

二、客户机程序