"По запросу пользователя "current_clients " вернуть список клиентов, подключенных к серверу в настоящее время"

В ходе разработки сервера, была создана функция, выполняющая по запросу пользователя "id_clients" возврат id всех подключенных к серверу клиентов.

Рисунок 3.1 - запуск сервера.

Рисунок 3.2 - запуск приложения "Клиент"

Рисунок 3.3 - передача имени в приложение "Клиент"

Рисунок 3.4 - запуск функции в приложении "Клиент"

Рисунок 3.5 - результат работы функции

Заключение

1. А.Ю. Молчанов. Системное программное обеспечение: Учебник для ВУЗов. 3-е изд. - СПБ.: Питер, 2010. - 400 с. : ил.

2. А.Ю. Молчанов. Системное программное обеспечение. Лабораторный практикум. - СПБ.: Питер, 2005. - 284 с. : ил.

3. Робин Хантер Основные концепции компиляторов = The Essence of Compilers. - М.: "Вильямс", 2002. - С. 256. - ISBN 5-8459-0360-2

4. Ашарина, И.В. Основы программирования на языках С и С++: Курс лекций для высших учебных заведений / И.В. Ашарина. - М.: Гор. линия-Телеком, 2012. - 208 c.

5. Страуступ, Б. Язык программирования С++. Специальное издание / Б. Страуступ. - М.: Бином, 2015. - 1136 c.

6. Фридман, А.Л. Основы объектно-ориентированного программирования на языке Си++ / А.Л. Фридман. - М.: Гор. линия-Телеком, 2012. - 234 c.

7. Гавриков, М.М. Теоретические основы разработки и реализации языков программирования: Учебное пособие / М.М. Гавриков, А.Н. Иванченко, Д.В. Гринченков. - М.: КноРус, 2010. - 184 c.

Приложение А.

Программа сервер

#include <iostream>

#include <winsock2.h>

#include <conio.h>

#include <list>

using namespace std;

WSADATA WsaData;

u_short Port=1111;

SOCKET socket_server;

SOCKET socket_client;

sockaddr_in local_addr;

sockaddr_in client_addr;

int client_count;

char Exit;

// list

list <string> user;

void replas(char *buff, int recv){

string s = string(buff);

string userT = "СПИСОК ПОДКЛЮЧЕНЫХ:";

if(s=="current_clients"){

for (auto iter = user.begin(); iter != user.end(); iter++)

{

//cout " *iter " "\t";

userT += *iter;

userT += " ";

}

strcpy(buff,userT.c_str());

}

}

DWORD WINAPI ClientFunction(LPVOID client_socket)

{

SOCKET mysock;

char buff[20*1024];

int b_recv;

mysock=((SOCKET*) client_socket)[0];

string name;

string S="Доступ разрешен!\n ВВЕДИТЕ ВАШЕ ИМЯ!";

send(mysock,S.c_str(),S.length()+1,0);

Sleep(10);

S="Доступ разрешен!\n ВВЕДИТЕ ВАШЕ ИМЯ!";

send(mysock,S.c_str(),S.length()+1,0); while((b_recv=recv(mysock,&buff[0],sizeof(buff),0))&&b_recv!=SOCKET_ERROR) // слушаем имя

{

if(buff[0]==0x1B) break;

name = string(buff);

string S="Здавствуйте, " + name + "!";

send(mysock,S.c_str(),S.length()+1,0);

user.push_back(name);

cout""Новое соеденение: " " name " endl;

break;

}

while((b_recv=recv(mysock,&buff[0],sizeof(buff),0))&&b_recv!=SOCKET_ERROR)

{

if(buff[0]==0x1B) break;

replas(buff, b_recv);

send(mysock,&buff[0],b_recv,0);

}

client_count--;

cout " "Разрыв соединения: " " name " endl;

closesocket(mysock);

for (auto iter = user.begin(); iter != user.end(); iter++)

{

if(*iter==name){

user.remove(*iter);

break;

}

}

return 0;

}

DWORD WINAPI AsseptFunction(LPVOID serv_socket)

{

int client_addr_size=sizeof(client_addr);

while((socket_client=accept(((SOCKET*)serv_socket)[0],(sockaddr*) &client_addr,

&client_addr_size)))

{

client_count++;

HOSTENT *host;

host=gethostbyaddr((char*) &client_addr.sin_addr.s_addr,4,AF_INET);

string string_msg=(const char*)host->h_name;

//////

//cout " "Новое соединение: "+string_msg " endl;

cout " client_count " " пользователей подключено." " endl;

DWORD id;

CreateThread(NULL,0,ClientFunction,&socket_client,0,&id);

}

return 0;

}

int main()

{

setlocale (0, "rus");

//инициализация библиотеки winsock

int err=WSAStartup(0x0202,&WsaData);

if(err==SOCKET_ERROR)

{

cout " "Ошибка загрузки библиотеки winsock: "+WSAGetLastError() "

endl;

return 1;

}

else

{

cout " "Загрузка библиотеки прошла успешно." " endl;

}

//Создаем сокет

socket_server=socket(AF_INET,SOCK_STREAM,0);

if(socket_server==INVALID_SOCKET)

{

cout " "Невозможно создать сокет: "+WSAGetLastError();

WSACleanup();

return 1;

}

else

{

//связываем соект с адресом

local_addr.sin_family=AF_INET;

local_addr.sin_port=htons(Port);

local_addr.sin_addr.s_addr=0;

if(bind(socket_server,(sockaddr*) &local_addr,sizeof(local_addr)))

{

cout " "Не удается установить связь" " endl;

closesocket(socket_server);

WSACleanup();

return 1;

}

else

{

//связали сокет и порт удачно, переходим в режим прослушивания

if(listen(socket_server,0x05))

{

cout " "Невозможно прослушивать порт" " endl;

closesocket(socket_server);

WSACleanup();

return 1;

}

}

cout " "Ожидается соединение..." " endl;

}

DWORD id1;

CreateThread(NULL,0,AsseptFunction,&socket_server,0,&id1);

cout " "Процесс пошел!" " endl;

cout " "Для остановки сервера нажмите Esc" " endl;

//Бесконечный цикл сервера

while(true)

{

Exit=getch();

if(Exit==0x1B)

{

cout " "Остановка сервера " " endl;

break;

}

}

closesocket(socket_server);

WSACleanup();

cout " "Сервер остановлен." " endl;

return 0;

}

Приложение Б.

Программа клиент

#if defined(UNICODE) && !defined(_UNICODE)

#define _UNICODE

#elif defined(_UNICODE) && !defined(UNICODE)

#define UNICODE

#endif

#include <winsock2.h>

#include <windows.h>

#include <tchar.h>

int retVal=0;

int err1;

WORD ver=MAKEWORD(2,2);

WSADATA WsaData;

LPHOSTENT hostEnt;

SOCKET clientSock;

SOCKADDR_IN serverInfo;

char szResponse [20*1024];

#define EDIT_MESSAGE 1001

#define EDIT_TEXT 1002

#define BUTTON_SEND 1003

HWND MessageEdit;

HWND TextEdit;

/* Declare Windows procedure */

LRESULT CALLBACK WindowProcedure (HWND, UINT, WPARAM, LPARAM);

DWORD WINAPI ReciverFunction(LPVOID serverSocket);

/* Make the class name into a global variable */

TCHAR szClassName[ ] = _T("KlientWindowsApp");

int WINAPI WinMain (HINSTANCE hThisInstance,

HINSTANCE hPrevInstance,

LPSTR lpszArgument,

int nCmdShow)

{

HWND hwnd; /* This is the handle for our window */

MSG messages; /* Here messages to the application are saved */

WNDCLASSEX wincl; /* Data structure for the windowclass */

/* The Window structure */

wincl.hInstance = hThisInstance;

wincl.lpszClassName = szClassName;

wincl.lpfnWndProc = WindowProcedure;

wincl.style = CS_DBLCLKS;

/* Catch double-clicks */

wincl.cbSize = sizeof (WNDCLASSEX);

/* Use default icon and mouse-pointer */

wincl.hIcon = LoadIcon (NULL, IDI_APPLICATION);

wincl.hIconSm = LoadIcon (NULL, IDI_APPLICATION);

wincl.hCursor = LoadCursor (NULL, IDC_ARROW);

wincl.lpszMenuName = NULL; /* No menu */

wincl.cbClsExtra = 0; /* No extra bytes after the window class */

wincl.cbWndExtra = 0; /* structure or the window instance */

/* Use Windows's default colour as the background of the window */

wincl.hbrBackground = (HBRUSH) COLOR_BTNSHADOW;

/* Register the window class, and if it fails quit the program */

if (!RegisterClassEx (&wincl))

return 0;

/* The class is registered, let's create the program*/

hwnd = CreateWindowEx (

0, /* Extended possibilites for variation */

szClassName, /* Classname */

_T("Prilozhenie - client"), /* Title Text */

WS_OVERLAPPEDWINDOW, /* default window */

CW_USEDEFAULT, /* Windows decides the position */

CW_USEDEFAULT, /* where the window ends up on the screen */

544, /* The programs width */

375, /* and height in pixels */

HWND_DESKTOP, /* The window is a child-window to desktop */

NULL, /* No menu */

hThisInstance, /* Program Instance handler */

NULL /* No Window Creation data */

);

MessageEdit=CreateWindowEx(WS_EX_CLIENTEDGE,"edit",NULL,WS_VISIBLE|WS_CHILD|BS_RIGHT|WS_VSCROLL|ES_AUTOVSCROLL|ES_MULTILINE,10,30,514,120,hwnd,(HMENU)EDIT_MESSAGE,hThisInstance,NULL);

//??????? ?????? ????????

TextEdit=CreateWindowEx(WS_EX_CLIENTEDGE, "edit", NULL,WS_VISIBLE|WS_CHILD|BS_RIGHT|WS_VSCROLL|ES_AUTOVSCROLL|ES_MULTILINE,10,160,514,100,hwnd,(HMENU)EDIT_TEXT,hThisInstance,NULL);

/* Make the window visible on the screen */

CreateWindow (TEXT("button"), TEXT("Peredat"),WS_VISIBLE|WS_CHILD|BS_DEFPUSHBUTTON,10,290,514,27,hwnd,(HMENU)BUTTON_SEND,hThisInstance,NULL);

ShowWindow (hwnd, nCmdShow);

/* Run the message loop. It will run until GetMessage() returns 0 */

while (GetMessage (&messages, NULL, 0, 0))

{

/* Translate virtual-key messages into character messages */

TranslateMessage(&messages);

/* Send message to WindowProcedure */

DispatchMessage(&messages);

}

/* The program return-value is 0 - The value that PostQuitMessage() gave */

return messages.wParam;

}

/* This function is called by the Windows function DispatchMessage() */

LRESULT CALLBACK WindowProcedure (HWND hwnd, UINT message, WPARAM wParam, LPARAM lParam)

{

switch (message) /* handle the messages */

{

case WM_CREATE:

err1=WSAStartup(ver,(LPWSADATA)&WsaData);

if(err1==SOCKET_ERROR){

MessageBox(hwnd,"Oshibka zagruzki biblioteki","ERROR",0);

}

hostEnt=gethostbyname("localhost");

if(!hostEnt){

MessageBox(hwnd,"Nevozmozhno poluchit imya hosta","ERROR",0);

WSACleanup();

} clientSock=socket(PF_INET,SOCK_STREAM,IPPROTO_TCP);

if(clientSock==SOCKET_ERROR){

MessageBox(hwnd, "Nevozmozhno sozdat socet", "ERROR",0);

WSACleanup();

}

serverInfo.sin_family=PF_INET;

serverInfo.sin_addr=*((LPIN_ADDR)*hostEnt->h_addr_list);

serverInfo.sin_port=htons(1111);

retVal=connect(clientSock,(LPSOCKADDR)&serverInfo,sizeof(serverInfo));

if(retVal==SOCKET_ERROR)

{

MessageBox(hwnd,"Soedinit nevozmozho","ERROR",0);

closesocket(clientSock);

WSACleanup();

}

DWORD id;

CreateThread(NULL,0,ReciverFunction,&clientSock,0,&id);

break;

case WM_CLOSE:

closesocket(clientSock);

WSACleanup();

DestroyWindow(hwnd);

break;

case WM_COMMAND:

if((HIWORD(wParam)==0)&&(LOWORD(wParam)==BUTTON_SEND)){

char Message[255];

GetWindowText(MessageEdit,Message,255);

SetWindowText(MessageEdit,"");

retVal=send(clientSock,Message,sizeof(Message),0);

if(retVal==SOCKET_ERROR)

{

MessageBox(hwnd,"Peredacha nevozmozhna","ERROR",0);

WSACleanup();

}

memset(Message,0,sizeof(Message));

}

break;

case WM_DESTROY: {

PostQuitMessage(0);

break;

}

/* All other messages (a lot of them) are processed using default procedures */

default:

return DefWindowProc(hwnd, message, wParam, lParam);

}

return 0;

}

DWORD WINAPI ReciverFunction(LPVOID serverSocket)

{

SOCKET mysock;

mysock = ((SOCKET*)serverSocket)[0];

char buff[20*1024];

int b_recv;

while ((b_recv=recv(mysock,&buff[0],sizeof(buff),0))&&b_recv!=SOCKET_ERROR)

{

SetWindowText(TextEdit,buff);

memset(buff,0,sizeof(buff));

}

}

Размещено на Allbest.ru