kafka消费方式

消息的消费一般有两种模式：推模式和拉模式。

• 推模式（push）是服务端主动将消息推送给消费者，很难适应消费的处理能力，有可能造成消费者处理不过来，导致拒绝服务或者消息拥塞。

#头条创作挑战赛#

一、概述

上篇我们讲述了如何使用原生API操作Zookeeper，本篇则介绍如何使用ZKClient来进行相关操作。

ZKClient由Datameer进行开发，其对ZooKeeper的原生API进行了封装，同时还进行了功能增强，新增了如：超时重连，Watcher反复注册等功能。

实际工作中不知道你遇没遇到这种问题：

1. 客户要求微信公众号菜单的配置链接采用https访问
2. 微信的接口对接自己服务器采用的是http访问
3. 然后只给了一个端口8088

这种能不能实现http能够访问到服务内容，https也能够访问到服务内容呢？

#头条创作挑战赛#

概述

提到锁，想必大家可能最先想到的是Java JUC中的synchronized关键字或者可重入锁ReentrantLock。它能够保证我们的代码在同一个时刻只有一个线程执行，保证数据的一致性和完整性。但是它仅限于单体项目，也就是说它们只能保证单个JVM应用内线程的顺序执行。

一、构建HTTPS网站

1. 获取证书和密钥对

1.1.1 自签名证书

常的会话解决方案

• 粘性会话 Sticky Session ，负载均衡实现，让一个用户的请求尽可能落在一个服务器上。但是当这台服务器下线的时候，就有可能发生问题（用户的session没有了，影响体验）
• 会话复制 Session Replication ，把每台机器上的一个会话都做一个复制。session的复制是有成本的，并且当访问量大的时候也会加剧服务端压力，同步延时的问题。

kafka作为主流的中间件相必大家都已经很熟了吧。kafka以其超强的性能吸引了一众的粉丝，称霸中间件领域。现在我们就来分析一下王者神器kafka有何与众不同吧

下边这是kafka的一个架构图，

1.kafka的主要开发语言是java和scala，在java圈比较流行。为啥就做kafka,因为当时作者正在看一个叫做kafka的作者写的书，所以就起了这个名字，这个也真是一桩佳话。

kafka是顺序写入，速度和内存速度相当，使用的是顺序i/o

注册中心zookeeper被重启，线上微服务全部掉线，怎么回事？！

最近因为一次错误的运维操作，导致线上注册中心zk被重启。而zk重启后发现所有线上微服务开始不断掉线，造成了持续30分钟的P0故障。

一、zookeeper的基本原理

数据模型，如下：