messaging相关内容

Apache Kafka:Java Producer 的可重用性

有人知道吗 kafka.javaapi.producer.Producer 可以在多个方法调用之间重用(例如多个 send(...))还是每次都应该关闭? 解决方案 是的，它肯定可以重复使用.Producer 创建操作非常缓慢，因为它需要与所有分区(可能还有 zookeeper)建立连接.因此，应该尽可能重用生产者. ..
发布时间：2021-11-12 03:07:00 其他开发

Apache Kafka:Java Producer 的可重用性

有人知道吗 kafka.javaapi.producer.Producer 可以在多个方法调用之间重用(例如多个 send(...))还是每次都应该关闭? 解决方案 是的，它肯定可以重复使用.Producer 创建操作非常缓慢，因为它需要与所有分区(可能还有 zookeeper)建立连接.因此，应该尽可能重用生产者. ..
发布时间：2021-11-12 03:02:13 其他开发

Kafka 有持久订阅功能吗?

我有兴趣在我的一个项目中使用 Kafka，但是当其中一个订阅者(消费者)断开连接时，消息代理必须保留这些消息. 我看到 JMS 有这个功能. 在网站上说 Kafka 具有耐用性特性. 是和JMS一样还是意思不同? 解决方案 Consumer 从 kafka(brokers)拉取数据.消费者指定它想要收集数据的位置的偏移量.如果消费者断开连接并返回，它可以从离开的地方继续. ..
发布时间：2021-11-12 02:55:20 其他开发

Kafka 如何保证消费者跨分区处理的消息排序?

来源:https://kafka.apache.org/intro “通过在主题内具有并行性(分区)的概念，Kafka 能够提供排序保证和负载平衡在消费者进程池上.这是通过分配将主题中的分区分配给消费者组中的消费者，以便每个分区由组中的一个消费者使用.经过这样做我们确保消费者是唯一的读者分区并按顺序消费数据." 这只是意味着每个消费者都会按顺序处理消息，但是在同一个消费者组中的消费者之 ..
发布时间：2021-11-12 02:49:06 其他开发

Kafka 生产者可以创建主题和分区吗?

目前我正在评估不同的消息系统.有一个与 Apache Kafka 相关的问题，我自己无法回答. Kafka 生产者是否可以动态创建主题和分区(也在现有主题上)?如果是，是否有任何缺点? 提前致谢 解决方案 更新: kafka broker 有一个属性:auto.create.topics.enable 如果您将其设置为 true，如果生产者使用新主题名称向主题发布消 ..
发布时间：2021-11-12 02:16:42 其他开发

流处理和消息处理的区别

流处理和传统消息处理的基本区别是什么?正如人们所说，kafka 是流处理的不错选择，但本质上 kafka 是一个类似于 ActivMQ、RabbitMQ 等的消息传递框架. 为什么我们通常不说 ActiveMQ 也适用于流处理. 消费者消费消息的速度是否决定了它是否是流? 解决方案 在传统的消息处理中，您对消息应用简单的计算——在大多数情况下，每条消息单独计算. 在流处理 ..
发布时间：2021-11-12 01:51:31 其他开发

如何使用Android App作为“生产客户端"卡夫卡?

使用 Android 应用程序作为 Apache Kafka 的“生产客户端"是否可能/是否有意义? 假设我的 Android 应用需要捕获和分析反应时间数据.目标是收集所有数据并在应用中实时显示平均反应时间. 另一种方法是使用某种应用服务器作为接受来自 android 应用程序的消息并将它们发布到的中介Kafka，而不是让应用自己成为 Kafka Producer. 解决方案 ..
发布时间：2021-11-12 01:47:47 移动开发

在 Camel 中进行故障过滤

我试图从我的路线中过滤掉空体.路由每半秒左右从函数中轮询一次.因此，我每隔半秒就会在控制台中收到此错误.这是堆栈跟踪: 消息历史-------------------------------------------------------------------------------------------------------------------------RouteId Proces ..
发布时间：2021-11-11 23:00:36 其他开发

使用 MockEndpoints 测试 Camel

我有一系列“流水线"组件，它们都通过 ActiveMQ 消息队列进行通信.每个组件都使用 Camel 将这些队列中的每一个都视为端点.每个组件都使用相同的基本模式: 每个组件从输入队列中消费消息，处理消息，然后将 1+ 条消息放置在出站/输出队列中.然后，“输出"队列成为链中下一个组件的“输入"队列.非常基本. 我现在正在尝试卷起袖子，使用 Camel 的测试 API 提供的 Mock ..
发布时间：2021-11-11 22:48:26 Java开发

Java 消息传递:ActiveMQ、Mule、ServiceMix 和 Camel 之间的区别

我是 Messaging 的新手，想知道 ActiveMQ、Mule、ServiceMix 和 Camel 之间的区别 有人知道这些产品有什么不同吗? 提前致谢！ 编辑:还想知道任何学习这些东西的好地方/资源. 解决方案 ActiveMQ 是一个消息代理，它实现了 JMS API 并支持 跨语言客户端和网络协议的数量.它允许您实现队列或主题，并编写侦听器或订阅者来响应队列 ..
发布时间：2021-11-11 22:48:05 Java开发

Apache Camel 生产者和消费者

我很难理解这个概念. 我正在尝试实现一个端点，该端点侦听专有格式的传入消息的 tcp 端口，然后转换消息并让骆驼接管转发和路由. 我是否正确理解生产者负责将消息发送到 Endpoint 而 Consumer 从该端点接收它们? 在研究接口时，我无法弄清楚这些对象之间的消息流，尤其是在消费者部分.Consumer 只定义了 start() 和 stop() 方法... 在框架 ..
发布时间：2021-11-11 22:47:17 其他开发

带有 Actor 的设计模式

基于演员的范式非常酷.它的有效扩展能力使其成为必须评估任何并发系统的范例.我已经阅读了一些关于它的内容，并且对核心意图有一个不错的想法:用消息和多个“参与者"驱动昂贵的操作，以最大限度地减少由于请求/响应交互而导致的等待，从而增加系统的吞吐量.但是，我还没有充分了解人们与演员一起使用的设计模式.我正在寻找基于角色的系统的设计模式. actor 设计模式的一个常见示例是一个系统，其中有一个主协 ..
发布时间：2021-10-26 16:35:38 其他开发

如何在 Telegram Api 中订阅聊天更新?

我正在使用 Telegram API 开发小型自定义聊天应用程序.我设法进行了一些基本操作，例如创建授权/聊天和邀请其他用户. 现在我需要能够获取和处理应该来自 Telegram 本身的更新 - 例如传入的聊天消息和其他更新. 如何在 Telegram API 中执行此操作?是否有任何长轮询机制或类似的机制?我阅读了所有 API 文档，但未能找到任何允许订阅更新消息的 API.我发现的 ..
发布时间：2021-09-04 20:30:19 C#/.NET

使用“navigator.serviceWorker.controller.postMessage"；它将始终“TypeError:无法读取 null 的属性 'postMessage'"；

我遇到的问题是，在注册 Service Worker 后，navigator.serviceWorker.controller 总是 null. 我想使用 postMessage 向 Service Worker 发送消息.但是，navigator.serviceWorker.controller 总是返回 null，并显示错误 TypeError: Cannot read property ..
发布时间：2021-06-21 20:38:12 其他开发

动态启动和关闭 KafkaListener 只是为了在会话开始时加载以前的消息

我有一个用于 kafkalistener 的工作代码，用于从主题的开头(offset=0)(始终运行)读取消息.对于我的用例(消息传递)，我需要两件事: 总是捕捉特定主题/分区的新消息(这个消费者总是在运行)并发送到前端 websocket+stomp.(这部分我已经有了) 启动新的消费者以获取从特定主题/分区的开始到当前的消息，只有在前端发出信号时才停止，以便可以获取这些数据(为迟到 ..
发布时间：2021-06-02 20:32:12 其他开发

向 RoR 消息收件箱系统添加通知

我有一个带有实习消息系统的 rails 应用程序.用户可以向其他用户发送消息.示例:用户 1 发送消息用户 2 可以反之亦然. 一切正常.但我想用通知功能升级这个系统.我想输入通知类型: 1) 在导航栏上2) 邮寄 问题:我不知道我该怎么做. 你能帮我吗? 对话表 class CreateConversations ..
发布时间：2021-06-02 20:32:09 其他开发