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


using System.IO;
using System.Threading;
using RabbitMQ.Client;




namespace RabbitmqClient
{
    /// <summary>
    /// P2P模式，即一個生產者一個消費者
    /// </summary>
    public class MyRabbitMq
    {
        private readonly ConnectionFactory rabbitMqFactory;
        const string ExchangeName = "test.exchange";
        const string QueueName = "test.queue";


        public MyRabbitMq(bool isLocal = true, string remoteAddress = "localhost")
        {
            if (isLocal)
                rabbitMqFactory = new ConnectionFactory { HostName = "localhost" };
            else 
                rabbitMqFactory = new ConnectionFactory { HostName = remoteAddress };
        }


        public void Register_durable_Exchange_and_Queue()
        {
            using (IConnection conn = rabbitMqFactory.CreateConnection())
            using (IModel channel = conn.CreateModel())
            {
                channel.ExchangeDeclare(exchange: ExchangeName, type: "direct", durable: true, autoDelete: false, arguments: null);
                channel.QueueDeclare(queue: QueueName, durable: true, exclusive: false, autoDelete: false, arguments: null);
                channel.QueueBind(queue: QueueName, exchange: ExchangeName, routingKey: QueueName);
            }
        }


        /// <summary>
        /// 生產者，插入訊息
        /// </summary>
        /// <param name="message">訊息</param>
        /// <param name="persistent">是否持久化</param>
        public void SendMessage(string message, bool persistent = true)
        {
            using (IConnection conn = rabbitMqFactory.CreateConnection())
            using (IModel channel = conn.CreateModel())
            {
                var props = channel.CreateBasicProperties();
                if (persistent)
                {
                    props.Persistent = true;                
                }


                var msgBody = Encoding.UTF8.GetBytes(message);
                channel.BasicPublish(exchange: ExchangeName, routingKey: QueueName, basicProperties: props, body: msgBody);


                Console.WriteLine(" [x] Sent {0}", message);
            }
        }


        /// <summary>
        /// 消費者，取出訊息
        /// </summary>
        /// <returns></returns>
        public string GetMessage()
        {
            using (IConnection conn = rabbitMqFactory.CreateConnection())
            using (IModel channel = conn.CreateModel())
            {
                BasicGetResult msgResponse = channel.BasicGet(queue: QueueName, noAck: true);


                string msgBody = Encoding.UTF8.GetString(msgResponse.Body);


                return msgBody;
            }
        }




        /// <summary>
        /// 一次都消費光，清空佇列，沒有訊息會阻塞等
        /// </summary>
        /// <returns></returns>
        public string Consume_messages_from_Queue_Subscription()
        {
            using (IConnection conn = rabbitMqFactory.CreateConnection())
            using (IModel channel = conn.CreateModel())
            {
                var consumer = new QueueingBasicConsumer(channel);


                channel.BasicConsume(QueueName, noAck: true, consumer: consumer);


                var msgResponse = consumer.Queue.Dequeue(); //blocking


                var msgBody = Encoding.UTF8.GetString(msgResponse.Body);


                return msgBody;
            }
        }




        public void Publish_5_messages_to_test_exchange()
        {
            using (IConnection conn = rabbitMqFactory.CreateConnection())
            using (IModel channel = conn.CreateModel())
            {
                for (var i = 0; i < 5; i++)
                {
                    var props = channel.CreateBasicProperties();
                    //props.SetPersistent(true);
                    props.Persistent = true;
                    string msg = "Hello, World!" + i;
                    var msgBody = Encoding.UTF8.GetBytes(msg);
                    channel.BasicPublish(ExchangeName, routingKey: QueueName, basicProperties: props, body: msgBody);
                }
            }
        }


    }
}