1 /**
 2  * @Description: 订单信息
 3  */
 4 public class Indent {
 5 
 6     /**
 7      * 订单ID
 8      */
 9     private String orderId;
10 
11     /**
12      * 顺序
13      */
14     private String order;
15 
16     public Indent(String orderId, String order) {
17         this.orderId = orderId;
18         this.order = order;
19     }
20 
21     public String getOrderId() {
22         return orderId;
23     }
24 
25     public void setOrderId(String orderId) {
26         this.orderId = orderId;
27     }
28 
29     public String getOrder() {
30         return order;
31     }
32 
33     public void setOrder(String order) {
34         this.order = order;
35     }
36 }

 1 import com.snails.rmq.common.RMQConstant;
 2 import com.snails.rmq.utils.ClientUtils;
 3 import com.snails.rmq.utils.DateUtils;
 4 import org.apache.rocketmq.client.producer.DefaultMQProducer;
 5 import org.apache.rocketmq.client.producer.MessageQueueSelector;
 6 import org.apache.rocketmq.client.producer.SendResult;
 7 import org.apache.rocketmq.common.message.Message;
 8 import org.apache.rocketmq.common.message.MessageQueue;
 9 import java.util.ArrayList;
10 import java.util.List;
11 
12 /**
13  * @Description: 发送顺序消息
14  */
15 public class OrderProducer {
16 
17     public static void main(String[] args) throws Exception {
18         // 获取生产者实例
19         DefaultMQProducer producer =
20                 ClientUtils.gainProducerInstance(RMQConstant.ORDER_GROUP, RMQConstant.NAEMSRV_ADDR);
21         // 消息标签
22         String[] tags = new String[]{RMQConstant.MSG_TAG_A, RMQConstant.MSG_TAG_B, RMQConstant.MSG_TAG_C};
23         // 订单列表
24         List<Indent> indentList = OrderProducer.buildIndents();
25 
26         for (int i = 0; i < indentList.size(); i++) {
27             // 获取消息
28             String msgBody = "顺序消息, ".concat(DateUtils.now().concat(":")) + indentList.get(i);
29             Message msg = new Message(RMQConstant.ORDER_TOPIC,
30                     tags[i % tags.length], "RMQKEYS" + i, msgBody.getBytes());
31 
32             // 发送消息
33             SendResult sendResult = producer.send(msg, new MessageQueueSelector() {
34                 @Override
35                 public MessageQueue select(List<MessageQueue> mqList, Message msg, Object obj) {
36                     //根据id选择要发送的消息队列queue
37                     long indentId = (Long) obj;
38                     long index = indentId % mqList.size();
39                     return mqList.get((int) index);
40                 }
41             }, Long.valueOf(indentList.get(i).getOrderId()));
42 
43             // 发送结果打印
44             System.out.printf("发送状态:%s, 消息队列id:%d, 消息内容:%s %n",
45                     sendResult.getSendStatus(),
46                     sendResult.getMessageQueue().getQueueId(),
47                     msgBody);
48         }
49 
50         // 关闭生产实例
51         ClientUtils.shutdownProducer(producer);
52     }
53 
54 
55     /**
56      * 生成模拟订单数据
57      */
58     private static List<Indent> buildIndents() {
59         List<Indent> indentList = new ArrayList<Indent>();
60 
61         Indent indentDemo = new Indent("15103111039", "0");
62         indentList.add(indentDemo);
63 
64         indentDemo = new Indent("15103111065", "1");
65         indentList.add(indentDemo);
66 
67         indentDemo = new Indent("15103111039", "2");
68         indentList.add(indentDemo);
69 
70         indentDemo = new Indent("15103117235", "3");
71         indentList.add(indentDemo);
72 
73         indentDemo = new Indent("15103111065", "4");
74         indentList.add(indentDemo);
75 
76         indentDemo = new Indent("15103117235", "5");
77         indentList.add(indentDemo);
78 
79         indentDemo = new Indent("15103111065", "6");
80         indentList.add(indentDemo);
81 
82         indentDemo = new Indent("15103111039", "7");
83         indentList.add(indentDemo);
84 
85         indentDemo = new Indent("15103117235", "8");
86         indentList.add(indentDemo);
87 
88         indentDemo = new Indent("15103111039", "9");
89         indentList.add(indentDemo);
90 
91         return indentList;
92     }
93 }