publish-subscribe

0热度

1回答

我想建立几个使用消息代理发送和接收消息的微服务：ActiveMQ。现在我探索消息类型选项（即String，byte[]，对象型）：发布味精XML/JSON格式，一旦收到它们被解析在XML发布味精/ JSON格式，采用的架构将它们转换为对象创建域对象，并加入到微服务依赖于数据交换这些都是3个选项我已经看了看，我倾向于选择1下面提到的原因：当一个新的领域有待只加那些需要这个领域需要改变微服务

6热度

2回答

在微服务中，我应该使用pub/sub而不是RPC来获得更松散的情侣架构？

我目前使用RPC调用通过TCP的另一个微服务并获得响应，但我认为我可以这样做：没有发出RPC调用，我可以使用pub/sub发送到一个服务，发布等request_user和订阅等object_user_response，然后被订阅此request_user其他服务的信道，信道的一些发布object_user_response。就像是： Service A <-- (sub)object_user

0热度

2回答

如何在事件采购和CQRS中使用发布/订阅模式

我正在开发微服务，我使用CQRS模式的事件采购，在我的情况下，如果用户从一项服务中删除/更新，我希望它发布一个事件和其他服务来订阅它，并从其db中删除关于该用户的条目。我想问如何在事件采购中使用pub/sub模式，可以使用哪个Event存储区，因为目前我已经看到一些人使用Azure Tables，但是如何将它用作pub/sub？

1热度

1回答

在NServiceBus 6中，端点是否可以在不知道发布端点的情况下订阅事件？

我已更新到NServiceBus 6，其中IProvideConfiguration<UnicastBusConfig>及其MessageEndpointMappings已过时。我遵循文档中的发布/订阅说明。据我了解，现在需要在订阅事件时明确命名发布端点。之前，我会具体事件接口，终点将是用户的名称： config.MessageEndpointMappings.Add( new

1热度

1回答

孤儿SYSTEM.MANAGED.DURABLE。*队列中的Websphere MQ

我有一个队列'SYSTEM.MANAGED.DURABLE.ABCD *** 109'一直在收取消息，没有人消耗它。我试图获取其订阅，但得到以下结果， dis sub(*) where (DEST LK 'SYSTEM.MANAGED.DURABLE.ABCD***109') AMQ8096: IBM MQ subscription inquired. SUBID(414D5120

0热度

1回答

回调函数不执行第二条语句 - C++ MQTT

我编写了一个处理MQTT消息（有效负载）的回调函数。我想切换的引脚不是基于传入的有效负载。我现在的问题是第一条语句在发送11时很好地执行。但第二条语句不起作用。奇怪的是，当我发送两条消息，一条包含1x和另一条x1时，我可以再次切换两个引脚。这是一个非常奇怪的问题！任何人都可以帮助我，非常感谢。我正在使用PubSubClient库。 void callback(char* topic, byte*

0热度

1回答

两个发布事件不适用于单击Dojo

两个publishGlobalMessage（）事件不起作用，首先单击代码中提到的附着点。首先点击发布事件不起作用。两个publishGlobalMessage（）的代码仅适用于第二次点击。清除缓存并再次尝试，但仍未找到解决方案。的代码片段是： - on(this._attachpTName", "click", lang.hitch(this.function(){ this._

0热度

1回答

如何将超时设置为Google Pubsub发布者和订阅者？

在我的java代码中，我使用Google -pubsub。我怎样才能设置用户超时 - 等待消息，直到超时？（我如何设置重试策略？）发布者 - 等到邮件发送时间为timeout时。（如何设置一个重试策略？）我看到这个post但没能翻译JS后去渣这是我如何设置我的子 final Subscriber subscriber = Subscriber .defaultBuild

0热度

1回答

如何配置谷歌pubsub使用队列机制？

我使用Google pub-sub（java）作为pub和sub。我找不到启用队列机制的方法。如果出版商发送消息之前，用户达含义，则消息不会丢失，并等待用户来获取。也许当我创建频道？ public void init(final String projectId, final InputStream inputStream) throws IOException { this.p

0热度

2回答

NATS发布者可以将单个消息发送到多个队列吗？

我正在构建一个系统，两个不同的实体需要处理来自同一个源的消息（以不同的方式 - 例如，一个会记录所有消息，而另一个实体可能需要聚合数据）。理想情况下，每个实体对于性能和弹性都是完全可扩展的，因此我们有多个发布者，多个日志订阅者和多个聚合订阅者，但每个发布的每个消息仍然由一个日志订阅者和一个聚合订阅者处理。通过AMQP，我们可以通过发布到扇出交换机来实现此目的，该交换机将消息分发到两个队列，其中每