kxs-mq/AppStart/RabbitMQPrize.cs

using System;
using System.Collections.Generic;
using System.Text;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using Library;
using System.Threading;

namespace MySystem
{
    public class RabbitMQPrize
    {
        public readonly static RabbitMQPrize Instance = new RabbitMQPrize();
        string UserName,Password,HostName,VirtualHostName;
        private RabbitMQPrize()
        {
            UserName = ConfigurationManager.AppSettings["MqPrizeUserName"].ToString();
            Password = ConfigurationManager.AppSettings["MqPrizePassword"].ToString();
            HostName = ConfigurationManager.AppSettings["MqPrizeHostName"].ToString();
            VirtualHostName = ConfigurationManager.AppSettings["MqPrizeVirtualHostName"].ToString();
        }

        #region 单对单发送
        public void SendMsg(string content, string QueueName)
        {
            _channel_send.BasicPublish("", QueueName, null, Encoding.Default.GetBytes(content));
            Utils.WriteLog(DateTime.Now.ToString() + "\n" + QueueName + "\n" + content + "\n\n\n", "发送奖励原始数据");
        }
        #endregion


        #region 单对单接收
        public static IModel _channel_send;
        public void CreateConn()
        { 
            var factory = new ConnectionFactory()
            {
                UserName = UserName,
                Password = Password,
                AutomaticRecoveryEnabled = true,  //如果connection挂掉是否重新连接
                TopologyRecoveryEnabled = true,  //连接恢复后，连接的交换机，队列等是否一同恢复
                VirtualHost = VirtualHostName,
            };
            List<AmqpTcpEndpoint> p = new List<AmqpTcpEndpoint>();
            string[] HostNames = HostName.Split(',');
            foreach (string subHostName in HostNames)
            {
                string[] subHostNameData = subHostName.Split(':');
                p.Add(new AmqpTcpEndpoint(subHostNameData[0], int.Parse(subHostNameData[1])));
            }
            var conn = factory.CreateConnection(p);
            _channel_send = conn.CreateModel();
            _channel_send.ExchangeDeclare("PRIZE_SEND_QUEUE", "topic", true);
            _channel_send.QueueBind("PRIZE_SEND_QUEUE_1", "PRIZE_SEND_QUEUE", "/");
            _channel_send.QueueBind("PRIZE_SEND_QUEUE_3", "PRIZE_SEND_QUEUE", "/");
            _channel_send.QueueBind("PRIZE_SEND_QUEUE_4", "PRIZE_SEND_QUEUE", "/");
            _channel_send.QueueBind("PRIZE_SEND_QUEUE_5", "PRIZE_SEND_QUEUE", "/");
            _channel_send.QueueBind("PRIZE_SEND_QUEUE_6", "PRIZE_SEND_QUEUE", "/");
            _channel_send.QueueBind("PRIZE_SEND_QUEUE_7", "PRIZE_SEND_QUEUE", "/");
        }
        #endregion
    }
}