messaging相关内容

Caliburn.Micro.使用 Autofac 为 IHandle 实现者自动调用 eventaggregator.Subscribe()

在 Caliburn.Micro 文档中,作者提到了这种可能性: 文档链接 IHandle 继承自标记接口 IHandle.这允许使用强制转换来确定对象实例是否订阅了任何事件.如果您与 IoC 容器集成,这将启用简单的自动订阅.大多数 IoC 容器(包括 SimpleContainer)都提供了一个在创建新实例时调用的钩子.只需连接容器的回调,检查正在创建的实例是否实现 IHandle ..
发布时间:2021-11-30 20:03:33 其他开发

Android 发送短信的意图是什么?

嘿!我想知道 android 在发送消息时发送的意图是什么.我如何在我的应用程序中监听这个意图.我想要这样,当我在原生 android 消息传递中发送消息时,我的应用程序会侦听此意图,因此它会知道已发送一条新消息. 那么,它是哪一个,以及如何倾听这个意图? 谢谢. 解决方案 我相信意图是: public static final String SMS_RECEIVED_ACT ..
发布时间:2021-11-27 16:09:33 移动开发

AMQP 0-9-1 对 1-0

我正在为一个新项目寻找消息服务,该项目必须将一些 C# 应用程序与一些 Java 应用程序连接起来.我真的很喜欢 RabbitMQ,因为它似乎对这两种技术都有惊人的支持.我在 RabbitMQ 规范中看到,目前只提供了 AMQP 0-9-1 模型. 那是节目的终结者吗?我应该向提供 AMQP 1.0 的 ActiveMQ 发送地址吗? 感谢您的建议 解决方案 您的问题在官方 中 ..
发布时间:2021-11-27 11:50:00 其他开发

在 FIFO 队列系统中,实现优先消息传递的最佳方式是什么?

对于不始终支持优先级消息的面向消息的中间件(例如 AMQP),当队列只有 FIFO 语义时,实现优先级消费的最佳方法是什么?一般用例是这样一种系统,其中当队列中存在大量消息积压时,消费者会在收到较低优先级消息之前收到较高优先级的消息. 解决方案 鉴于给定的单个队列仅支持 FIFO,您当然必须引入多个队列、中介或具有更复杂的消费者.> 可以通过多种方式处理多个队列.生产者和消费者可以同意在 ..
发布时间:2021-11-27 11:48:48 其他开发

为什么使用 AMQP/ZeroMQ/RabbitMQ

而不是编写自己的库. 我们正在这里开展一个项目,该项目将是一个自我分割的服务器池,如果一个部分变得太重,经理会将其分割并作为单独的进程放在另一台机器上.它还会提醒所有受此影响的已连接客户端连接到新服务器. 我很好奇使用 ZeroMQ 进行服务器间和进程间通信.我的伙伴更愿意自己动手​​.我期待社区来回答这个问题. 我自己是一个相当新手的程序员,刚刚了解了消息队列.正如我在谷歌上搜 ..
发布时间:2021-11-27 11:47:27 其他开发

如何有选择地从 AMQP (RabbitMQ) 队列中删除消息?

我想有选择地从 AMQP 队列中删除消息,甚至不读取它们. 场景如下: 发送方希望基于 X 类型的新信息到达的事实使 X 类型的消息过期.因为订阅者很可能还没有消费最新的 X 类型消息,发布者应该删除以前的 X 类型消息并将最新的消息放入队列中.整个操作应该对订阅者透明——事实上他应该使用像 STOMP 这样简单的东西来获取消息. 如何使用 AMQP 做到这一点?或者也许在另一种 ..
发布时间:2021-11-27 11:46:04 其他开发

RabbitMQ/AMQP:单个队列,同一消息的多个消费者?

我刚刚开始使用 RabbitMQ 和 AMQP. 我有一个消息队列 我有多个消费者,我想用相同的消息做不同的事情. 大多数 RabbitMQ 文档似乎都集中在轮询机制上,即单个消息由单个消费者消费,负载分布在每个消费者之间.这确实是我亲眼所见的行为. 一个例子:生产者有一个队列,每 2 秒发送一次消息: var amqp = require('amqp');var conne ..
发布时间:2021-11-27 11:43:44 其他开发

如何使用 Message Broker 和数据库设计分布式应用程序?

我想实现一个分布式销售点系统,有点像 销售点应用架构建议. 这是一个具有以下特点的分布式系统: 客户端是关键任务,即使网络连接或服务器出现故障,它们也应该可以工作,但只能持续几天左右. 客户端必须易于安装. 每个客户端都有自己的本地嵌入式数据库. 客户端和服务器之间的通信使用消息队列. 服务器用于备份、记账、统计和向客户分发价格. 服务器位于互联网上. 我正在以 Jav ..

微服务:REST 与消息传递

我听说亚马逊在其基于微服务的架构中使用 HTTP.另一种方法是使用消息系统,如 RabbitMQ 或 Solace 系统.我个人有使用基于 Solace 的微服务架构的经验,但从未使用过 REST. 知道 Amazon、Netflix、UK Gov 等各种大联盟实施使用什么吗? 另一个方面是,在微服务中,需要以下内容(除其他外): * 模式匹配 * 异步消息.. 接收系统可能已关闭 * ..
发布时间:2021-11-17 02:25:45 其他开发

微服务:什么是智能端点和哑管道?

我阅读了 Martin Fowler 的一篇文章“微服务",发现很难了解智能端点和哑管道.请解释这些术语,欢迎举例. 解决方案 我没有读过这篇文章,所以我只能推测他的确切意思,但正如他以 ESB 为例针对微服务和 ZeroMQ 作为一个例子以微服务为例,我希望我的推测非常准确: Unix(和Linux)的一个想法是构建小的独立应用程序并通过管道连接它们.我使用的可能最常见的两个命令集 ..
发布时间:2021-11-17 02:00:16 其他开发

共享数据库与消息传递架构

昨天我和我的一个朋友在酒吧里,我们开始讨论他工作的公司正在使用的架构.谈话基本上围绕着共享数据库架构与分布式独立应用程序架构的优缺点 - 我们无法达成共识,在这种情况下,我想听听人们对这两种方法的优缺点的看法. 基本上,他工作的公司拥有包含许多不同应用程序的大型架构.某些应用程序具有它们之间共享的单个数据库.例如,有 1 个应用程序为用户提供 UI 以更改参考数据.此参考数据由另一个也访问相同数 ..
发布时间:2021-11-17 01:59:45 其他开发

实现消息总线架构

我目前正在为我公司的新消息总线架构进行分析和设计.过去我曾尝试过 MSMQ 做这样的事情,它运行良好,并且正在考虑为这个项目再次做同样的事情,但使用 WCF 作为 API 而不是使用 System.Messaging API.有没有人在 WCF 中使用过 MSMQ?使用 System.Messaging API 是否更容易?与 System.Messaging 相比,使用 WCF 有什么好处,反之 ..
发布时间:2021-11-17 01:54:27 C#/.NET

用于实现实时聊天应用程序的推送通知与 Web 套接字?

我正在考虑为 iPhone 构建一个实时聊天应用程序(但这个问题也适用于 Android 和其他设备)基本上我希望应用程序在打开和关闭时接收实时消息,只是就像 iPhone 自带的“消息"应用一样. 当它关闭时,我可以使用像 APNS 这样的原生推送通知服务,当应用程序打开时,我可以运行我自己的 websockets 服务器或使用像 PubNub 或 Pusher 这样的 3rd 方提供商, ..

GoogleCloudMessaging - InstanceID.getInstance(),从客户端注册

我对 Java 编程和一般编程非常陌生.现在我决定制作我自己的应用程序,该应用程序应该使用 Google Cloud Messaging.不知何故我成功了,但后来我意识到我使用了方法 String regid = gcm.register(PROJECT_NUMBER); 这已被弃用,我现在应该使用令牌和 InstanceID.所以我尝试重写我的注册来使用它,但我遇到了 InstanceID. ..
发布时间:2021-11-15 02:54:08 Java开发

GoogleCloudMessaging - InstanceID.getInstance(),从客户端注册

我对 Java 编程和一般编程非常陌生.现在我决定制作我自己的应用程序,该应用程序应该使用 Google Cloud Messaging.不知何故我成功了,但后来我意识到我使用了方法 String regid = gcm.register(PROJECT_NUMBER); 这已被弃用,我现在应该使用令牌和 InstanceID.所以我尝试重写我的注册来使用它,但我遇到了 InstanceID. ..
发布时间:2021-11-15 02:53:23 Java开发

点差 vs MPI vs zeromq?

在 像 UDP 一样使用TCP 的可靠性,一位用户提到了 Spread 消息传递 API.我还遇到过一个名为 ØMQ 的问题.我也对 MPI 有所了解. 所以,我的主要问题是:为什么我会选择一个而不是另一个?更具体地说,既然有成熟的 MPI 实现,我为什么要选择使用 Spread 或 ØMQ? 解决方案 MPI 被设计为具有快速、可靠网络的紧耦合计算集群.Spread 和 ØMQ 是 ..
发布时间:2021-11-15 01:00:11 其他开发

将 3rd 方异步 API 与 Cap'n Proto RPC 集成的好方法是什么?

我有一个处理 Cap'n Proto RPC 请求的 Linux 服务器.其中一些请求需要将请求中的数据转发到另一台运行的服务器,在本例中为 Kafka 代理.librdkafka 和 Cap'n Proto KJ 库都可以使用 poll(),所以我认为操作系统将确保它们都可以异步运行,但我不确定是否需要或有益的进一步集成.有没有人有这方面的经验? 这个问题比我列出的细节要广泛一些.我将来可 ..
发布时间:2021-11-12 03:22:31 C/C++开发