Клиент подключается к серверу, но не выводит от него сообщение

@ASCII · Регистрация: 15.12.2013

Студворк — интернет-сервис помощи студентам

Всем привет, начал изучать winsock и socket API, по статье Криса Касперски "Самоучитель игры на Winsock", скопировал примеры tcp клиента и сервера, но проблема в том, что клиент подключается к серверу, но не выводит сообщение от сервера.

Сервер же принимает запрос на подключение клиента, если успех, то создается отдельный поток для клиента и отсылается строка - Hello user!

Которая по идее должна вывестись клиентом, но этого не происходит.

сервер:

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
#define _WINSOCK_DEPRECATED_NO_WARNINGS
#include <iostream>
#include <string>
#include <clocale>
#include <WinSock2.h>
#include <Windows.h>
#pragma comment(lib, "Ws2_32.lib")
 
#define PORT 666
#define wait_func system("pause >> void");
 
int connectClients = 0;
 
DWORD WINAPI inOutWithClient(LPVOID clientSocket)
{
    SOCKET mySocket = ((SOCKET *)clientSocket)[0];
    char buf[20 * 1024];
    int bytesOfUser;
 
    #define HELLO "Hello user!"
 
    send(mySocket, HELLO, sizeof(HELLO), 0);
 
    while ( (bytesOfUser = recv(mySocket, buf, sizeof(buf), 0)) && bytesOfUser != SOCKET_ERROR)
    {
        send(mySocket, buf, bytesOfUser, 0);
    }
 
    connectClients--;
    std::cout << "user disconnected" << std::endl;
 
    closesocket(mySocket);
    return 0;
}
 
void crashReport(const std::string &report)
{
    std::cout << report << std::endl;
    wait_func
    exit(1);
}
 
int main(int argc, char *argv[])
{
    using namespace std;
    setlocale(LC_ALL, "Russian");
 
    char BUFFER[1024];
 
    if (WSAStartup(MAKEWORD(1, 1), (WSADATA *)BUFFER))
    {
        crashReport("Не удалось инициализировать библиотеку WinSock" + WSAGetLastError());
    }
 
    SOCKET mainSock;
 
    if ((mainSock = socket(AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET)
    {
        WSACleanup();
        crashReport("Не удалось создать объект сокета.");       
    }
 
    sockaddr_in local_server;
    local_server.sin_family = AF_INET;
    local_server.sin_port = htons(PORT);
    local_server.sin_addr.s_addr = 0;
 
    if (bind(mainSock, (sockaddr *)&local_server, sizeof(local_server)))
    {
        closesocket(mainSock);
        WSACleanup();
        crashReport("Не удалось связать сокет с локальным адресом " + WSAGetLastError());
    }
 
    if (listen(mainSock, 0x10))
    {
        closesocket(mainSock);
        WSACleanup();
        crashReport("Ошибка прослушивания запросов " + WSAGetLastError());
    }
 
    cout << "Ожидание подключений..." << endl;
 
    SOCKET clientSock = 0;  // сокет для клиента
    sockaddr_in clientAddr; // адрес клиента(заполняется системой)
 
    int clientAddrSize = sizeof(clientAddr);    // функции accept требуется передать размер структуры
 
    // цикл извлечения запросов на подключение из очереди
 
    while ( (clientSock = accept(clientSock, (sockaddr *)&clientAddr, &clientAddrSize)) )
    {
        connectClients++;
        hostent *host;
 
        host = gethostbyaddr((char *)&clientAddr.sin_addr.s_addr, 4, AF_INET);
 
        cout << "+" << (host ? host->h_name : "") << " [" << inet_ntoa(clientAddr.sin_addr) << "] connected!" << endl;
 
        DWORD nextThread;
        CreateThread(NULL, NULL, inOutWithClient, &clientSock, NULL, &nextThread);
    }
 
    closesocket(mainSock);
    WSACleanup();
 
    wait_func
    return 0;
}

клиент:

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
#define _WINSOCK_DEPRECATED_NO_WARNINGS
#include <iostream>
#include <WinSock2.h>
#include <Windows.h>
#include <clocale>
#pragma comment(lib, "Ws2_32.lib")
 
#define PORT 666
#define SERVER_ADDRESS "127.0.0.1"
 
int main(int argc, char *argv[])
{
    using namespace std;
    setlocale(LC_ALL, "Russian");
 
    char buffer[1024];
    WSADATA versionLib;
 
    if (WSAStartup(MAKEWORD(1, 1), &versionLib))
    {
        cout << "Error WSAStartup(): " << WSAGetLastError() << endl;
        system("pause >> void");
        return -1;
    }
 
    SOCKET mySocket;
    if ((mySocket = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    {
        cout << "Error socket: " << WSAGetLastError() << endl;
        WSACleanup();
        system("pause >> void");
        return -1;
    }
 
    // пытаемся установить соединение
    sockaddr_in destAddr;
    destAddr.sin_family = AF_INET;
    destAddr.sin_port = htons(PORT);
    hostent *hst;
 
    // пытаемя преобразовать IP адрес из символного формата в сетевой формат
    if (inet_addr(SERVER_ADDRESS) != INADDR_NONE)
    {
        destAddr.sin_addr.s_addr = inet_addr(SERVER_ADDRESS);
    }
    else
    {
        if ((hst = gethostbyname(SERVER_ADDRESS)))
        {
            ((unsigned long *)&destAddr.sin_addr)[0] = 
                ((unsigned long **)hst->h_addr_list)[0][0];
        }
        else
        {
            cout << "Invalid address: " << SERVER_ADDRESS << endl;
            closesocket(mySocket);
            WSACleanup();
            system("pause >> void");
            return -1;
        }
    }
 
    if (connect(mySocket, (sockaddr *)&destAddr, sizeof(destAddr)))
    {
        cout << "Error connection: " << WSAGetLastError() << endl;
        closesocket(mySocket);
        WSACleanup();
        system("pause >> void");
        return -1;
    }
 
    cout << "Соединение с " SERVER_ADDRESS " успешно установлено!" << endl;
 
    int nbytes;
 
    while ( (nbytes = recv(mySocket, buffer, sizeof(buffer) - 1, 0)) != SOCKET_ERROR)
    {
        buffer[nbytes] = 0;
 
        printf("Сообщение от сервера: %s\n", buffer);
        printf("S<=C: "); fgets(buffer, sizeof(buffer) - 1, stdin);
 
        if (!strcmp(buffer, "quit"))
        {
            closesocket(mySocket);
            WSACleanup();
            return 0;
        }
 
        send(mySocket, buffer, nbytes, 0);
    }
 
    cout << "Recv error: " << WSAGetLastError() << endl;
    closesocket(mySocket);
    WSACleanup();
 
    system("pause >> void");
    return 0;
}

@МАРКИЗОЧКА · 01.05.2015, 16:45

ASCII, и в чем была проблему?

@ASCII · 01.05.2015, 17:48 **[ТС]**

Я так и не понял. Не работает и все. Переписал свой вариант и все заработало... писал сонным, поэтому мог что-то упустить. Заново в этом коде ковыряться нет желания. Могу скинуть рабочий вариант Простого клиент-сервера.

@МАРКИЗОЧКА · 01.05.2015, 17:56

ASCII,

Могу скинуть рабочий вариант Простого клиент-сервера.

буду очень благодарна

@ASCII · 01.05.2015, 18:33 **[ТС]**

сервер:

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
#define _WINSOCK_DEPRECATED_NO_WARNINGS
#include <iostream>
#include <string>
#include <clocale>
#include <WinSock2.h>
#include <Windows.h>
#pragma comment(lib, "Ws2_32.lib")
 
#define wait_func system("pause >> void");
 
int main(int argc, char *argv[])
{
    using namespace std;
    setlocale(LC_ALL, "Russian");
 
    char BUFFER[1024];
 
    // инициализируем winsock2
    if (WSAStartup(MAKEWORD(1, 1), (WSADATA *)BUFFER))
    {
        cout << "WSAStartup error: " << WSAGetLastError();
        wait_func
        return -1;
    }
 
    SOCKET mainSock;
    // создаем объект сокета
    if ((mainSock = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    {
        cout << "Socket error: " << WSAGetLastError();
        WSACleanup();
        wait_func
        return -1;
    }
 
    // создаем переменную для хранения локального адреса 127.0.0.1 по умолчанию
    sockaddr_in local;
    local.sin_family = AF_INET;
    local.sin_port = htons(13);
    local.sin_addr.s_addr = 0;
 
    // связываем наш сокет с локальным адресом
    if (bind(mainSock, (sockaddr *)&local, sizeof(local)))
    {
        cout << "Bind error: " << WSAGetLastError();
        closesocket(mainSock);
        WSACleanup();
        wait_func
        return -1;
    }
 
    // становимся на прослушку запросов. Очередь ставим равной в 256 запросов
    if (listen(mainSock, 0x100))
    {
        cout << "Listen error: " << WSAGetLastError();
        closesocket(mainSock);
        WSACleanup();
        wait_func
        return -1;
    }
 
    cout << "Server listening: ";
 
    SOCKET clientSocket = 0;
    sockaddr_in clientAddr;
    int size = sizeof(clientAddr);
 
    // вытаскиваем запросы на подключение из очереди сокета прослушки
    while ((clientSocket = accept(mainSock, (sockaddr *)&clientAddr, &size)) != SOCKET_ERROR)
    {
        string sendString;
        hostent *hst = gethostbyaddr((char *)&clientAddr.sin_addr.S_un.S_addr, 4, AF_INET);
 
        cout << endl << endl << "User connected..." << endl;
        if (hst) cout << "User Name: " << hst->h_name << endl;
        cout << "IP address: " << inet_ntoa(clientAddr.sin_addr) << endl;
 
        cout << "Input answer for user: ";
 
        getline(cin, sendString);
 
        send(clientSocket, sendString.c_str(), sendString.size(), 0);
        closesocket(clientSocket);
    }
 
    closesocket(mainSock);
    WSACleanup();
    wait_func
    return 0;
}

клиент

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
#define _WINSOCK_DEPRECATED_NO_WARNINGS
#include <iostream>
#include <clocale>
#include <WinSock2.h>
#include <Windows.h>
#pragma comment(lib, "Ws2_32.lib")
 
#define waito system("pause >> void");
#define ADDRESS "127.0.0.1"
 
int main(int argc, char *argv[])
{
    using namespace std;
    setlocale(LC_ALL, "Russian");
 
    WSADATA libVersion;
    if (WSAStartup(MAKEWORD(1, 1), &libVersion))
    {
        cout << "WSAStartup error: " << WSAGetLastError() << endl;
        waito
        return -1;
    }
 
    char buffer[1024];
    int readBytes = 0;
    SOCKET mainSocket;
 
    if ((mainSocket = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    {
        cout << "Socket error: " << WSAGetLastError() << endl;
        WSACleanup();
        waito
        return -1;
    }
 
    sockaddr_in server;
    server.sin_family = AF_INET;
    server.sin_port = htons(13);
 
    if (inet_addr(ADDRESS) != INADDR_NONE)
    {
        server.sin_addr.s_addr = inet_addr(ADDRESS);
    }
    else
    {
        cout << "Inet address error: " << WSAGetLastError() << endl;
        closesocket(mainSocket);
        WSACleanup();
        waito
        return -1;
    }
 
    if (connect(mainSocket, (sockaddr *)&server, sizeof(server)))
    {
        cout << "Connection error: " << WSAGetLastError() << endl;
        closesocket(mainSocket);
        WSACleanup();
        waito
        return -1;
    }
 
    while ((readBytes = recv(mainSocket, buffer, sizeof(buffer), 0)) > 0)
    {
        buffer[readBytes] = 0;
        cout << "Ответ сервера: " << buffer << endl;
    }
 
    closesocket(mainSocket);
    WSACleanup();
    waito
    return 0;
}

Компилировал в Visual Studio 2013

Добавлено через 1 минуту
в этом варианте нет создания потока для отдельного пользователя, запросы на подключения обрабатыавются последовательно.

Убежденный · 01.05.2015, 19:55

На всякий случай добавлю, что этот код концептуально некорректный, так
как на вызовах send и recv не учитывается возможная фрагментация TCP-потока.

@МАРКИЗОЧКА · 01.05.2015, 20:39

ASCII, безумно благодарна. вы помогли мне больше чем я ожидала. после анализа вашего кода я нашла в свою ошибку.

@ASCII · 02.05.2015, 19:50 **[ТС]**

МАРКИЗОЧКА, вообще-то, не за что

Новые блоги и статьи Все статьи Все блоги /
Автоматическое создание документа при проведении другого документа Maks 29.03.2026 Реализация из решения ниже выполнена на нетиповых документах, разработанных в конфигурации КА2. Есть нетиповой документ "ЗаявкаНаРемонтСпецтехники" и нетиповой документ "ПланированиеСпецтехники". В. . .	Настройка движения справочника по регистру сведений Maks 29.03.2026 Решение ниже реализовано на примере нетипового справочника "ТарифыМобильнойСвязи" разработанного в конфигурации КА2, с целью учета корпоративной мобильной связи в коммерческом предприятии. . . .	Автозаполнение реквизита при выборе элемента справочника Maks 27.03.2026 Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. При выборе "Спецтехники" (Тип Справочник. Спецтехника), заполняется. . .	Сумматор с применением элементов трёх состояний. Hrethgir 26.03.2026 Тут. https:/ / fips. ru/ EGD/ ab3c85c8-836d-4866-871b-c2f0c5d77fbc Первый документ красиво выглядит, но без схемы. Это конечно не даёт никаких плюсов автору, но тем не менее. . . всё может быть. . .
Автозаполнение реквизитов при создании документа Maks 26.03.2026 Программный код из решения ниже размещается в модуле объекта документа, в процедуре "ПриСозданииНаСервере". Алгоритм проверки заполнения реализован для исключения перезаписи значения реквизита,. . .	Команды формы и диалоговое окно Maks 26.03.2026 1. Команда формы "ЗаполнитьЗапчасти". Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. В качестве источника данных. . .	Кому нужен AOT? DevAlt 26.03.2026 Решил сделать простой ланчер Написал заготовку: dotnet new console --aot -o UrlHandler var items = args. Split(":"); var tag = items; var id = items; var executable = args;. . .	Отправка уведомления на почту при создании или изменении элементов справочника Maks 24.03.2026 Программная отправка письма электронной почты на примере типового справочника "Склады" в конфигурации БП3. Перед реализацией необходимо выполнить настройку системной учетной записи электронной. . .

@МАРКИЗОЧКА 3 / 3 / 1 Регистрация: 29.05.2014 Сообщений: 148
	01.05.2015, 16:45
	ASCII, и в чем была проблему? 0

@ASCII 99 / 70 / 13 Регистрация: 15.12.2013 Сообщений: 463
	01.05.2015, 17:48 [ТС]
	Я так и не понял. Не работает и все. Переписал свой вариант и все заработало... писал сонным, поэтому мог что-то упустить. Заново в этом коде ковыряться нет желания. Могу скинуть рабочий вариант Простого клиент-сервера. 0

Убежденный Ушел с форума 16481 / 7444 / 1187 Регистрация: 02.05.2013 Сообщений: 11,616 Записей в блоге: 1
	01.05.2015, 19:55
	На всякий случай добавлю, что этот код концептуально некорректный, так как на вызовах send и recv не учитывается возможная фрагментация TCP-потока. 2

@МАРКИЗОЧКА 3 / 3 / 1 Регистрация: 29.05.2014 Сообщений: 148
	01.05.2015, 20:39
	ASCII, безумно благодарна. вы помогли мне больше чем я ожидала. после анализа вашего кода я нашла в свою ошибку. 0

@ASCII 99 / 70 / 13 Регистрация: 15.12.2013 Сообщений: 463
	02.05.2015, 19:50 [ТС]
	МАРКИЗОЧКА, вообще-то, не за что 0

Клиент подключается к серверу, но не выводит от него сообщение

Решение