message-queue

首页 > TAG信息列表 > message-queue

linux-D-Bus是中间件IPC吗？

https://stackoverflow.com/a/33888439/156458说 D-Bus didn’t used to be a Linux (i.e. kernel) IPC, but an additional middleware IPC. But in the course of introduction of 07001, D-Bus became for several Linux distributions a part of the basic system

消息队列生成文件错误：未定义对“ mq_open”的引用

即使我在我的Makefile中链接了-lrt,如下所示,我仍然得到对’mq_open’的未定义引用.请帮忙！ all:get1 iserv1 get: get1.c gcc -Wall -o get1 get1.c -lrt iserv: iserv1.c gcc -Wall -o iserv1 iserv1.c -lrt clean: rm -fr *~ get1 iserv1 解决方法:您的makefile错

C#-Rabbit MQ中的多生产者,多消费者,具有单个队列

我是RabbitMQ的新手,我需要编写一个具有多个生产者和一个单一队列的多个使用者的程序.这可以做我在图像中显示的吗？我发现了很多示例,但它们都是由单个生产者提供的.任何生产者都会向任何消费者发送消息.解决方法:简而言之,答案是绝对可以有许多生产者发布到单个队列中.我建议您创建

C#-重新排队后保持交货顺序

我正在开发一个使用Rabbit MQ进行消息传递的应用程序.我使用显式ACK： model.BasicConsume(queueName,false, consumer); 并在处理消息后执行ACK： consumer.Received += (ch, ea) => { try {

如何将消息反序列化为强类型对象,然后为该消息动态调用运行时分配的处理程序

ew,真是个头衔… 我正在为一个学习项目的服务器上工作.我花了很多时间试图弄清楚如何正确地解决这个问题.一开始,我不认为我什至完全知道自己想要达到的目标. 我正在使用的是具有N个组件(N> = 0)的服务器. >在运行时使用DI添加每个组件. >每个组件都是一个“黑匣子”.当它收到一条

python-挂钩并在Windows消息队列中记录“所有内容”

有谁知道如何连接到Windows消息队列(post / sendMessage)并在其中记录所有消息的有效代码示例？最好在Python中. 我对此深感兴趣,以便能够更轻松地创建模拟用户输入的测试脚本.解决方法:通常,这是通过SetWindowsHookEx Function完成的. 在Python中,您可能必须使用第三方库,例如Python

java-JMS体系结构问题？

问候, 在我正在处理的应用程序中,我有一个长期运行的过程(DNA分析).用户可以发送请求,我正在考虑将请求放入JMS队列中,然后相应地处理队列中的请求.然后,将结果通过电子邮件发送给特定用户. 但是,管理员应该能够更改请求的顺序/优先级.我想知道是否可以更改JMS队列的顺序.我可以使

python-Celery任务消失-Django / Celery

这是我的代码：我的任务 from celery.decorators import task @task() def add(x, y): return x + y 使用我的任务 from core.tasks import add results = [] for i in range(100): results.append(add.delay(i, i)) 问题1 几秒钟后,我将执行以下操作： for result in

为什么NServiceBus OutgoingHeaders是静态的而不是ThreadStatic？

当传出标头为静态时,NServiceBus如何保持一致性？这是否意味着如果我要为特定消息设置传出标头,由于它是单例,它将影响所有其他传出消息？ namespace NServiceBus.MessageHeaders { [ComVisible(false)] public class MessageHeaderManager : IMutateOutgoingTransportMessages

父级和子级之间的消息队列导致msgsnd中的参数无效

该过程将创建n个孩子(从stdin中读取n个孩子),每个孩子每2秒必须向父级发送一条消息,然后父级将接收到的所有消息发送给所有子级.我正在使用2个消息队列：一个队列,其中所有子进程都将msg发送给父进程,而另一个队列中,父进程发送消息,每个子进程都读取.每个孩子在成功发送或接收后都会

c#-Microsoft消息队列和资源发布的最佳做法

我想知道您在使用和处理消息队列时的最佳做法是什么.如果在可视化部分中特别是在处理部分中有代码,我也将不胜感激.该语言使用C#或任何.NET语言都可以.正在使用的队列是Microsoft消息队列. 目前,我遇到一个错误,即我们的系统资源不足,但是硬件规格的内存和磁盘空间很高. 我遇到的

Java-JBoss 5.1.0添加队列

如何将自定义队列添加到JBoss 5.1.0？我找到了一种通过管理控制台执行此操作的方法,但是由于某些原因它仍然无法运行,因此我还需要能够快速轻松地将队列从一台JBoss Server移到另一台JBoss Server. 因此,基本上,我想知道是否存在一种在xml文件中创建自定义队列并将该文件添加到deplo

python-我需要基于Web的系统的消息/排队解决方案

我正在寻找在Ubuntu上运行的基于Web的系统的消息/队列解决方案. 该系统基于以下技术构建： Javascript (Extjs framework) – Frontend PHP Python (Daemon service which interacts with the encryption device) Python pyserial – (Serial port interactions) MySQL Linux

python – 需要一个线程安全的异步消息队列

我正在寻找一个Python类(最好是标准语言的一部分,而不是第三方库)来管理异步“广播风格”消息. 我将有一个线程将消息放入队列(‘putMessageOnQueue’方法不能阻止),然后多个其他线程将等待消息,可能会调用一些阻塞’waitForMessage’函数.当消息放在队列上时,我希望每个等待的线程

python – 使用主题交换运行多个Celery任务

我正在用Celery替换一些自己开发的代码,但很难复制当前的行为.我希望的行为如下： >创建新用户时,应使用user.created路由键将消息发布到任务交换. >此消息应触发两个Celery任务,即send_user_activate_email和check_spam. 我尝试通过使用ignore_result = True参数定义user_created任

python – 获取RabbitMQ队列中的消息数

我们使用amqplib来发布/使用消息.我希望能够读取队列中的消息数(理想情况下都是已确认和未确认).这将允许我向管理员用户显示一个很好的状态图,并检测某个组件是否跟不上负载. 我在amqplib文档中找不到有关读取队列状态的任何信息. 有人能指出我正确的方向吗？解决方法:使用鼠兔： imp

php – RabbitMQ实现

这里有一些我目前的设置. > REST API将数据推送(队列)到队列中 > Queue有一个消费者,它始终在运行并生成到Exchange> Exchange路由到其他几个队列(如20)>每个(20)队列都执行特定任务(消费者总是运行)> Cron作业运行以检查是否所有(20)任务都已完成并生成另一个队列我不确定我喜欢

python – 限制传入消息以避免重复的最佳方法

我有一个系统接受包含网址的邮件,如果邮件中包含某些关键字,则使用网址作为参数进行API调用. 为了节省处理并保持我的最终演示效率. 我不希望在特定时间范围内提交重复的网址. 所以如果这个网址—> http://instagram.com/p/gHVMxltq_8/进来,它被提交给api url = incomin

在Java程序中的IBM MQ中创建主题

我想在我的Java应用程序中创建一个名为“manipulation”的主题,但是我收到此错误： Exception in thread "main" com.ibm.mq.MQException: MQJE001: Completion Code '2', Reason '2085' 我的代码是： MQTopic subscriber = new MQTopic(queueManager, null, "manipulation&

java – LMAX Disruptor vs JMS Provider

我被告知有一段时间LMAX干扰器以及与标准消息队列相比的性能如何.我下载了最新版本,看到它是一个普通的JAR,包含许多类和类型,都围绕着它的超快速RingerBuffer对象. 最终,在一天结束时,基于队列的JMS提供程序将归结为管理Java队列对象(或者更可能是并发队列)的大量代码.所以在这方

c – 在Linux上从消息队列中读取时出错“错误地址”

当我需要编写简单的时间服务器和使用Linux消息队列的客户端时,我有分配.服务器打开一个消息队列,客户端发送一个带有PID的消息(类型为1的消息),服务器读取该消息并发送一个PID类型的消息(取自读取的消息).我把所有代码都放在下面,因为我不知道我在哪里弄错了.我不是Linux编程专家.

C中的消息队列：实现2路通信

我是学生和C的初学者.我想在C linux中使用消息队列实现双向通信.我需要两个队列或只需要一个才能完成这项任务吗？另外我想知道我可以将数据(以代码显示)发送到另一个进程,或者我需要将其声明为字符数组. typedef struct msg1 { int mlen; char *data; }M1; typedef struc

java – RabbitMQ中的消息丢失

我尝试构建持久消息队列,每条消息有一些延迟.在Java代码中,它看起来像这样： ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); Connection connection = factory.newConnection(); Channel channel = connection.createChanne

c – POSIX消息队列 – 重启后是否仍然存在？

在linux上,编写了一个简单的程序来创建一个POSIX消息队列,并向它发送一个msg,在进程终止后,似乎msg仍然存在. 问题是： >重启后msg是否仍然存在？ >如果它存在,那么它在磁盘上,如果它将msg存储在磁盘而不是内存上,它如何保证性能.解决方法:在Linux上,消息队列安装在虚拟文件系统上,文件

c – 如何通过boost :: interprocess :: message队列传递复杂对象(std :: string)

有没有人有一些示例代码显示序列化std :: string的管道,通过boost :: interprocess :: message_queue发送它并再次将其取回？解决方法:您需要序列化数据,因为boost :: interprocess :: message_queue在字节数组上运行.如果您的所有消息都是字符串,那么只需： size_t const max_msg_siz