通过linux消息队列传递的C结构间歇性失败

文章/答案/技术大牛

发布

1回答

c、linux、ipc、message

我有一个客户端进程，它构建一个IPC message struct queue_msg，该消息结构将通过linux IPC msg队列发送到服务器。大小为68字节。结构的指针，并为其分配错误的空间。代码裁剪 result = msg_snd(FooExchange, FooEntry, MsgSize, IPC_WAIT); 接收IPC消息的服务器正在获取68个字节(例如: sizeof FOO_TYPE)，然

浏览 37提问于2021-04-14得票数 0

1回答

用于存储持久消息的IBM延迟( Java客户机)

java、websphere、ibm-mq、websphere-liberty、mq

在用于“队列”的Websphere9控制台中，我们有“默认消息传递提供程序”和"WebSphere MQ消息传递提供程序“。我们的一个q是用“默认消息提供程序”创建的。现在我们观察到这个Q延迟区域的一些性能问题。当我们通过这个MQ在应用程序中有很高的负载时，延迟就会出现，并且数据不会在UI中被绘制。这是一个间歇性的问题，但我们想知道它是

浏览 3提问于2021-04-28得票数 0

1回答

如何将多个队列id传递给线程

c、multithreading、pthreads

我在C中的这个程序有一个问题。简而言之，我必须通过聚合器发送由传感器创建的数据。聚合器通过写入器线程将传感器生成的值通过三个读取器线程(thread_lettore)读取到三个不同的队列中，只有当我创建线程时，所有三个线程都连接到最后创建的队列。我希望每个线程都有自己的队列。传递传感器的消息队列</em

浏览 0提问于2021-04-14得票数 0

2回答

如何阻止HornetQ尝试重传

java、jms、spring-jms、hornetq

我有一个java客户机，它处理来自HornetQ的消息。处理可能会因为临时网络问题而失败，我可以通过抛出异常和配置队列来尝试重新传递来处理这些问题。然而，由于其他原因，处理可能会失败，这意味着不值得尝试重新传递。现在，我可以通过不抛出异常并让客户端使用消息来防止重新传递。但我不想这么做。我想要某种方式拒绝这条消息，实际上，我对队列说：“不要费心地重新传递

浏览 2提问于2018-05-11得票数 0

回答已采纳

1回答

EC2和AMQP:负载下奇怪的TCP问题

amazon-web-services、amazon-ec2、rabbitmq、amqp、aws-opsworks

我们的应用程序由一组EC2实例支持。其中之一是运行RabbitMQ，所有实例都从/向消息队列读取和写入消息。它开始间歇性地发生，然后一直都在发生。我重新启动了RabbitMQ，但没有帮助。重新启动实例:也没有帮助。据我所知(但我不确定)，问题在于实例无法相互通信(Rabb

浏览 1提问于2014-07-27得票数 1

回答已采纳

4回答

使用Linux消息队列

c、linux、posix、ipc

所有用户都应该使用Linux消息队列进行数据传递。信息将向两个方向流动。同时，多个客户端进程(Es)也可能已注册到服务器进程A。如何从其他客户端进程(Es)解除服务器进程A上的多路复用消息，以及从服务器进程A返回到相应的客户端进程，或者可能它可以发送回所有客户端进程(Es)，但必须仅在相应的客户端进程中处理。假设进程A已经创建了消息队列X。进程B和C现在正在出现，并且也打开消息<e

浏览 3提问于2013-04-23得票数 2

回答已采纳

1回答

Spring Integration JMS事务错误通道事务

jms、spring-integration

我创建的集成流程如下所示：我希望在JMS队列B和JMS队列C上保证消息的传递。但是，为了稍微增加难度，我希望将导致错误的消息存储在单独的JMQ队列中，并确认队列A上的消息。但是，如

浏览 0提问于2015-07-15得票数 1

1回答

将SQS与多个Laravel队列读取器一起使用时出错

php、laravel、amazon-sqs

我正在使用Laravel Jobs从SQS队列读取消息(Laravel版本5.7) 在Laravel indications之后，我使用supervisor同时运行多个queue:work进程。一切都很顺利，直到我收到与消息可用性相关的SQS错误： InvalidParameterValue (client): Value <R

浏览 20提问于2019-02-07得票数 3

1回答

Apache Flume -多个使用者从单个消息队列中摄取数据

apache、integration、message-queue、flume、solace

我目前正在开发Apache代理，它可以从单个消息队列(Solace)中摄取数据。由于消息处理速度慢是由于大小和将有大量的消息摄入，我正在考虑让多个代理来消费它们。然而，面临的挑战是，多个代理可能会接收相同的消息，从而导致水槽中的副本(登陆桶)。当一个代理正在处理消息(未确认)时，如果另一个代理从队列中获取消息，则可能会发生这种情况。

浏览 0提问于2018-07-19得票数 0

回答已采纳

2回答

像C#中的erlang那样具有非常大的数据流的消息传递

c#、erlang、message-queue、message-passing

这是一个关于消息传递的问题。这与用C#编写的内部应用程序特别相关。但它有一个类似于erlang的自行开发的“消息传递”系统。所以问题是:在erlang中，向进程发送消息的队列什么时候会满？erlang是否处理队列已满的情况？或者，在erlang中传递消息的队列是无限的

浏览 0提问于2012-01-03得票数 1

回答已采纳

1回答

在Linux中实现消息队列的非持久性

linux、persistence、message-queue

这可能是一个关于消息队列的完全陌生的问题，但我们在整个Linux系统中持久化消息队列时遇到了一些问题。我们正在运行Fedora 14，并使用消息队列向线程传递数据和从线程传递数据。问题是我们创建了一个消息队列：其中： s

浏览 5提问于2011-07-07得票数 1

回答已采纳

1回答

码头与主机系统的进程间通信

python、apache、multiprocessing

这应该可以通过网络使用HTTP访问。由于我希望Apache充当服务器，所以我使用python脚本将接收到的数据发送到我的程序，使用python multiprocessing.connection。如要发送的脚本 #!

浏览 3提问于2016-06-14得票数 0

回答已采纳

3回答

一种捕获webservice的结果并将结果发送给其他webservice的架构

c#、design-patterns、architecture

我正在用C#开发一个应用程序。我正在调用一个WS2服务(让我们称其为WS1)，并且我希望将结果发送到一个或多个其他(外部)WS2服务(例如WS2和WS3)。要实现这一点，好的架构是什么？有没有人有一个在线文档的链接，其中描述了这样的架构？

浏览 0提问于2019-01-16得票数 1

3回答

Amazon死信队列:它真的是死信还是毒药？

amazon-web-services、message-queue、amazon-sqs、message-bus

我试图弄清楚Amazon的SQS死信队列到底在做什么。死信队列-- SQS队列的ARN (Amazon )，它将接收用户在最大数量的接收后未成功处理的消息。这听起来不更像一个Poision队列吗？关键的区别在于消费者确实收到了信息。当消息可能很好，但无法传递时，可能是由于服务中断而发出的信是一纸空文。因为这听起来像是消息被成功地接收了多

浏览 1提问于2014-02-14得票数 23

回答已采纳

1回答

ActiveMQ将来会在Spring中作为传输被支持吗？

spring-xd

我们使用ActiveMQ作为我们的标准消息传递平台。XD已经支持ActiveMQ作为JMS源。作为传输的消息传递平台通过将有效负载放入以传输命名的错误队列中来帮助处理接收器故障。队列是使用批处理作业处理失败消息的更好方法。想知道将来是否支持ActiveMQ作为一种传输。

浏览 2提问于2014-07-03得票数 1

回答已采纳

2回答

当由多个线程执行时，我是否应该同步mq_timedreceive调用？

c、linux、posix、message-queue、shared-memory

我在Linux上使用Posix消息队列。基本上，我有多个线程通过调用mq_timedreceive从同一队列接收消息。如果多个线程同时运行并且队列不为空，是否可以保证消息不会被多次接收(即消息不会被传递到多个线程)？提前

浏览 4提问于2012-03-02得票数 4

回答已采纳

1回答

AWS上微服务之间的消息传递

microservices、aws、amazon-ec2

下面是一个场景：我们正在使用API和EC2实例在AWS上运行一个微服务风格的体系结构。假设有五种服务:照片服务、主题服务、用户发布服务、用户消息服务和用户配置文件服务。消息工作者复制所需的多个服务的消息，即如果用户评论服务、用户配置文件服务和用户消息服务都需要更新，则重复消息3次。消息工作者通过HTTP将数据发送到每个服务，每个服务通过HTTP进行响应，指示他们已经收到消

浏览 0提问于2017-09-05得票数 2

回答已采纳

1回答

莫斯基托对莫斯卡横向可伸缩性和弹性？

mqtt、mosquitto、mosca

我计划使用Mosca或Mosquitto代理(因为它们是开源的)，以实现具有消息队列复制的可伸缩体系结构，以避免在代理最终失败时丢失代理尚未传递的消息。正如我所读到的，蚊子是一种成熟且非常稳定的解决方案，具有使用桥梁的水平可伸缩性的能力。但是我找不到任何插件将消息写入数据库(对所有代理来说都是通用的)，所以我认为这是一个限制，因

浏览 3提问于2016-10-25得票数 2

1回答

PHPMailer / SMTP错误，但邮件仍在传递

php、email、phpmailer

最近，我一直在记录来自PHPMailer的邮件，这些邮件是通过SMTP通过Google帐户发送的。Google帐户上的“发送邮件”框时，这些消息仍然被成功地接收和传递。而且这些错误没有任何明显的一致性--看上去可能有3%的寄出邮件。我正在使用PHPMailer-5.2.16。没有什么特别的，特别是那些失败的信息，我可以用同样的方式成功地重发它们。$mail->send())

浏览 0提问于2018-02-02得票数 1

3回答

Linux多播中可能出现排队/缓冲延迟的位置在哪里？

linux、networking、multicast、latency、queueing

我们在LAN上的许多Linux服务器上大量使用多播消息。我们看到了很多延迟。我们基本上发送了大量的小包裹。我们更关心延迟而不是吞吐量。这些机器都是现代的多核机器(至少四台，如果算上超线程，通常是八台，16台)，负载总是在2.0或更低，通常负载小于1.0。网络硬件的容量也低于50%。消息传递结构基本上是这样的:在“发送线程”中，从队列中拉出消息，添加时间戳(使用gettimeofda

浏览 7提问于2010-02-18得票数 2

回答已采纳

点击加载更多