本文提供使用TCP协议下的.NET SDK收发定时消息的示例代码。目前支持的地域包括公网、华东1(杭州)、华北2(北京)、华东2(上海)、华南1(深圳)。
定时消息可以做到在指定时间戳之后才可被消费者消费,适用于对消息生产和消费有时间窗口要求,或者利用消息触发定时任务的场景。
定时消息的概念介绍及使用过程中的注意事项,请参见定时和延时消息。
前提条件
发送定时消息
说明 具体的示例代码,请以消息队列RocketMQ版代码库为准。
发送定时消息的代码示例如下所示。
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(ONSFactoryProperty.ProducerId, "XXX ");//您在控制台创建的Group ID。
factoryInfo.setFactoryProperty(ONSFactoryProperty.NAMESRV_ADDR, "XXX");//设置TCP接入域名,进入控制台的实例管理页面的“获取接入点信息”区域查看。
factoryInfo.setFactoryProperty(ONSFactoryProperty.PublishTopics, "XXX");//您在控制台创建的Topic。
factoryInfo.setFactoryProperty(ONSFactoryProperty.MsgContent, "XXX");//消息内容。
factoryInfo.setFactoryProperty(ONSFactoryProperty.AccessKey, "XXX");//AccessKey ID阿里云身份验证,在阿里云服务器管理控制台创建。
factoryInfo.setFactoryProperty(ONSFactoryProperty.SecretKey,"XXX");//AccessKey Secret阿里云身份验证,在阿里云服务器管理控制台创建。
// 创建producer。
Producer pProducer = ONSFactory.getInstance().createProducer(factoryInfo);
// 在发送消息前,必须调用start方法来启动Producer,只需调用一次即可。
pProducer.start();
Message msg = new Message(
// 消息主题。
factoryInfo.getPublishTopics(),
// 消息标签。
"TagA",
// 消息主体。
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();
}
}
}
订阅定时消息
订阅普通消息的说明和示例代码,更多信息,请参见订阅消息。
在文档使用中是否遇到以下问题
更多建议
匿名提交