全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
消息队列 MQ

收发普通消息

更新时间:2017-12-15 20:40:00

发送普通消息

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

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Runtime.InteropServices;
using ons;

namespace ons
{
    class onscsharp
    {
        static void Main(string[] args)
        {
            //Producer 创建和正常工作的参数,必须输入
            ONSFactoryProperty factoryInfo = new ONSFactoryProperty();
            factoryInfo.setFactoryProperty(factoryInfo.ProducerId, "PID_xxxx ");//您在 MQ 控制台申请的 Producer ID
            factoryInfo.setFactoryProperty(factoryInfo.PublishTopics, "xxx");//您在 MQ 控制台申请的 Topic
            factoryInfo.setFactoryProperty(factoryInfo.MsgContent, "xxx");//msg content
            factoryInfo.setFactoryProperty(factoryInfo.AccessKey, "xxx");//AccessKey 阿里云身份验证,在阿里云服务器管理控制台创建
                factoryInfo.setFactoryProperty(factoryInfo.SecretKey,"xxx");//SecretKey 阿里云身份验证,在阿里云服务器管理控制台创建

            //创建 producer
            ONSFactory onsfactory = new ONSFactory();
            Producer pProducer = onsfactory.getInstance().createProducer(factoryInfo);

            //在发送消息前,必须调用 start 方法来启动 Producer,只需调用一次即可
            pProducer.start();

            Message msg = new Message(
                //Message Topic
                factoryInfo.getPublishTopics(),
                //Message Tag
                "TagA",
                //Message Body
                factoryInfo.getMessageContent()
            );

            // 设置代表消息的业务关键属性,请尽可能全局唯一。
            // 以方便您在无法正常收到消息情况下,可通过 MQ 控制台查询消息并补发。
            // 注意:不设置也不会影响消息正常收发
            msg.setKey("ORDERID_100");

            //发送消息,只要不抛出异常,就代表发送成功
            try
            {
                SendResultONS sendResult = pProducer.send(msg);
            }
            catch(ONSClientException e)
            {
                //发送失败处理
            }

            // 在应用退出前,必须销毁 Producer 对象,否则会导致内存泄露等问题
            pProducer.shutdown();

        }
    }
}

订阅普通消息

关于订阅普通消息的说明和示例代码,详见订阅消息

本文导读目录