参考地址：《C#使用RabbitMQ》
C#操作RabbitMQ需要引用RabbitMQ的DLL，地址是：http://www.rabbitmq.com/releases/rabbitmq-dotnet-client/
下载最新版本即可，因为我使用的.Net Framework 4.5，所以选择
下载后解压
创建工程后，先引用RabbitMQ的库RabbitMQ.Client.dll，即第一个dll文件
这里我使用了一个新通用Class，首先需要引用RabbitMQ的命令空间 using RabbitMQ.Client;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;using RabbitMQ.Client;namespace MES_MonitoringClient.Common
{
/// <summary>
/// RabbitMQ队列上传动作
/// </summary>
public class RabbitMQClientHandler
{
// 定义一个静态变量来保存类的实例
private static RabbitMQClientHandler uniqueInstance;
//定义一个标识确保线程同步
private static readonly object locker = new object(); /*-------------------------------------------------------------------------------------*/ //ConnectionFactory
private static ConnectionFactory mc_ConnectionFactory = null;
//Connection
public IConnection Connection;
//Channel
public IModel Channel; /*-------------------------------------------------------------------------------------*/ /// <summary>
/// 定义私有构造函数，使外界不能创建该类实例
/// </summary>
public RabbitMQClientHandler()
{
//连接工厂
mc_ConnectionFactory = new ConnectionFactory(); //连接工厂信息
mc_ConnectionFactory.HostName = "localhost";
mc_ConnectionFactory.UserName = "guest";
mc_ConnectionFactory.Password = "guest"; //创建连接
Connection = mc_ConnectionFactory.CreateConnection();
//创建频道
Channel = Connection.CreateModel();
} /// <summary>
/// 定义公有方法提供一个全局访问点,同时你也可以定义公有属性来提供全局访问点
/// </summary>
/// <returns></returns>
public static RabbitMQClientHandler GetInstance()
{
// 当第一个线程运行到这里时，此时会对locker对象 "加锁"，
// 当第二个线程运行该方法时，首先检测到locker对象为"加锁"状态，该线程就会挂起等待第一个线程解锁
// lock语句运行完之后（即线程运行完之后）会对该对象"解锁"
// 双重锁定只需要一句判断就可以了
if (uniqueInstance == null)
{
lock (locker)
{
// 如果类的实例不存在则创建，否则直接返回
if (uniqueInstance == null)
{
uniqueInstance = new RabbitMQClientHandler();
}
}
}
return uniqueInstance;
} /*-------------------------------------------------------------------------------------*/ /// <summary>
/// 发送消息至服务端
/// </summary>
/// <param name="queueName"></param>
/// <param name="message"></param>
/// <returns></returns>
public bool publishMessageToServer(string queueName, string message)
{
try
{
//创建一个持久化的频道
bool durable = true;
Channel.QueueDeclare(queueName, durable, false, false, null); //设置消息持久性
//var properties = Channel.CreateBasicProperties();
//properties.SetPersistent(true); //消息内容转码，并发送至服务器
var messageBody = Encoding.UTF8.GetBytes(message);
Channel.BasicPublish("", "test", null, messageBody); return true;
}
catch (Exception ex)
{
return false;
}
} }
}
RabbitMQClientHandler
然后在调用时，只需要使用
Common.RabbitMQClientHandler.GetInstance().publishMessageToServer("test", "test message");
这里需要比较的地方是，在测试过程中发现
- 1.同一个服务器中，不能有两个一样名字的Queue
- 2.针对同一个Queue，发送端与接收端的Channel.QueueDeclare时指定的durable（bool类型）指定的不同，也不能顺利接收到
- 3.还有在发送时，Channel.BasicPublish(“”, “test”, null, messageBody); 其中的routing参数也需要与Queue保持一致（后期可以通过设置Exchange和Routing对Queue进行分配）
2019-01-04 发现一个问题：问题表现为，RabbitMQ发送服务为后台服务，在开发环境中，RabbitMQ服务器有可能会随时中断，那么后台服务一直在运行，建立的连接则只存在于过去，RabbitMQ重新启动后，之前创建的连接已经不存了，导致后台服务即使能读到Mongodb中的数据，但是无法通过之前建立的连接将数据发送至RabbitMQ服务器，这时，只需要将后台服务重新启动，重新创建新的连接即可正常服务，在代码中需要增加一些判断，如果发送RabbitMQ不能成功，则需要重新建立RabbitMQ连接，方便发送数据。
