0 君莫笑(๑˙ー˙๑)

尚未进行身份认证

欢迎互关,一起学习,共同进步

等级
TA的排名 6w+

Kafka Java 客户端里的生产者

KafkaJava客户端里的生产者生产者发送消息的基本流程使用Kafka生产者三种发送方式发送并忘记同步发送异步发送多线程生产常用配置顺序保证自定义分区器如果不了解Kafka的Java客户端,可以先看看示例KafkaJava客户端入门示例生产者发送消息的基本流程从创建一个ProducerRecord对象开始,ProducerRecord对象需要包含目标主题和要发送的内容...

2019-11-12 08:59:55

Kafka 多线程生产与消费示例

Kafka多线程生产与消费示例依赖用到的VO生产者消费者结果生产者消费者依赖<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>2.3.0</ver...

2019-11-12 10:44:00

Kafka Java 客户端入门示例

KafkaJava客户端入门示例生产者消费者结果生产者消费者生产者importorg.apache.kafka.clients.producer.KafkaProducer;importorg.apache.kafka.clients.producer.ProducerRecord;importjava.util.Properties;publicclassHelloKa...

2019-11-12 09:08:57

Kafka 的 Java 客户端 consumer 收不到消息

server.properties里broker.id=0listeners=PLAINTEXT://192.168.100.14:9092advertised.listeners=PLAINTEXT://192.168.100.14:9092zookeeper.connect=192.168.100.14:2181,192.168.100.15:2181,192.168.100.16:...

2019-11-11 10:19:14

Kafka 集群安装和配置

配置zookeeperKafka运行依赖zookeeper:zookeeper集群配置下载解压地址选择:kafka_2.11-2.3.0.tgz更改配置分别更改三台机器上的config/server.properties其中,broker.id需要更改,其它的直接粘贴上去就行。broker0:broker.id=0listeners=PLAINTEXT://192....

2019-11-11 10:03:30

Kafka 入门

目录基本概念消息和批次主题和分区生产者和消费者、偏移量、消费者群组Broker和集群保留消息为什么选择Kafka优点常见场景硬件配置对Kafka性能的影响磁盘吞吐量/磁盘容量内存网络如何估算Kafka集群中Broker的数量Broker如何加入Kafka集群基本概念消息和批次消息,Kafka里的数据单元,也就...

2019-11-10 16:53:56

分布式锁与 MySQL/Zookeeper 实现方案

分布式锁与MySQL/Zookeeper方案问题来源解决思路方案比较模板方法模式MySQL方案Zookeeper方案方案一方案二问题来源在一个JVM里我们要用锁,可以用synchronized和Lock。如果是在多个JVM里,该怎么办呢?解决思路MySQL里,对于同一数据库的同一张表,不能插入相同的数据。往数据库里插入数据可以当做上锁的过程。Zookeeper也...

2019-11-07 11:01:59

zookeeper 高级

zookeeper高级一致性协议两阶段提交two-phasecommit(2PC)三阶段提交three-phasecommit(3PC)Paxos算法集群解析集群特点集群中的角色集群一致性协议ZAB解析总览消息广播崩溃恢复背景(什么情况下会崩溃恢复)最终目的(恢复成什么样)一致性协议两阶段提交two-phasecommit(2PC)强一致性算法,很适合用作数据库的分...

2019-11-06 15:19:25

zookeeper 客户端源码解读(二)SendThread & EventThread

zookeeper客户端源码解读(二)关于2个线程SendThreadstartConnectClientCnxnSocket.connectClientCnxnSocketNIO.registerAndConnect关于2个线程在1.1.2.1.2ClientCnxn.start里创建了两个线程,这两个线程是干什么用的呢?SendThread改变状态为connecting...

2019-10-29 15:14:33

zookeeper 客户端源码解读(三)exists

publicStatexists(finalStringpath,Watcherwatcher)throwsKeeperException,InterruptedException{finalStringclientPath=path;PathUtils.validatePath(clientPath);...

2019-10-31 11:27:49

zookeeper 客户端源码解读(一)入口

zookeeper客户端源码解读1入口,ZooKeeperMain.main1.1ZooKeeperMain1.1.1MyCommandOptions.parseOptions1.1.2ZooKeeperMain.connectToZK1.1.2.1ZooKeeper1.1.2.1.1ClientCnxn1.1.2.1.2ClientCnxn.start1入口,ZooKeeperMa...

2019-10-26 13:24:53

zookeeper 与分布式系统

为什么学习ZK应该重点掌握分布式环境的演进过程,从一个单节点开始,慢慢过渡到分布式,为什么单节点不行,传统一个tomcat打天下有什么有点,缺点又是什么,当一个tomcat搞不定的时候,分布式的架构图又是什么样的,传统的单节点架构自然有问题,到了分布式的架构中,问题肯定也有不少,这些问题就是我们学习ZK要解决的,但学习这些解决方案之前,还是需要有点理论基础。接下来就要了解下什么是zk,...

2019-10-29 09:08:48

zookeeper 客户端源码之 MyCommandOptions

MyCommandOptions包含了两个东西:Command和Options。它们分别被用在两处:进入客户端之后和进入客户端之前进入客户端前:“zkCli.sh-server127.0.0.1:2181”这里,进入main的args是一个String数组:["-server",“127.0.0.1:2181”]:这里就会被parseOptions方法转...

2019-10-27 21:00:46

为什么用 System.nanoTime() / 1000000 而不是 System.currentTimeMillis()?

问题来源以下是zookeeper3.4.12源码里的一小部分:注释里有一句话是在读不懂:Time.currentElapsedTimewillchangebutnanoTimewon't.个人感觉应该是写错了(根据返回值,明显要变两个一起变),这里应该是说的currentTimeMillis()和nanoTime()的区别。于是去jdk1.8官方...

2019-10-26 21:13:07

zookeeper 基础

目录结构

2019-10-24 18:06:09

详解 https

详解https以及Nginx配置为什么要有https加密进化史对称加密非对称加密证书颁发机构颁发证书总结为什么要有https没有https,用户传输的数据,如账号密码,会被不法分子截获。加密进化史对称加密客户端请求一次服务端后,服务端给客户端一个密钥。然后他们传输的数据会用密钥加密。但第一次告诉客户端密钥的时候也可能被不法分子截获。非对称加密服务端有自己的公钥和私钥...

2019-10-22 14:01:22

Linux(CentOS7) 安装 zookeeper 集群并配置

下载地址https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/解压后进入conf文件夹cpzoo_sample.cfgzoo.cfgvimzoo.cfg创建dataDir文件夹:mkdir-p/soft/data/tmp/zookeeper进入文件夹:cd/soft/data/tmp/zookeeper...

2019-10-23 15:35:57

keepalived 解决入口机器(Nginx)挂掉的问题

keepalived解决最前端Nginx挂掉的问题问题来源LVS解决思路keepalived配置LVS过程主机配置从机配置检验keepalived的LVS效果keepalived监控Nginx主机配置从机配置充分利用从机问题来源我们有很多Tomcat服务器交由Nginx管理,可Nginx所在的这台机器挂了怎么办?你可能会想到再来2台Nginx机器...

2019-10-21 11:01:15

Nginx 资源压缩

Nginx资源压缩问题来源解决思路Nginx配置方法另外问题来源第一次打开页面,静态资源在浏览器上也没有缓存,响应有点慢,用户体验可能不太好,怎么办?解决思路浏览器在发送请求时,会附带自己支持的压缩方式:Nginx配置方法location~/(.*)\.(html|js|css|png)${ gzipon;#启用gzip压缩,默认是off,不启用 #...

2019-10-22 10:22:56

Nginx 配置防盗链

Nginx配置防盗链问题来源解决思路问题来源我的服务器里可能有很多好图片,那么别人可能会在自己的html里用img引用我的图片,这样就会给我的服务器带来压力。解决思路...

2019-10-21 22:11:10

查看更多

勋章 我的勋章
  • 新人勋章
    新人勋章
    用户发布第一条Blink获赞超过3个即可获得
  • 专栏达人
    专栏达人
    授予成功创建个人博客专栏的用户。专栏中添加五篇以上博文即可点亮!撰写博客专栏浓缩技术精华,专栏达人就是你!
  • 持之以恒
    持之以恒
    授予每个自然月内发布4篇或4篇以上原创或翻译IT博文的用户。不积跬步无以至千里,不积小流无以成江海,程序人生的精彩需要坚持不懈地积累!
  • 1024勋章
    1024勋章
    #1024程序员节#活动勋章,当日发布原创博客即可获得
  • 勤写标兵Lv4
    勤写标兵Lv4
    授予每个自然周发布9篇以上(包括9篇)原创IT博文的用户。本勋章将于次周周三上午根据用户上周的博文发布情况由系统自动颁发。