-
5 votesanswersviews
Kafka Java使用者永远不会收到任何消息
我'm trying to setup a basic Java consumer to receive messages from a Kafka topic. I'跟着样本 - https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example - 并且有这个代码： package org.example.kaf... -
2 votesanswersviews
是否有Kakao Talk Messaging API相当于LINE的Messaging API？
是否有Kakao Talk Messaging API相当于LINE的Messaging API？ LINE有“Messaging API”，允许第三方应用程序执行以下操作 . 自动回复LINE用户发来的消息 在任意时间将消息推送给LINE用户 等等 https://developers.line.me/en/services/messaging-api/ 我'd like to do... -
2 votesanswersviews
使用kafka即时消息传递
我正在尝试设计即时消息，或者更确切地说，我正在做基于回合制的游戏，其机制如下： 玩家“A”做某事并将有关他的步骤的信息发送给玩家“B” . 玩家“B”接收此信息也做某事并回复玩家“A” . 我正在考虑kafka sink连接器，如果它可以作为客户端托管在kafka之外？因为它是一种避免编写大量代码并通过分区为客户端提供良好的消息接收机制的好方法，因此可以使用schemas e.t.c.我想做以下事... -
5 votesanswersviews
Apache Kafka订单根据其值来窗口化消息
我正在尝试找到一种方法来重新排序主题分区中的消息并将有序消息发送到新主题 . 我有Kafka发布者发送以下格式的String消息： {system_timestamp}-{event_name}?{parameters} 例如： 1494002667893-client.message?chatName=1c&messageBody=hello 1494002656558-chat.sta... -
15 votesanswersviews
微服务：REST与消息传递
我听说亚马逊使用HTTP作为基于微服务的架构 . 另一种方法是使用RabbitMQ或Solace系统之类的消息传递系统 . 我个人有基于Solace的微服务架构的经验，但从未使用过REST .知道像亚马逊，Netflix，英国政府等各种大联盟实施使用的是什么？其他方面是，在微服务中，需要以下事项（除了其他事项）： 模式匹配*异步消息传递..接收系统可能已关闭*发布订阅*缓存加载事件..即在启动时... -
1 votesanswersviews
具有REST API和消息传递的微服务
是否可以让微服务将公共REST API暴露给网关，还可以通过消息传递与其他服务进行通信？ -
0 votesanswersviews
Wildfly Swarm - 资源适配器（IBM wmq.jmsra.rar）
在这些时刻，我正在尝试在Java项目中使用Wildfly Swarm配置IBM wmq.jmsra.rar资源适配器，但没有成功 . 这些是我到目前为止所做的步骤： 1）pom.xml（手工安装工件） <dependency> <groupId>com.ibm.mq</groupId> <artifactId>mq</artif... -
18 votesanswersviews
消息队列系统中的消息优先级本质上是不重要的吗？
似乎我所看到的大多数消息传递系统都具有对优先级消息队列的基本支持（如果有的话） . 例如，AMQP只有specifies至少2个优先级 . RabbitMQ，一个AMQP实现，doesn't support任何优先级 . 在几天内，ActiveMQ将在版本5.4中为10个消息优先级getting support . 10个优先级是JMS spec指定的 . 在非消息传递意义上的单词中的prio... -
0 votesanswersviews
生产环境 者（设备）和Messaging Server（Apache Qpid或RabbitMQ）之间的负载 balancer
最近我开始研究一个需要实现Messaging的项目，可行的选项有：Apache Qpid或RabbitMq，My Task是这样的： +A+ >>.[Millions Devices (Producers) -- Connected to -- Messaging Server (Clustered -- Qpid or RabbitMQ) ] { LOAD BALANCING) 然后... -
3 votesanswersviews
同一Websphere MQ JMS Queue上的两个使用者，都接收相同的消息
我正在与使用JMS Queues和IBM Websphere MQ实现负载 balancer 行为的人合作 . 因此，他们将多个Camel JMS使用者配置为从同一个队列中读取 . 尽管根据JMS规范（我上次无论如何看）这种行为是未定义的，但他们期望有一种循环/负载 balancer 行为 . 而且，虽然规范留下了这个未定义的，但我还是认为Websphere MQ的正常行为是将消息传递给其中一个消... -
1 votesanswersviews
了解未应用的消息重新排队顺序
首先，我引用RabbitMQ docs中的以下文字： 当消息重新排队时，如果可能，它将被放置在其队列中的原始位置 . 如果不是（由于当多个消费者共享队列时同时传递和来自其他消费者的确认），该消息将被重新排队到更靠近队列头的位置 . 现在想象一下，在同一个队列中有两条消息（A和B），两个都没有被解包：当官方文档说"[...] closer to queue head"给出任何... -
73 votesanswersviews
为什么要使用AMQP / ZeroMQ / RabbitMQ
而不是写自己的图书馆 . 我们正在开发一个项目，这个项目将是一个自我划分的服务器池，如果一个部分变得太重，管理员会将其划分并将其作为一个单独的进程放在另一台机器上 . 它还会警告所有连接的客户端，这会影响连接到新服务器 . 我很好奇使用ZeroMQ进行服务器间和进程间通信 . 我的伴侣宁愿自己动手 . 我期待社区回答这个问题 . 我自己是一个相当新手的程序员，只是学习了消息队列 . 正如我用Goo... -
0 votesanswersviews
双向消息队列
这似乎是一个属于常见问题解答的问题，但我无法用短语来回答这个问题 .无论如何，我目前正在研究消息队列（通过ZeroMQ，RabbitMQ教程），我认为MQ非常适合转换数据流 - 在Q1上收听格式为F1的消息，转换为F2并将转换后的消息放在Q2上 . 如果转换本质上是双向的并且没有明确定义的消费者和 生产环境 者，例如，如果发生了什么，则会出现自然的问题 . yaml < - > js... -
0 votesanswersviews
在activemq 5.8中配置纯主/从配置时出错？
我正在尝试配置纯主/从代理配置 . 在slave activemq.xml文件中，我有以下配置 <services> <masterConnector remoteURI="tcp://localhost:61616" /> </services> 当我启动奴隶经纪人时它会给我以下错误： 加载失败：类路径资源[activemq.x... -
1 votesanswersviews
显式的acking消息时是否需要打开ActiveMQ使用者？
我的应用程序通过从ActiveMQ读取消息来进行批处理 . 我通过实现 MessageListener 来阅读使用异步JMS API . 但是，只有在批处理成功时才通过调用 message.acknowldge() [1]来确认消息 . 我理想的是，在批处理进行之前，我没有收到来自JMS代理的任何消息 . 但我怀疑在关闭消费者之后，我是否能够确认我之前读过的消息以及正在处理的消息 . 换句话说，... -
2 votesanswersviews
如何将SQL Server 2008 R2用作ActiveMQ 5.9的持久存储
我的IT基础架构需要基于SQL Server 2008 R2数据库的持久性 . 我正在尝试在Windows上为ActiveMQ 5.9配置SQL Server持久性，但无论是否具有日志记录都无法找出正确的配置架构 . 默认配置使用kahadb，它可以工作： <persistenceAdapter> <kahaDB directory="${activemq.da... -
0 votesanswersviews
在Activemq中的同一连接中创建使用者和临时队列？
我是activemq的新手 . 当我为临时队列创建一个消费者时，消费者给出了在session.it中创建的临时队列的点 . 它将是一个同步进程 . 之后它将产生消息给broker（activemq） . 代码如下 // client side Destination tempDest = session.createTemporaryQueue(); MessageConsumer respo... -
1 votesanswersviews
如何在Spring Integration中处理繁重的消息加载？
外部模块将数千条消息发送到消息代理 . 每条消息的TimeToLive属性等于5秒 . 另一个模块应该使用和处理所有消息 . 从Spring Integration文档中我发现，分阶段事件驱动架构（消费者）对负载中的显着峰值做出了更好的响应 . 我目前的实现使用EDA（甚至驱动架构），例如， <si:channel id="inputChannel"/> <... -
3 votesanswersviews
生产环境 者和消费者之间的RabbitMQ消息延迟
我在RabbitMQ服务器上运行node.js amqp-node客户端 . 我已经以两种不同的方式设置了一个简单的发布/消费测试 - 每种方式产生不同的延迟，我无法弄清楚原因 . 延迟是从发送消息到发送消息的时间来衡量的 . 第一种方法使用两个单独的进程 - 一个用于发布应用程序 - 一个用于使用应用程序 . 它产生大约4ms的延迟 . 第二种方法只使用一个应用程序来生成和使用 . 这产生大约4... -
9 votesanswersviews
RabbitMQ Channels 创建指南
我正在编写一个简单的类，我的应用程序将使用RabbitMQ发送和接收消息 . 我已经阅读了尽可能多的How-Tos，博客文章，白皮书以及关于RabbitMQ的喜欢 . 大多数示例显示使用包含在using块中的连接和通道，并且通过说您应该将它们实现为单例来抵销它 . 特别是关于 Channels ，我看到评论说你不应该同时使用单个 Channels 的多个线程 . 我正在用c＃编写我的库 . 它是在... -
0 votesanswersviews
如何使用Yahoo IM消息api？ （unable_to_determine_oauth_type）
最近，我刚刚通过在线[yahoo oauth 2.0指南为开发人员创建了一个雅虎应用程序，] [2] 我可以获得OAuth 2.0凭据，但在调用雅虎IM相关[API] [3]时遇到“unable_to_determine_oauth_type”oauth问题 . 为什么？ 这是我的步骤： curl -v https://api.login.yahoo.com/oauth2/request_au... -
1 votesanswersviews
请求/响应消息传递模式 - Azure Service Bus
全部， 我对请求响应模式有疑问...假设以下是我的方案 1.I have a service running on Windows Azure. This service can be called by users to execute a command. 2.I have a client applications that is running on my intranet. This c... -
1 votesanswersviews
卡夫卡制片人配额
以下是我们的 IoT 平台中的入站消息流： Device ---(MQTT)---> RabbitMQ Broker ---(AMQP)---> Apache Storm ---> Kafka 我希望实现一个有效 limits/throttles 每秒发布到 Kafka 的数据量的解决方案。 当前的策略使用 Guava 的 RateLimiter，其中每个设备都有自己的本地缓存... -
0 votesanswersviews
Kafka 制片人表现不佳
我和kafka制作人有问题 . 其实我正在使用spring kafka，并通过KafkaTemplate发送消息： DefaultKafkaProducerFactory<K, V> defaultKafkaProducerFactory = new DefaultKafkaProducerFactory<>(producerParams); KafkaTemplate k... -
2 votesanswersviews
将chatbot集成到任何第三方消息传递API中
我希望为来自多个平台的消息制作一个统一的“收件箱”，其中一些得到所有大型聊天机器人服务的广泛支持，比如Facebook Messenger，其他一些比WhatsApp更加模糊，但其他人则不支持（如Steam Web Chat） . 我遇到过几种针对最流行的信使进行某种“一键式”集成的解决方案，但我找不到能让你集成第三方信使（理想情况下有一个API来读取/发送消息）的解决方案至少）进入类似聊天机器... -
97 votesanswersviews
RabbitMQ / AMQP：单个队列，同一个消息的多个消费者？
我一般只是开始使用RabbitMQ和AMQP . 我有一个消息队列 我有多个消费者，我想用 same message 做不同的事情 . 大多数RabbitMQ文档似乎都专注于循环，即单个消费者使用单个消息，负载在每个消费者之间传播 . 这确实是我见证的行为 . 例如： 生产环境 者有一个队列，每2秒发送一次消息： var amqp = require('amqp'); var conn... -
4 votesanswersviews
在微服务的发布/订阅模型中，如何每种服务类型只接收/使用一次消息
我们正在设计一个微服务架构模型，其中服务A发布消息和服务B，而C希望接收/消费该消息 . 但是，对于高可用性，服务B和C的多个实例同时运行 . 现在的问题是我们如何设计使得只有一个B的服务实例和一个C的服务实例接收消息而不是所有其他服务实例 . 据我所知，RabbitMQ实现这种行为并不容易 . 我想知道Kafka或任何其他消息传递框架是否内置了对此场景的支持，我认为这在微服务架构中应该非常普遍 ... -
0 votesanswersviews
使用RabbitMQ订阅一组消费者？
我不完全确定这是正确的问题，但我对RabbitMQ实现发布/订阅消息传递系统的功能有疑问 . 我正在调查RabbitMQ，看它是否符合我工作的公司的需求，我在官方文档或互联网上找不到这些问题的答案： 消费者是否可以订阅一组发布者？我想这是可能的，如果我们想要订阅的所有发布者都将他们的消息发送到交换机，然后将它们转发给订户 . 实现这个最合适的呼出类型是什么？ 是否可以订阅一组主题？例如，如... -
1 votesanswersviews
RabbitMQ：多个消息和单个消费者
我有RabbitMQ消费者的问题 . 实际上我有一个消费者从三个队列中发送消息 . 问题是我需要从每个消息中获取多条消息，但我的消费者每个队列只获得一个消息并且结束了 . 如果有人能帮助我解决这个问题，我将不胜感激 . 消费者代码如下 for (int i = 0; i < queueNames.size(); i++) { Channel channel = connec... -
8 votesanswersviews
如何实现具有多个使用者和多个队列的消费者 - 生产环境 者
假设有1个 生产环境 者P和2个消费者C1和C2 . 并且有两个队列Q1和Q2，都具有特定的容量 . P将 生产环境 物品并交替进入Q1和Q2 . 物品是为特定消费者 生产环境 的，不能被其他消费者消费 . 如何在Java中实现以下内容：在我启动3个线程后，如果Q1为空，则线程C1被阻塞，直到在Q1中存在某些内容时通知它 . Q2也是如此 . 当Q1和Q2都满时，P将被阻塞，直到Q1或Q2未满时...