C# 如何使用 RabbitMQ 实现消息收发

本文是基于http://www.cnblogs.com/cheng-lei/articles/7274513.html的项目结构进行搭建的，了解之前请先阅读http://www.cnblogs.com/cheng-lei/category/1047427.html中的前四篇文章。

 

工具 — Nuget包管理器 —程序包管理器控制台

PM> Install-Package RabbitMQ.Client -Version 5.1.0

PM> Install-Package EasyNetQ -Version 3.2.0

 

一、项目搭建

1． Weiz.MQ 项目，消息队列的通用处理类库，用于正在的订阅和发布消息。

　　1、在BusBuilder.cs中添加了对CreateAdvancedBus函数的实现。

 1 public static IAdvancedBus CreateAdvancedBus()
 2         {
 3             // 消息服务器连接字符串
 4             string connString = "host=dev.corp.wingoht.com:5672;virtualHost=cd;username=ishowfun;password=123456";
 5             if (connString == null || connString == string.Empty)
 6             {
 7                 throw new Exception("messageserver connection string is missing or empty");
 8             }
 9 
10             return RabbitHutch.CreateBus(connString).Advanced;
11         }

View Code