我对尝试使用微服务/SOA架构非常感兴趣,但很难理解服务之间的集成如何实现。 我喜欢使用消息传递来解耦客户端和服务端,但不明白一个系统如何完全使用它。异步操作和发布/订阅等典型的场景都是有意义的——例如创建新订单、广播用于报告的数据等。但我不明白是否通常尝试将消息传递用于常见的请求/响应场景...
在微服务架构的背景下,消息驱动、异步、基于事件的设计似乎越来越受欢迎(参见此处和此处以及反应式宣言-消息驱动特性),而不是同步的(可能是基于REST的)机制。 在这个背景下,假设一个过度简化的订单系统如下所示: 以及以下的消息流: 从某个来源(Web / 移动等)下单 订单服务接受...
在我的工作中,几乎每五分钟就会有人赞扬MQ Series、MSMQ或类似产品的优点,当这些炫酷的术语消失后,我总是想知道这些神奇的设备在现实世界中的一些实际应用 例子。 我希望找到一些能够激发我使用其中之一的用途,或者给我某种度量标准,以便评估消息总线/消息代理/消息队列,甚至能解释上述消息...
我有一系列经过“流水线化”处理的组件,它们都通过ActiveMQ消息队列进行通信。每个组件使用Camel将这些队列视为端点(Endpoint)。每个组件都使用相同的基本模式: 每个组件都会从输入队列中获取消息,处理这些消息,然后将1个或多个消息放置在输出队列上。 "输出"队列随后成为链中...
我目前正在为我们公司设计一种新的消息总线架构。我过去尝试使用MSMQ做类似的事情,它运作良好,现在考虑在这个项目中再次使用,但使用WCF作为API而不是使用System.Messaging API。有没有人在WCF中使用过MSMQ?相比使用System.Messaging API,使用它是否更...
我正在为我们的产品开发一个消息/通知系统。基本要求如下: 发出并忘记 一组持久化的消息,可能会更新,并保留到发送者说要删除它们为止 这些库将用C#编写。Spring.NET最近发布了一个里程碑版本,具有许多不错的消息抽象,这很好 - 我计划广泛使用它。我的基本问题归结为消息代理的问题。...
我的系统有两种不同类型的消息 - 类型 A 和 B。每个消息具有不同的结构 - 类型 A 包含一个 int 成员,而类型 B 包含一个 double 成员。我的系统需要将这两种类型的消息传递给多个业务逻辑线程。减少延迟非常重要,因此我正在研究使用 Disruptor 以机械方式传递消息从主线程...
我有一个Java应用程序,通过RESTful Web服务提供。我想创建一种机制,使客户端可以注册获得事件通知。但问题是不能保证客户端程序都是Java程序,因此无法使用JMS(如果每个客户端都是Java应用程序,则可以允许客户端订阅JMS主题并在那里侦听通知消息)。 使用情况大致如下: 1....