1. 云栖社区>
  2. 全部标签>
  3. #Consumer#
Consumer

#Consumer#

已有0人关注此标签

内容分类:
博客 | 问答 | 视频 | 资料 |

五分钟学后端技术:如何学习后端工程师必学的消息队列

原创声明 本文首发于微信公众号【程序员黄小斜】 本文作者:黄小斜 转载请务必在文章开头注明出处和作者。 本文思维导图 什么是消息队列 “RabbitMQ?”“Kafka?”“RocketMQ?”...在日常学习与开发过程中,我们常常听到消息队列这个关键词,可能你是熟练使用消息队列的老手,又或者你是不懂消息队列的新手,不论你了不了解消息队列,本文都将带你搞懂消息队列的一些基本理论。

分布式 消息队列 性能 集群 消息中间件 Consumer ActiveMQ Java,后端,消息队列

CompletableFuture异步编排

CompletableFuture异步编排什么是CompletableFuture#CompletableFuture是JDK8提供的Future增强类。CompletableFuture异步任务执行线程池,默认是把异步任务都放在ForkJoinPool中执行。

线程 static Consumer void Other

Flink kafka source & sink 源码解析

本文基于 Flink 1.9.0 和 Kafka 2.3 版本,对 Flink Kafka source 和 sink 端的源码进行解析,主要分为 Flink-kafka-source 源码解析、Flink-kafka-sink 源码解析两部分。

大数据 数据处理 源码 Consumer source Commit 流计算 flink 实时计算

kafka实现无消息丢失与精确一次语义(exactly once)处理

kafka实现无消息丢失与精确一次语义(exactly once)处理在很多的流处理框架的介绍中,都会说kafka是一个可靠的数据源,并且推荐使用Kafka当作数据源来进行使用。这是因为与其他消息引擎系统相比,kafka提供了可靠的数据保存及备份机制。

函数 配置 Consumer metadata

为什么阿里巴巴Java开发手册中强制要求不要在foreach循环里进行元素的remove和add操作?

在阅读《阿里巴巴Java开发手册》时,发现有一条关于在 foreach 循环里进行元素的 remove/add 操作的规约,具体内容如下: 错误演示 我们首先在 IDEA 中编写一个在 foreach 循环里进行 remove 操作的代码: import java.

编程语言 Java核心技术 java ADD string 多线程 Consumer void list arraylist

为什么阿里巴巴Java开发手册强制要求Arrays.asList()不能使用其修改方法?

在阅读《阿里巴巴Java开发手册》时,发现有一条关于在 foreach 循环里进行元素的 remove/add 操作的规约,具体内容如下: 错误演示 我们首先在 IDEA 中编写一个在 foreach 循环里进行 remove 操作的代码: import java.

Java核心技术 java 原创 ADD string 多线程 Consumer void list arraylist

揭秘 RocketMQ 新特性以及在金融场景下的实践

2019 年末, RocketMQ 正式发布了 4.6.0 版本,增加了“ Request-Reply ”的同步调用的新特性。“ Request-Reply ”这个新特性是由微众银行的开发者们总结实践经验,并反馈给社区的。

云栖社区 线程 负载均衡 Consumer 数据中心

Dubbo Consumer 共享连接说明

在Dubbo的consumer和provider的服务引用过程中,两者之间存在多个服务引用。 在consumer和provider之间建立的连接,存在共享连接和非共享连接两种情况,默认情况下使用的是共享连接。

云栖社区 url Consumer

微服务治理实践 | 金丝雀发布

本文是《微服务治理实践》系列篇的第三篇文章,主要分享 Spring Cloud & Dubbo 微服务框架下的金丝雀发布。 第一篇:《微服务治理解密》第二篇:《微服务治理实践:服务查询》 前言 阿里巴巴集团内部有不少故障是因为发布直接或间接引起。

云栖社区 Cloud Apache spring 集群 微服务 string 表达式 Consumer

Eeveteum - 在微服务架构中监听以太坊合约事件

当构建大规模DApp时,监视以太坊的事件会变得很痛苦。在这篇文章中,我们将介绍如何使用Eventeum将后端微服务与以太坊智能合约事件之间桥接起来。 以太坊教程链接:Dapp入门 | 电商Dapp实战 | ERC721实战 | Php对接 | Java对接 | Python对接 | C#对接 | Dart对接 1、什么是Eventeum Eventeum是一个以太坊事件监听服务,它提供了智能合约与中间件层之间的桥接功能。

架构 docker 微服务 电商 测试 Consumer type 事件监听 智能合约 eventeum

Pulsar与Kafka消费模型对比

kafka kafka 属于 Stream 的消费模型,为了支持多 partition 的消费关系,引入了 consumer group 的概念,同时支持在消费端动态的 reblance 操作,当多个 Consumer 订阅了同一个 Topic 时,会根据分区策略进行消费者订阅分区的重分配。

云栖社区 大数据 Image Consumer stream Pulsar

Dubbo 路由规则和权重的生效时机

这里的 Invoker 是 Provider 的一个可调用 Service 的抽象,Invoker 封装了 Provider 地址及 Service 接口信息 Directory 代表多个 Invoker,可以把它看成 List ,但与 List 不同的是,它的值可能是动态变化的,比如注册中心...

云栖社区 算法 集群 负载均衡 Consumer list service

Dubbo Consumer 初始化连接过程

开篇 这篇文章的目的在于梳理Dubbo Consumer的连接过程,在这个过程中会涉及Exchanger、Transporter、NettyClient的整个过程梳理。 在这个过程中会涉及到ChannelHandler的封装过程,调用过程中会涉及ChannelHandler的调用过程分析。

云栖社区 string static url Consumer class handler bootstrap

Dubbo Admin 2.7.X 初探

开篇 为了统一不同配置中心(如Zookeeper、Nacos、Etcd等)对于服务治理规则的实现,Dubbo2.7.3及之后的版本针对2.7.0以来的配置中心的部分实现进行了重构。 从实际代码来看,Dubbo Admin针对应用纬度的配置的实际生效需要在Dubbo 2.7.3及以后的版本,为了方便debug建议Dubbo的版本是dubbo-2.7.4.1。

云栖社区 Apache 配置 runtime Server Consumer scope demo type service github

Dubbo 动态规则配置分析

开篇 覆盖规则是Dubbo设计的在无需重启应用的情况下,动态调整RPC调用行为的一种能力。 在Dubbo2.6及更早版本中,所有的服务治理规则都只针对服务粒度(service),如果要把某条规则作用到应用粒度上,需要为应用下的所有服务(service)配合相同的规则,变更,删除的时候也需要对应的操作。

云栖社区 java Apache 配置 string url Consumer list

54
GO