最近学习了android的界面的跳转，一个是activity和fragment之间的跳转（之前的博客说过），一个是不同activity之间的跳转。 activity直接的跳转很简单，只需要用Intent即可，而且传递数据很简便，如果只是传递简单数据，即可直接使用,如果传递复杂的数据，比如一个类，就得需要把类定义为。
1、搭建部署好zookeeper集群和kafka集群，这里省略。 1 启动zk： 2 bin/zkServer.sh start conf/zoo.cfg。 3 验证zk是否启动成功： 4 bin/zkServer.sh status conf/zoo.cfg。 5 启动kafka： 6 bin/kafka-server-start.sh -daemon config/server.properties。 2、生产者和消费者代码如下所
搭建环境 搭建数据库 CREATE DATABASE mybatis; USE mybatis; CREATE TABLE `user`( `id` INT AUTO_INCREMENT NOT NULL, `name` VARCHAR(20), `pwd` VARCHAR(50), PRIMARY KEY(id) )ENGINE=INNODB DEFAULT CHARSET=utf8; 新建项目 使用idea创建一个普
案例三： 统计共同好友 任务需求： 如下的文本， A:B,C,D,F,E,O B:A,C,E,KC:F,A,D,ID:A,E,F,LE:B,C,D,M,LF:A,B,C,D,E,O,MG:A,C,D,E,FH:A,C,D,E,OI:A,OJ:B,OK:A,C,DL:D,E,FM:E,F,GO:A,H,I,J 求出哪些人两两之间有共同好友，及他俩的共同好友都是谁 b -ac -ad -aa -b c -b b -e b -j 解题思
MapReduce Cross 示例 MapReduce Cross 示例 package com.bsr.cross; import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.
MapReduce WordCount Combiner程序 MapReduce WordCount Combiner程序 注意使用Combiner之后的累加情况是不同的； pom.xml <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:sche
一、安装clipboard npm install clipboard --save 二、引入 1、全局引入 import Clipboard from 'clipboard'; Vue.prototype.Clipboard=Clipboard; 2、单页面引入 import Clipboard from "clipboard"; 3、:data-clipboard-text 中即为要复制的内容 4、完整代码 <templa
android数据库的操作和WEB类是，都是增删改查，但是android数据库操作的代码远比WEB的代码要少，而且简单不用写。如果有不懂请看代码注释 1、用entity、dao、database创建数据库 entity：是一个实体类 dao：是一个接口（interface），用来对数据库经常操作 database:继承Room
这篇文章是对上篇文章的优化。增加两个类，一个ViewModel管理界面数据，一个仓库类存放类。 1、Room本身支持LiveData，使用LiveData，我们就可以不用每次对页面进行刷新操作（自己写的页面刷新函数 ）。我们可以用observe来观察它是否发生改变，如果改变则进行页面改变。 2、在Databa
今天学习了一个android的控件：chronometer，方法都还是比较容易理解，但是有一点不懂，就是在回到主页面时，然后再进入，时间是从退出时候的时间开始计时。通过代码实现了，但是具体意思还是不太理解。如果有理解请留言。 stop()函数并不是让其停止，只是让画面显示的数定格，但是它依旧在
15个好用到哭的Python库 1. Dash 概念 Dash是用纯Python构建数据可视化App的理想选择，是Flask、Plotly.js和React.js的混合体 使用场景 特别适合处理数据的任何人 2. Pygame 概念 Pygame是SDL多媒体库的Python装饰器，SDL(Simple DirectMedica Layer)是一个跨平台开发库，旨在提供
因为是工作中遇到的问题，所以在自己电脑写了个简单例子还原记录一下 只在本地能load，不能在环境上load的代码写法： import org.springframework.core.io.ClassPathResource; import java.io.File; import java.io.IOException; public static void main(String[] args) {
一般你去面试的时候，面试官经常会问：请谈谈你对OOM的认识？然后，你可能会说OOM就是out of memory，那如果你只是这么答的话，这可不是面试官想要的答案；面试官又接着问，那你生产过程中有遇到哪些OOM呢？请你说说出常见的OOM问题？这时的你可能是懵的。你知道几种常见的OOM呢？欢迎评论区留言
1.创建一个Maven工程，在pom.xml中添加如下代码： <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-
提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档 文章目录 一、多分支if语句二、case分支语句三、实操1、系统控制服务脚本，控制服务的启动、重启、停止。2、根据学生的成绩，判断优秀、良好、和不及格几个等级。3.删除家目录2.读入数据剪刀石头布 电脑与人
文章目录 项目结构准备：完成登录功能和用户信息展示功能一、尝试使用视图跳转界面在config子包中创建自定义配置类MyMvcConfig效果 二、编写登录拦截器，限制非登录用户通过URL直接访问用户信息1.在interceptor子包中创建自定义拦截器MyInterceptor2.在自定义配置类中注入拦截
自定义view样色色差问题 自定义view在动态设置颜色的时候可能UI显示的效果和自己设置的值不一样，这个就是你的view中颜色层叠方式不太对， 使用 Paint.setXfermode(new PorterDuffXfermode(PorterDuff.Mode.DST_OVER));给画笔这个Xfermode,各种效果如下图所示 完整自定义view 仿照
文章目录 消息丢失概述 发送端消息丢失 消费端消息丢失 Code POM依赖 配置文件 生产者 消费者 单元测试 测试结果 源码地址 消息丢失概述 消息丢失得分两种情况 ： 生产者 和 消费者 都有可能因处理不当导致消息丢失的情况 发送端消息丢失 acks=0： 表示producer不需要等待
1、Kafka的消费者提交方式 1）、自动提交，这种方式让消费者来管理位移，应用本身不需要显式操作。当我们将enable.auto.commit设置为true，那么消费者会在poll方法调用后每隔五秒（由auto.commit.interval.ms指定）提交一次位移。和很多其他操作一样，自动提交也是由poll方法来驱动的，在调用
1、Producer的拦截器interceptor，和consumer端的拦截器interceptor是在kafka0.10版本被引入的，主要用于实现clients端的定制化控制逻辑，生产者拦截器可以用在消息发送前做一些准备工作，使用场景，如下所示： 1）、按照某个规则过滤掉不符合要求的消息。 2）、修改消息的内容。 3）
文章目录 概述 Code POM依赖 配置文件 生产者 消费者 单元测试 测试结果 源码地址 概述 一个partition同一个时刻在一个consumer group中只能有一个consumer instance在消费，从而保证消费顺序。 consumer group中的consumer instance的数量不能比一个Topic中的partition的
文章目录 概述 演示过程 Code POM依赖 配置文件 生产者 消费者 单元测试 测试结果 方式二 @KafkaListener 配置项 分布式下的concurrency 源码地址 概述 默认情况下， Spring-Kafka @KafkaListener 串行消费的。缺点显而易见生产者生产的数据过多时，消费端容易导致消息积压的
文章目录 概述 Code POM依赖 配置文件 配置类 SeekToCurrentErrorHandler 自定义逻辑处理消费异常 生产者 消费者 单元测试 测速结果 源码地址 概述 Spring-Kafka 提供消费重试的机制。当消息消费失败的时候，Spring-Kafka 会通过消费重试机制，重新投递该消息给 Consumer ，让
文章目录 概述 Code POM依赖 配置文件 生产者 消费者 单元测试 测速结果 源码地址 概述 传统的消息传递模式有2种：队列( queue) 和（publish-subscribe） queue模式：多个consumer从服务器中读取数据，消息只会到达一个consumer publish-subscribe模式：消息会被广播给所有的consumer
文章目录 概述 参数设置 Code POM依赖 配置文件 生产者 消费者 单元测试 测试结果 源码地址 概述 kafka提供了一些参数可以用于设置在消费端，用于提高消费的速度。 参数设置 https://kafka.apache.org/24/documentation.html#consumerconfigs 支持的属性 见源码 KafkaPro
