RocketMQ C#

### C# 中集成和使用 RocketMQ

#### 创建消息模型
为了发送和接收消息，在C#中定义一个简单的数据传输对象(DTO)，用于表示消息的内容。

/// <summary>
/// 发送RocketMQ测试消息实体
/// </summary>
public class RocketMQSampleModel {
    public string User_Name { get; set; }
    public string User_Account { get; set; }
}

此代码片段展示了如何创建一个基本的消息模型[^1]。

#### 配置依赖项和服务提供者
在 .NET Core 或 .NET Framework 应用程序中，通过NuGet包管理器安装`Aliyun.MQ.SDK`或其他适用于.NET的RocketMQ客户端库。配置服务提供商来初始化RocketMQ连接设置，这通常是在应用程序启动阶段完成的工作。

#### 实现消息生产者
构建一个能够向指定的主题(Topic)发布消息的服务端点或业务逻辑组件：

using Aliyun.MQ.Runtime;
using Aliyun.OpenServices.OnsModel;

// 假设已经设置了必要的环境变量或者配置文件读取机制
var producer = OnsFactory.GetProducer(producerId, new ProducerConfig() {
    AccessKey = accessKeyId,
    SecretKey = secretAccessKey,
    NameServerAddress = nameServers // 名字服务器地址列表
});

producer.Start();

try {
    var msg = MessageBuilder.WithTopic("your-topic-name")
                            .WithTag("tag")
                            .WithBody(JsonConvert.SerializeObject(new RocketMQSampleModel{
                                User_Name="testUser",
                                User_Account="account"
                            }))
                            .Build();
    
    SendResult sendResult = await producer.SendAsync(msg);
} finally {
    producer.Shutdown();
}

这段代码说明了怎样实例化并启动一个生产者，并且构造了一条消息发送给特定主题[^5]。

#### 构建消费者
实现一个可以订阅某个主题并处理接收到的消息的应用部分。由于原生支持可能有限制，考虑利用第三方库如 `EasyNetQ` 来简化操作流程。不过这里给出的是基于官方SDK的方式:

using System.Threading.Tasks;
using Aliyun.MQ.Runtime;
using Aliyun.OpenServices.OnsModel;

class Program {
    private static async Task Main(string[] args) {
        var consumer = OnsFactory.GetConsumer(consumerGroupId, new ConsumerConfig(){
            AccessKey=accessKeyId,
            SecretKey=secretAccessKey,
            NameServerAddress=nameServers
        });

        consumer.Subscribe("your-topic-name", "*", (msgList) => {
            foreach(var msg in msgList){
                Console.WriteLine($"Received message: {Encoding.UTF8.GetString(msg.Body)}");
            }

            return true;
        });
        
        consumer.Start();

        // Keep the application running to listen for messages.
        while(true){}

        consumer.Shutdown();  
    }
}

上述例子描述了一个持续运行的控制台应用程序作为消费者的简单形式[^2]。