请教消息往队列里面发送消息，应该是同步还是异步？

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 2447 天前的主题，其中的信息可能已经有所发展或是发生改变。

我理解应该是处理消息是异步处理，发送消息到消息队列应该要同步进行的

如果是发送消息到消息队列是异步处理的，可能没法保证消息确定会到达消息队列吧（譬如程序崩溃）？

然后现在公司要用 kafka 队列，我测试了下阿里云的 kafka 队列服务，同步发 10 条消息，要 19s （ 1000 条，55s ），怎么这么慢，是我哪里没理清楚吧？要用异步的方法？如果用异步的方法，怎么保证消息在程序崩溃前发送到消息队列里了

3 条回复 • 2018-03-06 12:53:05 +08:00

wellsc

2018-03-05 21:31:04 +08:00 via iPhone

异步

billlee

2018-03-05 22:03:54 +08:00

发送过程都是异步的，阻塞版本的 API 也是在等后台线程把数据发出去，默认的 linger.ms 是 1 s, 所以单线程阻塞发消息 1 条要 1 秒。一定要用阻塞 API, 请把 batch.size 或 linger.ms 改小。

iloveyou

2018-03-06 12:53:05 +08:00

发送当然是同步啊，处理是异步。阿里云发送慢是因为你用公网发送吧，生产环境应该是内网。