消息队列发附件
社区干货
消息队列选型之 Kafka vs RabbitMQ
**消息队列的应用场景**既然要选,那他们有什么应用场景呢?可以总结为 6 个字: **异步、解耦、削峰** 。 **异步**首先消息队列支持异步通信,发送方...
火山引擎 Redis 云原生实践
**消息队列**:Redis 支持 stream 数据,在 stream 数据结构基础上封装了 pub-sub 命令,实现了数据的发布和订阅,即提供了消息队列的基本功能。Redis 协议是二进制安全的文本协议。它很简单,可以通过 telnet 连接到一个 Redis server 实例上执行 get 和 set 操作。## K8s 简介K8s 是一个容器编排系统,可以自动化容器应用的部署、扩展和管理。K8s 提供了一些基础特性:- **自动装箱**:可指定 K8s 里 Pod 所需资源的最...
Actor模型 - 分布式应用框架Akka
Actor 只有收到消息才会触发自身的计算行为。**消息(Mail)** :Actor 的消息以邮件形式在多个 Actor 之间通信传递,每个 Actor 会有一个自己的邮箱(MailBox),用于接收来自其他 Actor 的消息,因此 Actor 模型中的消息也称为邮件。一般情况下,对于邮箱里面的消息,Actor 是按照**消息达到的先后顺序(FIFO)进行读取和处理**的。**Actor 工作原理**:3 个 Actor 之间基于消息和消息队列的工作流程进行说明。这 3 个 Actor 的...
RocketMQ 存储机制浅析
ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
特惠活动
消息队列发附件-优选内容
消息队列发附件-相关内容
普通消息
火山引擎消息队列 RocketMQ版提供同步发送和单向(Oneway)发送两种方式来发送普通消息。本文介绍如何通过不同方式发送普通消息。 前提条件已完成准备工作。 已阅读参数说明,了解常用参数的配置方式与填写格式。 发送方式火山引擎消息队列 RocketMQ版提供的普通消息发送方式包括以下三种,您可以根据业务要求选择合适的发送方式。 / 同步发送 单向(Oneway)发送 单向发送 发送方式 消息发送方发出一条消息到服务端,服务端接收并...
流式数据监控
流式数据监控依据监控规则,对消息队列 Kafka 版流式数据进行监控。本文将为您介绍如何设置并管理数据质量监控规则、报警提醒等。 1 前提条件已在概览页面购买大数据分析、湖仓一体、DataOps 敏捷研发或分布式数据自治解决方案。 已在消息队列 Kafka 版控制台创建消息队列 Kafka 版实例和 Topic。欲了解相关操作,可参见创建实例和创建Topic。 在项目的数据源管理页面,已配置 Kafka 数据源。欲了解相关操作,可参见配置数据源。 2 ...
火山引擎 Redis 云原生实践
**消息队列**:Redis 支持 stream 数据,在 stream 数据结构基础上封装了 pub-sub 命令,实现了数据的发布和订阅,即提供了消息队列的基本功能。Redis 协议是二进制安全的文本协议。它很简单,可以通过 telnet 连接到一个 Redis server 实例上执行 get 和 set 操作。## K8s 简介K8s 是一个容器编排系统,可以自动化容器应用的部署、扩展和管理。K8s 提供了一些基础特性:- **自动装箱**:可指定 K8s 里 Pod 所需资源的最...
Actor模型 - 分布式应用框架Akka
Actor 只有收到消息才会触发自身的计算行为。**消息(Mail)** :Actor 的消息以邮件形式在多个 Actor 之间通信传递,每个 Actor 会有一个自己的邮箱(MailBox),用于接收来自其他 Actor 的消息,因此 Actor 模型中的消息也称为邮件。一般情况下,对于邮箱里面的消息,Actor 是按照**消息达到的先后顺序(FIFO)进行读取和处理**的。**Actor 工作原理**:3 个 Actor 之间基于消息和消息队列的工作流程进行说明。这 3 个 Actor 的...
RocketMQ 存储机制浅析
ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
搞流式计算,大厂也没有什么神话
Twitter 开发的第一代流处理系统,只支持一些 low level 的 API。“所有的 Storm 任务都是在开发机上用脚本提交,运维平台处于非常原始的状态。如果 Storm 集群故障,作业都无法自动恢复,甚至无法找到所有存量作业。”张光辉对此记忆犹新。话虽这么说,但谁也别嫌弃谁。那时张光辉的履历上,并没有流式计算产品的经验,不过有些“沾亲带故”——参与过流式计算的上下游产品开发,比如数据采集、消息队列。好在趁着字节的...
火山引擎 DataLeap 计算治理自动化解决方案实践和思考
字节跳动数据平台目前使用了 1 万多个任务执行队列,支持 DTS、HSQL、Spark、Python、Flink、Shell 等 50 多种类型的任务。自动计算治理框架目前已经完成了离线任务的接入,包括 HSQL、Hive to X 的 DTS 任务、AB ... 但由于增加虚拟核可能导致超发,为保障队列稳定性,建议增加物理核。内存型优化:增加算力、减少物理核、增加虚拟核,以释放更多内存资源,确保内存得到充分利用。 ▌**自动化解决方案**接下来讲解针对上述场...
火山引擎 Redis 云原生实践
实现了数据的发布和订阅,即提供了消息队列的基本功能。Redis 协议是二进制安全的文本协议。它很简单,可以通过 telnet 连接到一个 Redis server 实例上执行 get 和 set 操作。 K8s 简介 K8s 是一个容器编排系统,可以自动化容器应用的部署、扩展和管理。K8s 提供了一些基础特性:* **自动装箱**:可指定 K8s 里 Pod 所需资源的最小值和最大值,即 limit 和 request 的值。K8s 可以根据 r...
干货 | 字节跳动一站式数据治理解决方案及平台架构
发现一些资产的问题,通过一些消息的方式推送到这些资产的责任人,进行一些比如说根因的登记,问题的登记,事故的复盘,最后进行一些总结和经验的共享等等;**第三层:工具能力层。**即为了满足于上面的视图层和方案... yarn队列,Hive、Spark、Flink等各种组件的数据,以及一些平台级的元数据采集,包括调度系统,数据地图、血缘、权限、任务、存储、数据应用等平台的一些元数据,在采集之后,会进行一些系统化的加工,我们遵循于数据仓的层...
