ApsaraMQ for RocketMQ:Send and receive normal messages

using System;
using ons;

public class ProducerExampleForEx
{
    public ProducerExampleForEx()
    {
    }

    static void Main(string[] args) {
        // Configure the producer properties.
        ONSFactoryProperty factoryInfo = new ONSFactoryProperty();

        // Load credentials from environment variables.
        // Set ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET
        // before running this example.
        factoryInfo.setFactoryProperty(ONSFactoryProperty::AccessKey, getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"));
        factoryInfo.setFactoryProperty(ONSFactoryProperty::SecretKey, getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));

        // Specify the Group ID created in the ApsaraMQ for RocketMQ console.
        factoryInfo.setFactoryProperty(ONSFactoryProperty.ProducerId, "<GROUP_ID>");

        // Specify the topic created in the ApsaraMQ for RocketMQ console.
        factoryInfo.setFactoryProperty(ONSFactoryProperty.PublishTopics, "<TOPIC>");

        // Specify the TCP endpoint from the Instance Details page
        // in the ApsaraMQ for RocketMQ console.
        factoryInfo.setFactoryProperty(ONSFactoryProperty.NAMESRV_ADDR, "<TCP_ENDPOINT>");

        // Specify the log file path.
        factoryInfo.setFactoryProperty(ONSFactoryProperty.LogPath, "C://log");

        // Create a producer instance.
        // Producer instances are thread-safe. A single instance can send
        // messages to multiple topics. In most cases, one instance per thread is sufficient.
        Producer producer = ONSFactory.getInstance().createProducer(factoryInfo);

        // Start the producer.
        producer.start();

        // Build a message with a topic, tag, and body.
        Message msg = new Message(factoryInfo.getPublishTopics(), "tagA", "Example message body");
        msg.setKey(Guid.NewGuid().ToString());

        // Send 32 messages in a loop.
        for (int i = 0; i < 32; i++) {
            try
            {
                SendResultONS sendResult = producer.send(msg);
                Console.WriteLine("send success {0}", sendResult.getMessageId());
            }
            catch (Exception ex)
            {
                Console.WriteLine("send failure{0}", ex.ToString());
            }
        }

        // Shut down the producer before exiting the thread.
        producer.shutdown();
    }
}

Kod incelemesi

1. Özellikleri yapılandırın -- ONSFactoryProperty aracılığıyla kimlik bilgilerini, Grup Kimliğini, konuyu, TCP uç noktasını ve günlük yolunu ayarlayın. AccessKey ID ve AccessKey Secret değerlerini ALIBABA_CLOUD_ACCESS_KEY_ID ve ALIBABA_CLOUD_ACCESS_KEY_SECRET ortam değişkenlerinden yükleyin.

2. Üreticiyi oluşturun ve başlatın -- ONSFactory.getInstance().createProducer(factoryInfo) çağrısı, iş parçacığı açısından güvenli bir üretici örneği döndürür. Birden fazla konuya mesaj gönderirken bile çoğu durumda her iş parçacığı için bir örnek yeterlidir.

3. Mesajları oluşturun ve gönderin -- Konu, etiket ve gövde içeren bir Message nesnesi oluşturun. Mesaj izleme için Guid.NewGuid() ile benzersiz bir anahtar atayın. Başarılı olduğunda producer.send(msg) çağrısı, mesaj kimliğini içeren bir SendResultONS döndürür.

4. Kapatma işlemi -- Üretici örneğini sonlandırmak için iş parçacığı çıkmadan önce producer.shutdown() yöntemini çağırın.