服務(wù)器與客戶機(jī)互傳消息

2019-11-17 05:36:51

字體：大中小

供稿：網(wǎng)友

　　一、服務(wù) 器程序
創(chuàng) 建一個(gè) 名為“server" 的項(xiàng) 目, 單文檔界面。
在serverview.h 中加入代碼：
           ＃include “winsock.h"
      添加變量：
            CSize       sizeTotal;// 控制滾動(dòng) 條
            int   count;// 信息條數(shù)
            CString m_data[1000];// 信息存放
            char    Hostname[260];
            char  Hostaddress[20];// 主機(jī)ip 地址
            SOCKET      m_sock;
            HANDLE      m_hListenThread;// 線程
            BOOL  m_bInitialized;// 是否初始化
            WSADATA     WSAData;
            BOOL  flag;
            SOCKADDR_IN saClnt;
            int   saClntLen;
            BOOL  Isconnect;// 是否連接

在serverview.cpp 中重載CServerView() 構(gòu) 造器, 創(chuàng) 建并綁定嵌套字：
      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";
}

在析構(gòu) 函數(shù) 中完成必需的清除操作:
      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 －>

上一篇：分而治之算法---殘缺棋盤(pán)

下一篇：非安全編程演示之高級(jí)篇