.NET绿叶社区!
返回

EasyNetQ使用方法示例附源码

2020-01-09 EasyNetQ RabbitMQ 408 0

使用Nuget安装EasyNetQ

本示例源码下载 http://www.leavescn.com/Files/downloads/MQTest.zip

创建连接:

使用EasyNetQ连接RabbitMQ,是在应用程序启动时创建一个IBus对象,并且,在应用程序关闭时释放该对象。

RabbitMQ连接是基于IBus接口的,当IBus中的方法被调用,连接才会开启。

发布消息Publish

bus1 = RabbitHutch.CreateBus(connectionStr);
var message = new MyMessage { Text = richTextBox1.Text };
//发布消息
bus1.Publish(message);

订阅消息Subscribe

bus2 = RabbitHutch.CreateBus(connectionStr);
//订阅消息
//点击按钮订阅,订阅后只要发布新的消息,收到消息后就会执行修改richTextBox2.Text的值
//用同一个subscribeid订阅了同一种消息类型两次或者多次,RabbitMQ会轮着给两个订阅发消息(两个订阅不会同时收到消息)
bus2.Subscribe<MyMessage>("subscribeid_1", (msg) => {
    string value = msg.Text;
    richTextBox2.Text += value+"\r\n";
});

EasyNetQ使用方法示例附源码

可以自己定义队列名称的发送消息Send/接受消息Receive

发送消息Send

bus1 = RabbitHutch.CreateBus(connectionStr);
//发送端代码
bus1.Send("queuename_1", new MyMessage { Text = richTextBox3.Text });

接受消息Receive

bus2 = RabbitHutch.CreateBus(connectionStr);
bus2.Receive<MyMessage>("queuename_1", message => richTextBox2.Text += message.Text + "\r\n");

EasyNetQ使用方法示例附源码

程序结束的时候关闭EasyNetQ使用的连接,渠道,消费者和所有其他资源。本示例中在窗口关闭时,关闭连接。

private void Form1_FormClosed_1(object sender, FormClosedEventArgs e)
{
    if (bus1 != null)
    {
        bus1.Dispose();
    }
    if (bus2 != null)
    {
        bus2.Dispose();
    }
    if (bus3 != null)
    {
        bus3.Dispose();
    }
}

以上是EasyNetQ的publish,Subscribe,Send和Receive基本用法。

EasyNetQ使用方法示例附源码

登录RabbitMQ管理后台队列里可以看到

执行bus2.Subscribe<MyMessage>("subscribeid_1", (msg) =>{});订阅时,如果是第一次订阅,Queues队列里会增加一个名为MQTest.MyMessage, MQTest_subscribeid_1的队列。

执行bus1.Send("queuename_1", obj);发送时,如果不存在queuename_1队列时,会增加一个名为queuename_1的队列。

执行bus5.Receive<MyMessage>("queuename_2", message => {});接受消息时,如果不存在queuename_2队列时,会新增一个名为queuename_2的队列。

点赞 收藏

顶部