云主机

  • 云主机服务 > 产品手册 > 消息队列 RocketMQ >SDK参考(TCP版本) >.NET >收发定时消息

    收发定时消息

    最近更新时间:2019-09-05 19:47:55

    目前支持的域包括公网、华东1、华北2、华东2、华南1。
    定时消息可以做到在指定时间之后才可被消费者消费,用于解决一些消息生产和消费有时间窗口要求的场景,或者通过消息触发定时任务的场景,类似于延迟队列。

    发送定时消息

    发送定时消息的代码示例如下:

    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, "XXX ");//您在控制台创建的 Group ID
                factoryInfo.setFactoryProperty(factoryInfo.NAMESRV_ADDR, "XXX"); //设置 TCP 接入域名,进入控制台的实例管理页面的“获取接入点信息”区域查看
                factoryInfo.setFactoryProperty(factoryInfo.PublishTopics, "XXX");//您在控制台创建的 Topic
                factoryInfo.setFactoryProperty(factoryInfo.MsgContent, "XXX");//消息内容
                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 Console 查询消息并补发。
                // 注意:不设置也不会影响消息正常收发
                msg.setKey("ORDERID_100");
                // deliver time 单位 ms,指定一个时刻,在这个时刻之后才能被消费,这个例子表示3s 后才能被消费
                long deliverTime = 获取系统当前时间(ms) + 3000;
                msg.setStartDeliverTime(deliverTime);
                //发送消息,只要不抛出异常,就代表发送成功
                try
                {
                    SendResultONS sendResult = pProducer.send(msg);
                }
                catch(ONSClientException e)
                {
                    //发送失败处理
                }
                // 在应用退出前,必须销毁 Producer 对象,否则会导致内存泄露等问题
                pProducer.shutdown();
            }
        }
    }
    
    以上内容是否对您有帮助?
  • Icon free helper
    Close