开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

连接已关闭，但`asio::ip::tcp::socket::write_some`在第一次调用时返回成功

问题描述：连接已关闭，但asio::ip::tcp::socket::write_some在第一次调用时返回成功。

回答：

这个问题涉及到网络通信和异步IO操作，需要一定的背景知识才能完整理解答案。

在使用boost.asio进行网络通信时，asio::ip::tcp::socket::write_some是用来发送数据的函数。当我们调用这个函数发送数据时，它会尽力将数据发送出去，并返回成功与否的结果。

然而，在网络通信中，发送数据的过程是异步的，数据并不会立即发送出去，而是被放入发送缓冲区等待发送。因此，当我们调用asio::ip::tcp::socket::write_some发送数据时，它只是将数据放入发送缓冲区，并不一定表示数据已经成功发送到对方。

当然，如果在第一次调用asio::ip::tcp::socket::write_some时返回成功，而实际上连接已经关闭，可能是由于以下原因：

在调用asio::ip::tcp::socket::write_some之前，连接已经被对方关闭。这种情况下，write_some函数仍然会成功返回，因为它只负责将数据放入发送缓冲区，不负责检测连接状态。
在调用asio::ip::tcp::socket::write_some之后，连接关闭了。这种情况下，write_some函数成功返回并不代表数据已经成功发送到对方，因为数据实际上还在发送缓冲区中等待发送，而此时连接已经关闭。

为了解决这个问题，我们可以通过以下方式进行判断和处理：

在调用asio::ip::tcp::socket::write_some之后，可以调用asio::ip::tcp::socket::error函数获取错误码，通过错误码来确定连接状态。
在使用asio::ip::tcp::socket::write_some发送数据时，可以使用asio::ip::tcp::socket::available函数判断发送缓冲区是否为空，如果为空，则说明数据已经成功发送出去。

同时，建议在实际开发中，采用更高层次的协议或框架，如HTTP、WebSocket等，来处理网络通信，这样可以更好地处理连接状态和异常情况。

推荐的腾讯云相关产品和产品介绍链接地址：

云服务器（ECS）：https://cloud.tencent.com/product/cvm
云数据库 MySQL 版：https://cloud.tencent.com/product/cdb_mysql
人工智能服务：https://cloud.tencent.com/product/ai
物联网套件：https://cloud.tencent.com/product/iot-suite
腾讯云存储（COS）：https://cloud.tencent.com/product/cos
腾讯云区块链服务（BCS）：https://cloud.tencent.com/product/bcs

页面内容是否对你有帮助？

有帮助

没帮助

相关·内容

19.4 Boost Asio 远程命令执行

命令执行机制的实现与原生套接字通信一致，仅仅只是在调用时采用了Boost通用接口，在服务端中我们通过封装实现一个run_command函数，该函数用于发送一个字符串命令，并循环等待接收客户端返回的字符串...bool run_command(ip::tcp::socket *socket, std::string command){ (*socket).write_some(buffer(command)...::tcp::endpoint ep(ip::tcp::v4(), 6666); ip::tcp::acceptor acceptor(io_service, ep); ip::tcp::socket...>using namespace boost::asio;// 实现命令执行,并发送到服务端bool exec_command(ip::tcp::socket *socket){ char command...)); } (*socket).write_some(boost::asio::buffer("goodbye lyshark")); _pclose(fp); return true;}int

2233 0

19.4 Boost Asio 远程命令执行

命令执行机制的实现与原生套接字通信一致，仅仅只是在调用时采用了Boost通用接口，在服务端中我们通过封装实现一个run_command函数，该函数用于发送一个字符串命令，并循环等待接收客户端返回的字符串...bool run_command(ip::tcp::socket *socket, std::string command) { (*socket).write_some(buffer(command...::tcp::endpoint ep(ip::tcp::v4(), 6666); ip::tcp::acceptor acceptor(io_service, ep); ip::tcp::socket...#include using namespace boost::asio; // 实现命令执行,并发送到服务端 bool exec_command(ip::tcp...= NULL) { (*socket).write_some(boost::asio::buffer(buffer, 1024)); memset(buffer, 0, sizeof

1866 0

19.10 Boost Asio 同步文件传输

，但使用这种方式也存在一个有点，那就是无需确定文件长度，因为无需读入文件所以在传输速度上要快一些，尤其是面对大文件时。...boost::asio; // 将远程特定目录下的文件拉取到本地目录 bool recv_remote_file(ip::tcp::socket *socket, std::string remote_file_path...error_code ec; char buffer[1024] = { 0 }; // 发送放入目标位置 bool ref = (*socket).write_some(boost::asio...::tcp::acceptor acceptor(io_service, ip::tcp::endpoint(ip::tcp::v4(), 6666)); ip::tcp::socket socket...::tcp::socket socket(io_service); ip::tcp::endpoint ep(ip::address_v4::from_string("127.0.0.1"), 6666

3075 0

第32章.Boost.Asio-网络编程

您可以与telnet客户端连接以获取当前时间。之后，时间服务器将关闭。时间服务器使用I/O对象boost::asio::ip::tcp::acceptor接受来自另一个程序的传入连接。...在示例中，类型为boost::asio::ip::tcp::endpoint的变量tcp_endpoint用于告诉tcp_acceptor在端口2014上接受Internet协议版本4的传入连接。...然后调用async_accept()接受第一次连接尝试。必须将套接字作为第一个参数传递给async_accept()，该套接字将用于在新连接上发送和接收数据。...此函数使用参数boost::asio::ip::tcp::socket::shutdown_send调用shutdown()，表示程序已通过套接字发送数据。...当boost::asio::async_write()和accept_handler()返回时，异步操作已开始，但尚未完成。数据必须存在，直到异步操作完成。如果数据是全局变量，则可以保证。

2.6K4 1

19.9 Boost Asio 同步字典传输

::ip::tcp; // 获取系统进程是否存在 std::string GetProcess(const char *procressName) { boost::format fmt("{'ProcName...while (1) { tcp::socket socket(io_service); acceptor.accept(socket); boost::array...boost::asio::ip::tcp; int main(int argc, char* argv[]) { try { boost::asio::io_service io_service...; tcp::endpoint end_point(boost::asio::ip::address::from_string("127.0.0.1"), 6666); tcp::socket...); // 获取远端返回结果 boost::array buf = { 0 }; size_t len = socket.read_some(boost

1903 0

19.9 Boost Asio 同步字典传输

::ip::tcp;// 获取系统进程是否存在std::string GetProcess(const char *procressName){ boost::format fmt("{'ProcName...(1) { tcp::socket socket(io_service); acceptor.accept(socket); boost::array buf = { 0 }; size_t len = socket.read_some(boost::asio

1663 0

试试Boost.Asio

连接表 **/ std::map<boost::asio::ip::tcp::socket::native_handle_type, std::pair< boost::shared_ptr..., 接受新Socket ptrCurSock = boost::shared_ptr( new boost::asio...::ip::tcp::socket>( new boost::asio::ip::tcp::socket(stMainService) ); stAccepter.async_accept...::ip::tcp::socket>( new boost::asio::ip::tcp::socket(stMainService) ); // Step 4....write和write_some函数在completion_condition返回0时才发送，否则将数据加入到发送窗口，并且没有发生数据拷贝，也就是说，如果是异步操作，开发者必须保证发送时数据有效。

1.9K3 0

试试Boost.Asio

连接表 **/ std::map<boost::asio::ip::tcp::socket::native_handle_type, std::pair< boost::shared_ptr..., 接受新Socket ptrCurSock = boost::shared_ptr( new boost::asio...::ip::tcp::socket>( new boost::asio::ip::tcp::socket(stMainService) ); stAccepter.async_accept...::ip::tcp::socket>( new boost::asio::ip::tcp::socket(stMainService) ); // Step 4....write和write_some函数在completion_condition返回0时才发送，否则将数据加入到发送窗口，并且没有发生数据拷贝，也就是说，如果是异步操作，开发者必须保证发送时数据有效。

4K1 0

19.8 Boost Asio 异或加密传输

异或操作的本质是对两个二进制数字进行比较，如果它们相同则返回0，如果不同则返回1。异或加密使用一把密钥将明文与密文进行异或运算，从而产生密文。同时，使用相同的密钥进行解密将返回原始的明文数据。...首先实现服务端部分，在服务端中我们通过实现Makecode函数，其可用于将特定的一段字符串异或处理，在本案例中服务端通过传入一段加密后的字符串以及一个pkey密钥对，则可实现解密操作，当服务端接收到结构体后...::tcp::acceptor acceptor(io_service, ip::tcp::endpoint(ip::tcp::v4(), 6666)); ip::tcp::socket socket...[sizeof(message) * 2] = { 0 }; socket.read_some(boost::asio::buffer(recv_buffer, sizeof(message) * 2...::tcp::socket socket(io_service); ip::tcp::endpoint ep(ip::address_v4::from_string("127.0.0.1"), 6666

2153 0

19.8 Boost Asio 异或加密传输

异或操作的本质是对两个二进制数字进行比较，如果它们相同则返回0，如果不同则返回1。异或加密使用一把密钥将明文与密文进行异或运算，从而产生密文。同时，使用相同的密钥进行解密将返回原始的明文数据。...首先实现服务端部分，在服务端中我们通过实现Makecode函数，其可用于将特定的一段字符串异或处理，在本案例中服务端通过传入一段加密后的字符串以及一个pkey密钥对，则可实现解密操作，当服务端接收到结构体后...::tcp::acceptor acceptor(io_service, ip::tcp::endpoint(ip::tcp::v4(), 6666)); ip::tcp::socket socket...recv_buffer[sizeof(message) * 2] = { 0 }; socket.read_some(boost::asio::buffer(recv_buffer, sizeof...::tcp::socket socket(io_service); ip::tcp::endpoint ep(ip::address_v4::from_string("127.0.0.1"), 6666

2065 0

C++ 基于Boost.Asio实现端口映射器

socket_pipe 类：表示端口映射的管道，负责在两个客户端之间传递数据。 async_listener 类：用于异步监听指定端口的连接请求，通过回调函数处理连接。...在错误处理中，如果出现错误，会关闭套接字并释放当前的 socket_pipe 实例。...1.3 async_listener async_listener 类负责异步监听指定端口，并通过回调函数处理连接。在连接建立时，会调用用户提供的回调函数进行处理。...该类的主要目的是实现异步监听，一旦有连接建立，就通过回调函数通知用户，并通过 handle_error 处理可能的错误。在连接建立后，会继续监听新的连接。...如果连接成功，创建两个 socket_pipe 实例，分别用于将数据从本地传输到远程和从远程传输回本地。

4371 0

19.8 Boost Asio 异或加密传输

异或操作的本质是对两个二进制数字进行比较，如果它们相同则返回0，如果不同则返回1。异或加密使用一把密钥将明文与密文进行异或运算，从而产生密文。同时，使用相同的密钥进行解密将返回原始的明文数据。...首先实现服务端部分，在服务端中我们通过实现Makecode函数，其可用于将特定的一段字符串异或处理，在本案例中服务端通过传入一段加密后的字符串以及一个pkey密钥对，则可实现解密操作，当服务端接收到结构体后...::tcp::acceptor acceptor(io_service, ip::tcp::endpoint(ip::tcp::v4(), 6666)); ip::tcp::socket socket...[sizeof(message) * 2] = { 0 }; socket.read_some(boost::asio::buffer(recv_buffer, sizeof(message) * 2...::tcp::socket socket(io_service); ip::tcp::endpoint ep(ip::address_v4::from_string("127.0.0.1"), 6666

1622 0

C++ Boost 异步网络编程基础

在异步模式下，程序除了发起IO操作外，还需要定义一个用于回调的完成处理函数。io_service将IO操作交给操作系统执行，但它不同步等待，而是立即返回。...在异步状态下，程序发起IO请求后会立即返回，无需等待IO操作完成。无论IO操作成功还是失败，程序都可以继续执行其他任务，不会被阻塞。...创建了一个新的 tcp::socket 对象，并使用 async_accept 异步等待连接请求。 accept_handler 函数被绑定，负责处理连接成功后的操作。...accept_handler 函数：当有客户端连接成功时，该函数会被调用。递归调用 start()，以便继续等待新的连接请求。输出远程客户端的IP地址。...::endpoint ep(ip::address::from_string("127.0.0.1"), 1000); ip::tcp::socket socket(io_service); socket.connect

6281 0

eos源码赏析（四）：基于boost::asio的httpserver架构

作为一个跨平台的库，Boost::asio可以在大多数操作系统上使用，且能够同时支持数千个并发的连接。...其网络部分的灵感来源于socket协议，提供了一套可以支持TCP、UDP、IMCP协议的API，而且如果有需要的话，可以对其进行扩展。...因此前面的前摄器模式可以简单的添加IO对象如图4所示：图4 添加IO对象之后的asio结构图以acceptor为例，通过源码可以发现他是basic_socket_acceptor在TCP模板参数下的一个实例...再如basic_socket是对socket IO操作的封装，提供了receive(),、async_recive()、read_some()、async_readsome()、write_some()...本例将使用者在QT配置的界面中写入的数据为返回内容，以json串的形式回传给客户端。

1.5K4 0

C++ ASIO 实现异步套接字管理

图片本章笔者将介绍如何通过ASIO框架实现一个简单的异步网络套接字应用程序，该程序支持对Socket套接字的存储，默认将套接字放入到一个Map容器内，当需要使用时只需要将套接字在容器内取出并实现通信，客户端下线时则自动从...::ip::tcp;// 异步连接地址与端口class AsyncConnect{public:AsyncConnect(boost::asio::io_service& ios, tcp::socket...million_seconds){bool connect_success = false;// 异步连接,当连接成功后将触发 connect_handle 函数socket_.async_connect...::asio::ip::address::from_string("127.0.0.1"), 10000);// 循环验证是否在线go_: while (1){// 验证是否连接成功,并定义超时时间为...(boost::asio::buffer(data, length));}// 根据ID号返回客户端IP地址string CAsyncTcpServer::GetRemoteAddress(int clientId

5032 0

C++ ASIO 实现异步套接字管理

本章笔者将介绍如何通过ASIO框架实现一个简单的异步网络套接字应用程序，该程序支持对Socket套接字的存储，默认将套接字放入到一个Map容器内，当需要使用时只需要将套接字在容器内取出并实现通信，客户端下线时则自动从...::ip::tcp; // 异步连接地址与端口 class AsyncConnect { public: AsyncConnect(boost::asio::io_service& ios, tcp...boost::asio::io_service io; tcp::socket socket(io); AsyncConnect hander(io, socket); boost::system...::error_code error; tcp::endpoint ep(boost::asio::ip::address::from_string("127.0.0.1"), 10000);...(boost::asio::buffer(data, length)); } // 根据ID号返回客户端IP地址 string CAsyncTcpServer::GetRemoteAddress(int

2805 0

MongoDB网络传输层模块源码实现二

说明在之前的>一文中分析了如何阅读百万级大工程源码、Asio网络库实现、transport传输层网络模块中线程模型实现，但是由于篇幅原因...当服务端接收到客户端新连接事件通知后，会触发执行acceptCb()回调，该回调中底层ASIO库通过epoll_wait获取到所有的accept事件，每获取到一个accept事件就代表一个新的客户端链接...(asio::ip::tcp::no_delay(true)); _socket.set_option(asio::socket_base::keep_alive(true));...此外，该链接_socket对应的客户端ip:port和服务端ip:port也在该初始化类中获取，最终保存到本session的_remote和_local成员中。...，同步模式发送为阻塞式写，只有当所有数据通过asio::write()发送成功后才返回；异步模式发送为非阻塞写，asio::write()不一定全部发送出去，因此需要再次调用asio库的asio::async_write

1.4K2 0

ASIO 应用层C++类声明

ASIO的核心是一个事件驱动的非阻塞I/O模型，这使得它非常适合用于需要处理大量并发连接的应用程序。本文将详细介绍ASIO在C++中的应用层类声明。1....asio::io_context io_context;1.2 ip::tcp::socketip::tcp::socket类表示一个TCP套接字，用于网络通信。...asio::ip::tcp::socket socket(io_context);1.3 ip::tcp::acceptorip::tcp::acceptor类用于接受传入的TCP连接请求。...它通常与ip::tcp::socket类一起使用，以处理客户端的连接。...ASIO异步模型ASIO的异步模型基于回调函数，这些回调函数在异步操作完成时被调用。以下是一些与异步模型相关的类和函数：2.1 async_readasync_read函数用于异步读取数据。

7590 0

C++ Boost 实现异步IO远控

::ip::tcp; int main(int argc, char * argv[]) { try { boost::asio::io_service io;...tcp::socket socket(io); AsyncConnect hander(io, socket); boost::system::error_code error...; tcp::endpoint ep(boost::asio::ip::address::from_string("127.0.0.1"), 10000); // 循环验证是否在线...while (1) { // 验证是否连接成功,并定义超时时间为5秒 if (hander.aysnc_connect(ep,...5000)) { io.run(); std::cout << "已连接到服务端." << std::endl;

8542 0

Boost ASIO proactor 浅析

通过回调函数通知用户时，用户无需在调用系统调用读取数据，因为数据已经存储在buffer中了。...首先调用perform，也就是直接send，send若成功直接调用io_service::post调用回调函数 n 如果文件描述符没有注册到epoll_wait，那么EPOLLIN | EPOLLERR...boost::asio::ip::tcp::socket中的异步方法的实现 l Socket中有async_打头的许多异步方法，这里已async_send为例 l boost/asio/ip/tcp.hpp... 声明了tcp::socket的原型，实际原型是 typedef basic_stream_socket socket; l basic_stream_socket是模板类，声明在boost/...;告诉我们service的原型是detail::reactive_socket_service，其声明文件为 boost/asio/detail/reactive_socket_service.hpp

2.5K6 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭