Wenli.Data.RabbitMQ

Wenli.Data.RabbitMQ

配置节点如下：

<?xml version="1.0" encoding="utf-8" ?> <configuration> <configSections> <section name="MQConfig" type="Wenli.Data.RabbitMQ.MQConfig,Wenli.Data.RabbitMQ"/> </configSections> <MQConfig Server="127.0.0.1" Port="5672" User="wenli" Password="wenli" RouteName="IMMQ" RouteType="direct" VirtualHost="/" QosCount="20000"/> <startup> <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" /> </startup> </configuration>

示例代码如下：

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Threading.Tasks;

namespace Wenli.Data.RabbitMQ.Console { using Console = System.Console;

class Program
{
    static void Main(string[] args)
    {
        Console.Title = "Wenli.Data.RabbitMQ.Console";
        Console.WriteLine("正连接到mq");

        try
        {
            Test();
        }
        catch (Exception ex)
        {
            Console.WriteLine("err:" + ex.Message + ex.Source + ex.StackTrace);
        }

        Console.Read();
    }


    static void Test()
    {

        var topic = "testtopic";

        var cnn = RabbitMQBuilder.Get(MQConfig.Default).GetConnection();

        var operation = cnn.GetOperation(topic);

        Console.WriteLine("正连接到订阅【" + topic + "】");

        operation.Subscribe();

        Console.WriteLine("正在入队");

        Task.Factory.StartNew(() =>
        {
            while (true)
            {
                operation.Enqueue(Encoding.UTF8.GetBytes(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "     hello!"));
                Thread.Sleep(1);
            }
        });




        Console.WriteLine("正在出队");



        Task.Factory.StartNew(() =>
        {
            while (true)
            {
                var result = operation.Dnqueue();

                if (result == null)
                {
                    Thread.Sleep(1);
                }
                else
                {
                    Console.WriteLine(Encoding.UTF8.GetString(result));
                }
            }
        });

        Console.ReadLine();

        Console.WriteLine("正在取消订阅");

        operation.UnSubscribe();

        Console.WriteLine("测试完成");
    }
}

}