• 首选通过在java项目里面Maven依赖方式引用RocketMQ Java SDK

  <dependency><groupId>com.alibaba.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>3.2.6</version>
  </dependency>

package com.pgsqlmybatis.common.rocketmq;/*
***************************************************************
* 公司名称    :
* 系统名称    :信用管家专业版
* 类 名 称    :Ios渠道idfa统计,推广统计用
* 功能描述    :
* 业务描述    :
* 作 者 名    :@Author Royal
* 开发日期    :2016-05-15
* Created     :IntelliJ IDEA
***************************************************************
* 修改日期    :
* 修 改 者    :
* 修改内容    :
***************************************************************
*/import com.alibaba.rocketmq.client.producer.DefaultMQProducer;
import com.alibaba.rocketmq.client.producer.SendResult;
import com.alibaba.rocketmq.common.message.Message;public class Producer {public static void main(String[] args) {DefaultMQProducer producer = new DefaultMQProducer("Producer");producer.setNamesrvAddr("xxxxxxxxxx:9876");try {producer.start();String pushMsg="kafka activeMq rocketMq 消息队列使用1";Message msg = new Message("PushTopic","push","1",pushMsg.getBytes("UTF-8"));SendResult result = producer.send(msg);System.out.println("id:" + result.getMsgId() +" result:" + result.getSendStatus());String pushMsg2="海量级消息记录单机测试2";msg = new Message("PushTopic","push","2",pushMsg2.getBytes("UTF-8"));result = producer.send(msg);System.out.println("id:" + result.getMsgId() +" result:" + result.getSendStatus());String pushMsg3="海量级消息记录单机测试3";msg = new Message("PullTopic","pull","1",pushMsg3.getBytes());result = producer.send(msg);System.out.println("id:" + result.getMsgId() +" result:" + result.getSendStatus());} catch (Exception e) {e.printStackTrace();} finally {producer.shutdown();}}
}

package com.pgsqlmybatis.common.rocketmq;/*
***************************************************************
* 公司名称    :
* 系统名称    :信用管家专业版
* 类 名 称    :Ios渠道idfa统计,推广统计用
* 功能描述    :
* 业务描述    :
* 作 者 名    :@Author Royal
* 开发日期    :2016-05-15
* Created     :IntelliJ IDEA
***************************************************************
* 修改日期    :
* 修 改 者    :
* 修改内容    :
***************************************************************
*/import java.io.UnsupportedEncodingException;
import java.util.List;import com.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer;
import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import com.alibaba.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import com.alibaba.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import com.alibaba.rocketmq.common.consumer.ConsumeFromWhere;
import com.alibaba.rocketmq.common.message.Message;
import com.alibaba.rocketmq.common.message.MessageExt;public class Consumer {public static void main(String[] args){DefaultMQPushConsumer consumer =new DefaultMQPushConsumer("PushConsumer");consumer.setNamesrvAddr("xxxxxxxxxxxx:9876");try {consumer.subscribe("PushTopic", "push");/*** 设置Consumer第一次启动是从队列头部开始消费还是队列尾部开始消费<br>* 如果非第一次启动，那么按照上次消费的位置继续消费*/consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);consumer.registerMessageListener(new MessageListenerConcurrently() {public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list,ConsumeConcurrentlyContext Context) {Message msg = list.get(0);System.out.println(msg.toString());String recString= null;try {recString = new String(msg.getBody() ,"UTF-8");} catch (UnsupportedEncodingException e) {e.printStackTrace();}System.out.println(recString);return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;}});consumer.start();} catch (Exception e) {e.printStackTrace();}}
}