Курсовая работа: Создание сетевой игры

                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);

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