Блог

Я разрабатываю клиент сокета TCP. Я пытаюсь написать клиент, у которого есть отдельный поток для отправки и получения данных. но когда я использую поток, появляется ошибка во время выполнения.

Процесс происходит следующим образом:

main.cpp:

 #include <iostream>
#include <thread>
#include <string>
#include <chrono>
#include <WS2tcpip.h>

#pragma comment(lib, "ws2_32.lib")

#include "TCPConnection.h"

SOCKET sock;

void SendRecive(SOCKET *isock) {
    // Do-While loop to send and recive data
    char buf[4096];

    while (true) {
        // Prompt the user for some text
        cout << "> ";
        // Wait for response
        ZeroMemory(buf, 4096);
        auto byteRecived = recv(*isock, buf, 4096, 0);
        if (byteRecived <= 0) continue;
        // Echo response to console
        cout << "SERVER> " << string(buf, 0, byteRecived) << endl;
    }
}

using namespace std;

int main() {
    TCPConnection tcpconn("192.168.1.4", 7705, amp;sock);
    SendRecive(amp;sock);
    return 0;
}
 

TCPConnection.h:

 //
// Created by Hamed on 8/21/2021.
//

#ifndef TCPCLIENT_TCPCONNECTION_H
#define TCPCLIENT_TCPCONNECTION_H

#include <iostream>
#include <thread>
#include <string>
#include <WS2tcpip.h>

#pragma comment(lib, "ws2_32.lib")

using namespace std;

class TCPConnection {
public:
    SOCKET *isock;
    TCPConnection(string ServerIPAddress, int ServerPort, SOCKET *sock);
    ~TCPConnection();
};

#endif //TCPCLIENT_TCPCONNECTION_H
 

TCPConnection.cpp:

 #include "TCPConnection.h"

TCPConnection::TCPConnection(string ServerIPAddress, int ServerPort, SOCKET *sock) {
    // Initialize WinSock
    WSAData data{};
    WORD ver = MAKEWORD(2, 2);
    int wsResult = WSAStartup(ver, amp;data);
    if (wsResult != 0) {
        cerr << "Can't start winsock, Err #" << wsResult << endl;
        return;
    }

    // Create socket
    *sock = socket(AF_INET, SOCK_STREAM, 0);
    if (*sock == INVALID_SOCKET) {
        cerr << "Can't create socket, Err #" << WSAGetLastError() << endl;
        WSACleanup();
        return;
    }

    // Fill in a hint structure
    sockaddr_in hint{};
    hint.sin_family = AF_INET;
    hint.sin_port = htons(ServerPort);
    inet_pton(AF_INET, ServerIPAddress.c_str(), amp;hint.sin_addr);

    // connect to server
    int connResult = connect(*sock, (sockaddr *) amp;hint, sizeof(hint));
    if (connResult == SOCKET_ERROR) {
        cerr << "Can't connect to server, Err #" << WSAGetLastError() << endl;
        closesocket(*sock);
        WSACleanup();
        return;
    }
    isock = sock;
}



TCPConnection::~TCPConnection() {
    // Gracefully close down everything
    closesocket(*isock);
    WSACleanup();
}
 

этот код работает правильно, но когда я изменяю «main.cpp» чтобы использовать такую нить, как эта:

 int main() {
    TCPConnection tcpconn("192.168.1.4", 7705, amp;sock);    
    thread DoRunTCPRecive(SendRecive,amp;sock);
    return 0;
}
 

Я получаю ошибку отладки «Библиотека среды выполнения Microsoft Visual C » при запуске приложения.

Обновление: На самом деле я хочу иметь функцию для отправки и другую функцию для получения данных . но когда я использую join, мой код остается в текущей функции, и после этого я не могу запустить другой код.

вы должны присоединиться к потоку после его создания

     thread DoRunTCPRecive(SendRecive,amp;sock);
    DoRunTCPRecive.join()