Използвам zeromq (последна версия, 2012.04.04), c++, ms срещу 2008 (x86 издание/дебъгване), windows 7 x64. Опитвам се да кодирам проста система клиент-сървър.
проблем
Проблемът ми е увисване на компютъра при команда recv() на Windows 7, когато много клиенти се свързват към сървъра едновременно.
При Windows Vista резултатът е като при Windows XP - клиентът има грешка:
http://research.makseq.com/testZMQ/2.Vista.png
http://research.makseq.com/testZMQ/1.PNG
След този отказ клиентите не могат да се свържат със сървъра, те пишат:
„Неуспешно твърдение: Адресът вече се използва: ... "
Ето изходния код:
http://research.makseq.com/testZMQ/testZMQ.rar
Как да използвам:
1) "testZMQ.exe сървър" към стартиране на сървъра,
2) натиснете enter и задръжте в "testZMQ.exe", за да стартирате много-много-много клиенти.
Опитайте да стартирате сървъра няколко пъти: Мисля, че тази грешка се случва, когато сървърът стартира два и повече пъти.
#include "stdafx.h"
#include "../Libraries/zeromq/include/zmq.h"
#include "../Libraries/zeromq/include/zhelpers.hpp"
#include <string>
using namespace std;
#ifdef WIN32
#pragma comment(lib, "../Libraries/zeromq/libzmq.lib")
#endif
//-----------------------------------------------------------------------------
int server()
{
cout << ":: Server ::" << endl;
zmq::context_t context(1);
zmq::socket_t server(context, ZMQ_REP);
server.bind("tcp://*:7774");
while (1) {
// receive
zmq::message_t messageR;
cout << "debug point 1" << endl;
server.recv(&messageR); // <== dead hanging here
cout << "debug point 2" << endl;
string recieved = string(static_cast<char*>(messageR.data()), messageR.size());
// send
string reply = "do something";
zmq::message_t messageS(reply.size());
memcpy(messageS.data(), reply.data(), reply.size());
cout << "debug point 3" << endl;
server.send(messageS);
cout << "debug point 4" << endl;
}
return 0;
}
//-----------------------------------------------------------------------------
int client()
{
cout << ":: Client ::" << endl;
// connect
zmq::context_t context(1);
zmq::socket_t *client = new zmq::socket_t (context, ZMQ_REQ);
client->connect("tcp://localhost:7774");
int linger = 0;
client->setsockopt (ZMQ_LINGER, &linger, sizeof (linger));
// send
string reply = "hello";
zmq::message_t messageS(reply.size());
memcpy(messageS.data(), reply.data(), reply.size());
client->send(messageS);
// receive
zmq::message_t messageR;
client->recv(&messageR);
string recieved = string(static_cast<char*>(messageR.data()), messageR.size());
// close
client->close();
delete client;
zmq_term(&context);
return 0;
}
int _tmain(int argc, _TCHAR* argv[])
{
if (argc == 2) server();
else client();
return 0;
}
Какво правя грешно?