我正在开始一个新项目,同时刚刚发现 Poco Library,我觉得它非常棒。但是我有点迷茫,因为例子不多。
我有一个 ServerApplication->TCPServer->ServerSocket + TCPServerConnectionFactory->TCPServerconnection 方法,如示例所示。我按照指示从 PocoNet 类继承。现在我可以将我的服务器作为服务运行,并接收传入的连接。
我想对以下事件采取事件处理方法:在每个连接(或每个客户端)的基础上,处理事件,例如客户端套接字上可读取的数据,客户端套接字上发生错误(断开连接或超时) ), 在客户端套接字上无错误地发送数据。
我该怎么做? Poco/Foundation/Events 是我要找的东西,还是在 Poco::Net 中实现了某种机制?
我已经看到了 Poco::Net::NetExpections,但当 netcat 连接关闭时,它们似乎并没有被抛入我的 TCPServerConnection 派生类中。
最佳答案
我最终使用的是一种不同的方法,因为 TCPServer 是完全不同的野兽。按照发布的示例 here我最终得到了一个继承自 ServerApplication 的类,以及一个由 SocketReactor 本质上成为连接处理程序的类。
Deamonizer header :
class Daemon : public ServerApplication
{
public:
Daemon();
/// @Brief The main loop of the daemon, everything must take place here
int main();
};
Deamonizer 实现:
int Daemon::main()
{
// Server Socket
ServerSocket svs(2222);
// Reactor-Notifier
SocketReactor reactor;
Poco::Timespan timeout(2000000); // 2Sec
reactor.setTimeout(timeout);
// Server-Acceptor
SocketAcceptor<ConnectionHandler> acceptor(svs, reactor);
// Threaded Reactor
Thread thread;
thread.start(reactor);
// Wait for CTRL+C
waitForTerminationRequest();
// Stop Reactor
reactor.stop();
thread.join();
return Application::EXIT_OK;
}
处理程序类可以是任何东西,只要它有一个符合要求的构造函数(参见 Poco::Net 文档)。 在我的例子中,标题看起来像这样:
class ConnectionHandler
{
public:
/**
* @Brief Constructor of the Connection Handler
* @Note Each object is unique to an accepted connection
* @Param SteamSocket is the socket accepting the connections
* @See SocketAcceptor http://pocoproject.org/docs/Poco.Net.SocketAcceptor.html
* @Param SocketReactor is the reacting engine (threaded) which creates notifications about the socket
*/
ConnectionHandler(StreamSocket &, SocketReactor &);
/**
* @Brief Destructor
*/
~ConnectionHandler();
/**
* @Brief Event Handler when Socket becomes Readable, i.e: there is data waiting to be read
*/
void onSocketReadable(const AutoPtr<ReadableNotification>& pNf);
/**
* @Brief Event Handler when Socket was written, i.e: confirmation of data sent away (not received by client)
*/
void onSocketWritable(const AutoPtr<WritableNotification>& pNf);
/**
* @Brief Event Handler when Socket was shutdown on the remote/peer side
*/
void onSocketShutdown(const AutoPtr<ShutdownNotification>& pNf);
/**
* @Brief Event Handler when Socket throws an error
*/
void onSocketError(const AutoPtr<ErrorNotification>& pNf);
/**
* @Brief Event Handler when Socket times-out
*/
void onSocketTimeout(const AutoPtr<TimeoutNotification>& pNf);
private:
/**
* @Brief Read bytes from the socket, depending on available bytes on socket
*/
void readBytes();
/**
* @Brief Send message to the socket
* @Param std::string is the message (null terminated)
*/
void sendMessage(std::string);
/// Stream Socket
StreamSocket _socket;
/// Socket Reactor-Notifier
SocketReactor& _reactor;
/// Received Data Buffer
std::vector<char *> in_buffer;
};
如何实现处理程序取决于您,只要您唯一需要做的就是注册处理事件的类方法,如下所示:
_reactor.addEventHandler(_socket,NObserver<ConnectionHandler, ReadableNotification>(*this, &ConnectionHandler::onSocketReadable));
_reactor.addEventHandler(_socket,NObserver<ConnectionHandler, ShutdownNotification>(*this, &ConnectionHandler::onSocketShutdown));
_reactor.addEventHandler(_socket,NObserver<ConnectionHandler, ErrorNotification>(*this, &ConnectionHandler::onSocketError));
_reactor.addEventHandler(_socket,NObserver<ConnectionHandler, TimeoutNotification>(*this, &ConnectionHandler::onSocketTimeout));
总而言之,两个类,几行代码,简单干净。绝对开始爱上 Poco 图书馆! :)
关于c++ - Poco::Net 服务器和客户端 TCP 连接事件处理程序,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/14632341/