rocketmqrocketmq默认使用哪个配置文件

消息中间件metaq和rocketmq的区别

metaq是阿里自研的消息中间来件，发展了 1.0 、2.0、 3.0后。

对外开源出了一版本叫做 rocketmq。

2016 年双11 前后，阿里巴巴将RocketMQ 捐赠给Apache 基金会，自吸引了全球的开源爱好者参与到RocketMQ社区中，并于2017 年9 月成为Apache 基金会的顶级项目。

在开源社区的帮百助下，RocketMQ 具备了对接主流大数据流度计算平台、对接存储平台以及离在线数据处理的能力。

java怎样连接rocketmq

public class RocketProducer { private DefaultMQProducer producer; public RocketProducer() { this.init(); } private void init() { if (producer == null) { try { producer = new DefaultMQProducer("DataRecord"); producer.setNamesrvAddr("192.168.1.11:9876"); producer.start(); } catch (Exception ex) { LogUtil.error(ex); this.destory(); producer = null; } } } public boolean send(String group, String queue, byte[] message) { try { this.init(); Message msg = new Message(group, queue, message); SendResult result = producer.send(msg); return (SendStatus.SEND_OK.equals(result.getSendStatus())); } catch (Exception ex) { LogUtil.error(ex); } return false; } public void destory() { if (this.producer != null) { thi

rocketmq默认使用哪个配置文件

// 指定配置文件 if mandLine.hasOption(‘c‘)) { String file =mandLine.getOptionValue(‘c‘); if (file != null) { configFile = file; InputStream in = new BufferedInputStream(new FileInputStream(file)); properties = new Properties(); properties.load(in); MixAll.properties2Object(properties, brokerConfig); MixAll.properties2Object(properties,tyServerConfig); MixAll.properties2Object(properties,tyClientConfig);