messaging

0热度

1回答

我想在角2做消息，但我有一个问题。我的问题是：如何处理接收到的消息列表时自动刷新当另一个用户给我发送消息？（现在我必须刷新页面才能拥有它）。也许我可以使用Observable，但是如何？谢谢你的帮忙！

0热度

1回答

我有2个JMS队列，我的应用程序可以根据收到请求的节点将消息发布到任何一个队列。 Pentaho应该积极地看待这两个队列，并且应该能够在消息到达队列中的任何一个时立即进行处理。目前，我已经实现了一项工作来主动侦听一个队列并处理该消息并发布相同的响应。如何配置pentaho以同时主动侦听两个队列，并在任何队列发布消息时执行相同的操作？编辑我不知道Pentaho提供此类内部服务通信的任何此类直接

0热度

1回答

订阅一群使用RabbitMQ的消费者？

我不能完全肯定这是提出正确的地方，但我对的RabbitMQ的运作问题，实现发布/订阅消息系统。我调查的RabbitMQ，看它是否适合我工作的公司的需要，我找不到任何回答这些问题无论是在官方文档或在互联网上：是否有可能为一消费者订阅一组发布者？我想这是可能的，如果我们想要订阅的所有发布者都将他们的消息发送给交换机，然后将它们转发给订阅者。执行此操作最适合的呼气类型是什么？是否可以订阅一组主题？例

1热度

1回答

卡夫卡生产者配额

这里是我们的物联网平台的入站邮件传递流程： Device ---(MQTT)---> RabbitMQ Broker ---(AMQP)---> Apache Storm ---> Kafka 我期待实现解决方案，有效地限制/节流数据以每个发布到卡夫卡每秒量客户基础。当前的策略利用Guava的RateLimiter，每个设备都有自己的本地缓存实例。当接收到设备消息时，映射到该deviceId

0热度

2回答

是否有意义使用Apache卡夫卡对于这种情况？

有几个应用程序必须集成在一起，他们必须交换问题。所以他们中的一个会解决问题，然后做一些事情，然后改变这个问题的状态。其他可能涉及此问题的应用程序应该获得新的信息。这一直持续到问题达到最终状态结束。问题是必须映射问题，因为这些应用程序并不都支持相同的数据格式。我不知道是否总是发送整个问题还是只发送新状态作为事件。卡夫卡如何支持数据转换？如果我的问题有一个附件？（> 5MB）谢谢你的建议

0热度

1回答

RabbitMQ同步消息传递的优缺点

因为我们都知道像rabbitMQ这样的消息总线主要用于异步消息传递，因此标准接近是在公共汽车上发布和发布消息，而不用担心谁会处理发布的消息或何时。但是我正在考虑我们的开发团队中有关消息同步处理的最新讨论：情况是将消息发布到服务总线，并且作为发布者，我想等待任何订阅者处理消息并将结果返回给我 - 因此它看起来像而是作为请求 - 响应模型。我现在正在考虑一个类似于这个模型中性能下降的问题。你怎么看？何

3热度

1回答

Microsoft.ServiceBus.Messaging与Microsoft.Azure.ServiceBus

MS最近推出了Microsoft.Azure.ServiceBus命名空间。 https://github.com/Azure/azure-service-bus/blob/master/samples/readme.md 它非常适合新.NET标准框架（好像MS没有足够的半冗余代码基地）我的问题是，如何更好地难道是在条款的表现？我可以有把握地说，Microsoft.ServiceBus.Mes

-1热度

1回答

ArtemisMQ - 在基于点对点的集群中工作吗？

我需要写关于ArtemisMQ的快速评论。有一点考虑ArtemisMQ在集群中的体系结构。根据文档（或者我理解这点），节点独立工作 - 每个节点都可以被发现，然后在彼此之间创建一些核心桥接。这似乎是P2P。我对吗？

0热度

2回答

Microsoft.Azure.ServiceBus .net标准 - 如何批量接收

我期待将使用Microsoft.ServiceBus的一些工作迁移到Microsoft.Azure.ServiceBus。这是为了我们可以瞄准.net标准。以前的代码使用ReceiveBatchAsync为了在一次调用中检索多个消息。在新的命名空间中我看不到一种方法。设计中是否有新的东西使得这个冗余，还是1.0.0发布版本只部分完成？最佳实践指南似乎指向Microsoft.ServiceB

-1热度

1回答

使用REST API和消息传递的微服务

将微服务暴露给网关的公共REST API并通过消息传递与其他服务通信可以吗？