Sanya-ips/ipslib/Ips.Library.Basic/IpsMessenger.cs

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

namespace Ips.Library.Basic
{
    /// <summary>
    /// 消息发布订阅(非线程安全)
    /// </summary>
    public class IpsMessenger
    {
        public static IpsMessenger Default = new IpsMessenger();

        //支持重复key的字典
        Dictionary<string, List<dynamic>> cache = new Dictionary<string, List<dynamic>>();
        private IpsMessenger()
        {
        }
        public void Sub<T>(string key, Action<T> act)
        {
            if (!cache.ContainsKey(key))
                cache.Add(key, new List<dynamic>());
            cache[key].Add(act);
        }
        public void UnSub<T>(string key, Action<T> act)
        {
            if (cache.ContainsKey(key))
            {
                var items = cache[key].Skip(0).ToList();
                foreach (var item in items)
                {
                    if (item is Action<T> actExist)
                    {
                        cache[key].Remove(actExist);
                    }
                }
            }

        }
        public void Pub<T>(string key, T data)
        {
            if (cache.TryGetValue(key, out List<dynamic> list))
            {
                foreach (var item in list)
                {
                    if (item is Action<T> act)
                    {
                        act?.Invoke(data);
                    }
                }
            }
        }

    }
}