搜索结果
查询Tags标签： consumer，共有 108条记录-
Java学习:实际应用场景中的多线程没有start()解决方法
今天在做多线程练习的时候，参考资料给的是使用extends继承Thread类的方式创建的子类对象，天然带有start()方法 题目如下： /** * 生产者-消费者问题 * 生产者最多生产20个产品，生产完就得等待 * 交由服务员来调度生产者和消费者 * 消费者没有能消费产品的时候，等待 **…
2022/3/1 20:51:46 人评论 次浏览 -
Java面试题之：Kafka里的生产者与消费者设计
Java面试题之：Kafka里的生产者与消费者设计 一、负载均衡（partition 会均衡分布到不同 broker 上）二、批量发送三、压缩（GZIP 或 Snappy）四、消费者设计一、负载均衡（partition 会均衡分布到不同 broker 上）由于消息 topic 由多个 partition 组成，且 partition 会…
2022/2/22 11:23:57 人评论 次浏览 -
Java8新特性 - 03 - 函数式接口03 - Consumer详解
1.Consumer接口说明消费者接口 核心方法 void accept(T t) : 有参数，无返回值* 说明 ：* 1.接口名称 ： Consumer* 2.方法* void accept(T t) : 有参数，无返回值；* default Consumer<T> andThen(Consumer<? super T> after) ： 有多个的时…
2022/2/21 22:26:31 人评论 次浏览 -
kafka
Kafka是为大数据而生的消息中间件，在数据采集、传输、存储的过程中发挥着举足轻重的作用。 优点： 性能卓越，单机写入TPS约在百万条/秒，最大的优点，就是吞吐量高。 时效性：ms级 可用性：非常高，kafka是分布式的，一个数据多个副本，少数机器宕机，不会丢失数据，不会…
2022/2/17 23:21:02 人评论 次浏览 -
consumer负载均衡
Consumer and Consumer groupa.每个consumer客户端被创建时,会向zookeeper注册自己的信息; b.此作用主要是为了"负载均衡". c.同一个Consumer Group中的Consumers，Kafka将相应Topic中的每个消息只发送给其中一个Consumer。 d.Consumer Group中的每个Consumer读…
2022/2/16 23:42:56 人评论 次浏览 -
kafka的Rebalance机制
选举机制 如果kafka集群有多个broker节点，消费组会选择哪个partition节点作为Coordinator节点呢？它会通过如下公式，其中的50代表着kafka内部主题consumer offset的分区总数 Math.abs(hash(groupID)) % 50 那么当前Consumer Group的Coordinator就是上述公式计算出的part…
2022/2/10 6:13:33 人评论 次浏览 -
简单的python请求http接口
import requests import json import random import datetimereal_data = { "sys_id": "123321","ab_id": "123321","ser_id": "", "partition_key": "25","data_cycle": …
2022/2/7 11:12:59 人评论 次浏览 -
SpringBoot整合RocketMQ
0. 启动Name Server与 Broker 1. 引入依赖 添加 RocketMQ 客户端访问支持，具体版本和安装的 RocketMQ 版本一致即可。 <dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.7.1…
2022/1/31 23:15:07 人评论 次浏览 -
Java传递函数的原理
总所周知，jdk1.8以上支持使用 lambda 作为参数传递 list.forEach(t -> System.out.println(t)); 我之前就一直有一个疑问：java也开始支持函数型的参数了？到今天真正用到，才明白其中的原理 看一下 forEach的源码 default void forEach(Consumer<? super T> a…
2022/1/28 11:05:37 人评论 次浏览 -
rocketmq安装部署 ，运行避坑（python3）
按照rocketmq官网的快速入门，进行linux上的安装：快速入门 - Apache RocketMQ 避坑： 1、rocketmq可执行命令的路径：xx/xx/rocketmq/rocketmq-all-4.9.2/distribution/target/rocketmq-4.9.2/rocketmq-4.9.2/bin//xx/xx为下载rocketmq时的存放路径否则会报错：apache.xx…
2022/1/18 17:11:03 人评论 次浏览 -
rocketmq安装部署 ，运行避坑（python3）
按照rocketmq官网的快速入门，进行linux上的安装：快速入门 - Apache RocketMQ 避坑： 1、rocketmq可执行命令的路径：xx/xx/rocketmq/rocketmq-all-4.9.2/distribution/target/rocketmq-4.9.2/rocketmq-4.9.2/bin//xx/xx为下载rocketmq时的存放路径否则会报错：apache.xx…
2022/1/18 17:11:03 人评论 次浏览 -
RocketMQ 消息详解
目录MQ消息发送&消费模式One-To-One（单生产者单消费者）生产者消费者One-To-Many（单生产者多消费者）生产者消费者负载均衡模式广播模式Many-To-Many（多生产者多消费者）消息类别同步消息异步消息单向消息延时消息批量消息消息过滤分类过滤属性过滤（SQL 过滤）消息…
2022/1/17 6:05:56 人评论 次浏览 -
RocketMQ 消息详解
目录MQ消息发送&消费模式One-To-One（单生产者单消费者）生产者消费者One-To-Many（单生产者多消费者）生产者消费者负载均衡模式广播模式Many-To-Many（多生产者多消费者）消息类别同步消息异步消息单向消息延时消息批量消息消息过滤分类过滤属性过滤（SQL 过滤）消息…
2022/1/17 6:05:56 人评论 次浏览 -
Dubbo服务消费者Consumer启动流程(五)
在看完上篇的服务提供者启动流程之后，再来看消费者的启动流程就简单很多了，其大体的设计流程是差不多的。服务消费者的启动主要调用ReferenceConfig#get(), get方法跟服务提供者的export方法类似，主要关注checkAndUpdateSubConfigs和init方法。ReferenceConfig#checkAn…
2021/12/28 23:12:10 人评论 次浏览 -
Dubbo服务消费者Consumer启动流程(五)
在看完上篇的服务提供者启动流程之后，再来看消费者的启动流程就简单很多了，其大体的设计流程是差不多的。服务消费者的启动主要调用ReferenceConfig#get(), get方法跟服务提供者的export方法类似，主要关注checkAndUpdateSubConfigs和init方法。ReferenceConfig#checkAn…
2021/12/28 23:12:10 人评论 次浏览
