1、Handler负责发送Message和处理Mesage2、Message就是消息载体，可用what区分，也可传递对象3、MessageQueue消息队列，存储Message4、Looper循环取出MessageQueue里的Message交给Handler处理。5、一个线程只有一个Looper和MessageQueue，子线程中使用Handler一

grpc跟常见的clientserver模型相似（dubbo）grpc编码之前需要准备以下环境：安装protobuf，grpc的client与server之间消息传递使用的protoc格式消息，比起json，xml速度快安装grpc的源码包下面开始编写grpc示例代码：1.首先编写proto文件，示例：helloworld

Netty流量统计netty专门提供了一个traffic包用于流量的统计，如下图所示：!(https://static.oschina.net/uploads/space/2016/1119/154414_NUEo_159239.png)分别提供了全局的GlobalTrafficShapingHandler和针对channel的Ch

消息的存储原理：　　消息的文件存储机制:　　前面我们知道了一个topic的多个partition在物理磁盘上的保存路径，那么我们再来分析日志的存储方式。通过   \root@localhost~\ls/tmp/kafkalogs/firstTopic1/命令找到对应partition下的日志内容

HandlerThreadHandlerThread继承了Thread,它是一种可以使用Handler的Thread，它实现也很简单，就是在run中通过Looper.prepare()来创建消息队列，并且通过Looper.loop()来开启消息循环，这样再实际使用中就允许在HandlerThread中创建Handle了。publiccla

varSub"123a\bc'4'5:67,89";1.字符串替换：        Sub.replace(''.'/');replace只能替换第一个    Sub.replace(/\\/g,"/");/\\/g：g是全局变量，/\\/是转义符2.字符串截取：

1.RabbitMQ是一个由erlang开发的AMQP（AdvancedMessageQueue）的开源实现。 RabbitMQ的优势:         除了Qpid，RabbitMQ是唯一一个实现了AMQP标准的消息服务器；         可靠性，RabbitMQ的持久化支持，保证了消息的稳定性；

第一步  第一个Netty应用服务端_(serverChannel)_EchoServerHandler简单的接收打印，将所接收的消息返回给发送者冲刷所有待审消息到远程节点关闭通道后，操作完成服务端_(server)_EchoServer创建Ev

1：事件机制共享队列：利用消息机制在两个队列中，通过传递消息，实现可以控制的生产者消费者问题要求：readthread读时，writethread不能写；writethread写时，readthread不能读。基本方法时间类（Event）·set：设置事件。将标志位设为True。

生产者消息发送流程消息发送的整体流程，生产端主要由两个线程协调运行。分别是main线程和sender线程（发送线程）。在Kafka（2.6.0版本）源码中，可以看到。源码地址：kafka\clients\src\main\java\org.apache.kafka.clients.producer.KafkaProdu