public class rockermq1 {

    public static void main(String[] args) {
        DefaultMQProducer defaultMQProducer = new DefaultMQProducer("GROUP",getAclRPCHook());
        // 1 指定NameServer的地址
        //defaultMQProducer.setNamesrvAddr("10.10.1.19:9876");
        // 2 設定訊息同步傳送失敗時的重試次數，預設為 2
        defaultMQProducer.setRetryTimesWhenSendFailed(2);
        // 3 設定訊息傳送超時時間，預設3000ms
        defaultMQProducer.setSendMsgTimeout(3000);
        // 4 這裡設定為false
        defaultMQProducer.setVipChannelEnabled(false);
        try {
            // 5 啟動生產者
            defaultMQProducer.start();
            Message message = new Message("topic-test", "test-tag", "測試資料001".getBytes());
            // 2 非同步傳送訊息
            SendResult s = defaultMQProducer.send(message);
            System.out.println("傳送的訊息："+s);
        } catch (Exception e) {
            //log.error("啟動rocketMq生產者異常", e);
            System.out.println("錯誤："+e);
        }

    }
    //設定賬號密碼
    static RPCHook getAclRPCHook() {
        return new AclClientRPCHook(new SessionCredentials("xxx", "xxx"));
    }
}
 

maven

    </dependency>

        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-client</artifactId>
            <version>4.8.0</version>
            <scope>compile</scope>
        </dependency>

        <dependency>
            <groupId>org.apache.rocketmq</groupId>
            <artifactId>rocketmq-acl</artifactId>
            <version>4.8.0</version>
        </dependency>
    </dependencies>