1.producer调用publish方法是为了向zookeeper注册topic，同时注册broker节点改变事件，用于新机器加入时生产者的负载均衡
2.sendmessage时，先选择partition，再根据partition选择一台broker
3.构造putcommand，传入opaque给putcommand（自增，线程安全），用于区分command，主要作用是区分本地的回调方法（消息发送过快而服务器响应过慢，可能由于本地回调对象过多造成内存溢出）
3.调用RemotingClientWrapper（是gecko的RemotingClient对象的装饰器，提供统计消息功能）的sendToGroup方法，发送消息
4.remoteclient调用asyncWriteToSession发送消息（有超时时间，）
分享到：
相关推荐
整理后的Metaq原理应用文档，欢迎大家看看。
metamorphosis(metaq) 服务端1.4.3版本 包括客户端 发送一个序列化对象
metaQ向spark传数据
Metaq在JDk 7下的异常及解决方案,希望可以帮助学习者!
metaq-server-1.4.6.2服务端+客户端+javadoc文档，打包于一个压缩包
metaq-server-1.4.6.2.tar.gz
Metamorphosis是淘宝开源的一个Java消息中间件，他类似apache-kafka，但不是一个简单的山寨拷贝，而是做了很多改进和优化，项目的主页在淘蝌蚪上。服务端、客户端、javadoc都包含在内。
metaQ的安装包
metaq--1.4.6.2.zip 和原版一样就是换了个名字,方便大家一起学习.
MetaQ 分布式消息服务中间件.pdf
Memorphosis是一个消息中间件，它是linkedin开源MQ——kafka的Java版本，针对淘宝内部应用做了定制和优化。Metamorphosis的设计原则 • 消息都是持久的，保存在磁盘 • 吞吐量第一 • 消费状态保存在客户端 ...
Metamorphosis(MetaQ)是一个高性能、高可用、可扩展的分布式消息中间件，类似于LinkedIn的Kafka，具有消息存储顺序写、吞吐量大和支持本地和XA事务等特性，适用于大吞吐量、顺序消息、广播和日志数据传输等场景，在...
rocketMQ
数据生产者，producer 的用法:《producer 的用法》、《producer 使用注意》 数据消费者，consumer 的用法:《consumer 的用法》 迓有些零碎的，关亍通信段的源码览读:《net 包源码览读》、《broker 配置》 扩展的...
分享一下 RocketMq的文档RocketMQ运维指令 rocketmq在阿里内部叫metaq
Metamorphosis, 一种高可用高性能的分布式 #新闻MetaQ 1.4.6.2 发布。更新日志MetaQ 1.4.6.1 发布。更新日志MetaQ 1.4.5.1 发布。更新日志MetaQ 1.4.5发布。更新日志meta: 一个用于的ruby 客户端。 源代码
该文档为storm模拟项目系列文档之一，是MetaQ与storm接口的说明文档，主要介绍了如何集成MetaQ到项目代码中。软件（阿里），其对应的许多技术文档还是比较容易看的，并且Github提供了许多的应用实例，所以使用MetaQ...
RocketMQ是一个纯java、分布式、队列模型的开源消息中间件，前身是Metaq，当 Metaq 3.0发布时，产品名称改为 RocketMQ。