RocketMQ最佳实践之Producer

投递状态

发送消息时,将得到包含SendStatusSendResult。首先,我们假设消息的isWaitStoreMsgOK = true(默认是true)。如果不是,我们将总会得到SEND_OK,如果没有抛出异常。下面是关于每个状态的描述列表:

  • FLUSH_DISK_TIMEOUT

    如果 Broker 设置MessageStoreConfigFlushDiskType=SYNC_FLUSH(默认是ASYNC_FLUSH),并且代理没有在MessageStoreConfig的syncFlushTimeout(默认是5秒)时间内完成刷盘,您将获得这个状态。

  • FLUSH_SLAVE_TIMEOUT

    如果 Broker 的角色是 SYNC_MASTER (默认是ASYNC_MASTER),并且 Slave Broker 没有在MessageStoreConfig的syncFlushTimeout(默认是5秒)时间内完成同步,您将得到这个状态。

  • SLAVE_NOT_AVAILABLE

    如果代理的角色是SYNC_MASTER(默认是ASYNC_MASTER),但是没有配置 Slave Broker ,您将获得这个状态。

  • SEND_OK

    SEND_OK 并不意味着它是可靠的。为了确保没有信息会丢失,应启用 SYNC_MASTER 或 SYNC_FLUSH

重复或者丢失消息

如果您得到FLUSH_DISK_TIMEOUTFLUSH_SLAVE_TIMEOUT并且 Broker 恰好在此时意外宕机,您会发现你的消息丢失。此时,您有两个选择,一个是不管它,这可能导致这个消息丢失;另一个是重新发送消息,这可能会导致消息重复。我们经常建议重新发送,然后再消费时使用某个方法移除重复的消息。除非你觉得一些信息丢失并不重要。但是请记住,当您得到 SLAVE_NOT_AVAILABLE 状态时,重新发送是没有用的。如果出现这种情况,您应该保存场景并通知集群管理

超时

客户端发送请求到 Broker ,并等待响应,但如果最大等待时间过去了,没有返回响应,客户端就会抛出一个RemotingTimeoutException。默认的等待时间是3秒。您还可以使用 send(msg, timeout) 代替 send(msg) 来传递超时参数。注意,我们不建议等待时间过小,因为 Broker 需要一些时间来刷新磁盘或与 Slave 进行同步。而且,如果它超过 syncFlushTimeout,那么它的值可能不会有多大的影响,因为在超时之前,代理可能会以FLUSH_SLAVE_TIMEOUTFLUSH_SLAVE_TIMEOUT返回响应。

消息大小

我们建议的消息的大小应该不超过 512 K。

异步发送

默认 send(msg) 将阻塞直到返回的响应。所以如果你关心的是性能,我们建议你使用 send(msg, callback) ,这将会以异步方式发送。

生产者组

正常情况下,生产者组没有影响。但如果你开启了事物,你应该注意它。默认情况下,您只能在同一个JVM中只创建同一个生产者组,这通常是足够的。

线程安全

生产者是线程安全的,您可以在业务解决方案中使用它。

性能

如果您希望在一个JVM中有多个生产者进行大数据处理,我们建议:

  • 与一些生产者一起使用异步发送(3 ~ 5就足够了)
  • 为每个生产者setInstanceName
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 220,699评论 6 513
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 94,124评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 167,127评论 0 358
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 59,342评论 1 294
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 68,356评论 6 397
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 52,057评论 1 308
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,654评论 3 420
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,572评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 46,095评论 1 318
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 38,205评论 3 339
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,343评论 1 352
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 36,015评论 5 347
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,704评论 3 332
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,196评论 0 23
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,320评论 1 271
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,690评论 3 375
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,348评论 2 358

推荐阅读更多精彩内容