.NET SDK 发送普通消息怎么是实现？

MQ 发送普通消息


您可以运行以下代码进行消息发送。请按说明正确设置相关参数。

1. using System;
2. using System.Collections.Generic;
3. using System.Linq;
4. using System.Text;
5. using System.Runtime.InteropServices;
6. using ons;
8. namespace ons
9. {
10.     class onscsharp
11.     {
12.         static void Main(string[] args)
13.         {
14.             //Producer创建和正常工作的参数，必须输入
15.             ONSFactoryProperty factoryInfo = new ONSFactoryProperty();
16.             factoryInfo.setFactoryProperty(factoryInfo.ProducerId, "PID_xxxx ");//您在MQ控制台申请的Producer ID
17.             factoryInfo.setFactoryProperty(factoryInfo.PublishTopics, "xxx");//您在MQ控制台申请的Topic
18.             factoryInfo.setFactoryProperty(factoryInfo.MsgContent, "xxx");//msg content
19.             factoryInfo.setFactoryProperty(factoryInfo.AccessKey, "xxx");//AccessKey 阿里云身份验证，在阿里云服务器管理控制台创建
20.                 factoryInfo.setFactoryProperty(factoryInfo.SecretKey,"xxx");//SecretKey 阿里云身份验证，在阿里云服务器管理控制台创建
22.             //创建producer
23.             ONSFactory onsfactory = new ONSFactory();
24.             Producer pProducer = onsfactory.getInstance().createProducer(factoryInfo);
26.             //在发送消息前，必须调用start方法来启动Producer，只需调用一次即可
27.             pProducer.start();
29.             Message msg = new Message(
30.                 //Message Topic
31.                 factoryInfo.getPublishTopics(),
32.                 //Message Tag
33.                 "TagA",
34.                 //Message Body
35.                 factoryInfo.getMessageContent()
36.             );
38.             // 设置代表消息的业务关键属性，请尽可能全局唯一。
39.             // 以方便您在无法正常收到消息情况下，可通过 MQ 控制台查询消息并补发。
40.             // 注意：不设置也不会影响消息正常收发
41.             msg.setKey("ORDERID_100");
43.             //发送消息，只要不抛出异常，就代表发送成功
44.             try
45.             {
46.                 SendResultONS sendResult = pProducer.send(msg);
47.             }
48.             catch(ONSClientException e)
49.             {
50.                 //发送失败处理
51.             }
53.             // 在应用退出前，必须销毁Producer对象，否则会导致内存泄露等问题
54.             pProducer.shutdown();
56.         }
57.     }
58. }