C#下实现RabbitMQ。
1.首先需要下载.net下的驱动类。rabbitmq.client.dll.安装后可以使用提供的文档。当然也可以直接从别的地方只下载rabbitmq.client.dll使用。
下载地址：http://www.rabbitmq.com/dotnet.html
?文档和安装程序都有了。
2.然后建立项目导入引用
???????? 一、首先建立一个消息的发送者类Sender
?
using System;using System.Collections.Generic;using System.Linq;using System.Text;using RabbitMQ.Client;using RabbitMQ.Util;namespace receiver{ public class receiver { static void Main(string[] args) { // Uri uri = new Uri("amqp://127.0.0.1:8688/"); string exchange = "routing"; string exchangeType = "direct"; string routingKey = "rk"; string serverAddress ="amqp://127.0.0.1:8688/"; ConnectionFactory cf = new ConnectionFactory(); cf.Uri = serverAddress; cf.UserName = "gyg"; cf.Password = "123456"; cf.VirtualHost = "gyg001"; cf.RequestedHeartbeat = 0; //cf.Endpoint = new AmqpTcpEndpoint(uri); using (IConnection conn = cf.CreateConnection()) { using (IModel ch = conn.CreateModel()) { //普通使用方式BasicGet //noAck = true，不需要回复，接收到消息后，queue上的消息就会清除 //noAck = false，需要回复，接收到消息后，queue上的消息不会被清除， //直到调用channel.basicAck(deliveryTag, false); //queue上的消息才会被清除 而且，在当前连接断开以前，其它客户端将不能收到此queue上的消息 BasicGetResult res = ch.BasicGet("q", false/*noAck*/); if (res!= null) { Console.WriteLine(System.Text.UTF8Encoding.UTF8.GetString(res.Body)); ch.BasicAck(res.DeliveryTag, false); } else { Console.WriteLine("无内容!!"); } ch.Close(); } conn.Close(); } Console.ReadLine(); } } }?当然了这种方式是最简单的每次发送一个。接受者每次取得一个。
注意：这种方式发送者和接受者不能同时访问服务器。
?