NetPro.EasyNetQ 6.0.5-beta.7

EasyNetQ使用

对EasyNetQ的封装，简化使用，支持多库

使用

appsetting.json

"EasyNetQOption": {
    "ConnectionString": [
      {
        "Key": "rabbit2", //连接串key别名，唯一
        "Value": "host=192.168.18.129:5672;virtualHost=/;username=admin;password=123456;timeout=60" //别名key对应的连接串
      },
      {
        "Key": "rabbit1", //连接串key别名，唯一
        "Value": "host=192.168.18.129:5672;virtualHost=/;username=admin;password=123456;timeout=60" //别名key对应的连接串
      }
    ]
  },

启用服务

没有基于NetPro.Web.Api 的使用场景，必须手动进行初始化，如下：

IConfiguration Configuration;

public void ConfigureServices(IServiceCollection services)
{    
       services.AddEasyNetQ(Configuration);
}

基于NetPro.Web.Api的使用，只需要添加引用后配置以上appsetting.josn配置EasyNetQOption节点即可

使用说明

 public class RabbitmqService : IRabbitmqService
    {
        private readonly IEasyNetQMulti _easyNetQMulti;
        public RabbitmqService( IEasyNetQMulti easyNetQMulti)
        {
            _easyNetQMulti=easyNetQMulti;
        }

        /// <summary>
        /// 
        /// </summary>
        public void Method()
        {
             //订阅/Subscribe
                    _idbus ["rabbit2"].Subscribe<TextMessage>("subscriptionId", tm =>
                    {
                        Console.WriteLine("Recieve Message: {0}", tm.Text);
                    });

           //发布/Publish
                using (var bus = _easyNetQMulti["rabbit21"])
                {
                    var input = "";
                    Console.WriteLine("Please enter a message. 'q'/'Q' to quit.");
                    while ((input = Console.ReadLine()).ToLower() != "q")
                    {
                        bus.PubSub.Publish(new TextMessage
                        {
                            Text = input
                        });
                    }
                }
        }
    }

更新中...

reference 使用rabbitmq消息队列——EasyNetQ插件介绍