2013-04-15 57 views
0

有沒有辦法向客戶端發送數據包,知道remote_endpoint對象,其中endpoint.addressendpoint.port被使用?發送數據包給客戶端給定的remote_endpoint對象和套接字?

編輯:我加入了async_write免費的功能,但我仍然不知道如何指定的IP地址或端口爲socket_發送data_到(客戶端)。升級異步服務器示例中的更改是第44-49行。

#include <cstdlib> 
#include <iostream> 
#include <boost/bind.hpp> 
#include <boost/asio.hpp> 

using boost::asio::ip::tcp; 

class session 
{ 
public: 
    session(boost::asio::io_service& io_service) 
    : socket_(io_service) 
    { 
    } 

    tcp::socket& socket() 
    { 
    return socket_; 
    } 

    void start() 
    { 
     std::cout<<"start(): "<<std::endl; 
      socket_.async_read_some(boost::asio::buffer(data_, max_length), 
      boost::bind(&session::handle_read, this, 
      boost::asio::placeholders::error, 
      boost::asio::placeholders::bytes_transferred)); 
    } 
void read_handler(const boost::system::error_code& ec, std::size_t bytes_transferred); 


private: 
    void handle_read(const boost::system::error_code& error, 
     size_t bytes_transferred) 
    { 
     std::cout<<"handle read: bytes_transferred"<<bytes_transferred<<std::endl; 
    if (!error) 
    { 
      data_ = {'0','1','2','3','4','5','6','7','8','9'}; 
      /*read_handler(error, bytes_transferred); 
      boost::asio::async_write(socket_,boost::asio::buffer(data_, bytes_transferred), 
       boost::bind(&session::handle_write, this, 
          boost::asio::placeholders::error));*/ 
      boost::system::error_code ec; 
      boost::asio::ip::tcp::endpoint endpoint = socket_.remote_endpoint(ec); 
      std::cout<<"ip address: "<<endpoint.address()<<std::endl; 
      std::cout<<"port: "<<endpoint.port()<<std::endl; 
      //how to get the socket to send data to specific port, ip-address e.g. changing the ip-address and port by editing it? 
      async_write(socket_, boost::asio::buffer(data_, max_length), boost::bind(&session::writeHandler, this, boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred)); 
    } 
    else 
    { 
     delete this; 
    } 
    } 
    void writeHandler(const boost::system::error_code& errorCode, size_t bytesTransferred) 
    { 
     std::cout << "DEBUG> Transfered " << bytesTransferred << " bytes to " << socket_.remote_endpoint().address().to_string() << std::endl; 
    } 
    void handle_write(const boost::system::error_code& error) 
    { 
     std::cout<<"handle write: "<<std::endl; 

    if (!error) 
    { 
      std::cout<<"before: "<<data_<<std::endl; 

      socket_.async_read_some(boost::asio::buffer(data_, max_length), 
      boost::bind(&session::handle_read, this, 
      boost::asio::placeholders::error, 
      boost::asio::placeholders::bytes_transferred)); 

      std::cout<<"after: "<<data_<<std::endl; 
    } 
    else 
    { 
     delete this; 
    } 
    } 

    tcp::socket socket_; 
    enum { max_length = 1024 }; 
    char data_[max_length]; 
}; 
void session::read_handler(const boost::system::error_code& ec, std::size_t bytes_transferred) 
{ 
     std::cout<<bytes_transferred<<std::endl; 
} 

class server 
{ 
public: 
    server(boost::asio::io_service& io_service, short port) 
    : io_service_(io_service), 
     acceptor_(io_service, tcp::endpoint(tcp::v4(), port)) 
    { 
    start_accept(); 
    } 


private: 
    void start_accept() 
    { 
    session* new_session = new session(io_service_); 
    acceptor_.async_accept(new_session->socket(), 
     boost::bind(&server::handle_accept, this, new_session, 
      boost::asio::placeholders::error)); 
    } 

    void handle_accept(session* new_session, 
     const boost::system::error_code& error) 
    { 
    if (!error) 
    { 
     new_session->start(); 
    } 
    else 
    { 
     delete new_session; 
    } 

    start_accept(); 
    } 

    boost::asio::io_service& io_service_; 
    tcp::acceptor acceptor_; 
}; 

int main() 
{ 
    try 
    { 
    boost::asio::io_service io_service; 
    server s(io_service, 4000); 

    io_service.run(); 
    } 
    catch (std::exception& e) 
    { 
    std::cerr << "Exception: " << e.what() << "\n"; 
    } 

    return 0; 
} 

回答

1

假設TCP套接字,因爲這是你在文檔中鏈接到的東西,沒有這是不可能的。您需要一個套接字對象來發送數據,而不僅僅是一個端點。使用免費函數async_write(),它的許多重載之一或任何套接字類方法來發送數據。

+0

好的,我改變了主意,並且'socket'對象可用,但是我只能使用'write'或'send' no? – pandoragami

+0

@lost答案已更新 –

+0

我查看了'async_write'的頁面,但非參數採用'remote_endpoint'?這如何適合這幅畫? http://www.lost.org/doc/libs/1_43_0/doc/html/boost_asio/reference/async_write.html – pandoragami

相關問題