prism WPF 消息的订阅或发布

prism WPF 消息的订阅或发布

EventMessage

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

namespace Cjh.PrismWpf
{
    /// <summary>
    /// 事件消息
    /// </summary>
    public class EventMessage : PubSubEvent
    {
    }

    /// <summary>
    /// 事件消息 参数
    /// </summary>
    public class EventMessageArgs : PubSubEvent<object>
    {

    }

    /// <summary>
    /// 事件消息 参数，委托
    /// </summary>
    public class EventAction
    {
        /// <summary>
        /// 结果委托
        /// </summary>
        public Action<bool> ResultAction { get; set; }
    }
}

Messenger

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

namespace Cjh.PrismWpf
{
    /// <summary>
    /// 全局静态 事件
    /// </summary>
    public class Messenger
    {
        /// <summary>
        /// 全局静态 事件
        /// </summary>
        public static IEventAggregator Defualt { get; set; }
    }
}

MainWindow

using Prism.Events;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Navigation;
using System.Windows.Shapes;

namespace Cjh.PrismWpf
{
    /// <summary>
    /// MainWindow.xaml 的交互逻辑
    /// </summary>
    public partial class MainWindow : Window
    {
        //IEventAggregator 消息对象 
        public MainWindow(IEventAggregator eventAggregator)
        {
            InitializeComponent();
            //this.DataContext = new MainViewModel();

            //方式一
            //1.获取消息对象，通过注入的方式获取
            //2.通过消息对象进行订阅或发布
            //总线 事件对象
            // Subscribe 订阅
            eventAggregator.GetEvent<EventMessage>().Subscribe(Receive);
            //Publish 发布
            eventAggregator.GetEvent<EventMessage>().Publish();

            //方式二
            //全局静态处理 
            //发布和订阅 注意先后顺序，先发布再订阅
            Messenger.Defualt.GetEvent<EventMessageArgs>().Subscribe(Receive);
            Messenger.Defualt.GetEvent<EventMessageArgs>().Publish("Hello");//有参

            //发布委托消息后要一个返回结果
            Messenger.Defualt.GetEvent<EventMessageArgs>().Publish(new EventAction()
            {
                ResultAction = new Action<bool>(state => {
                    //state 就是返回的结果
                    MessageBox.Show("执行结果："+ state);
                })
            });

            //订阅 增加过滤条件 arg => arg.Id == 1 是过滤条件
            Messenger.Defualt.GetEvent<EventMessageArgsDataModel>().Subscribe(ReceiveDataModel, arg => arg.Id == 1);
            Messenger.Defualt.GetEvent<EventMessageArgsDataModel>().Publish(new DataModel(){ Id = 1});

            Messenger.Defualt.GetEvent<EventMessageArgsDataModel>().Subscribe(ReceiveDataModel2, arg => arg.Id == 2);
            Messenger.Defualt.GetEvent<EventMessageArgsDataModel>().Publish(new DataModel() { Id = 2 });

            //keepSubscriberReferenceAlive 为true时，对象销毁的时候，要做注销操作
            //public SubscriptionToken Subscribe(Action<TPayload> action, bool keepSubscriberReferenceAlive)
            Messenger.Defualt.GetEvent<EventMessageArgs>().Subscribe(Receive, true);// 在窗口关闭时做注销操作

            //多线程状态控制
            //public SubscriptionToken Subscribe(Action<TPayload> action, ThreadOption threadOption)
            //关于ThreadOption选项
            //PublisherThread ：发布者在什么线程发布的，这个注册的逻辑就在哪个线程执行
            //UIThread : 不管发布者在哪个线程发布，这里注册的逻辑总在UI线程执行，如果执行逻辑里有页面控件的操作，可以选择这个选项
            //BackgroundThread ： 不管发布者在哪个线程发布，这里注册的逻辑总在后台线程执行。(新建一个线程)如果执行逻辑与主线程无关，可以用这个
            Messenger.Defualt.GetEvent<EventMessageArgs>().Subscribe(Receive, ThreadOption.PublisherThread);
        }

        /// <summary>
        /// 订阅 接收消息
        /// </summary>
        private void Receive()
        { 
            
        }

        /// <summary>
        /// 订阅 接收消息（有参数）
        /// </summary>
        private void Receive(object args)
        {
            MessageBox.Show(args.ToString());
        }

        /// <summary>
        /// 订阅 接收消息（有参数）
        /// </summary>
        private void ReceiveDataModel(DataModel args)
        {
            MessageBox.Show(args.Id.ToString());
        }

        /// <summary>
        /// 订阅 接收消息（有参数）
        /// </summary>
        private void ReceiveDataModel2(DataModel args)
        {
            MessageBox.Show(args.Id.ToString());
        }

        private void Window_Closed(object sender, EventArgs e)
        {
            //keepSubscriberReferenceAlive 为true时，对象销毁的时候，要做注销订阅操作
            if (Messenger.Defualt.GetEvent<EventMessageArgs>().Contains(Receive))//判断是否存在订阅操作
            {
                Messenger.Defualt.GetEvent<EventMessageArgs>().Unsubscribe(Receive);//注销订阅
            }            
        }
    }
}

SubWindow

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Shapes;

namespace Cjh.PrismWpf
{
    /// <summary>
    /// SubWindow.xaml 的交互逻辑
    /// </summary>
    public partial class SubWindow : Window
    {
        public SubWindow()
        {
            InitializeComponent();

            Messenger.Defualt.GetEvent<EventMessageArgs>().Subscribe(Receive);
        }

        private void Receive(object obj)
        {
            if (obj is EventAction)
            {
                //一些处理逻辑
                //....................
                var ea = obj as EventAction;
                ea.ResultAction.Invoke(true);//true 是返回的值
            }
        }
    }
}

App.xaml

using Prism.Events;
using Prism.Ioc;
using Prism.Unity;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Linq;
using System.Threading.Tasks;
using System.Windows;

namespace Cjh.PrismWpf
{
    /// <summary>
    /// App.xaml 的交互逻辑
    /// </summary>
    public partial class App : PrismApplication
    {
        /// <summary>
        /// 提供主窗口的对象
        /// </summary>
        /// <returns></returns>
        /// <exception cref="NotImplementedException"></exception>
        protected override Window CreateShell()
        {
            //单例 全局静态
            Messenger.Defualt = Container.Resolve<IEventAggregator>();
            new SubWindow().Show();
            //return new MainWindow() { Title = "PrismMainWindow" };
            return Container.Resolve<MainWindow>();
        }

        /// <summary>
        /// 业务中所有需要注入的对象，在这个方法里注册
        /// </summary>
        /// <param name="containerRegistry"></param>
        /// <exception cref="NotImplementedException"></exception>
        protected override void RegisterTypes(IContainerRegistry containerRegistry)
        {
            
        }
    }
}