message-queue

2热度

2回答

我想了解如何动态地向外扩展应用程序，它消耗的话题（可惜我不能减少其数量 - 通过设计每个主题是特定类型的数据）的数量庞大。我想我的应用集群从所有的200个多种主题分担负载。例如，当一个新的应用程序节点添加到集群中时，它应该从旧节点“偷走”一些主题订阅，这样负载将再次均匀分布。据我了解，卡夫卡partinions /消费群体帮助并行的话题，不共享多个主题之间的负载。

1热度

1回答

为什么我的信号处理程序不仅仅是等待子进程？

我的代码是一个多进程并发服务器进程，它使用系统V消息队列与客户端进程进行通信，一个客户端与一个子进程通信。第一个我希望等待子进程不再使用。当我设置SIGCHLD处理程序与SIG_IGN，程序可以正常工作，但总是错误，当我赶上SIGCHLD，错误是客户端进程阻塞在mesrcv系统调用，这意味着服务器不会发送消息给客户端。秒,当我输入^ \来退出我的客户端进程时，服务器进程终止，我使它成为一个守护

0热度

1回答

正在寻找消耗MDB消息来自远程队列的MDB当前示例10

我有一个定义队列的Wildfly 10实例，发布到该队列以及通过MDB从该队列接收消息。这已经完成了。现在我想添加第二个Wildfly 10实例，在另一台机器上运行，它也将接收来自第一个实例中定义的相同（远程）队列的消息。我花了2天寻找当前如何做到这一点的例子。有很多问题和一些过时的答案。它似乎是从Q实现中期望的最微不足道的事情之一，但我找不到任何示例。有人请向我介绍一个好的和当前的例

0热度

1回答

使用消息队列的线程同步不是为了

以下代码是从Raymond's Pycon keynotes on cuncurrency，很棒的演示。这是一个有点长，所以我会用这个问题开始：如果消息加到一起到队列，以前被认为是一个线程中完成的，怎么来的，他们都应该打印打印烂漫？在线程初始化之间添加一个100ms的延迟解决了这个问题，输出和预期的一样。 - import Queue, time counter_queue = Queue.

0热度

1回答

如何从REST通信到消息队列

REST Microservice如何与另一个混合的Microservice进行通信，这意味着他可以与REST和Message Queue进行通信。例如一个API网关。对于外部世界，他可以通过REST与应用程序，手机进行通信，但是来自后端的通信是通过消息队列进行的。使用案例：我的主页想要从数据库中获得车辆。他通过GET-Request请求API网关。 API网关接受GET请求并将其发布到消息队

1热度

1回答

想要在同一个RabbitMQ队列上运行多个使用者

我在后端有一个RabbitMQ应用程序。所以我想开发自定义的第三方分析代码，它连接RabbitMQ上的应用程序队列并收集数据。所以我的问题是我想确保应用程序和我的代码不会从rabbitmq中丢失任何数据。如果可能的话，我该如何配置RabbitMQ队列？我有RabbitMQ的管理权限。我希望，因为我没有访问做应用程序代码它不是生产问题的代码感谢您的帮助

0热度

1回答

混淆Masstransit ReceiveFrom方法和消费者行为

我想创建一个队列与RabbitMq在哪里我会发送一些消息在一边，并在另一个应用程序接收。我'与下面的代码这样做： return ServiceBusFactory.New(x => { var uriString = string.Format(@"rabbitmq://{0}/{1}/{2}?prefetch={3}", host, virtualHost, queue

1热度

1回答

如何在Masstransit/RabbitMQ中组织队列？

我想知道消费消息的最佳实践。我已经阅读了MassTransit文档，并且正在寻找这方面的内容，但是我没有得出任何结论。我有一个api（托管公交车实例），正在发布消息。这些消息是多种多样的，因为这个API不是微服务（购买，销售等的消息）。如何组织我的消费者/队列？一个队列类型的过程？例如，一个用于购买，另一个用于销售，这个解决方案可能涉及许多流程，我不确定它是否是一个好的解决方案。如果我想购买

0热度

1回答

进程间通信的最佳途径是什么？

嗨我要在.net中开发应用程序。它是.net核心。这是网络应用程序。我有一个进程在同一台机器上运行。这是用c编程编写的。我想在我的.net应用程序和进程之间进行双向通信。那么哪种机制非常适合？像我将在Linux环境中托管我的.net应用程序的要求，并且过程也在Linux环境中运行。我经历了命名管道，消息队列等。按照我的要求，这将是一个好的解决方案？在这方面可以有人帮助我吗？任何帮助将不胜感激。谢谢

0热度

1回答

限制在ActiveMq主题中发送消息的订户的最大数量

假设有一个ActiveMq实例，并且有100个客户端正在监听主题。当在主题中发布新消息时，是否可以限制接收它的订阅者数量（仅示例10）？如果现在有其他消息传递组件能够做到这一点，或者存在解决方案/合并最佳实践？