澳门至尊网站-首页

您的位置:澳门至尊网站 > 技术教程 > 事件剖析

事件剖析

2019-10-20 05:24

本节对事件进行总结。

为什么使用ReactiveCocoa

二、事件:

1、开发过程中,状态及状态之间依赖过多,状态变化很难跟踪,令人头痛,RAC能更加有效处理事件流,而无需去管理状态。

1、概念:Event:A member that enables an object or class to provide notifications;官方的解释是这样,就是说在C#中,事件是使

2、减少方法的调用,由于它跟踪状态和值的变化,因此不需要状态更新时手动调用,减少出错的可能。

对象或者类具备通知能力的成员。比如说手机收到短信提醒我去开会,那么手机就充当了一个具备通知能力的成员。说白了,事件

3、提供统一的消息传递方法,将通知、代理、kvo以及其他所有UIControl事件的变化都进行监控,当发生变化时,就会传递事件和值。

的作用就是对象和类之间的信息传递的桥梁。

4、当值随着事件变化时,可以使用combineLatest、map、filter等函数便利地对值进行变化操作。

2、原理:源于发生-响应模型:

5、事件的处理及监听可以放在一起,符合高内聚、低耦合的思想

事件源(event source) + 事件本身(event) => 事件的订阅者(event subscriber) + 事件处理器(event handler)           

RAC的编程思想

(另外还有事件的订阅者和事件源之间的订阅关系subscribe relationship)

面向过程:以处理事件的过程为核心,一步一步实现。

还是以手机收到短信提醒我去开会为例,事件源:手机吗,事件:收到短信,事件的订阅者:我,事件处理器:去开会,订阅关系:我订阅手机

面向对象:万物皆对象

3、事件的声明:分为详细声明和简略声明:

链式编程:将多个操作通过点号链接在一起成为一句代码,是代码的可读性更好,代表masonry框架

(1)详细声明:

public delegate void MyDelegateEventHandler();
    public class Event
    {
        private MyDelegateEventHandler myDelegateEventHandler;
        public event MyDelegateEventHandler MyDelegate
        {
            add
            {
                this.myDelegateEventHandler += value;
            }
            remove
            {
                this.myDelegateEventHandler -= value;
            }
        }
    }

链式编程的特点:方法的返回值是block,block必须有返回值(本身对象),block参数(需要操作的值)

(2)简略说明:

public delegate void MyDelegateEventHandler();
    public class Event
    {
         public event MyDelegateEventHandler myDelegate;
    }

响应式编程:不需要考虑调用的顺序,只需要考虑结果,类似于蝴蝶效应,产生一个事件,会影响很多东西,这些事件就像流一样的传播出去,借用面向对象的一句话就是万物皆流。

可以看到,在完整声明中首先添加了一个委托类型的字段,然后暴漏了添加和移除事件处理器的功能,但是我们经常用的是简略声明,因为代码更加简洁,

代表:KVO

可以看出事件对外界隐藏了大部分功能,它的本质就是对其中委托字段的一个封装(encapsulation),防止外界偷用滥用委托字段。

函数式编程:把操作尽量写成一系列嵌套的函数或者方法调用

那么问题来了:第一个问题:有了委托为什么还会有事件呢,事件内部不就是委托吗,原因是为了防止public型的委托字段在外面被滥用,比如委托可以用invoke调用,

函数式编程的特点:每一个方法必须有返回值(本身对象),把函数或者block当做参数,block参数(需要操作的值)block返回值(操作结果)

但是事件只能在+=或-=的左侧,这样就增加了整个程序的安全性。

代表:ReactiveCocoa

第二个问题:那委托和事件的关系什么样的呢?我们说事件是基于委托的。一方面,事件需要委托来做一个约束,这个约束规定了事件源发送什么要求给事件的订阅者,

ReactiveCocoa常见类

事件订阅者的事件处理器必须和这个约束相对应才可以订阅这个事件,另一方面,事件订阅者收到事件以后做出事件处理器,而这个事件处理器必须通过委托才可以做到。

在RAC中最核心的类RACSiganl,搞定这个类就能用ReactiveCocoa开发了。

4、简单实例:

RACSignal:信号类,一般表示将来有数据传递,只要有数据变化,信号内部接收到数据,就会马上发出数据。

Example:做一个窗口,有文本框和按钮,点击按钮文本框显示时间,不用WindowsForms

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

namespace ConsoleApp14
{
    class Program
    {
        public static TextBox textBox;
        public static Button button;
        static void Main(string[] args)
        {
            Form form = new Form();
            TextBox textBox = new TextBox();
            Button button = new Button();
            form.Controls.Add(textBox);
            form.Controls.Add(button);
            textBox.Width = 400;
            button.Top = 100;
            button.Click += Button_Click;
            form.ShowDialog();
        }

        private static void Button_Click(object sender, EventArgs e)
        {
            textBox.Text = DateTime.Now.ToString();
        }
    }
}

图片 1

 

注意:

这里举的事例就是windowsforms内部的代码,我们说事件本身是不会发生的是由事件源内部的逻辑所触发,在本例中,并不是人按了按钮然后按钮触发了事件,

信号类(RACSignal),只是表示当数据改变时,信号内部会发出数据,它本身不具备发信号的能力,而是交给内部一个订阅者去发出。

这其中还有一个小过程,就是当按钮被key down再key up时,向程序内部发送了一系列电讯号,通知电脑,然后再发生事件,

默认一个信号都是冷信号,也就是值改变了也不会触发,只有订阅了这个信号,这个信号才变成热信号,值改变了才会触发。

5、声明事件的相关约定:

RACSignal的简单使用:

用于声明事件的委托一般用:事件+EvnetHandler,参数一般有2个,第一个事件源,第二个EventArgs的派生类,用于触发事件的方法名一般为On+方法名,

   //RACSignal底层实现:

访问级别Protected。可能有点蒙,举个实例就懂了。

    //1创建信号,首先把didSubscribe保存到信号中,还不会触发

Example:举一个顾客在KFC点餐的例子

namespace ConsoleApp15
{
    class Program
    {
        static void Main(string[] args)
        {
            Customer customer = new Customer();
            Waitor waitor = new Waitor();
            customer.Order += waitor.Serve;
            customer.Eat();
            customer.Pay();
        }
    }
    public delegate void OrderEventHandler(Customer customer, OrderEventArgs e);
    public class Customer
    {
        public int Money { get; set; }
        public event OrderEventHandler Order;
        public void Pay()
        {
            Console.WriteLine($"OK,{Money} dollars");
        }
        public void Eat()
        {
            Console.WriteLine("Let's go to the KFC...");
            Console.WriteLine("Stand in front of the waitor...");
            Console.WriteLine("A hamburger,Please...");
            OnOrder();
        }
        protected void OnOrder()
        {
            OrderEventArgs orderEventArgs = new OrderEventArgs();
            orderEventArgs.Snack = "Hamburger";
            orderEventArgs.Size = "large";
            this.Order.Invoke(this, orderEventArgs);

        }
    }
    public class OrderEventArgs : EventArgs
    {
        public string Snack { get; set; }
        public string Size { get; set; }
    }
    class Waitor
    {
        public void Serve(Customer customer, OrderEventArgs e)
        {
            Console.WriteLine($"Here is your snack {e.Snack}");
            int price = 20;
            switch (e.Size)
            {
                case "large":
                    price *= 2;
                    break;
                case "small":
                    price *= 1;
                    break;
                default:
                    break;
            }
            customer.Money += price;
        }
    }
}

    //2当信号被订阅,也就是调用signal的subscribeNext:nextBlock

图片 2

 

    //2.1subscribeNext内部创建订阅者subscriber,并且把nextBlock保存到subcriber中

按照事件的五个要素,首先需要事件源,做一个Customer类,还需要一个事件订阅者,做一个Waitor类,然后根据订阅关系去写具体的方法,订阅关系customer.Order += waitor.Serve; Customer点餐Waitor服务,waitor类中上餐并算好价格,这个时候需要一个事件处理器OrderEventHandler,这个委托的参数需要一个OrderEventArgs,创建这个类写好属性,在写好委托和事件,然后在Customer类中写点餐事件,点餐事件为Protected的,和public型的委托字段一样防止被外界滥用,提高安全性。

    //2.2subscribeNext内部调用signal的didSubscribe

想融会贯通其实也不难,只需要将事件的5个要素每一个列举出来,那么最后事件也就出来了。

    //3.Signal的didsubscribe中调用[subscriber sendNext:@1];

 

    //3.2sendNext底层其实就是执行subscriber的nextBlock

至此事件总结完毕,有不明之处还请指教。                2018-08-17   16:43:19

 

    //1创建信号

    RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {

        //每当有订阅者订阅信号,就会调用该block

        //3发送信号

        [subscriber sendNext:@"1"];

        [subscriber sendNext:@"2"];

        [subscriber sendNext:@"3"];

        //如果不再发送数据,内部会自动调用[RACDisposable disposable]取消订阅信号

        [subscriber sendCompleted];

        [subscriber sendNext:@"5"];

        return [RACDisposable disposableWithBlock:^{

            //block调用的时刻:当信号发送完成或者发送错误,就会执行这个blcok,取消订阅信号

            //执行完block后,当前信号就不存在被订阅了

            NSLog(@"信号订阅者被销毁");

        }];

    }];

    //2订阅信号,才会激活信号

    [signal subscribeNext:^(id  _Nullable x) {

        //每当有信号发出数据,调用该block

        NSLog(@"接收数据:%@",x);

    }];

RACSubscriber:表示订阅者的意思,用于发送信号,这是一个协议,不是一个类,只要遵循这个协议,并且实现方法才能成为订阅者。通过create创建的信号,都有一个订阅者,帮助他发送数据。

RACDisposable:用于取消订阅或者清理资源,当信号发送完成或者发送错误的时候,就会自动触发它。

使用场景:不想监听某个信号时,可以通过它主动主动取消订阅信号

RACSubject:信号提供者,自己可以充当信号,又能发送信号。

使用场景:通常用来代替代理,有了它,就不必定义代理了。

RACReplaySubject:重复提供信号类,RACSubject的子类。

RACReplaySubject与RACSubject区别:

RACReplaySubject可以先发送信号,再订阅信号,RACSubject就不可以

使用场景一:如果一个信号每被订阅一次,就需要把之前的值重新发送一遍,使用重复提供信号类

使用场景二:可以设置capacity数量来限制缓存的value的数量,即值缓存最新的几个值。

RACSubject和RACReplaySubject的简单使用:

//RACSubject:底层实现与RACSignal不一样

    //1调用subscribeNext订阅信号,只是把订阅者保存起来,并且订阅者的nextBlock已经赋值了

    //2调用sendNext发送信号,遍历刚刚保存的所有订阅者,一个一个调用订阅者的nextBlock

    //1创建信号

    RACSubject *subject = [RACSubject subject];

    //2订阅信号

    [subject subscribeNext:^(id  _Nullable x) {

        NSLog(@"第一个订阅者%@",x);

    }];

    [subject subscribeNext:^(id  _Nullable x) {

        NSLog(@"第二个订阅者%@",x);

    }];

    //3发送信号

    [subject sendNext:@"1"];

    //RACReplaySubject的底层实现:

    //1.调用sendNext发送信号,把值保存起来,然后遍历刚刚保存的所有的订阅者,一个一个调用订阅者的nextBlock

    //2.调用subscribeNext订阅信号,遍历保存的所有值,一个一个调用订阅者的nextBlock

    //如果想当一个信号被订阅,就重复播放之前所有值,需要先发信号,再订阅信号(也就是先保存值,再订阅值)

    //1.创建信号

    RACReplaySubject *replaySubject = [RACReplaySubject replaySubjectWithCapacity:2];

    [replaySubject subscribeNext:^(id  _Nullable x) {

        NSLog(@"第0个订阅者收到的数据%@",x);

    }];

    //2发送信号

    [replaySubject sendNext:@"1"];

    [replaySubject sendNext:@"2"];

    [replaySubject sendNext:@"3"];

    //3订阅信号

    [replaySubject subscribeNext:^(id  _Nullable x) {

        NSLog(@"第一个订阅者收到的数据%@",x);

    }];

    [replaySubject subscribeNext:^(id  _Nullable x) {

        NSLog(@"第二个订阅者收到的数据%@",x);

    }];

 

RACTuole:元组类,类似于NSArray,用于包装值

RACSequence:RAC中的集合类,用于代替NSArray,NSDictionary,可以使用它来快速遍历数组和字典。

RACCommand:RAC中用于处理事件的类,可以把事件如何处理,实践中数据如何传递,包装到这个类中,它可以很方便的监控事件的执行过程。

使用场景:监听按钮点击,网络请求

RACCommand的简单使用:

 

RACMulticasConnection:用于当一个信号,被多次订阅时,为了保证创建信号时,避免多次调用信号中的block,造成副作用,可以使用这个类处理。

使用注意:RACMulticastConnection通过RACSignal的-publish或者-muticast方法创建。

RACScheduler:RAC中的队列,用GCD封装的。

RACUnit:表示stream不包含有意义的值,也就是看到这个,可以直接理解为nil

RACEVent:把数据包装成信号事件(singnal event)。它主要通过RACSignal的-materialize来使用的。

ReactiveCocoa开发常见用法

代替代理:rac_signalForSelector

代替KVO:rac_valueAndChangesForKeyPath

监听事件:rac_signalForControlEvents

代替通知:arc_addObserverForName

监听文本框文字改变:rac_textSignal

ReactiveCocoa常见宏

RAC(TARGET,[KEYPATH,[NIL_VALUE]]):用于给某个对象的某个属性绑定

//只要文本框文字改变,就会改变label的文字

//只要文本框文字改变,就会修改label的文字

RAC(self.labelView,text) = _textfield.rac_textSignal;

RACObserve(self,name):监听某个对象的属性,返回的是信号

[RACObserve(self.view,center) subscribeNext:(^id x){

        NSLog(@"%@",x);

}

@weakfy(Obj)和@strongfy(Obj),需要手动导入RACEXTScope.h才能使用

RACTuplePack:把数据包装成RACTuple(元组类)

//把参数中的数据包装成元组

RACTuple *tuple = RACTuplePack(@10,@20);

RACTupleUnpack:把RACTuple(元组类)解包成对应的数据

参考:

 

本文由澳门至尊网站发布于技术教程,转载请注明出处:事件剖析

关键词: