ZeroMQPUB/SUB中的高低消耗话题以及设置特定话题消息丢失策略
社区干货
替换 Spring Cloud,使用基于 Cloud Native 的服务治理
而是从工程师的实践中抽象出特点,最后形成完整的生态。到今天,Spring Cloud 组件已经比较的完善了,包含配置、服务解藕、服务发现、熔断、路由、消息传递、API 网关、tracing、CI 管道和测试等。这些构成了整个 Spr... Spring Cloud 原生的默认设置无法实现全链路灰度,需要改 load balance 策略,这样会导致同源数据里的开发工作量增加。但是在云原生体系里, Istio 直接配一个 virtualservice 就能完成。虽然 Istio 有一些功能还在开...
替换 Spring Cloud,使用基于 Cloud Native 的服务治理
首次 Meetup 中的同名分享,主要介绍了 Spring Cloud 技术体系和云原生技术体系的区别与联系,以及如何借助云原生能力构建微服务系统。 作者|夏岩,火山引擎高级研发工程师大家好,我是火山引擎的... 而是从工程师的实践中抽象出特点,最后形成完整的生态。到今天,Spring Cloud 组件已经比较的完善了,包含 **配置、服务解耦、服务发现、熔断、路由、消息传递、API 网关、tracing、CI 管道和测试** 等。这些构成了整...
火山引擎 Redis 云原生实践
Redis 集群模式的原理是把保存在其中的数据做了分片,每一部分数据由不同的 Redis 实例承担。Redis 的典型应用场景有以下 3 种:- **缓存**:因为 Redis 是基于内存的存储,它的读写请求会在内存执行,请求响应的延迟很低,所以很多场景下会把 Redis 当做缓存使用。- **数据库**:Redis 支持持久化,可以把它当做 KV 数据库使用。- **消息队列**:Redis 支持 stream 数据,在 stream 数据结构基础上封装了 pub-sub 命令,实现了...
系统集成在一些特定行业的相关概念
消息队列也根据不同的需要将消息进行持久化,这样保证消息在投递的过程中不会被丢失。3、系统可靠性:集成系统中有一方出现故障,不影响系统之间的通信,保证了有效信息的传递。保证了系统的异步执行,从某种角度来说也提升了系统性能。消息队列算是一种兼顾了性能、可靠性和松耦合的一种理想集成方式。目前实现消息队列的产品有很多,比如微软的MSMQ,开源产品ActiveMQ,RabbitMQ,ZeroMQ等。(5)系统接口标准采用SOA体系架构,通过服...
特惠活动
ZeroMQPUB/SUB中的高低消耗话题以及设置特定话题消息丢失策略
-优选内容
ZeroMQPUB/SUB中的高低消耗话题以及设置特定话题消息丢失策略
-相关内容
火山引擎 Redis 云原生实践
Redis 集群模式的原理是把保存在其中的数据做了分片,每一部分数据由不同的 Redis 实例承担。Redis 的典型应用场景有以下 3 种:* **缓存**:因为 Redis 是基于内存的存储,它的读写请求会在内存执行,请求响应的延迟很低,所以很多场景下会把 Redis 当做缓存使用。* **数据库**:Redis 支持持久化,可以把它当做 KV 数据库使用。* **消息队列**:Redis 支持 stream 数据,在 stream 数据结构基础上封装了 pub-sub 命令,实现了数...
Go 语言微服务介绍与开发实战|社区征文
微服务架构不与特定的技术相联系。在谈论微服务时,编排和服务发现是微服务中非常重要的部分。像 Kubernetes 这样的工具可以用来编排和协调 Docker 容器。一般来说,微服务的最佳实践就是每个微服务有一个 Doc... 默认的消息传递系统是一个 HTTP 事件消息代理。- 事件流: PubSub 对于异步通知来说是很好的,但对于更高级的用例,事件流是首选。提供持久性存储,从网络中的 offset(片偏移量) 和 acking(确认字符) 中进行消费。 ...
快速开始
主账号需要为 IAM 用户授予消息队列 Kafka版相关资源和操作的权限。 示例代码 创建实例通过 Volcengine Java SDK 调用消息队列 Kafka版 V2 API CreateInstance 的示例代码如下。 Java package com.volcengine.kafka.examples;import com.volcengine.ApiClient;import com.volcengine.ApiException;import com.volcengine.kafka.KafkaApi;import com.volcengine.kafka.model.*;import com.volcengine.sign.Credentials;public cl...
快速开始
主账号需要为 IAM 用户授予消息队列 Kafka版相关资源和操作的权限。 示例代码本文档以消息队列 Kafka 版的基本资源创建流程为例,演示使用 Volcengine Go SDK 实现相关功能的方式。 创建实例通过 Volcengine Go SD... SubnetId: volcengine.String("subnet-rrps5hvr1bswv0x58fp****"), UserName: volcengine.String("kafka2001"), UserPassword: volcengine.String("Test@123456"...
快速开始
主账号需要为 IAM 用户授予消息队列 Kafka版相关资源和操作的权限。 示例代码 创建实例通过 Volcengine Python SDK 调用消息队列 Kafka版 V2 API CreateInstance 的示例代码如下。 Python from __future__ import... subnet_id="subnet-rrps5hvr1bswv0x58fp****", user_name="kafka2001", user_password="Test@123456", charge_info=volcenginesdkkafka.ChargeInfoForCreateInstanc...
电商业务部署及数据库上云
文中出现的所有截图、费用等均为示例信息,无实际意义。您在实际操作中请以控制台展示为准。 方案介绍数据库上云有如下两种场景: 场景一:把火山引擎云服务器上自建数据库中的数据,通过火山引擎数据库传输服务DTS,迁... 负载均衡CLB 是一种将访问流量按策略分发给多台后端服务器的服务,可以扩展系统对外服务能力,通过消除单点故障提升应用系统的可用性。 云服务器ECS 是一种由CPU、内存、云盘组成的资源集合,可以结合自己的需求申请...
Lua 脚本中支持的命令
本文介绍 Lua 脚本中支持的 Redis 命令详情供您参考。 说明 缓存数据库 Redis 版支持的所有命令详情,请参见命令支持。 关于 Lua 脚本使用的更多详情,请参见 Lua 脚本使用指南。 关于表格中的标识,说明如下:✔️ :表... Pub/Sub命令 是否支持在 Lua 脚本中使用 PUBLISH ✔️ PUBSUB ✔️ PSUBSCRIBE ❌ PUNSUBSCRIBE ❌ SUBSCRIBE ❌ UNSUBSCRIBE ❌ Scripting and Functions命令 是否支持在 Lua 脚本中使用 EVAL ❌ EVALSHA ❌ SCRI...
RTC 端到端视频体验优化技术实践与探索
左边是发布端 Pub(Publisher),右边是接收端 Sub(Subscriber),把视频流从发布端通过一连串的媒体级联服务器送到接收端,就是“发布——接收”的整体链路。在这条链路上,我们可以有效利用一些信息来帮助 RTC 系统做端到端优化,比如把接收端的信息送回发布端做优化。 上图是一个比较常见的端到端优化的例子——上下行带宽联动探测。发布端上行带宽有 1 Mbps,接收端下行带宽只有 0.5 Mbps,如果发布端和接收端不做“沟通”,发布端...
命令支持
缓存数据库 Redis 版支持多个引擎版本和架构类型,不同的引擎版本和架构类型对命令的支持程度不同。本文以原生 Redis 的相关命令为基准,介绍缓存数据库 Redis 版详细的命令支持情况。 说明 关于表格中的标识,说明如... PSUBSCRIBE ✔️ ✔️ ✔️ PUBLISH ✔️ ✔️ ✔️ PUBSUB CHANNELS ✔️ ✔️ ✔️ PUBSUB NUMPAT ✔️ ✔️ ✔️ PUBSUB NUMSUB ✔️ ✔️ ✔️ PUBSUB SHARDCHANNELS ❌ ❌ ❌ PUBSUB SHARDNUMSUB ❌ ❌ ❌ ...
