dotnet add package NewLife.RocketMQ --version 2.0.2022.325-beta0806

//Producer.
var mq = new Producer
{
    Topic = "TopicTest1", //For a non-general cluster, you need to concatenate the complete topic, such as MQ_INSTxxx_aaa%TopicTest.
    NameServerAddress = "127.0.0.1:9876",// Enter it on the Tencent Cloud page.
    Log = XTrace.Log,
    AclOptions = new AclOptions
    {
        AccessKey = "AccessKey of the page",
        SecretKey = "SecretKey of the page",
    },
};
mq.Start();
for (var i = 0; i < 10; i++)
{
    var str = "Message production test" + i;
    var sr = mq.Publish(str, "TagA");
}

//Consumer.
var consumer = new Consumer
{
    Topic = "TopicTest1", //For a non-general cluster, you need to concatenate a complete topic, such as MQ_INSTxxx_aaa%TopicTest.
    Group = "test", // For a non-general cluster, you need to concatenate a complete group, such as MQ_INSTxxx_aaa%GroupTest.
    NameServerAddress = "127.0.0.1:9876",
    FromLastOffset = true,
    SkipOverStoredMsgCount = 0,
    BatchSize = 20,
    Log = XTrace.Log,
    AclOptions = new AclOptions
    {
        AccessKey = "AccessKey of the page",
        SecretKey = "SecretKey of the page",
    },
};
consumer.OnConsume = (q, ms) =>
{
    XTrace.WriteLine("[{0}@{1}] received message [{2}]", q.BrokerName, q.QueueId, ms.Length);
    foreach (var item in ms.ToList())
    {
        XTrace.WriteLine($"message {item.Keys}, sending time {item.BornTimestamp.ToDateTime()}, content {item.Body.ToStr()}");
    }
    return true;
};
consumer.Start();