如何从C ++ / Qt Linux应用程序逐行读取FIFO /命名管道?
今天,我可以从Qt程序的fifo中打开和读取数据,但是我无法使该程序逐行读取数据。Qt读取整个文件,这意味着他要等到“发送方”关闭其会话。
让我们以一些shell命令为例,展示我希望应用程序执行的操作。
首先创建一个fifo
mkfifo MyPipe
然后我们可以用猫从fifo中读取
cat MyPipe
然后我们与另一只猫一起发送一些数据
cat > MyPipe
然后开始输入内容,每次您按Enter键,它就会到达阅读器。然后,当您使用Ctrl + D闭合时,两端均会结束。
现在,使用QTextStream可以轻松创建发送方,只需要在发送时刷新即可。
QFile file("MyPipe");
if (!file.open(QIODevice::WriteOnly | QIODevice::Text))
return;
QTextStream out(&file);
for(int i=0; i<3; i++) {
out << "Hello...: " << i << "\n";
out.flush();
sleep(2);
}
file.close();
但是后来写了一个逐行读取的小读者,这是我现在遇到的问题,我对Qt lib的所有尝试最终都得到了我的数据,但直到发送方在fifo上使用file.close()
。不是在他脸红的时候,而是当我用猫来阅读时。
像这个例子:
QFile file("MyPipe");
if (!file.open(QIODevice::ReadOnly | QIODevice::Text))
return 0;
QTextStream in(&file);
QString line;
do {
line = in.readLine();
qDebug() << line;
} while (!in.atEnd());
file.close();
我想念什么?
感觉就像我需要在流上使用某种isReady或lineAvailable之类的东西,但是在文档中找不到合适的东西…
/谢谢
注意事项 :
如果我使用低级c风格,并且同时读一个字符,那么我确实得到了Im寻找的风格。但是能够执行相同的Qt样式会很好。
FILE *fp;
fp=fopen("MyPipe", "r");
char c;
while((c=getc(fp)) != EOF)
{
printf("%c",c);
}
fclose(fp);
更新 :
当我启动调试器时,程序挂在readLine()上,并且在另一方关闭fifo之前不要继续执行。
我确实使用“ >>”得到了相同的结果
line = in.readLine();
in >> line;
使用低级c样式并一次读取一个字符。
FILE *fp;
fp=fopen("MyPipe", "r");
char c;
while((c=getc(fp)) != EOF)
{
printf("%c",c);
}
fclose(fp);
问题内容: 从标准输入逐行读取的Scala配方是什么?类似于等效的Java代码: 问题答案: 最直接的前瞻性的方式将只使用它的一部分。但是,这很丑陋,因为您需要检查最终的空值: 这太冗长了,您宁可使用它。 我认为将使用更漂亮的方法:
问题内容: 我想逐行将输出到python。 我正在使用的脚本是这个(first.py)- 不幸的是,“行”被分成由空格分隔的单词。因此,例如,如果我这样做 我得到的输出是 如何编写脚本以使输出为 ? 问题答案: 建议不要从 标准输入 ()中读取,而不要使用命令行参数。Python有一个简单的惯用法,用于遍历以下行: 我的用法示例(上面的代码已保存到): 以您的示例为例:
我试图重命名每个构建变量的APK文件,以包括应用程序名称、版本名、版本代码和构建编号(如果存在)。到目前为止,除了应用程序名之外,我的一切都正常工作。 我想使用与< code>AndroidManifest.xml文件用于android:label相同的值。这来自字符串资源< code>@string/app_name。我看到了通过使用以下内容来替换资源值的能力: 但我只想读取这个值并用它来命名我
问题内容: 我正在使用以下命令行调用来处理带有node的文本文件: 文件的每一行都需要单独处理,但是一旦处理完,输入行可能会被忘记。 使用标准输入的数据侦听器,我得到了按字节大小分块的输入流,因此进行了设置。 但这似乎草率。必须在行数组的第一项和最后一项周围进行按摩。有没有更优雅的方式做到这一点? 问题答案: 您可以使用readline模块逐行从stdin进行读取:
问题内容: 我有一个.gz格式的文件。读取此文件的Java类是GZIPInputStream。但是,此类不会扩展Java的BufferedReader类。结果,我无法逐行读取文件。我需要这样的东西 尽管我创建了扩展java的Reader或BufferedReader类并使用GZIPInputStream作为其变量之一的类。 但是,这在我使用时不起作用 有人可以建议如何进行.. 问题答案: 装饰器的
稳定性: 2 - 稳定的 require('readline') 模块提供了一个接口,用于从可读流(如 process.stdin)读取数据,每次读取一行。 它可以通过以下方式使用: const readline = require('readline'); 例子,readline 模块的基本用法: const readline = require('readline'); const rl