rocketmq发送消息代码

Posted 2020-09-30 jhcelue

        DefaultMQProducer defaultMQProducer = new DefaultMQProducer();
        defaultMQProducer.setProducerGroup(Constant.operationLogGroup);
        defaultMQProducer.setInstanceName(Constant.operationLogInstance);
        defaultMQProducer.setNamesrvAddr(Constant.rocketQueneAddr);
        try {
            defaultMQProducer.start();
            defaultMQProducer.send(message);
        } catch (Exception e) {
            logger.error("produce operation log message error", e);
        } finally {
            defaultMQProducer.shutdown();
        }