教练我想敲代码

应用系统的高性能，类似于如何让一个人一直保持健康，不去找医生。保持健康的方法我们都知道，饮食均衡、按时休息、持续锻炼身体等等，而对于一个应用系统，一般则需要考虑硬件、操作系...

对于一个分区来说，它的消息是有序的。如果一个生产者向一个分区先写入消息A，然后写入消息B，那么消费者会先读取消息A再读取消息B。 当消息写入所有in-sync状态的副本后，...

其中，只有group.id是不同的属性，而它也不是严格必须的，这个参数是消费者的消费组。 获取消费数据也很简单，由于生产者产生的数据消费者是不知道的，KafkaConsum...

环境的搭建不再赘述，个人练习的话，基于Docker已经很方便了，比如：在Docker环境下部署Kafka，或者你还是喜欢传统的方式，在Windows上搭建Kafka，在Li...

我们首先要知道 Kafka 的消息是存在于文件系统之上的。一般情况下大家认为 “磁盘是缓慢的”，对于Kafka采用这样的设计可能持有怀疑态度。实际上，一个好的磁盘结构设计可...

Kafak的内部数据单元成为消息，类似与数据库的一条记录。对于Kafka而言，消息只是一个字节数组，每个消息都有一个可选的元数据（metadata），称为键值（key）。当...

Protocol Buffer(简称ProtoBuf)是google的一个语言中立，平台中立，可扩展的对结构化的数据进行序列化的一种机制，和XML类似，但是比XML更小，更...

上一节我们介绍了LineBasedFrameDecoder，其以换行符\n或者\r\n作为依据，遇到\n或者\r\n都认为是一条完整的消息。 而DelimiterBased...

LineBasedFrameDecoder 和LineEncoder采用的通信协议非常简单，即按照行进行分割，遇到一个换行符，则认为是一个完整的报文。在发送方，使用Line...

大多数的协议（私有或者公有），协议头中会携带长度字段，用于标识消息体或者整包消息的长度，例如SMPP、HTTP协议等。由于基于长度解码需求 的通用性，Netty提供了Len...

其中：frameLength就是我们指定的长度。 可以看到FixedLengthFrameDecoder的确将请求的数据，按照每3个字节当做一个完整的请求报文。 通常情况下...

编码:发送方要将发送的二进制数据转换成协议规定的格式的二进制数据流，称之为编码(encode)，编码功能由编码器(encoder)完成。 解码:接收方需要根据协议的格式，对...

在TCP编程中，通常Sever端与Client通信时的消息都有着固定的消息格式，称之为协议(protocol)，例如FTP协议、Telnet协议等。 那么协议到底是干什么的...

整体来看，ServerBootStrap继承自AbstractBootstrap，其代表服务端的启动类，当调用其bind方法时，表示启动服务端。在启动之前，我们会调用gro...

一个worker线程来处理用户提交的任务，任务接受和任务处理是在同一个worker线程中进行的，没有进行区分。这样做存在一个很大的问题是，必须要等待某个task处理完成之后...

基于JDK1.4之前，基于BIO，我们通常使用java.net包中的ServerSocket和Socket来代表服务端和客户端。 在之后引入NIO编程之后，我们使用java...

这里，我们首先直接以Netty入门案例入手，先感性认识一下Netty。TimeClient发送“QUERY TIME ORDER”请求，TimeServer接受到这个请求后...

为了提高操作系统的稳定性及可用性，虚拟内存被操作系统划分成两块：内核空间和用户空间。 内核空间是操作系统所在区域。内核代码有特别的权力：它能与设备控制器通讯，控制着用户区域...

在URL中制定参数“_search?search_type=dfs_query_then_fetch”，会把每个分片的词频和文档频率搜集后，完整的进行一次算分。但会耗费更多...

利用Jsoup爬取数据， Jsoup是一款Java 的HTML解析器，可直接解析某个URL地址、HTML文本内容，可通过DOM，CSS以及类似于jQuery的操作方法来取出...