ApsaraMQ for RocketMQ:スケジュールされたメッセージの送受信

前提条件

• SDK for。NETがダウンロードされます。 詳細については、「リリースノート」をご参照ください。

• 環境を整えます。 詳細については、「環境の準備」をご参照ください。

• コードで指定するリソースは、ApsaraMQ for RocketMQコンソールで作成されます。 リソースには、インスタンス、トピック、および消費者グループが含まれます。 詳細については、「リソースの作成」 をご参照ください。

• Alibaba CloudアカウントのAccessKeyペアが取得されます。 詳細については、「AccessKey の作成」をご参照ください。

スケジュールされたメッセージの送信

次のサンプルコードは、HTTPクライアントSDK forを使用してスケジュールされたメッセージを送信する方法の例を示しています。NET:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Runtime.InteropServices;
using ons;

namespace ons
{
    class onscsharp
    {
        private static readonly DateTime Jan1st1970 = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);

        public static long CurrentTimeMillis()
        {
           return (long) (DateTime.UtcNow - Jan1st1970).TotalMilliseconds;
        }    
       
        static void Main(string[] args)
        {
            // The parameters that are required to create and use the producer. 
            ONSFactoryProperty factoryInfo = new ONSFactoryProperty();
            // The ID of the consumer group that you created in the ApsaraMQ for RocketMQ console. 
            factoryInfo.setFactoryProperty(ONSFactoryProperty.ProducerId, "XXX ");
            // The TCP endpoint. You can obtain the endpoint in the TCP Endpoint section of the Instance Details page in the ApsaraMQ for RocketMQ console. 
            factoryInfo.setFactoryProperty(ONSFactoryProperty.NAMESRV_ADDR, "XXX");
            // The topic that you created in the ApsaraMQ for RocketMQ console. 
            factoryInfo.setFactoryProperty(ONSFactoryProperty.PublishTopics, "XXX");
            // The message content. 
            factoryInfo.setFactoryProperty(ONSFactoryProperty.MsgContent, "XXX");
            // Make sure that the environment variables ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET are configured. 
            // The AccessKey ID that is used for authentication. 
            factoryInfo.setFactoryProperty(ONSFactoryProperty::AccessKey, getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"));
	          // The AccessKey secret that is used for authentication. 
            factoryInfo.setFactoryProperty(ONSFactoryProperty::SecretKey, getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
            
            // Create the producer. 
            Producer pProducer = ONSFactory.getInstance().createProducer(factoryInfo);

            // Before you send the message, call the start() method only once to start the producer. 
            pProducer.start();

            Message msg = new Message(
                // The message topic. 
                factoryInfo.getPublishTopics(),
                // The message tag. 
                "TagA",
                // The message body. 
                factoryInfo.getMessageContent()
            );

            // The message key. A key is the business-specific attribute of a message and must be globally unique whenever possible. 
            // If you cannot receive a message as expected, you can use the key to query the message in the ApsaraMQ for RocketMQ console. 
            // Note: You can send and receive a message even if you do not specify the key. 
            msg.setKey("ORDERID_100");

            // The delivery time. Unit: ms. A message is consumed only after the specified time. In this example, the message is consumed after 3 seconds. 
            long deliverTime = CurrentTimeMillis() + 3000;
            msg.setStartDeliverTime(deliverTime);

            // Send the message. If no exception is thrown, the message is sent. 
            try
            {
                SendResultONS sendResult = pProducer.send(msg);
            }
            catch(ONSClientException e)
            {
                // The logic for handling failures. 
            }

            // Before you exit your application, destroy the producer. If you do not destroy the producer, issues such as memory leaks may occur. 
            pProducer.shutdown();

        }
    }
}           

スケジュールされたメッセージの購読

スケジュールされたメッセージをサブスクライブするためのサンプルコードは、通常のメッセージをサブスクライブするためのサンプルコードと同じです。 詳細については、『メッセージのサブスクライブ』をご参照ください。