可以完全按照问题中发布的方式将套接字绑定到特定端口:
using boost::asio::ip::tcp;
boost::asio::io_service io_service;
tcp::socket socket(io_service, tcp::endpoint(tcp::v4(), 2000));
assert(socket.local_endpoint().port() == 2000); // true
在这种情况下,socket
对象将被构造,打开并绑定到地址和端口的本地端点。INADDR_ANY
2000
由于建立连接的方式,本地端点可能会发生变化。当从socket.connect()
或socket.async_connect()
成员函数发起连接操作时,套接字将尝试连接到远程端点,并在必要时打开套接字。因此,当在已经打开的套接字上调用时,套接字的本地端点不会改变。
另一方面,当从任一函数connect()
或async_connect()
自由函数启动连接操作时,套接字在尝试连接到任何端点之前都会关闭。因此,套接字将绑定到未指定的端口。自由函数文档中的参数部分定义了这种行为:
socket
要连接的。如果socket
已经打开,它将被关闭。
此外,没有干净的方法来控制这种行为,因为socket.close()
和socket.connect()
成员函数在实现中一个接一个地被调用。
这是一个完整的示例,演示了上述行为:
#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/lexical_cast.hpp>
// This example is not interested in the handlers, so provide a noop function
// that will be passed to bind to meet the handler concept requirements.
void noop() {}
// Helper function used to initialize the client socket.
void force_endpoint(boost::asio::ip::tcp::socket& client_socket)
{
using boost::asio::ip::tcp;
client_socket.close();
client_socket.open(tcp::v4());
client_socket.bind(tcp::endpoint(tcp::v4(), 2000));
std::cout << "client socket: " << client_socket.local_endpoint()
<< std::endl;
}
int main()
{
using boost::asio::ip::tcp;
boost::asio::io_service io_service;
// Create all I/O objects.
tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 0));
tcp::socket server_socket(io_service);
tcp::socket client_socket(io_service);
// ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
// Initiate the connect operation directly on the socket.
server_socket.close();
force_endpoint(client_socket);
acceptor.async_accept(server_socket, boost::bind(&noop));
client_socket.async_connect(acceptor.local_endpoint(), boost::bind(&noop));
// Print endpoints before and after running the operations.
io_service.run();
std::cout << "After socket.async_connect(): "
<< client_socket.local_endpoint() << std::endl;
// ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
// Initiate the connection operation with the free async_connect function.
server_socket.close();
force_endpoint(client_socket);
acceptor.async_accept(server_socket, boost::bind(&noop));
boost::asio::async_connect(
client_socket,
tcp::resolver(io_service).resolve(
tcp::resolver::query("127.0.0.1",
boost::lexical_cast<std::string>(acceptor.local_endpoint().port()))),
boost::bind(&noop));
// Run the service, causing the client to connect to the acceptor.
io_service.reset();
io_service.run();
std::cout << "After async_connect(): "
<< client_socket.local_endpoint() << std::endl;
}
这产生了以下输出:
client socket: 0.0.0.0:2000
After socket.async_connect(): 127.0.0.1:2000
client socket: 0.0.0.0:2000
After async_connect(): 127.0.0.1:53115