发送和订阅顺序消息，请使用 Java SDK 1.2.7 及以上版本。
顺序消息是 MQ 提供的一种按照顺序进行发布消费的消息类型，适用由于需要严格按照先进先出的原则进行消息发布和消费的场景。详情请参考顺序消息文档。
全局顺序消息和分区顺序消息的收发方式基本一样，具体请参考以下示例代码。
发送消息示例代码：
package com.aliyun.openservices.ons.example.order;import com.aliyun.openservices.ons.api.Message;import com.aliyun.openservices.ons.api.ONSFactory;import com.aliyun.openservices.ons.api.PropertyKeyConst;import com.aliyun.openservices.ons.api.SendResult;import com.aliyun.openservices.ons.api.order.OrderProducer;import java.util.Properties;public class ProducerClient { public static void main(String[] args) { Properties properties = new Properties(); properties.put(PropertyKeyConst.ProducerId, "XXX");// 您在控制台创建的 Producer ID properties.put(PropertyKeyConst.AccessKey, "XXX");// AccessKey 阿里云身份验证，在阿里云服务器管理控制台创建 properties.put(PropertyKeyConst.SecretKey, "XXX");// SecretKey 阿里云身份验证，在阿里云服务器管理控制台创建 //PropertyKeyConst.ONSAddr地址请根据实际情况对应以下几类进行输入： //公共云生产环境：http://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal //公共云公测环境：http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet //杭州金融云环境：http://jbponsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal //杭州深圳云环境：http://mq4finance-sz.addr.aliyun.com:8080/rocketmq/nsaddr4client-internal //亚太东南1公共云环境（只适用于新加坡ECS）：http://ap-southeastaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal properties.put(PropertyKeyConst.ONSAddr, "http://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal");//此处以公共云生产环境为例 OrderProducer producer = ONSFactory.createOrderProducer(properties); // 在发送消息前，必须调用 start 方法来启动 Producer，只需调用一次即可。 producer.start(); for (int i = 0; i < 1000; i++) { String orderId = "biz_" + i % 10; Message msg = new Message(// // Message所属的Topic "Order_global_topic", // Message Tag, 可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在MQ服务器过滤 "TagA", // Message Body 可以是任何二进制形式的数据， MQ 不做任何干预，需要 Producer 与 Consumer 协商好一致的序列化和反序列化方式 "send order global msg".getBytes() ); // 设置代表消息的业务关键属性，请尽可能全局唯一。 // 以方便您在无法正常收到消息情况下，可通过 MQ 控制台查询消息并补发。 // 注意：不设置也不会影响消息正常收发 msg.setKey(orderId); // 分区顺序消息中区分不同分区的关键字段，sharding key于普通消息的key是完全不同的概念。 // 全局顺序消息，该字段可以设置为任意非空字符串。 String shardingKey = String.valueOf(orderId); // 发送消息，只要不抛异常就是成功 SendResult sendResult = producer.send(msg, shardingKey); System.out.println("Message Id:" + sendResult.getMessageId()); } // 在应用退出前，销毁Producer对象 // 注意：如果不销毁也没有问题 producer.shutdown(); }}订阅消息示例代码：
package com.aliyun.openservices.ons.example.order;import com.aliyun.openservices.ons.api.Message;import com.aliyun.openservices.ons.api.ONSFactory;import com.aliyun.openservices.ons.api.PropertyKeyConst;import com.aliyun.openservices.ons.api.order.ConsumeOrderContext;import com.aliyun.openservices.ons.api.order.MessageOrderListener;import com.aliyun.openservices.ons.api.order.OrderAction;import com.aliyun.openservices.ons.api.order.OrderConsumer;import java.util.Properties;public class ConsumerClient { public static void main(String[] args) { Properties properties = new Properties(); properties.put(PropertyKeyConst.ConsumerId, "XXX");// 您在控制台创建的 Consumer ID properties.put(PropertyKeyConst.AccessKey, "XXX");// AccessKey 阿里云身份验证，在阿里云服务器管理控制台创建 properties.put(PropertyKeyConst.SecretKey, "XXX");// SecretKey 阿里云身份验证，在阿里云服务器管理控制台创建 //公有云生产环境：http://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal //公有云公测环境：http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet //杭州金融云环境：http://jbponsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal //杭州深圳云环境：http://mq4finance-sz.addr.aliyun.com:8080/rocketmq/nsaddr4client-internal properties.put(PropertyKeyConst.ONSAddr, "http://onsaddr-internal.aliyun.com:8080/rocketmq/nsaddr4client-internal");//此处以公有云生产环境为例 properties.put(PropertyKeyConst.SuspendTimeMillis, "100"); // 顺序消息消费失败进行重试前的等待时间 单位(毫秒) properties.put(PropertyKeyConst.MaxReconsumeTimes, "20"); // 消息消费失败时的最大重试次数 // 在订阅消息前，必须调用 start 方法来启动 Consumer，只需调用一次即可。 OrderConsumer consumer = ONSFactory.createOrderedConsumer(properties); consumer.subscribe( // Message所属的Topic "Jodie_Order_Topic", // 订阅指定Topic下的Tags： // 1. * 表示订阅所有消息 // 2. TagA || TagB || TagC 表示订阅TagA 或 TagC 或 TagD 的消息 "*", new MessageOrderListener() { /** * 1. 消息消费处理失败或者处理出现异常，返回OrderAction.Suspend<br> * 2. 消息处理成功，返回与返回OrderAction.Success */ @Override public OrderAction consume(Message message, ConsumeOrderContext context) { System.out.println(message); return OrderAction.Success; } }); consumer.start(); }}