1. Build a Maven project
<! -- https://mvnrepository.com/artifact/org.apache.rocketmq/rocketmq-client --> <dependency> < the groupId > org. Apache. Rocketmq < / groupId > < artifactId > rocketmq - client < / artifactId > < version > 4.8.0 < / version > < / dependency >Copy the code2. Write a simple sender:
public class Producer { public static void main(String[] args) throws Exception{ DefaultMQProducer producer = new DefaultMQProducer("xxogp"); // Set the nameserver address producer.setNamesrvaddr ("localhost:9876"); producer.start(); Message Message = new Message("mytop111", "hello".getbytes ()); SendResult send = producer.send(message); System.out.println("send = " + send); List<Message> messageList = new ArrayList<Message>(); Message message1 = new Message("mytop111", "hello 1".getbytes ()); Message2 = new Message("mytop111", "hello 2".getbytes ()); Message3 = new Message("mytop111", "hello 3".getbytes ()); messageList.add(message1); messageList.add(message2); messageList.add(message3); producer.send(messageList); System.out.println(" send finished...") ); producer.shutdown(); }}Copy the code3. Write a message consumer
public class Consumer { public static void main(String[] args) throws Exception{ DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("xxogp"); consumer.setNamesrvAddr("localhost:9876"); Subscribe ("mytop111","*"); subscribe("mytop111","*"); consumer.registerMessageListener(new MessageListenerConcurrently() { public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext consumeConcurrentlyContext) { for (MessageExt msg : msgs) { byte[] body = msg.getBody(); System.out.println(new String(body)); } / / by default, this message will only be a consumer consumption point-to-point return ConsumeConcurrentlyStatus. CONSUME_SUCCESS; }}); consumer.start(); System.out.println("start...." ); }}Copy the code