java 使用 rocketmq的一个生产者和消费者的实现,其中要先启动rocket的nameserver 和borker