Dojo
话题
新佳
订阅
极道
元认知
元逻辑
元设计
元编程
元语言
消息队列教程
Kafka消息分发、主题分区与消费组的概念
本文主要从Kafka与传统JMS消息系统的对比中挖掘Kafka在消息分发和主题分区上的独特特点,Kafka通过主题topic、分区和消费组这三个概念灵活适应各种消息场合,业务设计关键是如何用好这三个概念,当然前提是理解这三个概念内在机制和逻辑性。 以下是英
Spring Boot和Kafka实战自定义复杂配置示例
这篇博客文章展示了如何配置Spring Kafka和Spring Boot以使用JSON发送消息并以多种格式接收它们:JSON,纯字符串或字节数组。基于此配置,您还可以将Kafka生成器从发送JSON切换到其他序列化方法。此示例应用程序还演示了同一消费组中三个Kafka消费者的使用情
为什么我们从RabbitMQ切换到apache kafka?
Trello过去三年一直在使用RabbitMQ,在RabbitMQ之前,我们还使用了于Redis Pub-Sub实现。最近,由于RabbitMQ在发生网络分区时出现了可疑行为,我们已经切换到了Kafka。 这篇博文深入介绍了我们的RabbitMQ实现,为什
小白解释:什么是分布式微服务中的幂等? - LispCast
幂等意味着重复无关紧要。这意味着您可以安全地重试操作而不会出现问题。典型的例子是电梯按钮:你按两次它就不会叫来两部电梯。我们在这里探索为什么我们希望在电子邮件服务器中使用该属性。 什么是幂等?为什么它对分布式系统中的编程有很大帮助?到本集结束时
在建立优步大型支付系统过程中学到的分布式架构概念
这是优步Uber员工Gergely Orosz自己的经验分享: 两年前我加入了优步,担任移动软件工程师,有一些后端经验,我构建了带有支付功能的应用程序 - 并在后来重写了它。之后,我就晋升工程管理并领导了一个团队。这意味着需要接触更多的后端,因为我的团队负
使用Spring Boot和Redis实现消息队列
在本文中,我们将介绍如何通过Spring Data Redis将Redis与Spring Boot一起使用的基础知识库。我们将构建一个应用程序,演示如何通过Web界面执行CRUD操作Redis,
分布式系统中的解耦模式:概要事件 - mathiasverraes
不要发出领域事件流,而是发出一个概要/摘要事件Summary Event。 问题业务流程涉及许多步骤,每个步骤都会产生领域事件。事件的消费者依赖于这些事件中的信息,并要侦听所有这些事件以做出有意义的决定。当只有少数事件类型时工作很好,但是当
GitHub - fencyio:为RabbitMQ消费者提供幂等性保证的库包
fency是一个使用SpringBoot和Redis消除RabbitMQ中重复消息的开源项目。即使发送方应用程序仅发送一次消息,接收方应用程序也可能不止一次地接收消息。幂等元一词在数学中用于描述一个函数,如果它应用于自身,则产生相同的结果:f(x)= f(f(x))。在消息处
如何迁移到微服务和事件溯源EventSourcing
这是一篇提供如何从单体大型应用迁移到微服务+事件溯源的指导性文章,文章提供了六条建议,主要是确定微服务边界,将事件作为首要设计,将系统从过去面向接口的耦合变成面向事件数据的耦合,从而大大地增加微服务的独立性和灵活性,同时为性能的弹性扩展提供了可能。所谓面向接口耦合,就是你事先设计几个接口,定义其中的
数据总线(Data Bus)
目的允许在应用程序的组件之间发送消息/事件,而无需彼此了解。他们只需要知道正在发送的消息/事件的类型。
Spring Boot和Apache Kafka结合实现错误处理,消息转换和事务支持?
Spring为Kafka带来了熟悉的Spring编程模型。它提供了KafkaTemplate用于发布记录和用于异步执行POJO侦听器的侦听器容器。Spring Boot自动配置连接了大部分基础架构,因此您可以专注于业务逻辑。 错误恢
Facebook是如何防止消息系统在新年前夕发生崩溃?
这是一篇来自IEEE Spectrum的文章,Facebook的Messenger的13亿用户会在新年前夜集中发送的消息,比如新年快乐等祝愿,这种发送量比一年中任何其他日子都多得多。如果一切顺利,这些消息将在不到100毫秒的时间内到达收件人,但是,如果消息系统服务停止或失败,位于公司
在Java中本地进行线程间数据传输的三种方式和源码展示
在线程之间进行通信或发信号时首先想到的是java.lang.Object类方法:wait,notify和notifyAll。这是最基本和最广泛认可的概念,但本博客并非讲这些。JVM实例上运行的线程缺少强大的预设模型,就像在UNIX中进行交互通信一样,尽管有一些第三方框架可以帮助我们实
EIP消息通道模式(EIP Message Channel)
目的当两个应用程序使用消息传递系统进行通信时,它们通过使用系统的逻辑地址(即所谓的消息通道)来实现。
Oracle Advance Queuing是否适合您?
最近在EmbedIT工作中,我需要评估Oracle AQ是否是一个替代旧的异步任务管理系统的不错选择。所以,让我分享一下我的经验。首先,有关Oracle AQ的文档非常庞大,因此我将
分布式系统中解耦的模式:胖事件 - mathiasverraes
将冗余信息添加到领域事件(增加颗粒度),这样可以降低使用者的复杂性。 问题消费者对来自生产者的一种事件类型感兴趣,对其作出反应或向用户报告信息,这是就需要对生产者的事件设计有
分布式系统中的解耦模式:完整性保证 - mathiasverraes
在事件的生产者这边设计一组领域事件,这些事件能够可完整用于重建生产者的状态。 问题通常,生产者发出的事件是随意设计的。只要新功能需要,就会添加新事件类型。消费者需要了解事件,因此我们在生产者这边提出对事件进
可靠的JMS与分布式事务
这篇Atomikos公司的技术提示文章仔细研究了“可靠”的消息传递方式以及如何实现它。正如我们将看到的,这完全取决于您如何配置和使用JMS。 关于JMSJMS(Java消息服务)是一种从Java或J2EE应
上页
下页
关闭