上一篇文章RocketMQ架构设计之启动过程解析 分析了 NameServer, Broker, Producer, Consumer 四个部分的启动过程, 这边文章我们分析 消息的收发过程.
生产者发送消息过程解析我们还是看上篇文章中的例子:
// 使用GroupName初始化Producer DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name"); // 指定NameSrv的地址: 也可以通过环境变量NAMESRV_ADDR来指定,则不需要下面这一行。 producer.setNamesrvAddr
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)