RocketMQ中的start()和shutdown

Question

通常生产者  生产完消息需要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();
}

Answer 1

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