消息类型-顺序消息
順序消息
順序消息是消息隊(duì)列提供的一種嚴(yán)格按照順序來發(fā)布和消費(fèi)的消息類型。
package com.leon.test;import com.leon.OrderApplication; import org.apache.rocketmq.client.producer.SendCallback; import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner;@RunWith(SpringRunner.class) @SpringBootTest(classes = OrderApplication.class) public class MessageTypeTest {@Autowiredprivate RocketMQTemplate rocketMQTemplate;//單向消息@Testpublic void testOneWay() {for (int i = 0; i < 10; i++) {rocketMQTemplate.sendOneWay("test-topic-1", "這是一條單向消息");}}//單向順序消息@Testpublic void testOneWayOrderly() {for (int i = 0; i < 10; i++) {//第三個參數(shù)的作用是用來決定這些消息發(fā)送到哪個隊(duì)列的上的rocketMQTemplate.sendOneWayOrderly("test-topic-1", "這是一條單向消息","xx");}} }?
總結(jié)