消息队列 JCQ

产品文档

消息队列 JCQ

生产者

生产者Producer是指具体的客户端生产对象,JCQ中分为Producer与GlobalOrderProducer两种,前者用于向普通消息topic发送消息,后者用于向顺序消息Topic发送消息。

Producer

普通生产者支持同步发送、异步发送、OneWay发送三种接口,每种接口都支持发送单条消息或者批量消息。

  1. 同步发送 使用同步发送接口发送消息时,客户端会一直阻塞,直到结果正确或超时返回,此接口适用于追求延迟的场景。

  2. 异步发送 当使用异步发送接口发送消息时,需要注册一个回调函数,用于通知发送结果。异步发送接口不会阻塞当前线程,当发送结果正确返回或超时返回后,通过回调函数通知调用者,调用者根据回调函数的结果做相应的重试等后续操作。

  3. OneWay 当使用OneWay接口发送消息时,类似于异步接口,也不会阻塞当前线程。不需要注册回调函数,所以,OneWay不关心发送的结果。此接口适用于高并发、但对结果不敏感的场景,如日志处理等。

GlobalOrderProducer

全局顺序生产者仅支持同步发送接口,该接口支持发送单条消息或者批量消息。因为需要严格保证消息的有序性,异步接口不能保证,消息到达服务器的顺序与生产者发出的顺序一致。所以全局顺序消息生产者不支持异步发送、OneWay发送接口。

更新时间:2021-03-09 14:15:46
文档反馈 docs feedback