TCP服务器的奇怪行为(使用Winsock)
weird behavior of tcp server (using winsock)
我正在为 tcp 服务器使用 winsock 和 c++ 11 线程。对于每个客户端,我创建一个新的 ReceiveThread 对象,该对象具有 std::thread 对象。Tcp 客户端是 Java 的。我想创建一个简单的广播功能。(如果有人发送消息,则服务器会将其转发给所有人)。我为客户端套接字使用包装类,其中包括互斥锁。(同步unordered_map)。每条消息都是结构化的。第一个字节是消息的长度,第二个字节表示类型,然后是实际数据。(数据的长度是已知的,第一个字节就是那个)
[编辑]我现有的代码适用于一个客户端。当第二个客户端连接时,他也可以发送消息,两个客户端都收到它。但是,如果我使用第一个客户端发送消息,服务器会在属于第二个客户端的第二个线程上接收它(顺便说一句,消息正确到达)。在此之后,服务器不会从第一个客户端接收任何内容。(我去掉了'转发给大家'的部分,因为接收部分出现了问题,我也编辑了void ReceiveThread::receive()
,现在只叫一次,以后再处理)
服务器.cpp
#include "Server.h"
#include <thread>
#include <string>
#include <winsock2.h>
#include <iostream>
#include "ReceiveThread.h"
using namespace std;
Server::Server(string ip, int port):ip(ip),port(port){
init();
}
int Server::init(){
//init the winsock library
WSADATA wsaData;
int iResult = WSAStartup(MAKEWORD(2, 2), &wsaData);
if (iResult != NO_ERROR){
cout << "Error WSAStartup!";
return -1;
}
// Create a SOCKET for listening for incoming connection requests.
listenSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (listenSocket == INVALID_SOCKET) {
cout << "Error at socket(): " << WSAGetLastError();
WSACleanup();
return -1;
}
//----------------------
// The sockaddr_in structure specifies the address family,
// IP address, and port for the socket that is being bound.
sockaddr_in service;
service.sin_family = AF_INET;
service.sin_addr.s_addr = inet_addr(ip.c_str());
service.sin_port = htons(port);
if ( ::bind(listenSocket, (SOCKADDR*)&service, sizeof(service)) == SOCKET_ERROR) {
cout << "Bind error.";
closesocket(listenSocket);
WSACleanup();
return -1;
}
//----------------------
// Listen for incoming connection requests.
// on the created socket
if (listen(listenSocket, 1) == SOCKET_ERROR) {
cout << "Error listening on socket.n";
closesocket(listenSocket);
WSACleanup();
return -1;
}
// Accept connections
acceptConnections();
}
void Server::acceptConnections(){
// Create a SOCKET for accepting incoming request.
SOCKET acceptSocket;
cout << "Waiting for clients.";
int counter = 0;
while (1){
acceptSocket = accept(listenSocket, NULL, NULL);
if (acceptSocket == INVALID_SOCKET){
cout << "Accept error";
closesocket(listenSocket);
WSACleanup();
return;
}
else{
clientSockets.add(acceptSocket);
cout << "Client connected.";
// create a new receive thread object for every client
counter++;
ReceiveThread receiveThread(clientSockets, acceptSocket,counter);
}
}
}
接收线程.cpp
#include "ReceiveThread.h"
#include <winsock2.h>
#include "Message.h"
#include <iostream>
#include <string>
using namespace std;
ReceiveThread::ReceiveThread(ClientSockList &clients, SOCKET &socket,int counter) :clients(clients), socket(socket),counter(counter){
//cout << clients.getList().size();
receiveThread = new thread(&ReceiveThread::receive, this);
}
void ReceiveThread::terminateThread(){
terminated = true;
}
void ReceiveThread::receive(){
int res;
while (!terminated){
char recvbuf[BUF_SIZE]; // BU_SIZE = 1024
int recv_len = 0;
res = recv(socket, recvbuf + recv_len, BUF_SIZE - recv_len, 0);
if (!checkSocket(res)) break;
cout << "[" << counter << "] ";
for (int i = 0; i < res; ++i){
cout << recvbuf[i];
}
cout << endl;
}
//delete receiveThread;
}
bool ReceiveThread::checkSocket(int res){
if (res == SOCKET_ERROR || res == 0){
terminated = true;
cout << endl << "Terminated" << endl;
clients.remove(socket);
closesocket(socket);
return false;
}
else{
return true;
}
}
这是我从客户端发送消息的方式:
public void sendMessageForBroadcast(String message) throws IOException {
//String m = buildMessage(message,Message.TYPE_BROADCAST);
StringBuffer buff = new StringBuffer();
buff.append(Character.toChars(message.length()));
buff.append(Character.toChars(1));
buff.append(message);
//System.out.println("Sending message: " + m + "["+m.length()+"]");
outputStream.write(buff.toString().getBytes("UTF8"));
outputStream.flush();
}
[编辑] 场景:
- 与客户连接1
- 使用客户端发送消息1
- 在服务器上接收消息(线程 1)
- 与客户联系2
- 使用客户端发送消息2
- 在服务器上接收消息(线程 2)
- 使用客户端发送消息1
- 在服务器上接收消息(线程 2) 从
- 现在开始,服务器不会从客户端接收任何内容1
您有一个严重的未定义行为案例。
这一切都从这一行开始:
ReceiveThread receiveThread(clientSockets, acceptSocket,counter);
这将创建一个ReceiveThread
对象(其构造函数创建引用this
的线程)。问题是,一旦进行了声明,变量的代码块就会结束,这使得变量超出范围并破坏对象。
一旦对象被销毁,任何取消引用前一个对象的代码this
指针(这是使用对象的非静态成员变量或函数的所有代码)都将取消引用被破坏对象的指针,从而导致所述未定义的行为。
我建议你保留一个指向线程对象的指针集合,既可以将对象保留在作用域中,直到需要销毁它,也可以保留对该对象的引用(如果您以后需要从其他线程使用它)。
还有另一个可能的未定义行为来源,因为我没有看到您初始化成员变量terminated
这意味着当您在线程中引用它时,它的值将是不确定的。
- 使用 winsock 接收 http 请求
- 如何使用winsock在c++应用程序中实现安全套接字通信
- 使用 WinSock 处理多个用户
- 使用 WinSock 时接收SOCKET_ERROR
- 使用 winsock 库发送 GET HTTP 请求时出现 400 错误请求错误
- 如何使用 winsock (c++) 发送recv 非字符数据
- 使用Winsock API同时打开TCP连接
- 如何使用Winsock LSP修改出站UDP流量
- 如何使用WINSOCK获得IP地址?c++
- 使用Winsock创建SSL连接
- 使用winsock(c++)进行文件传输
- 为什么我在使用 winsock 时没有收到 UDP 数据包?
- TCP服务器的奇怪行为(使用Winsock)
- 如何在C++中使用winsock将$getsuperglobal传递到localhost上的.php
- 在win10机器上使用winsock的UDP广播不工作
- 使用winsock,如何从IE接收POST Http消息
- 使用winsock解析DNS,服务器位于路由器后面
- 是否可以使用winsock从c++应用程序发送电子邮件?
- (GET HTTP请求)c++ sockets使用winsock.h
- 使用winsock vc++通过UDP发送数字数组