全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 阿里云办公 培训与认证 物联网
消息队列 MQ

发送普通消息

更新时间:2017-08-24 17:13:15

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