迭代器出现的原因 Python中的列表,有可能会占用很大的空间。而迭代器,它是每一次用__next__调用时才计算出值,这会节省内存空间。 迭代器、生成器、可迭代对象的关系 可迭代对象一般是列表、元组、字典、字符串等可以For循环的对象。可通过以下语句判断是不是可迭代对象。 from collect ...
分类:
其他好文 时间:
2020-02-01 10:53:01
阅读次数:
64
Context 作用:跨组件传递数据(比如主题,语言等) 使用步骤: 1.使用Reat.creatContext()创建Provider(提供数据和 Consumer(消费数据) 两个组件 2.使用Provider组件作为父节点 3.使用value属性,表示要传递的数据 4.使用Consumer 组 ...
分类:
其他好文 时间:
2020-01-31 23:07:22
阅读次数:
100
一、项目结构 项目结构如何 两个模块,一个为消费方,一个为提供方,也可将两个模块合一,配置文件合一。 二、整合步骤 一、pom.xml 生产方、消费方一致 二、Producer模块 测试代码: 三、Consumer模块 1.配置文件 2.监听器 分别监听提供方queue和topic的消息 启动消费方 ...
分类:
编程语言 时间:
2020-01-30 20:54:55
阅读次数:
101
DefaultMQPushConsumer(以push为例).start()调用mQClientFactory.start(),其中pullMessageService.start在一个循环中从pullRequestQueue中获取pullRequest, 执行pullMessage方法,调用的是r ...
分类:
其他好文 时间:
2020-01-29 21:25:32
阅读次数:
75
问题描述 产品 生产者 java package product; / 消费者 / public class Consumer implements Runnable{ private Storage storage = new Storage(); public Consumer(Storage ...
分类:
其他好文 时间:
2020-01-29 17:49:12
阅读次数:
66
一.错误的2个显示 1.错误显示 2.在 Project Structure中设置报错 二.错误原因 在cloud consumer dept 80的Project Structure设置中多了cloud consumer dept feign的资源目录 三.解决方法 将属于cloud consum ...
分类:
其他好文 时间:
2020-01-29 10:49:48
阅读次数:
168
一、kafka的基础架构 kafka是一个分布式的基于发布/订阅模式的消息队列,主要应用于大数据实时处理领域。 kafka的具体架构如图: 学习kafka的架构前,我们需要了解图中的每个角色: (1)consumer group 消费者组:这是kafka消息队列特有的角色,它是一堆消费组组合成的。消 ...
分类:
其他好文 时间:
2020-01-28 20:47:17
阅读次数:
139
1 Eureka Server 提供服务注册和发现 2 Service Provider 服务提供方 将自身服务注册到Eureka,从而使服务消费方能够找到 3 Service Consumer 服务消费方 从Eureka获取注册服务列表,从而能够消费服务 介绍 我们的服务发现一般分为两种模式一种为 ...
分类:
编程语言 时间:
2020-01-27 23:47:25
阅读次数:
139
目录 简介 Kafka架构 Kafka存储策略 Kafka删除策略 Kafka broker Kafka Design The Producer The Consumer 复制(Replication) 日志压缩(Log Compaction) Distribution Zookeeper协调控制 ...
分类:
其他好文 时间:
2020-01-26 19:24:21
阅读次数:
67
使用Kafka自带的kafka-consumer-groups.sh脚本可随意设置消费者组(consumer group),这是0.11.0.0版本提供的新功能,设置的前提是:consumer group状态是inactive的,即不能是处于正在工作中的状态。重设位移的流程由下面3步组成:1、确定位 ...
分类:
其他好文 时间:
2020-01-25 23:42:39
阅读次数:
549