22得票5回答
微服务和面向服务架构(SOA)的消息传递使用

我对尝试使用微服务/SOA架构非常感兴趣,但很难理解服务之间的集成如何实现。 我喜欢使用消息传递来解耦客户端和服务端,但不明白一个系统如何完全使用它。异步操作和发布/订阅等典型的场景都是有意义的——例如创建新订单、广播用于报告的数据等。但我不明白是否通常尝试将消息传递用于常见的请求/响应场景...

21得票3回答
如何在基于事件、消息驱动的微服务架构中,在故障情况下恢复状态

在微服务架构的背景下,消息驱动、异步、基于事件的设计似乎越来越受欢迎(参见此处和此处以及反应式宣言-消息驱动特性),而不是同步的(可能是基于REST的)机制。 在这个背景下,假设一个过度简化的订单系统如下所示: 以及以下的消息流: 从某个来源(Web / 移动等)下单 订单服务接受...

20得票6回答
有人能解释一下消息代理的用途吗?

在我的工作中,几乎每五分钟就会有人赞扬MQ Series、MSMQ或类似产品的优点,当这些炫酷的术语消失后,我总是想知道这些神奇的设备在现实世界中的一些实际应用 例子。 我希望找到一些能够激发我使用其中之一的用途,或者给我某种度量标准,以便评估消息总线/消息代理/消息队列,甚至能解释上述消息...

20得票1回答
使用MockEndpoints测试Camel

我有一系列经过“流水线化”处理的组件,它们都通过ActiveMQ消息队列进行通信。每个组件使用Camel将这些队列视为端点(Endpoint)。每个组件都使用相同的基本模式: 每个组件都会从输入队列中获取消息,处理这些消息,然后将1个或多个消息放置在输出队列上。 "输出"队列随后成为链中...

20得票3回答
实施消息总线架构

我目前正在为我们公司设计一种新的消息总线架构。我过去尝试使用MSMQ做类似的事情,它运作良好,现在考虑在这个项目中再次使用,但使用WCF作为API而不是使用System.Messaging API。有没有人在WCF中使用过MSMQ?相比使用System.Messaging API,使用它是否更...

20得票5回答
多播、消息传递、ActiveMQ与MSMQ的比较?

我正在为我们的产品开发一个消息/通知系统。基本要求如下: 发出并忘记 一组持久化的消息,可能会更新,并保留到发送者说要删除它们为止 这些库将用C#编写。Spring.NET最近发布了一个里程碑版本,具有许多不错的消息抽象,这很好 - 我计划广泛使用它。我的基本问题归结为消息代理的问题。...

19得票1回答
使用Redis实现JMS/AMQP消息模式

这个问题是因为我看到一些提及(例如this)使用消息传递软件,如ZeroMQ与Redis,但我一直听说Redis本身就是一个消息系统。因此,如果Redis与其他消息系统一起使用,是否意味着Redis本身作为消息系统时存在一些严重缺陷? 虽然我清楚Redis用于缓存和发布/订阅的用途,但不清楚...

19得票3回答
如何使用Disruptor处理多种消息类型

我的系统有两种不同类型的消息 - 类型 A 和 B。每个消息具有不同的结构 - 类型 A 包含一个 int 成员,而类型 B 包含一个 double 成员。我的系统需要将这两种类型的消息传递给多个业务逻辑线程。减少延迟非常重要,因此我正在研究使用 Disruptor 以机械方式传递消息从主线程...

18得票4回答
如何使用RESTful Web服务创建异步通知系统?

我有一个Java应用程序,通过RESTful Web服务提供。我想创建一种机制,使客户端可以注册获得事件通知。但问题是不能保证客户端程序都是Java程序,因此无法使用JMS(如果每个客户端都是Java应用程序,则可以允许客户端订阅JMS主题并在那里侦听通知消息)。 使用情况大致如下: 1....

18得票5回答
RabbitMQ等待多个队列完成

好的,以下是正在发生的事情的概述: M <-- Message with unique id of 1234 | +-Start Queue | | | <-- Exchange /|\ / | \ / | \ <...