我写了这个:
#include <vector>
#include <iostream>
#include <sstream>
#include <boost/asio.hpp>
#include <tr1/memory>
#include <boost/bind.hpp>
#include <stdint.h>
using namespace boost::asio;
using namespace boost::asio::ip;
class tcpServer{
public:
class connection{
tcp::socket socketConnection;
enum {CONNECTED, CLOSED, CREATED}STATUS;
public:
uint32_t addr;
uint16_t port;
connection(boost::asio::io_service &ioServ): socketConnection(ioServ){
STATUS = CREATED;
}
void setConnected(bool is) {
if (is) {
STATUS = CONNECTED;
port = socketConnection.remote_endpoint().port();
addr
= socketConnection.remote_endpoint().address().to_v4().to_ulong();
std::cout << "Connected to "
<< socketConnection.remote_endpoint().address().to_v4().to_string()
<< " : " << socketConnection.remote_endpoint().port()
<< "\n";
}
}
tcp::socket& getSocket(){
return socketConnection;
}
};
typedef std::tr1::shared_ptr<tcpServer::connection> CONNSHPTR;
private:
boost::asio::io_service io_service;
tcp::acceptor tcpAcceptor;
int localPort;
void accept(CONNSHPTR connection, const boost::system::error_code& error){
connection->setConnected(true);
std::cout.flush();
}
void startAccept(){
CONNSHPTR newConn(new connection(tcpAcceptor.io_service()));
tcpAcceptor.async_accept(newConn->getSocket(), boost::bind(
&tcpServer::accept, this, newConn,
boost::asio::placeholders::error));
}
public:
tcpServer(int localPort) :
io_service(), tcpAcceptor(io_service, tcp::endpoint(tcp::v4(),
localPort)) {
this->localPort = localPort;
}
void start(){
io_service.run();
startAccept();
}
};
int main(int argc, char** argv) {
try{
tcpServer tp(1033);
tp.start();
}catch(std::exception &e){
std::cout << e.what();
}
sleep(5000);
return 0;
}
然后我在终端上写了 telnet localhost 1033。Telnet 说我已连接,但处理程序没有被调用(gdb 没有命中断点并且 coutS 没有效果)。如果我杀死程序 telnet 会说连接已关闭。所以似乎连接已经建立,但为什么处理程序没有被调用?
编辑:
奇怪的是,如果在 start() 中我将 ioservice.run() 放在 startAccept()之后,它会起作用。现在我想知道为什么这行得通......事实上后来我再次调用 start accept 并且它仍然有效,并且它是在 ioservice.run() 调用之后......