Создание сетевой игры

          }

    }

    else

    {

          memset(&CallAddress, 0, sizeof(CallAddress));

          CallAddress.snb_family = AF_NETBIOS;

          CallAddress.snb_type = NETBIOS_UNIQUE_NAME;

          strcpy(CallAddress.snb_name,NETBIOS_SERVER_NAME);

          if(connect(NetBiosSocket , (PSOCKADDR  )&CallAddress, sizeof(CallAddress)) < 0)

          {

              Application->MessageBox("Connect Error","Ошибка",MB_OK+MB_ICONHAND);

              closesocket(NetBiosSocket);

              Application->Terminate();

          }

          rc = WSAAsyncSelect(NetBiosSocket, Handle, WSA_NETEVENT, FD_READ);

          if (rc != 0)

          {

              Application->MessageBox("Ошибка WSAAsyncSelect","Ошибка",MB_OK+MB_ICONHAND);

              closesocket(NetBiosSocket);

              NetBiosSocket = INVALID_SOCKET;

              Application->Terminate();

          }

    }

   

    WindowProc = NetBiosWndProc;

}

//-------------------Прием и accept---------------------------------------------

void __fastcall TMainForm::NetBiosWndProc(Messages::TMessage &Message)

{

    int rc;

    char Buf[80];

    if (Message.Msg == WSA_NETEVENT)

    {

        if (Message.LParam == FD_READ)

        {

            rc = recv((SOCKET)Message.WParam, Buf, sizeof(Buf)-1, 0);

            if (rc == SOCKET_ERROR)

            {

                rc = WSAGetLastError();

                Application->MessageBox("Ошибка recv NetBios","Ошибка",MB_OK+MB_ICONHAND);

                closesocket(NetBiosSocket);

                NetBiosSocket = INVALID_SOCKET;

                Application->Terminate();

            }

            if (rc >= 1)

            {

                if(IsVisitApplicationBox) return;

                Priem(CharToMas(Buf));

            }

         }

    }

    else if(Message.Msg == WSA_ACCEPT)

    {

        if(Message.LParam == FD_ACCEPT)

        {

            int sizeCallAddress = sizeof(CallAddress);

            NetBiosSocket  = accept (NetBiosSocket, (LPSOCKADDR   )&CallAddress, (int FAR *)&sizeCallAddress);

            if(NetBiosSocket  == INVALID_SOCKET)

            {

                  Application->MessageBox("Ошибка Accept","Ошибка",MB_OK+MB_ICONHAND);

                  Application->Terminate();

            }

            char *strPered=DannieToChar(0,KolKub,MaxOch);

            NetBiosSend(strPered);

            InterfaceBeginNewGame();

            ChangeInterfacePerehodHoda(1);

            rc = WSAAsyncSelect(NetBiosSocket, Handle, WSA_NETEVENT, FD_READ);

            if (rc != 0)

            {

                Application->MessageBox("Ошибка WSAAsyncSelect","Ошибка",MB_OK+MB_ICONHAND);

                closesocket(NetBiosSocket);

                NetBiosSocket = INVALID_SOCKET;

                Application->Terminate();

            }

         }

     }

     WndProc(Message);

}

//-------------------отправка---------------------------------------------------

void __fastcall TMainForm::NetBiosSend(char *Buf)

{

    int rc;

    rc = send(NetBiosSocket, Buf, strlen(Buf)+1, 0);

    if (rc == SOCKET_ERROR)

    {

        rc = WSAGetLastError();

        Application->MessageBox("Ошибка sendto NetBios","Ошибка",MB_OK+MB_ICONHAND);

        closesocket(NetBiosSocket);

        NetBiosSocket = INVALID_SOCKET;

        Application->Terminate();

    }

}

//----------------разрыв-------------------------------------------------------

void __fastcall TMainForm::NetBiosCloseConnection(void)

{

    closesocket(NetBiosSocket);

    WSACleanup();

}

//---------------------------------------------------------------------------

Pipe.cpp

//---------------------------------------------------------------------------

#pragma hdrstop

#include <stdio.h>

#include <stdlib.h>

#include <StrUtils.hpp>

#include "Pipe.h"

#include "Main.h"

#include "Podkluch.h"

//---------------------------------------------------------------------------

#pragma package(smart_init)

HANDLE PipeReceiveHandle, PipeSendHandle;

extern bool IsServer;

extern AnsiString ServerHostName;

extern int KolKub;

extern int MaxOch;

//-----------------------подключение--------------------------------------------

void __fastcall TMainForm::PipeConnect(void)

{

  if(IsServer)

  {

    PipeReceiveHandle = CreateNamedPipe("\\\\.\\pipe\\pipe_s", PIPE_ACCESS_INBOUND,

        PIPE_TYPE_BYTE|PIPE_NOWAIT, PIPE_UNLIMITED_INSTANCES,

        1000, 1000, 5000, NULL);

    if (PipeReceiveHandle == INVALID_HANDLE_VALUE)

    {

        Application->MessageBox("Ошибка при создании pipe на сервере","Ошибка",MB_OK+MB_ICONHAND);

        TimerPipe->Enabled = false;

        Application->Terminate();

    }

    TimerPipe->Enabled = true;

  }

  else

  {

    PipeReceiveHandle = CreateNamedPipe("\\\\.\\pipe\\pipe_c", PIPE_ACCESS_INBOUND,

        PIPE_TYPE_BYTE|PIPE_NOWAIT, PIPE_UNLIMITED_INSTANCES,

        1000, 1000, 5000, NULL);

    if (PipeReceiveHandle == INVALID_HANDLE_VALUE)

    {

        Application->MessageBox("Ошибка при создании pipe на клиенте","Ошибка",MB_OK+MB_ICONHAND);

        TimerPipe->Enabled = false;

        Application->Terminate();

    }

    TimerPipe->Enabled = true;

    char Buf[100];

    sprintf(Buf, "\\\\%s\\pipe\\pipe_s", ServerHostName.c_str());

    PipeSendHandle = CreateFile(Buf, GENERIC_WRITE, FILE_SHARE_READ, NULL, OPEN_EXISTING, 0, NULL);

    if (PipeSendHandle == INVALID_HANDLE_VALUE)

    {

        int rc;

        rc=GetLastError();  //5   51

        Application->MessageBox("Ошибка при подключении к pipe на сервере","Ошибка",MB_OK+MB_ICONHAND);

        Application->Terminate();

    }

    char CompName[50];

    unsigned long cnl = 50;

    GetComputerName(CompName, &cnl);

    int i=StrLen(CompName);

    if(i>=50)

    {

       CompName[49]='\0';

    }

    unsigned long cbWritten;

    char BufExchange[100];

    strcpy(BufExchange,"connect;");

    strcat(BufExchange,CompName);

    WriteFile(PipeSendHandle, BufExchange, i+9, &cbWritten, NULL);

  }

}

//---------------прием и accept--------------------------------------

void __fastcall TMainForm::TimerPipeTimer(TObject *Sender)

{

 int      Rc;

 DWORD    cbRead;

 DWORD    cbWritten;

 char     Buf[100];

 ConnectNamedPipe(PipeReceiveHandle, NULL);

 Rc = GetLastError();

 if (Rc == ERROR_PIPE_CONNECTED) //535

 {

    if (ReadFile(PipeReceiveHandle, Buf, sizeof(Buf)-1, &cbRead, NULL))

    {

        if(LeftStr(AnsiString(Buf),7)=="connect")

        {

           char *Buftmp;

           char BufConnect[150];

           Buftmp=AnsiStrScan(Buf,';');

           Buftmp++;

           sprintf(BufConnect, "\\\\%s\\pipe\\pipe_c", Buftmp);

           PipeSendHandle = CreateFile(BufConnect, GENERIC_WRITE, FILE_SHARE_READ, NULL,

                        OPEN_EXISTING, 0, NULL);

           if (PipeSendHandle == INVALID_HANDLE_VALUE)

           {

                Application->MessageBox("Ошибка при подключении к pipe на клиенте","Ошибка",MB_OK+MB_ICONHAND);

                Application->Terminate();

           }

           char *strPered=DannieToChar(0,KolKub,MaxOch);

           PipeSend(strPered);

           InterfaceBeginNewGame();

           ChangeInterfacePerehodHoda(1);

        }

        else

        {

           if(IsVisitApplicationBox) return;

           Priem(CharToMas(Buf));

        }

    }

 }

}

//-----------------отправка-----------------------------------------------------

void __fastcall TMainForm::PipeSend (char* Buf)

{

 unsigned long cbWritten=0;

 WriteFile(PipeSendHandle, Buf, strlen(Buf)+1, &cbWritten,NULL);

}

//-------------------разрыв соединения-----------------------------------------

void __fastcall TMainForm::PipeCloseConnection(void)

{

 CloseHandle(PipeSendHandle);

 CloseHandle(PipeReceiveHandle);

 TimerPipe->Enabled = false;

}


Mailslot.cpp

//---------------------------------------------------------------------------

#pragma hdrstop

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include "MailSlot.h"

#include "Podkluch.h"

#include "Main.h"

//------------------------------------------------------------------------------

#pragma package(smart_init)

HANDLE ReceiveMailslotHandle, SendMailslotHandle;

int HisPrevNomMessage=0;

int MyCurrNomMessage=0;

extern bool IsServer;

extern AnsiString ServerHostName;

extern int KolKub;

extern int MaxOch;

//-----------------------подключение--------------------------------------------

void __fastcall TMainForm::MailSlotConnect(void)

{

 if(IsServer)

 {

    ReceiveMailslotHandle = CreateMailslot("\\\\.\\mailslot\\msserver", 0, MAILSLOT_WAIT_FOREVER, NULL);

    if (ReceiveMailslotHandle == INVALID_HANDLE_VALUE)

    {

        Application->MessageBox("Ошибка при создании mailslot","Ошибка",MB_OK+MB_ICONHAND);

        Application->Terminate();

    }

    TimerMailSlot->Enabled = true;

 }

 else

 {

    ReceiveMailslotHandle = CreateMailslot("\\\\.\\mailslot\\msclient", 0, MAILSLOT_WAIT_FOREVER, NULL);

    if (ReceiveMailslotHandle == INVALID_HANDLE_VALUE)

    {

        Application->MessageBox("Ошибка при создании mailslot","Ошибка",MB_OK+MB_ICONHAND);

        Application->Terminate();

    }

    TimerMailSlot->Enabled = true;

    char BufConnect[70];

    sprintf(BufConnect, "\\\\%s\\mailslot\\msserver" , ServerHostName.c_str());

    SendMailslotHandle = CreateFile(BufConnect, GENERIC_WRITE, FILE_SHARE_READ, NULL, OPEN_EXISTING, 0, NULL);

    if (SendMailslotHandle == INVALID_HANDLE_VALUE)

    {

        Application->MessageBox("Ошибка при открытии mailslot","Ошибка",MB_OK+MB_ICONHAND);

        Application->Terminate();

    }

    char CompName[50];

    unsigned long cnl = 50;

    GetComputerName(CompName, &cnl);

    int i=StrLen(CompName);

    if(i>=50)

    {

       CompName[49]='\0';

    }

    unsigned long cbWritten;

    char BufExchange[50];

    MyCurrNomMessage=1;

    strcpy(BufExchange,"1;");

    strcat(BufExchange,CompName);

    WriteFile(SendMailslotHandle,BufExchange, strlen(BufExchange)+1, &cbWritten, NULL);

 }

}

//-----------------------прием и accept-----------------------------------------

void __fastcall TMainForm::TimerMailSlotTimer(TObject *Sender)

{

 if(IsVisitApplicationBox) return;

 int rc;

 unsigned long cbMessages, cbMsgNumber, cbRead;

 char *BufExchange;

 rc = GetMailslotInfo(ReceiveMailslotHandle, NULL, &cbMessages, &cbMsgNumber, NULL);

 if (!rc)

 {

     Application->MessageBox("Ошибка GetMailslotInfo","Ошибка",MB_OK+MB_ICONHAND);

     Application->Terminate();

 }

 if (cbMsgNumber == 0) return;

 BufExchange = new char[cbMessages];

 ZeroMemory(BufExchange, cbMessages);

 if (ReadFile(ReceiveMailslotHandle, BufExchange, cbMessages, &cbRead, NULL))

 {

     int HisCurrNomMessage;

     char Buftmp[150];

     strcpy(Buftmp,BufExchange);

     HisCurrNomMessage=atoi(strtok(BufExchange,";"));

     if(HisCurrNomMessage>HisPrevNomMessage)

     {

        HisPrevNomMessage=HisCurrNomMessage;

        char *Buf;

        Buf=AnsiStrScan(Buftmp,';');

        Buf++;

        if(IsServer && HisCurrNomMessage==1)

        {

            char BufConnect[100];

            sprintf(BufConnect, "\\\\%s\\mailslot\\msclient" , Buf);

            SendMailslotHandle = CreateFile(BufConnect, GENERIC_WRITE, FILE_SHARE_READ, NULL, OPEN_EXISTING, 0, NULL);

            if (SendMailslotHandle == INVALID_HANDLE_VALUE)

            {

                Application->MessageBox("Ошибка при открытии mailslot","Ошибка",MB_OK+MB_ICONHAND);

                Application->Terminate();

            }

            char *strPered=DannieToChar(0,KolKub,MaxOch);

            MailSlotSend(strPered);

            InterfaceBeginNewGame();

            ChangeInterfacePerehodHoda(1);

        }

        else

        {

            Priem(CharToMas(Buf));

        }

     }

 }

 delete [] BufExchange;

}

//------------------------отправка----------------------------------------------

void __fastcall TMainForm::MailSlotSend(char *Buf)

{

 unsigned long cbWritten;

 char BufExchange[100];

 MyCurrNomMessage++;

 itoa(MyCurrNomMessage,BufExchange,10);

 strcat(BufExchange,";");

 strcat(BufExchange,Buf);

 WriteFile(SendMailslotHandle, BufExchange, strlen(BufExchange)+1, &cbWritten, NULL);

}

//----------------------разрыв соединения---------------------------------------

void __fastcall TMainForm::MailSlotCloseConnection(void)

{

 CloseHandle(SendMailslotHandle);

 CloseHandle(ReceiveMailslotHandle);

 TimerMailSlot->Enabled = false;

 MyCurrNomMessage=0;

 HisPrevNomMessage=0;

}


Страницы: 1, 2, 3, 4, 5, 6, 7



Реклама
В соцсетях
рефераты скачать рефераты скачать рефераты скачать рефераты скачать рефераты скачать рефераты скачать рефераты скачать