如何从进程中获得实时、非阻塞的输出
从进程中获得实时、非阻塞的输出可以通过以下几种方式实现：
- 使用管道（Pipe）：管道是一种进程间通信的机制，可以将一个进程的输出连接到另一个进程的输入。在Linux系统中，可以使用命令行工具
pipe或者编程语言中的相关函数来创建管道。通过管道，可以实现实时、非阻塞地获取进程的输出。 - 使用套接字（Socket）：套接字是一种网络通信的机制，可以在不同的进程之间进行通信。可以在进程中创建一个套接字，并将其绑定到一个特定的端口上。然后，可以通过套接字接收进程的输出数据。这种方式可以实现实时、非阻塞地获取进程的输出，并且可以在不同的主机之间进行通信。
- 使用异步IO（Asynchronous I/O）：异步IO是一种非阻塞的IO操作方式，可以在进行IO操作的同时执行其他任务。可以使用编程语言中提供的异步IO库或框架，通过异步IO方式获取进程的输出。这种方式可以实现实时、非阻塞地获取进程的输出，并且可以提高系统的并发性能。
- 使用消息队列（Message Queue）：消息队列是一种在进程之间传递消息的机制，可以实现进程间的解耦和异步通信。可以在进程中创建一个消息队列，并将进程的输出数据发送到消息队列中。然后，可以通过读取消息队列中的消息来获取进程的输出数据。这种方式可以实现实时、非阻塞地获取进程的输出，并且可以在不同的进程之间进行通信。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云管道（Pipe）相关产品：https://cloud.tencent.com/product/pipe
- 腾讯云套接字（Socket）相关产品：https://cloud.tencent.com/product/socket
- 腾讯云异步IO（Asynchronous I/O）相关产品：https://cloud.tencent.com/product/async-io
- 腾讯云消息队列（Message Queue）相关产品：https://cloud.tencent.com/product/mq
相关·内容
3回答
Linux -使用第二进程建立IPC的选项
linux、ipc
为了让linux机器上的进程与同一台机器上的第二个进程(而不是子进程)建立IPC，我正在努力研究我能找到的所有不同方法。我确实发现可以使用socket，因为我知道第二个进程正在侦听的文件系统上的路径。
是否可以通过其他方式与第二个进程进行IPC通信？我不希望第一个进程知道第二个进程的pid/uid。该场景更倾向于与不受信任的进程进行通信，由不同的作者在同一台计算机上，但仍然有一些信息，如第二个进程中的套接字正在侦听的位置？
浏览 3提问于2014-07-27得票数 0
2回答
.Net套接字发送、接收和调度
c#、sockets、udp
我目前正在一个个人项目的学习目的。我想在UDP上建立一个连接，用于游戏之类的应用程序。发送的每个数据报都有一个特定的标头，指示它属于哪个“逻辑”通道--例如，通道0就像带有额外头开销的UDP，而通道1使用更多的头来带来一些额外的可靠性。通道的目标是“自动”将消息划分为逻辑组，最多达到一个特定的数量。
在我当前的代码中，在处理发送和接收的单独线程中有一个简单的循环：
// This is pseudo code
public void Tick() {
if(Socket.Poll) {
do {
ReadMessage();
}
浏览 0提问于2016-01-02得票数 1
回答已采纳
2回答
在应用程序中使用套接字连接的最佳方式是什么？
android
我的应用程序(在线游戏)在许多活动中都必须使用套接字连接，并且它应该始终保持连接。每个活动都需要实时接收来自套接字的消息，有时活动会向套接字发送消息。我试图将套接字从一个活动传递给其他活动，但失败了。我尝试使用服务，但无法发送或接收来自该服务的消息，只能在日志目录中的system.out.println()中看到它。游戏开发者有没有最好的方式或者常用的方式？对不起，我的英语很差。
浏览 3提问于2014-02-19得票数 1
3回答
如何使进程交替进行？
c、process、fork
至于线程，我有互斥和条件，所以我可以很容易地操作它们。
但是，如果我用fork()创建了两个进程，我如何让它们交替呢？
或者，有没有办法为流程创建一个“关键部分”？
我打算编写一个打印"r“和"w”的程序，下面是代码。
#include <stdio.h>
#include <stdlib.h>
int pipe_1[2];
int flag = 0;
void r();
void w();
int main() {
pipe(pipe_1);
if(fork())
r();
else
w
浏览 1提问于2013-05-05得票数 3
回答已采纳
3回答
PHP应用程序+基于WebSocket的Socket.IO通知
php、apache、node.js、websocket、socket.io
我有一个用PHP编写的web应用程序，使用laravel。
现在，我必须添加实时通知系统，该系统可以从服务器->客户端推送消息，并可以检索来自客户端->服务器的消息。
由于Socket.IO是向后兼容的，并且会优雅地退化，所以我想将它用于WebSocket / AJAX轮询部分。
问题是，默认情况下，Socket.IO与Node.JS后端一起工作。
我有对服务器的根访问权，并行运行(Apache和Node)或添加任何额外的东西都没有问题。
问题是，如何从PHP发送消息到Node + Sockets.IO?
然后，如何将消息从Sockets.IO + Node传输到PHP?
我把No
浏览 0提问于2012-08-31得票数 16
回答已采纳
1回答
如何使用消息队列来寻址特定的客户/用户？
node.js、message-queue
我用node.js和socket.io开发了一个拍卖平台。
但是，我想用消息队列替换socket.io。
虽然我在实现基于套接字的拍卖平台方面没有任何问题，但我不知道如何使用消息队列来实现这一点。
我不明白的主要问题是如何解决特定的客户/用户问题。
有了socket.io，我就拥有了socket.id：
io.sockets.connected[socket.id].emit('notify', msg)
如何处理像这样的消息队列？
如果有人能解释一下这是怎么回事，我会很高兴的。
浏览 3提问于2016-05-18得票数 2
回答已采纳
1回答
如何将管理器对象传递给进程
python、multiprocessing、python-multiprocessing、file-locking
我试图将整个马槽对象传递给一个进程，但我无法这样做。当我试图得到这个错误时：
Traceback (most recent call last):
File "TwitchMarketDatabase.py", line 46, in <module>
multiprocessing.Process(target=accept_thread, args=(SERVER, M)).start()
File "C:\Program Files\Python36\lib\multiprocessing\process.py", line 1
浏览 2提问于2017-02-26得票数 4
回答已采纳
1回答
Perl中的基本网络聊天应用
perl、network-programming
为了学习目的，我尝试用Perl编写一个基本的网络聊天应用程序。我目前有一个服务器和客户端程序，其功能几乎与我所希望的一样。多个客户端可以连接到服务器，并向服务器发送消息。然而，我不太确定如何从一个客户端发送消息到另一个客户端，并希望在这里向正确的方向推进。这是我到目前为止的代码，想法？
注意:这是我第一次尝试在适当的项目中使用网络或使用Perl，因此对于如何编写它的任何其他指导也将不胜感激。
chat_server.pl
#!/usr/bin/perl -w
# chat_server.pl
use strict;
use IO::Socket::INET;
my $port = shift
浏览 0提问于2015-09-22得票数 6
4回答
IPC vs域sock vs命名管道
c、ipc、system
IPC和Unix域套接字和命名管道有什么不同？
我从不同的书中得到了模糊的定义，但不清楚哪一个应该用在哪里。
浏览 1提问于2009-09-12得票数 8
回答已采纳
3回答
使用socketpair的双向通信:挂起读出子进程的输出
c++、linux、sockets、ipc
我尝试使用套接字对让父进程向执行不同程序(例如grep)的子进程提供输入，然后读取结果输出。程序挂起在while循环中，该循环读取子程序执行的程序的输出。子进程将stdin和stdout欺骗到套接字对的一端，而父进程和子进程都关闭了套接字对中未使用的一端。
有趣的是，如果孩子执行了我编写的程序(好的，我从Unix环境中的史蒂文斯高级编程中抄袭了它)，一切都会按预期运行。但是，如果子进程执行grep (或其他标准程序)，父进程在尝试读取输出时总是挂起。我不知道是输入没有到达grep，还是grep无法确定输入的结束，或者输出不知何故丢失了。
代码如下：
#include <sys/types
浏览 0提问于2010-08-27得票数 1
回答已采纳
3回答
用于线程间通信的Windows套接字
c++、multithreading、sockets、synchronization、winsockets
我有一个线程，它等待阻塞调用(通过select)，并希望它同时与父线程通信。因为当父程序向阻塞调用发送消息时，它可能会涉及到阻塞调用，所以我不能使用WaitForMultipleObjects。我想知道是否可以在子线程和父线程之间使用套接字，但是所有的文献都表明套接字最好用于进程间而不是线程间的通信。同时，我没有找到它们可能不适合我的用例的原因。我可能遗漏了什么吗?或者对于这样的用例是否有另一种解决方案。(寻找基于c++的解决方案)
浏览 2提问于2018-06-18得票数 0
回答已采纳
2回答
java如何执行发件人线程
java、multithreading、queue、blocking、sender
有人告诉我，任何通过输出流(在我的例子中使用tcp/ip )输出的数据都可能被阻塞。在这种情况下，我不希望通过等待数据输出而停止应用程序。
我需要一个如何做这件事的模型。
我需要通过这个流发送消息对象。
我认为我需要一个包含这些消息对象的阻塞队列。线程的run()方法将获取可用的任何消息对象，并将其发送到true。
我的问题是
是否有比一个时间真循环更好的方法来完成这个任务？也许在while真循环中，如果没有消息要发送，我可以告诉yield/sleep.Is线程有一个更好的模型可以使用吗？我担心，如果我的代码中有一段时间(真)，它将占用等待消息的处理器周期。
拜托，有这方面经验的人，告诉我是否
浏览 2提问于2009-07-06得票数 0
1回答
在节点域创建同步网络i/o
node.js、sockets、http、networking、io
是否有任何阻塞的network I/O库用于Node.js？我们有用于文件系统I/O的同步工具，但我不确定Node.js中的网络I/O是否存在等效的功能。
我们可以创建这样的阻塞网络操作：
var available = true;
var messages = [];
var socket = io('http://localhost:8080');
socket.on('RESPONSE_RECEIVED', function () {
available = true; //we can confirm receipt, so we are f
浏览 1提问于2016-01-11得票数 0
回答已采纳
1回答
应用程序如何使用WSA_IO_PENDING接收数据？
winapi、networking、spi、iocp、sniffer
我正在使用LSP/SPI为指定的应用程序做一个嗅探器。但是我不明白这个应用程序是如何与网络一起工作的。
没有“连接”或WSAConnect调用。我拦截了WSPRecv、WSPSend、WSPCloseSocket，但没有拦截WSPConnect。
另一件奇怪的事- WSPRecv总是返回WSA_IO_PENDING，但是lpOverlapped中的hEvent是null，lpCompletionRoutine也是null。并且不调用WSPGetOverlappedResult (WSAGetOverlappedResult，GetOverlappedResult)和GetQueuedCompl
浏览 6提问于2014-05-06得票数 2
1回答
我们可以在android NDK代码中使用系统IPC吗
android、c、android-ndk
在这里，我想使用系统IPC方法，比如
<sys/msg.h> /* SysV message queues */
<sys/ipc.h> /* General IPC definitions */
在这里，我的android NDK代码是用C语言编写的，我使用消息队列IPC机制与其他C应用程序进行通信。
所以，请让我知道有什么方法可以实现这个IPC目标？如何在android NDK代码中实现此IPC机制？
浏览 0提问于2012-07-11得票数 6
回答已采纳
4回答
BSD套接字-如何使用非阻塞套接字？
c++、sockets、tcp、bsd、nonblocking
我正在尝试使用非阻塞TCP套接字。问题是他们仍然在封锁。代码如下-
服务器代码-
struct sockaddr name;
char buf[80];
void set_nonblock(int socket) {
int flags;
flags = fcntl(socket,F_GETFL,0);
assert(flags != -1);
fcntl(socket, F_SETFL, flags | O_NONBLOCK);
}
int main(int agrc, char** argv) {
int sock, new_sd, adrle
浏览 3提问于2011-07-15得票数 3
回答已采纳
2回答
不同IPC机制的用法
c++、ipc
我是一名c++程序员。
我想知道一个实时场景，在这个场景中我们可以使用不同的IPC机制，比如管道/命名、共享内存。
我大致知道在哪里可以使用套接字和消息队列。但是对于管道/命名管道和共享内存，我没有任何想法。
这仅仅是为了理解不同的IPC机制及其用法。
谢谢,
浏览 0提问于2011-01-31得票数 6
回答已采纳
2回答
服务器端和客户端套接字编程？
javascript、webclient
服务器想要向客户端应用程序(java脚本)发送消息。如果客户端收到消息，它将激活一些东西。(实时)我应该使用socket.io吗？可以使用哪种库或方法？
浏览 2提问于2014-10-12得票数 0
3回答
IM Android V3 Demo无法运行？
官方文档、android、即时通信 IM
请描述您的问题
标题：Demo快速入门 - 云通信 - 产品文档 - 帮助与文档 - 腾讯云
地址：https://cloud.tencent.com/document/product/269/1531
浏览 457提问于2018-02-28
1回答
C中的管道，用于读取stdin的缓冲区
c、pipe、buffer、stdin
我在试着理解这个。尤其是，数据是如何跨进程流动的？
我假设输入流通过与管道连接的输出通过子输入流，然后由父流通过管道输出收集。但是，在新一轮循环并在子循环中执行命令之前，读取的数据会发生什么情况？
数据是否在父进程中缓冲(不知为何？)(我想知道是什么原因造成的)，然后这个缓冲区在fork()之后被复制并传递给一个子程序，然后子程序将保存的输入传递给exec()
编辑-其他方面：
(在我给出的示例中，新管道是用循环的每一个回合创建的，并在调用pipe()时填充了新的描述符。我已经创建了一个工作修改，其中描述符表在循环之外创建并重新填充。它如何影响先前从先前执行的命令中读取的数据？当创建新管道和在
浏览 7提问于2021-12-07得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
