messagebroker相关内容

在 .NET 中使用 RabbitMQ 发布/订阅示例

我已经构建了这个示例:.net 中的 RabbitMQ 入门，但做了 2 个程序: 单一出版商 一个订阅者 我使用 BasicPublish 发布和 BasicAck 来收听，如示例所示.如果我在来自发布者的每条“发送消息"上运行一个发布者和几个订阅者，那么只有一个订阅者会收到它.因此，发布者向订阅者发送消息时存在某种顺序(当订阅者开始时)，我想向所有订阅者发送一条消息.那个样本有什 ..

发布时间：2022-01-11 17:57:35 c# rabbitmq publish-subscribe messagebroker C#/.NET

ActiveMQ 到 Apollo 的转换，Openwire 到 Stomp 的协议配置

我正在尝试从 ActiveMQ 5.6 切换到 Apollo 1.5.我有两个软件正在交换消息，使用发布/订阅主题. 第一个是 c++ 并且使用 openwire 和 tcp 第二个是 Javascript 并使用带有 websockets 的 stomp 使用 ActiveMQ 一切正常，我发送的消息可以在两个软件上读写，此后我没有更改客户端. 现在，我从 c++ soft( ..

发布时间：2021-11-15 22:07:02 activemq messagebroker apollo 其他开发

REST API 和消息传递

我有一个系统，它公开了一个 REST API，其中包含一组丰富的 CRUD 端点来管理不同的资源.REST API 也由使用 Ajax 执行调用的前端应用程序使用. 我想让其中一些调用异步并增加可靠性. 显而易见的选择似乎是消息代理(ActiveMQ、RabbitMQ 等...). 以前从未使用过消息代理，我想知道是否可以将它们“置于"REST API 之前而无需重写它们. ..

发布时间：2021-11-15 02:21:05 rest api esb messagebroker 其他开发

Kafka 0.8中producer能不能找到broker的增删改查?

我们知道，在kafka 0.7中，我们可以为producer指定zk.connect，这样producer可以找到broker的增删.但是在 kafka 0.8 中，我们不能为生产者指定 zk.connect.kafka 0.8 中的生产者能找到吗?如果不是，系统的扩展性不比0.7版本差? 解决方案 您仍然可以使用 ZooKeeper 客户端来检索代理列表: ZkClient zkCli ..

发布时间：2021-11-15 00:01:50 producer-consumer apache-zookeeper messagebroker apache-kafka 其他开发

从 Kafka 0.11.0.1 中的 _transaction_state 主题读取数据

我想读取事务的元数据(Kafka 0.11.0.1 支持)，以便我可以确定特定事务 ID 的事务是否已提交.目前我正在从 _transactional_state 主题获取键和值，但它采用某种编码格式.以下是我在轮询 __transaction_state 主题时收到的一些相同的键/值:键 = 10000000mmm，值 = +' ) 解决方案 您可以在 kafka/tools/DumpL ..

发布时间：2021-11-12 02:47:40 apache-kafka kafka-consumer-api messagebroker string-decoding 其他开发

Kafka 0.8中producer能不能找到broker的增删改查?

我们知道，在kafka 0.7中，我们可以为producer指定zk.connect，这样producer可以找到broker的增删.但是在 kafka 0.8 中，我们不能为生产者指定 zk.connect.kafka 0.8 中的生产者能找到吗?如果不是，系统的扩展性不比0.7版本差? 解决方案 您仍然可以使用 ZooKeeper 客户端来检索代理列表: ZkClient zkCli ..

发布时间：2021-11-12 02:23:09 producer-consumer apache-zookeeper messagebroker apache-kafka 其他开发

Kafka 基于键/值对的消息传递的目的是什么?

Kafka |producers 将 ProducerRecord 的键/值对显示为 not只是相同的类型(所有示例都显示 )，但具有相同的 值.例如: producer.send(new ProducerRecord("someTopic", Integer.toString(i), Integer.toString(i))); 但是在 Kafka 文档中，我似乎找不到解释键/值概念(及其潜 ..

发布时间：2021-11-12 02:06:51 apache-kafka message-queue messaging key-value messagebroker 其他开发

WSO2 MB 启动错误

我已经下载了 WSO2 MB 2.1.0 并使用 Windows 7 64 位的内置 Cassandra 服务器运行它.但启动过程失败并显示以下错误消息. [2013-12-14 11:27:03,371] 错误 {org.apache.cassandra.service.AbstractCassandraDaemon} -线程 Thread[Thread-21,5,main] 中的异常ja ..

发布时间：2021-09-29 18:53:18 wso2 messagebroker 其他开发

从Kafka 0.11.0.1中的_transaction_state主题读取数据

我想读取交易的元数据(在Kafka 0.11.0.1中受支持)，这样我可以弄清楚是否已提交特定交易ID的交易.目前，我正在从_transactional_state主题获取键和值，但是它采用某种编码格式.以下是我轮询__transaction_state主题时收到的一些相同的键/值:键= 10000000mmm，值= +' ) 解决方案 您可以在 kafka/tools/DumpLogSe ..

发布时间：2021-04-08 18:57:37 apache-kafka kafka-consumer-api messagebroker string-decoding 其他开发

生产者可以在Kafka 0.8中找到经纪人的添加和删除吗?

我们知道，在kafka 0.7中，我们可以为生产者指定zk.connect，因此生产者可以找到代理的添加和删除.但是在kafka 0.8中，我们不能为生产者指定zk.connect.kafka 0.8中的生产者可以找到那个吗?如果不是，那么系统的可扩展性是否不低于0.7版本? 解决方案 您仍然可以使用ZooKeeper客户端来检索代理列表: ZkClient zkClient = ne ..

发布时间：2021-04-08 18:51:32 producer-consumer apache-zookeeper messagebroker apache-kafka 其他开发

LASTMOVE循环无法正常工作

我的xml看起来像 - - + + + - - ..

发布时间：2020-11-26 02:08:53 ibm-mq messagebroker 其他开发

错误:WebSphere MQ原因码2538?

我在Linux上安装了WebSphere MQ和WebSphere Message Broker，执行mqsicreateexecutiongroup时出现错误消息: BIP1046E:无法连接队列管理器(无法连接到队列管理器"NSPZPAI1"(MQ原因代码2538)). 当我搜索此原因代码时，我了解到这是一个主机不可用错误. 有人可以告诉我如何解决此错误吗? 当我运行run ..

发布时间：2020-11-26 01:39:27 ibm-mq messagebroker 其他开发

Google发布/订阅队列或主题吗?

我对JMS熟悉，对Google Pub/Sub还是新手. 在JMS中，有2个选项: 队列:只有一个消费者可以接受消息. 主题:每个消费者都接受来自该主题的每条消息 我相信Google Pub/Sub应该支持这样的功能，但是快速谷歌搜索并不能帮助我回答这个问题. 请向我指出相应的文档部分. 解决方案 正如名称"Pub/Sub"所示，Google Pub/Sub支持与 ..

发布时间：2020-11-18 21:51:54 jms google-cloud-pubsub messagebroker 其他开发

直接与最终用户客户端一起使用消息代理

我想找到一种方法，以从服务器向同一终端的多个最终用户客户端实施推送消息。 我发现的一种选择是使用消息代理并使用它来实现 pub / sub 模式。在这种情况下，我不确定应该被认为是消费者。 我认为使用消息代理时的一般体系结构是： 最终用户客户端消息代理服务器（客户端和服务器也可以在与主题消息无关的事情上互相交谈） 我至少认为应该发生的过程是这样的： ..

发布时间：2020-10-21 02:04:42 design-patterns publish-subscribe messagebroker 其他开发

我的RabbitMQ集群是“主动”还是“主动”？

我已经使用join_cluster命令创建了由三个RabbitMQ节点组成的集群。 ie rabbitmqctl –n rabbit2 @ MYPC1 join_cluster rabbit2 @ MYPC1 （当前群集在单台计算机上运行） 问题： 在文档中说 我配置了什么？ 我该如何配置？知道吗？ 如何进行更改？ 在Active Ac ..

发布时间：2020-10-03 02:39:37 queue rabbitmq cluster-computing messagebroker 其他开发

REST API和消息传递

我有一个系统，该系统公开了具有丰富CRUD端点集的REST API，以管理不同的资源. REST API也被使用Ajax执行调用的前端应用程序使用. 我想使其中一些调用异步进行并增加可靠性. 显而易见的选择似乎是消息代理(ActiveMQ，RabbitMQ等). 以前从未使用过消息代理，我想知道它们是否可以“放在" REST API的前面而不必重写它们. 我不想仅通过消息传 ..

发布时间：2020-09-05 20:14:36 rest api esb messagebroker 其他开发

是否可以将REST和消息传递结合用于微服务?

我们拥有基于微服务架构的应用程序的第一个版本.我们使用REST进行内部和外部通信. 现在，我们想从CP(CAP定理)*切换到AP，并使用消息总线在微服务之间进行通信. 关于如何基于Kafka，RabbitMQ等创建事件总线的信息很多. 但是我找不到结合REST和消息传递的最佳实践. 例如，您创建了汽车服务，并且需要添加不同的汽车组件.为此，将REST与POST请求一起使用会更有意义.另一方面 ..

发布时间：2020-07-19 19:21:10 rest microservices messagebroker event-bus cap-theorem 其他开发

Spring @SubscribeMapping是否真的向客户端订阅了某个主题?

我正在将Spring Websocket与STOMP(简单消息代理)一起使用. 在我的@Controller中，我使用方法级别的@SubscribeMapping，该方法应将客户端订阅一个主题，以便客户端以后可以接收该主题的消息.假设客户订阅了主题“聊天" : stompClient.subscribe('/app/chat', ...); 当客户端订阅"/app/chat "而不是" ..

发布时间：2020-07-09 05:20:16 spring stomp messagebroker spring-websocket spring-messaging 其他开发

MessageQueue的契约：如果有MessageQueues，则示例提供程序测试

我已通过参考pact仓库中给出的示例示例为MessageProvider编写了示例Pact测试。以下是消费者测试，该测试正在为Provider期望的消息生成PACT json文件。 对于API，要验证PACT，我可以使用“ pact-jvm-provider-maven”插件来执行此操作。在这种情况下，将根据提供商的 actual 托管API服务对PACT进行验证。 我的问题是，在Me ..

发布时间：2020-06-07 18:41:34 messagebroker broker contract pact 其他开发

没有持久性的ActiveMQ

我想在产生消息的服务器和许多接收消息的客户端之间建立基于发布者-订阅者的通信协议。经过一些研究，我决定使用ActiveMQ。我查看了一些教程和ActiveMQ网站，并按如下所示设置了代理： BrokerService broker = new BrokerService（）; broker.setPersistent（false）; broker.addConnector（“ tc ..

发布时间：2020-06-01 19:12:55 java configuration activemq messagebroker Java开发