using NewLife;
using NewLife.Log;
using NewLife.RocketMQ;
using NewLife.RocketMQ.Common;
using NewLife.RocketMQ.Protocol;
using System;
using System.Collections.Generic;
using System.IO;
using System.IO.Compression;
using System.Linq;
using System.Threading;

namespace Test
{
    class Program
    {
        static void Main(String[] args)
        {
            XTrace.UseConsole();

            Test5();

            //TestAliyun();

            Console.WriteLine("OK!");
            Console.ReadKey();
        }

        static void Test1()
        {
            var mq = new Producer
            {
                Topic = "nx_test",
                NameServerAddress = "127.0.0.1:9876",

                Log = XTrace.Log,
            };

            mq.Configure(MqSetting.Current);
            mq.Start();

            //mq.CreateTopic("nx_test", 2);

            for (var i = 0; i < 1000_000; i++)
            {
                var str = "学无先后达者为师" + i;
                //var str = Rand.NextString(1337);

                var sr = mq.Publish(str, "TagA", null);

                //Console.WriteLine("[{0}] {1} {2} {3}", sr.Queue.BrokerName, sr.Queue.QueueId, sr.MsgId, sr.QueueOffset);

                // 阿里云发送消息不能过快，否则报错“服务不可用”
                Thread.Sleep(100);
            }

            Console.WriteLine("完成");

            mq.Dispose();
        }

        private static Consumer _consumer;
        static void Test2()
        {
            var consumer = new Consumer
            {
                Topic = "nx_test",
                Group = "test",
                NameServerAddress = "127.0.0.1:9876",

                FromLastOffset = false,
                //SkipOverStoredMsgCount = 0,
                //BatchSize = 20,

                Log = XTrace.Log,
                ClientLog = XTrace.Log,
            };

            consumer.OnConsume = OnConsume;

            consumer.Configure(MqSetting.Current);
            consumer.Start();

            _consumer = consumer;
        }

        static void TestAliyun()
        {
            var consumer = new Consumer
            {
                Topic = "nx_test",
                Group = "test",
                NameServerAddress = "127.0.0.1:9876",

                Aliyun = new AliyunOptions
                {
                    AccessKey = "appId",
                    SecretKey = "appSecret",
                },

                //FromLastOffset = false,
                //SkipOverStoredMsgCount = 0,
                //BatchSize = 20,

                Log = XTrace.Log,
                ClientLog = XTrace.Log,
            };

            consumer.OnConsume = OnConsume;

            consumer.Configure(MqSetting.Current);
            consumer.Start();

            _consumer = consumer;
        }

        private static Boolean OnConsume(MessageQueue q, MessageExt[] ms)
        {
            Console.WriteLine("[{0}@{1}]收到消息[{2}]", q.BrokerName, q.QueueId, ms.Length);

            foreach (var item in ms.ToList())
            {
                Console.WriteLine($"消息：主键【{item.Keys}】 Topic 【{item.Topic}】，产生时间【{item.BornTimestamp.ToDateTime()}】，内容【{item.Body.ToStr(null, 0, 64)}】");
            }

            return true;
        }

        static void Test3()
        {
            var dic = new SortedList<String, String>(StringComparer.Ordinal)
            {
                ["subscription"] = "aaa",
                ["subVersion"] = "ccc",
            };
            Console.WriteLine(dic.Join(",", e => $"{e.Key}={e.Value}"));

            Console.WriteLine('s' > 'V');

            Console.WriteLine();
            var cmp = Comparer<String>.Default;
            Console.WriteLine(cmp.Compare("s", "S"));
            Console.WriteLine(cmp.Compare("s", "v"));
            Console.WriteLine(cmp.Compare("s", "V"));

            Console.WriteLine();
            var cmp2 = StringComparer.OrdinalIgnoreCase;
            Console.WriteLine(cmp2.Compare("s", "S"));
            Console.WriteLine(cmp2.Compare("s", "v"));
            Console.WriteLine(cmp2.Compare("s", "V"));

            Console.WriteLine();
            cmp2 = StringComparer.Ordinal;
            Console.WriteLine(cmp2.Compare("s", "S"));
            Console.WriteLine(cmp2.Compare("s", "v"));
            Console.WriteLine(cmp2.Compare("s", "V"));

            //dic.Clear();
            //dic = dic.OrderBy(e => e.Key).ToDictionary(e => e.Key, e => e.Value);
            //Console.WriteLine(dic.Join(",", e => $"{e.Key}={e.Value}"));

            var list = new List<BrokerInfo>
            {
                new BrokerInfo { Name = "A", WriteQueueNums = 5 },
                new BrokerInfo { Name = "B", WriteQueueNums = 7,Addresses=new[]{ "111","222"} },
                new BrokerInfo { Name = "C", WriteQueueNums = 9 },
            };
            var list2 = new List<BrokerInfo>
            {
                new BrokerInfo { Name = "A", WriteQueueNums = 5 },
                new BrokerInfo { Name = "B", WriteQueueNums = 7 ,Addresses=new[]{ "111","222"}},
                new BrokerInfo { Name = "C", WriteQueueNums = 9 },
            };

            Console.WriteLine(list[1].Equals(list2[1]));
            Console.WriteLine(list2.SequenceEqual(list));

            var robin = new WeightRoundRobin();
            robin.Set(list.Select(e => e.WriteQueueNums).ToArray());
            var count = list.Sum(e => e.WriteQueueNums);
            for (var i = 0; i < count; i++)
            {
                var idx = robin.Get(out var times);
                var bk = list[idx];
                Console.WriteLine("{0} {1} {2}", i, bk.Name, times - 1);
            }
        }

        static void Test4()
        {
            var a1 = File.ReadAllBytes("a1".GetFullPath());
            var a2 = File.ReadAllBytes("a2".GetFullPath());

            //var ms = new MemoryStream(a1);
            //ms.Position += 2;
            //var ds = new DeflateStream(ms, CompressionMode.Decompress);
            //var buf = ds.ReadBytes();

            var buf = a1.ReadBytes(2).Decompress();

            var rs = a2.ToBase64() == buf.ToBase64();
            Console.WriteLine(rs);

            Console.WriteLine(buf.ToStr());
        }

        static void Test5()
        {
            var _consumers = new List<Consumer>();
            var topics = new List<string>() { "flow", "flow2" };

            for (int i = 0; i < 2; i++)
            {
                var consumer = new Consumer
                {
                    Topic = topics[i],
                    //Group = "test",
                    NameServerAddress = "172.19.177.185:9876",

                    BatchSize = 1,
                    Log = XTrace.Log,
                };

                consumer.OnConsume = OnConsume;
                consumer.Start();

                _consumers.Add(consumer);

            }
        }
    }
}