• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

RabbitMQ学习系列二-C#代码发送消息

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

RabbitMQ学习系列二:.net 环境下 C#代码使用 RabbitMQ 消息队列

http://www.80iter.com/blog/1437455520862503

上一篇已经讲了Rabbitmq如何在Windows平台安装,不懂请移步:RabbitMQ学习系列一:windows下安装RabbitMQ服务

一、理论:
.net环境下,C#代码调用RabbitMQ消息队列,本文用easynetq开源的.net Rabbitmq api来实现。

EasyNetQ 是一个易于使用的RabbitMQ的.Net客户端API。

RabbitMQ 是由 LShift 提供的一个 Advanced Message Queuing Protocol (AMQP) 的开源实现,由以高性能、健壮以及可伸缩性出名的 Erlang 写成,因此也是继承了这些优点。

AMQP 里主要要说两个组件:Exchange 和 Queue (在 AMQP 1.0 里还会有变动),

如下图所示,绿色的 X 就是 Exchange ,红色的是 Queue ,这两者都在 Server 端,又称作 Broker ,

这部分是 RabbitMQ 实现的,而蓝色的则是客户端,通常有 Producer 和 Consumer 两种类型:

二、asp.net项目搭建
1、新建项目(略)

2、项目nuget需要使用的三方dll,本文案例使用的版本如下图

3、消息队列类库结构说明

4、BusBuilder.cs管道创建类,主要负责链接Rabbitmq

/// <summary>
/// 消息服务器连接器
/// </summary>
public class BusBuilder
{
    public static IBus CreateMessageBus()
    {
        //消息服务器连接字符串
        var connectionString = ConfigurationManager.ConnectionStrings["RabbitMQ"];
        if (connectionString == null || connectionString.ConnectionString == string.Empty)
        {
            throw new Exception("messageserver connection string is missing or empty");
        }
        return RabbitHutch.CreateBus(connectionString.ConnectionString);
    }
}

5、IProcessMessage类,定义了一个消息方法,用于消息传递


public interface IProcessMessage
{
    void ProcessMsg(Message msg);
 
    void Notice();
}

6、Message类,定义了消息传递的实体属性字段等信息


public class Message
{
    public string MessageID { get; set; }
     
    public string MessageTitle { get; set; }
 
    public string MessageBody { get; set; }
 
    public string MessageRouter { get; set; }
}

7、MQHelper类,负责创建消息管道、创建消息管道、发送消息体等工作


/// <summary>
/// 发送消息
/// </summary>
public static void Publish(Message msg)
{
    //// 创建消息bus
    IBus bus = BusBuilder.CreateMessageBus();
    try
    {
        using (var publishChannel = bus.OpenPublishChannel())   //创建消息管道
        {
            publishChannel.Publish(msg, x => x.WithTopic(msg.MessageRouter));  //通过管道发送消息
        }
    }
    catch (EasyNetQException ex)
    {
        //处理连接消息服务器异常
    }
    bus.Dispose();//与数据库connection类似,使用后记得销毁bus对象
}

8、web项目进行调用后台消息队列方法


RabbitMQ.Message msg = new RabbitMQ.Message();
msg.MessageID = "test";
msg.MessageBody = DateTime.Now.ToString();
msg.MessageTitle = "test";
msg.MessageRouter = "pcm.notice.zhangsan";
RabbitMQ.MQHelper.Publish(msg);

这样就可以用c#发送消息到队列中,测试结果如下图:

查看队列下的消息记录

获取队列消息尝试

至此,C#向Rabbitmq消息队列发送消息已经简单完成


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
C#运算符重载发布时间:2022-07-13
下一篇:
如何实现C/S模式下客户机与服务器采用统一的时间发布时间:2022-07-13
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap