- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
UPDATE_2我最终使用了
if (socket.available())
如果套接字上有数据,我读取它,如果没有,我跳过。
已更新我有个问题。 io_service::run() 在以下代码片段中从不返回:
客户端:
#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/array.hpp>
using namespace std;
using boost::asio::ip::tcp;
void handler(
const boost::system::error_code &error,
size_t bytes_transferred
)
{
cout << "Handler called" << endl;
}
int main()
{
//establishing connection
boost::asio::io_service io_service;
tcp::socket socket(io_service);
tcp::resolver resolver(io_service);
tcp::resolver::query query("localhost", "17073");
tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);
boost::asio::connect(socket, endpoint_iterator);
//connection established
boost::array<char, 128> buf;
socket.async_read_some(boost::asio::buffer(buf), boost::bind(handler, _1, _2));
//async_read_some returns
io_service.run(); //I suppose that handler_for_async_response is called if:
//1) EOF was read (no data read twice) by async_read_some
//2) something was in fact read
//is this right?
//execution does not get here
return 0;
}
服务器端(只接受连接并卡在那里什么都不做):
#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/array.hpp>
using namespace std;
using boost::asio::ip::tcp;
int main()
{
//establishing connection
boost::asio::io_service io_service;
tcp::socket socket(io_service);
tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 17073));
acceptor.accept(socket);
std::cout << "connection has been established!" << std::endl;
//connection established
while (true)
{
//do nothing
}
return 0;
}
我想做的是查看套接字上是否有任何数据。如果是 - 然后阅读它,如果不是 - 然后继续。
PS 我打算同时从套接字读取并写入它。
无论如何,我是 boost::asio 的新手,我希望有人能告诉我我做错了什么。谢谢!
最佳答案
UPDATE 用代码回应更新的问题:
您的客户端正在等待 128 字节或 EOF。这些都没有,因为服务器没有发送任何东西(但没有关闭连接)。
要么改变
客户,例如
不要等待实际数据到达
boost::array<char, 0> buf;
或者在 deadline_timer
之后(大约如此。
服务器,例如用真正的套接字写入替换无限循环
这是一个例子
#include <boost/array.hpp>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <iostream>
using boost::asio::ip::tcp;
using namespace std;
#ifdef SERVER
int main()
{
//establishing connection
boost::asio::io_service io_service;
tcp::socket socket(io_service);
tcp::acceptor acceptor(io_service, tcp::endpoint(tcp::v4(), 17073));
acceptor.accept(socket);
std::cout << "connection has been established!" << std::endl;
//connection established
socket.send(boost::asio::buffer(std::string("Hello world\n")));
}
#else
void handler(
boost::array<char, 128> const& buf,
const boost::system::error_code &error,
size_t bytes_transferred
)
{
cout << "Handler called (" << error.message() << "): " << endl;
cout.write(buf.data(), bytes_transferred);
}
int main()
{
//establishing connection
boost::asio::io_service io_service;
tcp::socket socket(io_service);
tcp::resolver resolver(io_service);
tcp::resolver::query query("127.0.0.1", "17073");
tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);
boost::asio::connect(socket, endpoint_iterator);
//connection established
boost::array<char, 128> buf;
socket.async_read_some(boost::asio::buffer(buf), boost::bind(handler, boost::ref(buf), _1, _2));
//async_read_some returns
io_service.run(); //I suppose that handler_for_async_response is called if:
//1) EOF was read (no data read twice) by async_read_some
//2) something was in fact read
//is this right?
//execution does not get here
return 0;
}
#endif
打印:
//(server)
connection has been established!
//(client)
Handler called (Success):
您必须决定是同步编程还是异步编程。
在这种情况下,我认为您可能真的在寻找 tcp::istream
。
当任务用完时运行返回:
The
run()
function blocks until all work has finished and there are no more handlers to be dispatched, or until theio_service
has been stopped.Multiple threads may call the
run()
function to set up a pool of threads from which theio_service
may execute handlers. All threads that are waiting in the pool are equivalent and theio_service
may choose any one of them to invoke a handler.A normal exit from the
run()
function implies that theio_service
object is stopped (the stopped() function returns true). Subsequent calls torun()
,run_one()
,poll()
orpoll_one()
will return immediately unless there is a prior call toreset()
.
所以您还有其他待处理的服务工作(io_service::work?)。检查一下。让您的代码成为 SSCCE,我们将能够看到更多内容。
关于c++ - io_service::run() 永不返回,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/33575080/
按照目前的情况,这个问题不适合我们的问答形式。我们希望答案得到事实、引用或专业知识的支持,但这个问题可能会引发辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开,visit the
在编码时,我问了自己这个问题: 这样更快吗: if(false) return true; else return false; 比这个? if(false) return true; return
如何在逻辑条件下进行“返回”? 在这样的情况下这会很有用 checkConfig() || return false; var iNeedThis=doSomething() || return fa
这是我的正则表达式 demo 如问题所述: 如果第一个数字是 1 则返回 1 但如果是 145 则返回 145 但如果是 133 则返回 133 样本数据a: K'8134567 K'81345678
在代码高尔夫问答部分查看谜题和答案时,我遇到了 this solution返回 1 的最长和最晦涩的方法 引用答案, int foo(void) { return! 0; } int bar(
我想在下面返回 JSON。 { "name": "jackie" } postman 给我错误。说明 Unexpected 'n' 这里是 Spring Boot 的新手。 1日龄。有没有正确的方法来
只要“is”返回 True,“==”不应该返回 True 吗? In [101]: np.NAN is np.nan is np.NaN Out[101]: True In [102]: np.NAN
我需要获取所有在 6 号或 7 号房间或根本不在任何房间的学生的详细信息。如果他们在其他房间,简单地说,我不希望有那个记录。 我的架构是: students(roll_no, name,class,.
我有一个表单,我将它发送到 php 以通过 ajax 插入到 mysql 数据库中。一切顺利,php 返回 "true" 值,但在 ajax 中它显示 false 消息。 在这里你可以查看php代码:
我在 Kotlin 中遇到了一个非常奇怪的无法解释的值比较问题,以下代码打印 假 data class Foo ( val a: Byte ) fun main() { val NUM
请注意,这并非特定于 Protractor。问题在于 Angular 2 的内置 Testability service Protractor 碰巧使用。 Protractor 调用 Testabil
在调试窗口中,以下表达式均返回 1。 Application.WorksheetFunction.CountA(Cells(4 + (i - 1) * rows_per_record, 28) & "
我在本地使用 jsonplaceholder ( http://jsonplaceholder.typicode.com/)。我正在通过 extjs rest 代理测试我的 GET 和 POST 调用
这是 Postman 为成功调用我的页面而提供的(修改后的)代码段。 var client = new RestClient("http://sub.example.com/wp-json/wp/v2
这个问题在这里已经有了答案: What to do with mysqli problems? Errors like mysqli_fetch_array(): Argument #1 must
我想我对 C 命令行参数有点生疏。我查看了我的一些旧代码,但无论这个版本是什么,都会出现段错误。 运行方式是 ./foo -n num(其中 num 是用户在命令行中输入的数字) 但不知何故它不起作用
我已经编写了一个类来处理命名管道连接,如果我创建了一个实例,关闭它,然后尝试创建另一个实例,调用 CreateFile() 返回 INVALID_HANDLE_VALUE,并且 GetLastErro
即使 is_writable() 返回 true,我也无法写入文件。当然,该文件存在并且显然是可读的。这是代码: $file = "data"; echo file_get_contents($fil
下面代码中的变量 $response 为 NULL,尽管它应该是 SOAP 请求的值。 (潮汐列表)。当我调用 $client->__getLastResponse() 时,我从 SOAP 服务获得了
我一直在网上的不同论坛上搜索答案,但似乎没有与我的情况相符的... 我正在使用 Windows 7,VS2010。 我有一个使用定时器来调用任务栏刷新功能的应用程序。在该任务栏函数中包含对 LoadI
我是一名优秀的程序员,十分优秀!