消息队列教程
-
Oracle 高级队列:指南
4 7K在本文中,我们将了解什么是 Oracle 高级队列 (AQ),探讨一些用例,并在实现队列时考虑常见的最佳实践。企业应用程序通常是组织独有的大型复杂程序。这需要高度的安全性和可扩展性。通常,内部和外部购.
-
Disruptor-rs:Rust中Disruptor库
37 1这是一个用 Rust 编写的低延迟、线程间通信库。特征 单一生产者单一消费者 (SPSC)。 多生产者单消费者 (MPSC)。 具有消费者相互依赖关系的多生产者多消费者 (MPMC)。 忙碌旋转等待策.
-
RabbitMQ中发布者通过确认机制确保消息发布
8 14K在本教程中,我们将学习如何使用发布者确认来确保将消息发布到RabbitMQ代理。然后,我们将了解如何使用消费者确认来告知代理我们已成功使用消息。场景在简单的应用程序中,我们在使用 RabbitMQ 时.
-
Rust中四种进程相互通信方式
38 15K探索在同一台机器上执行的不同进程之间的不同通信方式,并尽可能快地完成。我们专注于高速进程间通信 (IPC),但其中一些方法可以扩展到网络。我们将使用 Rust 进行探索。由于这些是独立的进程,因此我们.
-
Python中排队理论:吞吐量与延迟
34 7K在本文中,了解高级容量估计和工作负载优化所需的排队理论基础知识。到处都是排队! Java 的 fork-join 池使用具有工作窃取机制的多个队列。 相比之下,所有老式的Java 线程池默认都使用无界.
-
PgQueuer:一次一个队列,构建更顺畅的工作流程
46 2KPgQueuer 是一个极简、高性能的 Python 作业队列库,充分利用了 PostgreSQL 的强大功能。PgQueuer 专为简单和高效而设计,使用 PostgreSQL 的 LISTEN/N.
-
即时通讯ICQ自2024年6月26日关闭
51即时通讯鼻祖ICQ 将于2024年6月26日起停止服务。背景ICQ则是由以色列的Mirabilis公司开发,ICQ发布后不久,腾讯发布了中国版QQ,当时界面和概念上非常类似ICQ,同时期还有微软MSN.
-
工作流从无状态切换到有状态的好处
40在这篇文章中,描述了工作流应用程序从无状态到有状态设计的演变。初始无状态设计 最初建立在 Heroku 的免费 dynos(容器)上,它会在传入请求时启动。 由于 Heroku 不提供免费存储,因此使.
-
数据Redpanda平台简介
66 10KRedpanda 是一个开源流媒体平台,旨在快速、可扩展且可靠,满足现代数据密集型应用程序的需求。它提供了与 Apache Kafka 兼容的 API,可以轻松迁移现有应用程序。本文将探讨 RedPa.
-
Rill:Go语言中并发+事务的批处理开源项目
42 12KRill(名词:小流)是一个用于流式传输、并行处理和管道构建的综合 Go 工具包。它旨在减少样板文件并简化使用,使开发人员能够专注于核心逻辑,而不会因并发的复杂性而陷入困境。通过通道转换、类型安全、批.
-
异步API中事件、命令和状态区别
57 8K事件、命令、状态和时间序列值的区别:事件: 用户已创建 ECS实例已启动 命令/说明/请求 : 向用户 X 发送重置密码电子邮件 从用户 Y 处收取 £x 的付款 状态 : 用户(完整对象.
-
Go中使用Redis实现消息队列教程
96 9KRedis 和 Golang这对充满活力的组合将彻底改变我们处理消息系统的方式。Redis 作为内存数据存储以其速度和多功能性而闻名,它与 Golang(一种以其简单性和高性能而闻名的语言)无缝协作,.
-
Kafka中手工提交偏移量的4种方法
104 5K在Kafka中,消费者从分区读取消息。在读取消息时,需要考虑一些问题,例如确定从分区中读取哪些消息,或者防止重复读取消息或在发生故障时丢失消息。解决这些问题的方法是使用偏移量。在本教程中,我们将了解 .
-
Redpanda简介
138 10K在本教程中,我们将讨论一个名为Redpanda的强大事件流平台。这是对事实上的行业流媒体平台Kafka 的竞争,有趣的是,它还与 Kafka API 兼容。我们将了解 Redpanda 的关键组件、功.
-
Hatchet:Python中分布式、容错任务队列
88这是一个分布式、容错的任务队列开源项目。Hatchet 取代了难以管理的遗留队列或发布/订阅系统,因此您可以设计持久的工作负载,从故障中恢复并解决并发性、公平性和速率限制等问题。您可以使用 Hatch.
-
Go中使用消息队列实现微服务之间异步数据处理
84 16K在本文中,我们将深入研究微服务架构的世界,其中每个服务代表一个能够与其他服务协同工作的自治实体。但是如何在这样一个动态环境中管理数据呢?这正是异步成为我们盟友的地方。我们将探讨为什么异步数据处理对于微.
-
Java运行时添加Camel路由
113 8KApache Camel是一个 Java 框架,可以轻松实现各种企业集成模式 (EIP),从而为企业集成提供解决方案。集成模式中的常见任务之一是根据特定规则和条件确定运行时的消息路由。Apache C.
-
Python中使用Postgres用于队列的实现代码
70 3K事件表:id | status | updated_at------------------------------------------UUID | SMALLINT | TIMESTAM.
-
Java中多线程异步读写文件
117 7K当涉及到 Java 中的文件处理时,管理大文件而不引起性能问题可能具有挑战性。通过使用两个线程,我们可以在不阻塞主线程的情况下高效地读与写文件。通过多线程同时执行多个文件操作,利用多核处理器以及将 I.
-
什么是事件驱动编程范式?
111事件驱动编程是一种范例,其中程序的执行由用户操作或消息等事件决定。程序通过预定义的操作响应事件,从而允许异步和响应行为,这在 GUI 应用程序和分布式系统中常见。事件驱动编程范式的优点 实现异步处理,.
-
Java中的ArrayBlockingQueue教程
93 15KArrayBlockingQueue 是 Java 中一个强大的并发集合,它提供了阻塞队列的线程安全实现。这种数据结构在多线程需要以生产者-消费者模式进行通信和交换数据的场景中特别有用。在这篇博文中,.
-
GoLang中后台作业终极指南
141 15K在这篇博文中,我们将探讨GoLang、Redis和 Gocraft的强大组合,以及它们如何将您的Web 开发项目提升到一个新的水平。 GoLang是一种流行的编程语言,以其速度、并发性和效率而闻名,通.
-
Solid Queue:Ruby中基于数据库的后端队列作业系统
109Solid Queue 是一个基于数据库的Active Job队列后端,设计时考虑到了简单性和性能。除了常规作业排队和处理之外,Solid Queue 还支持延迟作业、并发控制、暂停队列、每个作业的数.
-
使用 POSTGRES 作为消息队列
424 6K本文研究了 Postgres 的轻量级通知机制,并讨论如何利用它来实现简单但有效的基于推送的消息队列。它还研究了使用此队列在 Kubernetes 部署上的副本之间进行通信,以及实现通用任务处理框架。.
-
KIP-932:Kafka用作一个简单的队列
97简单队列要求:无消息排序要求想使用Kafka作为一个简单的队列?有了新的KIP-932:引入共享(消费者)群体之前的Kafka消费者组Kafka常规消费者组非常适合可伸缩性和保持消息顺序两种选择。 保.
-
LMAX Disruptor 4.0.0 发布
419LMAX Disruptor是高性能线程间消息传递库: 现在最低 Java 版本为 11 问题#323 -WorkerPool已WorkProcessor被删除,不再存在Disruptor::hand.
-
Java 中使用 wait、notify、notifyAll快速指南
217 11K首先,你永远不应该直接使用wait, notify, 或notifyAll(除非你有充分的理由)。如果您需要执行多线程操作,请使用并发库。使用 wait/notify/notifyAll 构建生产者/.
-
Spring Modulith增加事件外部化的支持
398 2KSpringBoot应用程序的事务绑定#发件箱模式 实现,专门基于Kafka、AMQP和JMS的代理。应用程序模块之间交换的一些事件可能对外部系统感兴趣。Spring Modulith 允许将选定的事.
-
一张图比较:RabbitMQ、Kafka和ActiveMQ
600RabbitMQ: 基于Erlang构建 支持多种协议,包括AMQP、MQTT和STOMP。 以开发人员友好而闻名。 非常适合多个消费者的复杂路由。 Kafka: 基于Scala和Java构建 高度. -
EDA中事件内容的设计权衡
413用例:下订单。成功下订单后(付款成功并且向餐厅成功下订单后),订单服务会发布一个事件:食品配送合作伙伴服务,用于安排送货人员到达餐厅、挑选食物并将订单配送到用户的地址将积分记入用户帐户的忠诚度服务通知.