Send and receive ordered messages

Send ordered messages

The sample code for sending ordered messages is as follows:

using System;
using ons;
public class OrderProducerExampleForEx
{
    public OrderProducerExampleForEx()
    {
    }
    static void Main(string[] args) {
        // Configure your account according to the following settings. You can obtain these settings in the console.
        ONSFactoryProperty factoryInfo = new ONSFactoryProperty();
        // The AccessKeyId you created in the Alibaba Cloud console for identity authentication.
        factoryInfo.setFactoryProperty(ONSFactoryProperty.AccessKey, "Your access key");
        // The AccessKeySecret you created in the Alibaba Cloud console for identity authentication.
        factoryInfo.setFactoryProperty(ONSFactoryProperty.SecretKey, "Your access secret");
        // The group ID you created in the console.
        factoryInfo.setFactoryProperty(ONSFactoryProperty.ProducerId, "GID_example");
        // The topic you created in the console.
        factoryInfo.setFactoryProperty(ONSFactoryProperty.PublishTopics, "T_example_topic_name");
        // Set the TCP endpoint: Go to the **Instances** page in the RocketMQ console, and view the endpoint in the **Endpoint Information** area.
        factoryInfo.setFactoryProperty(ONSFactoryProperty.NAMESRV_ADDR, "NameSrv_Addr");
        // Set the log path.
        factoryInfo.setFactoryProperty(ONSFactoryProperty.LogPath, "C://log");
        // Create producer instances.
        // Note: Producer instances are thread-secure and can be used to send messages of different topics. Each of your threads
        // needs only one producer instance.
        OrderProducer producer = ONSFactory.getInstance().createOrderProducer(factoryInfo);
        // Start the instance at the client.
        producer.start();
        // Create message objects.
        Message msg = new Message(factoryInfo.getPublishTopics(), "tagA", "Example message body");
        string shardingKey = "App-Test";
        for (int i = 0; i < 32; i++) {
            try
            {
                SendResultONS sendResult = producer.send(msg, shardingKey);
                Console.WriteLine("send success {0}", sendResult.getMessageId());
            }
            catch (Exception ex)
            {
                Console.WriteLine("send failure{0}", ex.ToString());
            }
        }
        // Disable the producer instance when the thread is about to exit.
        producer.shutdown();
    }
}

The sample code for consuming ordered messages is as follows:

using System;
using System.Text;
using System.Threading;
using ons;
namespace demo
{
    public class MyMsgOrderListener : MessageOrderListener
    {
        public MyMsgOrderListener()
        {
        }
        ~MyMsgOrderListener()
        {
        }
        public override ons.OrderAction consume(Message value, ConsumeOrderContext context)
        {
            Byte[] text = Encoding.Default.GetBytes(value.getBody());
            Console.WriteLine(Encoding.UTF8. GetString(text));
            return ons.OrderAction.Success;
        }
    }
    class OrderConsumerExampleForEx
    {
        static void Main(string[] args)
        {
            // Configure your account according to the following settings. You can obtain these settings in the console.
            ONSFactoryProperty factoryInfo = new ONSFactoryProperty();
            // The AccessKeyId you created in the Alibaba Cloud console for identity authentication.
            factoryInfo.setFactoryProperty(ONSFactoryProperty.AccessKey, "Your access key");
            // The AccessKeySecret you created in the Alibaba Cloud console for identity authentication.
            factoryInfo.setFactoryProperty(ONSFactoryProperty.SecretKey, "Your access secret");
            // The group ID you created in the console.
            factoryInfo.setFactoryProperty(ONSFactoryProperty.ConsumerId, "GID_example");
            // The topic you created in the console.
            factoryInfo.setFactoryProperty(ONSFactoryProperty.PublishTopics, "T_example_topic_name");
            // Set the TCP endpoint: Go to the **Instances** page in the RocketMQ console, and view the endpoint in the **Endpoint Information** area.
            factoryInfo.setFactoryProperty(ONSFactoryProperty.NAMESRV_ADDR, "NameSrv_Addr");
            // Set the log path.
            factoryInfo.setFactoryProperty(ONSFactoryProperty.LogPath, "C://log");
            // Create producer instances.
            OrderConsumer consumer = ONSFactory.getInstance().createOrderConsumer(factoryInfo);
            // Subscribe to topics.
            consumer.subscribe(factoryInfo.getPublishTopics(), "*",new MyMsgOrderListener());
            // Start the consumer instance.
            consumer.start();
            // Enable the main thread to sleep for a period of time.
            Thread.Sleep(30000);
            // Disable the consumer instance when you no longer use it.
            consumer.shutdown();
        }
    }
}