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

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

数据库路由中间件MyCat源代码篇（4）2\.前端连接建立与认证CreatedwithRaphaël2.1.0MySql连接建立以及认证过程clientclientMySqlMySql1.TCP连接请求2.接受TCP连接3.TCP连接建立4.握

目前Kafka并没有提供直接的工具来帮助我们获取某个topic的当前总消息数，需要我们自行写程序来实现。下列代码可以实现这一功能，特此记录一下：/获取某个topic的当前消息数Java8only@paramtopic@

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

更多参考：http://freeswitch.net.cn/86.html(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Ffreeswitch.net.cn%2F86.html)中间件下载地址，含windows,linux旧版本下载地址：http://121.40.24

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

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

微信公众号：\中间件兴趣圈\作者简介：《RocketMQ技术内幕》作者Dubbo序列化支持java、compactedjava、nativejava、fastjson、fst、hessian2、kryo，其中默认hessian2。其中java、compactedjava、nativejava属于原生java的序列化。整个Du

condition\_variablewait()notify\_onenotify\_allcondition\_variable条件变量的实际用途：比如有两个线程A和B，在线程A中等待一个条件满足，(消息队列中有要处理的消息)，线程B专门往队列中丢数据。当B往线程中放入数据，同时B通