验证中...
码云 Gitee IDE 全新上线——支持 Git 管理的轻量在线编码环境
快速使用MessageQueue 消息队列
原始数据 复制代码
using System;
using System.Collections.Generic;
using System.Linq;
using System.Messaging;
using System.Web;
namespace APSWcfService.Helper
{
public class MessageHelper
{
/// <summary>
/// 新增消息到消息队列,有队列则增加消息,没有队列则新增队列后增加消息
/// </summary>
/// <param name="path">.\\private$\\NewOrder</param>
/// <param name="label">消息列表标签</param>
/// <param name="body">消息队列内容</param>
public static string AddMessageQueue(string path, string label, string body)
{
try
{
var mq = MessageQueue.Exists(path) ? new MessageQueue(path) : MessageQueue.Create(path);
Message message = new Message();
message.Label = label;
message.Formatter = new XmlMessageFormatter(new Type[] { typeof(string) });
message.Body = body;
mq.Send(message);
return message.Id;
}
catch (Exception)
{
throw;
}
}
}
}
//方法 调用代码示例
//部署得服务器一定要安装MessageQueue服务
// 注意一下示例 队列地址用的private 是专用队列
// MessageHelper.AddMessageQueue($".\\private$\\messge", "这里是消息标签", "这里是消息内容(一般为JSON,XML....)");

评论列表( 0 )

你可以在登录后,发表评论

搜索帮助