RocketMQ中的start()和shutdown

裸奔的饺子 发布于 07/22 17:03
阅读 133
收藏 0

通常生产者  生产完消息需要shutdown吗,还是让它一直开着。

producer我是通过@Bean拿到的。拿出时,已经start()过了。

@RequestMapping(value = "/produceMessage", method = RequestMethod.POST)
public GeneralResponseDto produceMessage(@RequestBody JSONObject json) throws InterruptedException, RemotingException, MQClientException, MQBrokerException {
    Message message = new Message();
    message.setBody(json.toJSONString().getBytes());
    message.setTopic("spring-demo");
    message.setTags("a");
    DefaultMQProducer producer = producerConfig.getRocketMQProducer();
    producer.send(message);
    logger.info("MQ发送消息:{}", json.toJSONString());
    producer.shutdown();
    return GeneralResponseDto.addSuccess();
}
加载中
0
wgslucky
wgslucky

这要看你的业务需求了,如果很长时间才会生产消息,最好是发送完就关闭,这样可以节省资源,比如内存和线程,网络IO。但是如果你的业务生产消息比较频繁,最好是一直开着,需要发送消息的时候,直接调用就可以了。这样可以避免创建链接时阻塞当前操作,提高消息处理的效率。

返回顶部
顶部