0
我正在尝试使用boost单元测试来测试我的boost asio套接字侦听器。监听器的目的是简单地监听一个端口并读取所有内容并将其保存到一个队列中并发回一个http响应头。即使长时间等待，C++线程也不会加入
作为第一步，我创建了一个客户端向侦听器发送消息并读取来自侦听器的响应消息。我还创建了一个线程来启动侦听器。主线程将发送和接收来自Listener的消息。我可以在客户端和列表程序之间发送和接收消息。但是当我尝试加入时，它并没有加入并继续等待加入（我猜）。
请帮助我出了什么问题。
在此先感谢。
Listener.hpp
#ifndef Listener_hpp
#define Listener_hpp
#include <iostream>
#include <stdio.h>
#include <atomic>
#include <boost/asio.hpp>
#include "sharedQueue.hpp"
using namespace std;
using namespace boost;
using boost::asio::ip::tcp;
class Listener{
private:
int port;
std::atomic<bool> m_stop;
boost::system::error_code error;
boost::asio::io_service io_service;
std::shared_ptr<sharedQueue> queue_ptr;
void saveMessageToQueue(std::string,std::string);
Listener(int portToListen, std::shared_ptr<sharedQueue> queue_unique_ptr);
Listener(const Listener&);
Listener& operator=(const Listener&);
public:
static Listener& getInstance(int portToListenOn, std::shared_ptr<sharedQueue> queue_unique_ptr);
void listen();
};
#endif /* Listener_hpp */
Listener.cpp
#include "Listener.hpp"
Listener::Listener(int portToListen, std::shared_ptr<sharedQueue> queue_unique_ptr):port(portToListen), queue_ptr(queue_unique_ptr),m_stop(false)
{;}
Listener& Listener::getInstance(int portToListenOn, std::shared_ptr<sharedQueue> queue_unique_ptr)
{
static Listener instance(portToListenOn, queue_unique_ptr);
return instance;
}
void Listener::stopListen(){
m_stop = true;
}
void Listener::listen()
{
try{
tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), port));
while(!m_stop)
{
std::cout<<"Server is listening on port "<<port<<std::endl;
boost::asio::ip::tcp::socket socket(io_service);
acceptor.accept(socket);
std::cout<<"Connection Request Accepted "<<std::endl;
std::array<char, 512> buf;
socket.read_some(boost::asio::buffer(buf), error);
std::string responseBack =" HTTP:300";
boost::asio::write(socket, boost::asio::buffer(responseBack, responseBack.size()), error);
}
}
catch (std::exception& e)
{
std::cerr <<"Listener Exception : "<< e.what() << std::endl;
exit(0);
}
}
sharedQueue.hpp
#ifndef SharedQueue_hpp
#define SharedQueue_hpp
#include <stdio.h>
#include <iostream>
class sharedQueue{
public:
sharedQueue(){};
void pushToQueue(std::string str){};
};
#endif /* SharedQueue_hpp */
ClientTestHelper.hpp
#ifndef ClientTestHelper_hpp
#define ClientTestHelper_hpp
#include <iostream>
#include <boost/asio.hpp>
using namespace std;
class ClientTestHelper
{
string address = "";
public:
ClientTestHelper(std::string addressToPush){
this->address = addressToPush;
};
~ClientTestHelper(){};
std::string sendMessage(string message);
};
#endif /* ClientTestHelper_hpp */
ClientTestHelper.cpp
#include "ClientTestHelper.hpp"
std::string ClientTestHelper::sendMessage(string message){
boost::asio::io_service io_service;
boost::asio::ip::tcp::resolver resolver(io_service);
boost::asio::ip::tcp::resolver::query query(address, boost::asio::ip::resolver_query_base::numeric_service);
boost::asio::ip::tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);
boost::asio::ip::tcp::socket socket(io_service);
boost::asio::connect(socket, endpoint_iterator);
boost::asio::streambuf writeBuffer;
boost::asio::streambuf readBuffer;
std::string str = message;
boost::system::error_code error;
boost::asio::write(socket, boost::asio::buffer(str, str.size()), error);
std::array<char,1024> buf;
socket.read_some(boost::asio::buffer(buf), error);
std::string respo = buf.data();
cout<<respo<<std::endl;
return respo;
}
ListenerTest.hpp
#ifndef ListenerTest_hpp
#define ListenerTest_hpp
#define BOOST_TEST_DYN_LINK
#define BOOST_TEST_MAIN
#include <iostream>
#include <stdio.h>
#include <thread>
#include <boost/test/unit_test.hpp>
#include "Listener.hpp"
#include "ClientTestHelper.hpp"
#include "SharedQueue.hpp"
struct ListenerTestFixture{
public:
void startListen(Listener &receiver){
receiver.listen();
}
std::shared_ptr<sharedQueue> myQueue = std::make_shared<sharedQueue>();
Listener &receiver = Listener::getInstance(8282, myQueue);
void doRun(){
receiver.listen();
}
ClientTestHelper *client = new ClientTestHelper("8282");
ListenerTestFixture(){};
~ListenerTestFixture(){};
};
#endif /* ListenerTest_hpp */
ListenerTest.cpp
#include "ListenerTest.hpp"
BOOST_FIXTURE_TEST_CASE(connectionTest, ListenerTestFixture)
{
std::thread t1(&ListenerTestFixture::doRun, *this);
std::string response = "";
response = client->sendMessage("SomeRandom Messages \r\n\r\n\r\n");
//receiver.~Listener();
receiver.stopListen();
std::cout<<"Response Received "<<response;
t1.join();
std::cout<<"Finished Testing "<<endl;
}
控制台输出对于澄清：
Running 1 test case...
Server is listening on port 8585
Connection Request Accepted
Server is listening on port 8585
HTTP:300
在这个执行没有停止之后等待加入。
编辑：修改后的监听器类添加成员m_stop和stopListen（），更改为（;;）成while（！m_stop）。包含头文件。
为什么你手动调用一个对象的析构函数？ – Blacktempel
为了加入，线程函数必须退出。 “听”会退出吗？ –
请提供示例代码SSCCE。由于错误 – sehe